|
|
|
|
@ -57,7 +57,7 @@ class SynchronousBackgroundJob extends QueuedJob { |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
try { |
|
|
|
|
$output = $provider->process($task->getUserId(), $input, fn(float $progress) => $this->taskProcessingManager->setTaskProgress($task->getId(), $progress)); |
|
|
|
|
$output = $provider->process($task->getUserId(), $input, fn (float $progress) => $this->taskProcessingManager->setTaskProgress($task->getId(), $progress)); |
|
|
|
|
} catch (ProcessingException $e) { |
|
|
|
|
$this->logger->warning('Failed to process a TaskProcessing task with synchronous provider ' . $provider->getId(), ['exception' => $e]); |
|
|
|
|
$this->taskProcessingManager->setTaskResult($task->getId(), $e->getMessage(), null); |
|
|
|
|
|