Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Refactor DaemonRun::afterProcess for better readability

Browse Source 
[MAILPOET-4684]
This commit is contained in:
Rostislav Wolny
2022-09-28 17:28:54 +02:00
committed by Aschepikov
parent de22257af3
commit 9c0ce5ed7a
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
mailpoet/lib/Cron/ActionScheduler/Actions/DaemonRun.php
View File

@@ -85,17 +85,21 @@ class DaemonRun {
* After Action Scheduler finishes its work we need to check if there is more work and in case there is we trigger additional runner.
*/
public function afterProcess(): void {
$lastDurationWasTooShort = ($this->lastRunDuration < self::SHORT_DURATION_THRESHOLD) && ($this->remainingExecutionLimit > 0);
// Schedule next action in case we have more jobs to do.
$hasJobsToDo = $this->wordpressTrigger->checkExecutionRequirements();
if (!$hasJobsToDo) {
return;
}
// The $lastDurationWasTooShort check prevents scheduling the next immediate action in case the last run was suspiciously short.
// If there was still some execution time left, the daemon should have been continued.
if ($this->wordpressTrigger->checkExecutionRequirements() && !$lastDurationWasTooShort) {
$this->actionScheduler->scheduleImmediateSingleAction(self::NAME);
// The automatic rescheduling schedules the next recurring action to run after 1 second.
// So we need to wait before we trigger new remote executor to avoid skipping the action
sleep(2);
$this->remoteExecutorHandler->triggerExecutor();
$lastDurationWasTooShort = ($this->lastRunDuration < self::SHORT_DURATION_THRESHOLD) && ($this->remainingExecutionLimit > 0);
if ($lastDurationWasTooShort) {
return;
}
$this->actionScheduler->scheduleImmediateSingleAction(self::NAME);
// The automatic rescheduling schedules the next recurring action to run after 1 second.
// So we need to wait before we trigger new remote executor to avoid skipping the action
sleep(2);
$this->remoteExecutorHandler->triggerExecutor();
}
/**