fix batching on products import

synolia · Nov 16, 2023 · 0102f56 · 0102f56
1 parent 2ffa9ba
commit 0102f56
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/Task/Product/ProcessProductsTask.php b/src/Task/Product/ProcessProductsTask.php
@@ -103,7 +103,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
             $this->process($payload);
         }
 
-        $this->processManager->waitForAllProcesses();
+        $this->processManager->startAll();
 
         return $payload;
     }
@@ -114,6 +114,9 @@ private function handleProducts(
         int &$count = 0,
         array &$ids = [],
     ): void {
+        $this->processManager->setInstantProcessing($payload->getProcessAsSoonAsPossible());
+        $this->processManager->setNumberOfParallelProcesses($payload->getMaxRunningProcessQueueSize());
+
         while (
             ($page instanceof Page && $page->hasNextPage()) ||
             ($page instanceof Page && !$page->hasPreviousPage()) ||