setAllowParallelRuns(false);
}
/**
* @param array{taskId: int} $argument
* @inheritDoc
*/
protected function run($argument) {
$taskId = $argument['taskId'];
$task = $this->textProcessingManager->getTask($taskId);
try {
$this->textProcessingManager->runTask($task);
$event = new TaskSuccessfulEvent($task);
} catch (\Throwable $e) {
$event = new TaskFailedEvent($task, $e->getMessage());
}
$this->eventDispatcher->dispatchTyped($event);
}
}
ue='44287-fix-avatar-fed-share-receiver'>44287-fix-avatar-fed-share-receiver
blob: 36629a0273f2171d9e72a98a3c8f7215da1cdcf8 (
plain)