fix: Fixed chunk with queue delay (#38)

tenantcloud · Sep 12, 2024 · 43e7963 · 43e7963
1 parent 35f9a87
commit 43e7963
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/Mixins/EloquentBuilderMixin.php b/src/Mixins/EloquentBuilderMixin.php
@@ -285,10 +285,14 @@ public function chunkWithQueue(): callable
 
 			$builder = new SerializableBuilder($query);
 
+			$delayNumber = 1;
+
 			for ($chunkNumber = $minChunkNumber; $chunkNumber <= $maxChunkNumber; $chunkNumber++) {
 				dispatch(new GenerateChunksJob($builder, $params, $chunkNumber))
 					->onQueue($settings->queueOptions->pieceQueue)
-					->delay($settings->queueOptions->delay ? $settings->queueOptions->delay * ($chunkNumber - 1) : null);
+					->delay($settings->queueOptions->delay ? $settings->queueOptions->delay * ($delayNumber - 1) : null);
+
+				$delayNumber++;
 			}
 
 			return true;