diff --git a/src/ReC.Application/Common/Interfaces/IRecDbContext.cs b/src/ReC.Application/Common/Interfaces/IRecDbContext.cs
index 44585f7..af2220d 100644
--- a/src/ReC.Application/Common/Interfaces/IRecDbContext.cs
+++ b/src/ReC.Application/Common/Interfaces/IRecDbContext.cs
@@ -29,7 +29,8 @@ public interface IRecDbContext
 
 public static class RecDbContextSaveExtensions
 {
-    public static async Task<string> ExecuteDynamicSqlAsync(this IRecDbContext context, string sql)
+    //TODO: Once it is finalized, move it to Common.Infrastructure
+    public static async Task<string> ExecuteDynamicSqlAsync(this IRecDbContext context, string sql, CancellationToken cancel = default)
     {
         var result = new List<Dictionary<string, object?>>();
 
@@ -37,10 +38,10 @@ public static class RecDbContextSaveExtensions
 
         command.CommandText = sql;
 
-        await context.Database.OpenConnectionAsync();
+        await context.Database.OpenConnectionAsync(cancel);
 
-        using var reader = await command.ExecuteReaderAsync();
-        while (await reader.ReadAsync())
+        using var reader = await command.ExecuteReaderAsync(cancel);
+        while (await reader.ReadAsync(cancel))
         {
             var row = new Dictionary<string, object?>();