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

Add inactive subscribers check to cron trigger

Browse Source 
[MAILPOET-1791]
This commit is contained in:
Rostislav Wolny
2019-04-16 15:11:32 +02:00
committed by M. Shull
parent 5d70af106b
commit ade19d561e
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
lib/Cron/Triggers/WordPress.php
View File

@@ -1,7 +1,7 @@
<?php <?php
namespace MailPoet\Cron\Triggers; namespace MailPoet\Cron\Triggers;
use Carbon\Carbon; use MailPoet\Cron\Workers\InactiveSubscribers;
use MailPoet\Services\Bridge; use MailPoet\Services\Bridge;
use MailPoet\Cron\CronHelper; use MailPoet\Cron\CronHelper;
use MailPoet\Mailer\MailerLog; use MailPoet\Mailer\MailerLog;
@@ -97,6 +97,12 @@ class WordPress {
'scheduled_in' => [self::SCHEDULED_IN_THE_PAST], 'scheduled_in' => [self::SCHEDULED_IN_THE_PAST],
'status' => ['null', ScheduledTask::STATUS_SCHEDULED] 'status' => ['null', ScheduledTask::STATUS_SCHEDULED]
]); ]);
// inactive subscribers check
$inactive_subscribers_tasks = self::getTasksCount([
'type' => InactiveSubscribers::TASK_TYPE,
'scheduled_in' => [self::SCHEDULED_IN_THE_PAST],
'status' => ['null', ScheduledTask::STATUS_SCHEDULED]
]);
// check requirements for each worker // check requirements for each worker
$sending_queue_active = (($scheduled_queues || $running_queues) && !$sending_limit_reached && !$sending_is_paused); $sending_queue_active = (($scheduled_queues || $running_queues) && !$sending_limit_reached && !$sending_is_paused);
@@ -112,6 +118,7 @@ class WordPress {
|| $sending_service_key_check_active || $sending_service_key_check_active
|| $premium_key_check_active || $premium_key_check_active
|| $stats_notifications_tasks || $stats_notifications_tasks
|| $inactive_subscribers_tasks
); );
} }