diff --git a/SqlKata.Execution/QueryFactory.cs b/SqlKata.Execution/QueryFactory.cs
index ce42dd40..49b08f75 100644
--- a/SqlKata.Execution/QueryFactory.cs
+++ b/SqlKata.Execution/QueryFactory.cs
@@ -527,7 +527,7 @@ public void Chunk<T>(
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 if (!func(result.List, result.Page))
                 {
                     return;
@@ -543,7 +543,7 @@ public async Task ChunkAsync<T>(
             int? timeout = null
         )
         {
-            var result = await this.PaginateAsync<T>(query, 1, chunkSize);
+            var result = await this.PaginateAsync<T>(query, 1, chunkSize, transaction);
 
             if (!func(result.List, 1))
             {
@@ -552,7 +552,7 @@ public async Task ChunkAsync<T>(
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 if (!func(result.List, result.Page))
                 {
                     return;
@@ -568,7 +568,7 @@ public void Chunk<T>(Query query, int chunkSize, Action<IEnumerable<T>, int> act
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 action(result.List, result.Page);
             }
         }
@@ -587,7 +587,7 @@ public async Task ChunkAsync<T>(
 
             while (result.HasNext)
             {
-                result = result.Next();
+                result = result.Next(transaction);
                 action(result.List, result.Page);
             }
         }