Skip to content

Commit

Permalink
Use process configuration using "continue" option
Browse files Browse the repository at this point in the history
  • Loading branch information
TheGrimmChester committed Jun 7, 2024
1 parent ad6151b commit d65f5e7
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/Handler/Task/SymfonyProcessTaskHandler.php
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit d65f5e7

Please sign in to comment.