Schedule it immediately if needed
[MAILPOET-2340]
This commit is contained in:
committed by
Jack Kitterhing
parent
c871efdb3e
commit
d6a29e1b91
@ -1,15 +1,18 @@
|
|||||||
<?php
|
<?php
|
||||||
namespace MailPoet\Cron\Workers;
|
namespace MailPoet\Cron\Workers;
|
||||||
|
|
||||||
|
use Carbon\Carbon;
|
||||||
use MailPoet\Util\Security;
|
use MailPoet\Util\Security;
|
||||||
use MailPoet\Cron\CronHelper;
|
use MailPoet\Cron\CronHelper;
|
||||||
use MailPoet\Models\Subscriber;
|
use MailPoet\Models\Subscriber;
|
||||||
use MailPoet\Models\Newsletter;
|
use MailPoet\Models\Newsletter;
|
||||||
use MailPoet\Models\ScheduledTask;
|
use MailPoet\Models\ScheduledTask;
|
||||||
|
use MailPoet\WP\Functions as WPFunctions;
|
||||||
|
|
||||||
class UnsubscribeTokens extends SimpleWorker {
|
class UnsubscribeTokens extends SimpleWorker {
|
||||||
const TASK_TYPE = 'unsubscribe_tokens';
|
const TASK_TYPE = 'unsubscribe_tokens';
|
||||||
const BATCH_SIZE = 1000;
|
const BATCH_SIZE = 1000;
|
||||||
|
const AUTOMATIC_SCHEDULING = false;
|
||||||
|
|
||||||
function processTaskStrategy(ScheduledTask $task) {
|
function processTaskStrategy(ScheduledTask $task) {
|
||||||
$subscribers_count = $this->addTokens(Subscriber::class);
|
$subscribers_count = $this->addTokens(Subscriber::class);
|
||||||
@ -36,4 +39,10 @@ class UnsubscribeTokens extends SimpleWorker {
|
|||||||
}
|
}
|
||||||
return count($instances);
|
return count($instances);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static function getNextRunDate() {
|
||||||
|
$wp = new WPFunctions;
|
||||||
|
return Carbon::createFromTimestamp($wp->currentTime('timestamp'));
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user