return;
} $this->scheduledTaskRepository->
update([ [ 'id' =>
$taskEntity->
getId(),
'status' => ScheduledTaskDefinition::STATUS_QUEUED,
],
],
$context);
$task =
new $taskClass();
$task->
setTaskId($taskEntity->
getId());
$this->bus->
dispatch($task);
} private function buildCriteriaForNextScheduledTask(): Criteria
{ $criteria =
new Criteria();
$criteria->
addFilter( new EqualsAnyFilter('status',
[ ScheduledTaskDefinition::STATUS_SCHEDULED,
ScheduledTaskDefinition::STATUS_SKIPPED,
])