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

Move scheduleImmediately to SimpleWorker

Browse Source 
[MAILPOET-3585]
This commit is contained in:
Jan Lysý
2021-04-29 13:56:03 +02:00
committed by Veljko V
parent cfa29c9df1
commit 6ae390bd3d
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
lib/Cron/Workers/SimpleWorker.php
View File

@ -50,6 +50,10 @@ abstract class SimpleWorker implements CronWorkerInterface {
$this->cronWorkerScheduler->schedule(static::TASK_TYPE, $this->getNextRunDate()); $this->cronWorkerScheduler->schedule(static::TASK_TYPE, $this->getNextRunDate());
} }
protected function scheduleImmediately(): void {
$this->cronWorkerScheduler->schedule(static::TASK_TYPE, $this->getNextRunDateImmediately());
}
public function checkProcessingRequirements() { public function checkProcessingRequirements() {
return true; return true;
} }
@ -73,6 +77,10 @@ abstract class SimpleWorker implements CronWorkerInterface {
return $date; return $date;
} }
protected function getNextRunDateImmediately(): Carbon {
return Carbon::createFromTimestamp($this->wp->currentTime('timestamp'));
}
public function scheduleAutomatically() { public function scheduleAutomatically() {
return static::AUTOMATIC_SCHEDULING; return static::AUTOMATIC_SCHEDULING;
} }

8
lib/Cron/Workers/SubscribersEngagementScore.php
View File

@ -40,14 +40,6 @@ class SubscribersEngagementScore extends SimpleWorker {
return true; return true;
} }
public function scheduleImmediately(): void {
$this->cronWorkerScheduler->schedule(static::TASK_TYPE, $this->getNextRunDateImmediately());
}
public function getNextRunDateImmediately(): Carbon {
return Carbon::createFromTimestamp($this->wp->currentTime('timestamp'));
}
public function getNextRunDate() { public function getNextRunDate() {
// random day of the next week // random day of the next week
$date = Carbon::createFromTimestamp($this->wp->currentTime('timestamp')); $date = Carbon::createFromTimestamp($this->wp->currentTime('timestamp'));