diff --git a/ECMJobRunner.Infrastructure/Services/SQLExecutor.cs b/ECMJobRunner.Infrastructure/Services/SQLExecutor.cs
index b13170d..597c3c6 100644
--- a/ECMJobRunner.Infrastructure/Services/SQLExecutor.cs
+++ b/ECMJobRunner.Infrastructure/Services/SQLExecutor.cs
@@ -1,6 +1,5 @@
 #if NET48
 using System.Data.Entity;
-using System.Linq;
 #else
 using Microsoft.EntityFrameworkCore;
 #endif
@@ -8,6 +7,7 @@ using ECMJobRunner.Application.Common.Interfaces;
 using ECMJobRunner.Infrastructure.Data;
 using System.Threading;
 using System.Threading.Tasks;
+using System.Linq;
 
 namespace ECMJobRunner.Infrastructure.Services
 {
@@ -41,16 +41,16 @@ namespace ECMJobRunner.Infrastructure.Services
             // Entity Framework 6 implementation
             var result = await _context.Database
                 .SqlQuery<TResult>(sql)
-                .FirstOrDefaultAsync(cancellationToken);
-            
-            return result;
+                .ToListAsync(cancellationToken);
+
+            return result.FirstOrDefault();
 #else
             // Entity Framework Core implementation
             var result = await _context.Database
                 .SqlQueryRaw<TResult>(sql)
-                .FirstOrDefaultAsync(cancellationToken);
+                .ToListAsync(cancellationToken);
             
-            return result;
+            return result.FirstOrDefault();
 #endif
         }
     }