diff --git a/src/Handler/Task/SymfonyProcessTaskHandler.php b/src/Handler/Task/SymfonyProcessTaskHandler.php index 3d6be7f4..1387e310 100644 --- a/src/Handler/Task/SymfonyProcessTaskHandler.php +++ b/src/Handler/Task/SymfonyProcessTaskHandler.php @@ -76,6 +76,9 @@ public function batch( public function continue(PipelinePayloadInterface $pipelinePayload): void { + $this->processManager->setInstantProcessing($pipelinePayload->getProcessAsSoonAsPossible()); + $this->processManager->setNumberOfParallelProcesses($pipelinePayload->getMaxRunningProcessQueueSize()); + $totalItemsCount = $this->count($pipelinePayload->getTmpTableName()); if (0 === $totalItemsCount) {