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

Use constants from ScheduledTaskEntity

Browse Source 
[MAILPOET-4309]
This commit is contained in:
Jan Lysý
2022-08-17 13:23:36 +02:00
committed by Veljko V
parent 419ec52f38
commit f9261dbeb4
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
mailpoet/lib/Cron/Workers/SendingQueue/SendingQueue.php
View File

@ -16,7 +16,6 @@ use MailPoet\Mailer\MailerError;
use MailPoet\Mailer\MailerLog; use MailPoet\Mailer\MailerLog;
use MailPoet\Mailer\MetaInfo; use MailPoet\Mailer\MetaInfo;
use MailPoet\Models\ScheduledTask; use MailPoet\Models\ScheduledTask;
use MailPoet\Models\ScheduledTask as ScheduledTaskModel;
use MailPoet\Models\StatisticsNewsletters as StatisticsNewslettersModel; use MailPoet\Models\StatisticsNewsletters as StatisticsNewslettersModel;
use MailPoet\Models\Subscriber as SubscriberModel; use MailPoet\Models\Subscriber as SubscriberModel;
use MailPoet\Newsletter\NewslettersRepository; use MailPoet\Newsletter\NewslettersRepository;
@ -246,7 +245,7 @@ class SendingQueue {
'after queue chunk processing', 'after queue chunk processing',
['newsletter_id' => $newsletter->id, 'task_id' => $queue->taskId] ['newsletter_id' => $newsletter->id, 'task_id' => $queue->taskId]
); );
if ($queue->status === ScheduledTaskModel::STATUS_COMPLETED) { if ($queue->status === ScheduledTaskEntity::STATUS_COMPLETED) {
$this->loggerFactory->getLogger(LoggerFactory::TOPIC_NEWSLETTERS)->info( $this->loggerFactory->getLogger(LoggerFactory::TOPIC_NEWSLETTERS)->info(
'completed newsletter sending', 'completed newsletter sending',
['newsletter_id' => $newsletter->id, 'task_id' => $queue->taskId] ['newsletter_id' => $newsletter->id, 'task_id' => $queue->taskId]
@ -422,7 +421,7 @@ class SendingQueue {
// update the sent count // update the sent count
$this->mailerTask->updateSentCount(); $this->mailerTask->updateSentCount();
// enforce execution limits if queue is still being processed // enforce execution limits if queue is still being processed
if ($sendingTask->status !== ScheduledTaskModel::STATUS_COMPLETED) { if ($sendingTask->status !== ScheduledTaskEntity::STATUS_COMPLETED) {
$this->enforceSendingAndExecutionLimits($timer); $this->enforceSendingAndExecutionLimits($timer);
} }
$this->throttlingHandler->processSuccess(); $this->throttlingHandler->processSuccess();