23 $this->
_init(
'cron_schedule',
'schedule_id');
42 [
'status' => $newStatus],
43 [
'schedule_id = ?' => $scheduleId,
'status = ?' => $currentStatus]
71 'existing.job_code = current.job_code ' .
72 'AND (existing.executed_at > UTC_TIMESTAMP() - INTERVAL 1 DAY OR existing.executed_at IS NULL) ' .
73 'AND existing.status = ?',
79 [
'existing' => $this->
getTable(
'cron_schedule')],
83 ->where(
'current.schedule_id = ?', $scheduleId)
84 ->where(
'current.status = ?', $currentStatus)
85 ->where(
'existing.schedule_id IS NULL');
87 $update =
$connection->updateFromSelect($selectIfUnlocked, [
'current' => $this->
getTable(
'cron_schedule')]);
_init($mainTable, $idFieldName)
trySetJobStatusAtomic($scheduleId, $newStatus, $currentStatus)
trySetJobUniqueStatusAtomic($scheduleId, $newStatus, $currentStatus)