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

Disable marking subscribers as processed on error

Browse Source 
[MAILPOET-4200]
This commit is contained in:
Jan Lysý
2022-04-19 13:09:46 +02:00
committed by Veljko V
parent 4733bcd03f
commit 1310e5afec
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -387,9 +387,7 @@ class SendingQueue {
$error = $sendResult['error']; $error = $sendResult['error'];
assert($error instanceof MailerError); assert($error instanceof MailerError);
$this->errorHandler->processError($error, $sendingTask, $preparedSubscribersIds, $preparedSubscribers); $this->errorHandler->processError($error, $sendingTask, $preparedSubscribersIds, $preparedSubscribers);
} } elseif (!$sendingTask->updateProcessedSubscribers($preparedSubscribersIds)) { // update processed/to process list
// update processed/to process list
if (!$sendingTask->updateProcessedSubscribers($preparedSubscribersIds)) {
MailerLog::processError( MailerLog::processError(
'processed_list_update', 'processed_list_update',
sprintf('QUEUE-%d-PROCESSED-LIST-UPDATE', $sendingTask->id), sprintf('QUEUE-%d-PROCESSED-LIST-UPDATE', $sendingTask->id),

2
mailpoet/lib/Tasks/Subscribers.php
View File

@ -51,8 +51,10 @@ class Subscribers {
->where('subscriber_id', $subcriberId) ->where('subscriber_id', $subcriberId)
->findResultSet() ->findResultSet()
->set('failed', ScheduledTaskSubscriber::FAIL_STATUS_FAILED) ->set('failed', ScheduledTaskSubscriber::FAIL_STATUS_FAILED)
->set('processed', ScheduledTaskSubscriber::STATUS_PROCESSED)
->set('error', $errorMessage) ->set('error', $errorMessage)
->save(); ->save();
$this->checkCompleted();
} }
private function checkCompleted($count = null) { private function checkCompleted($count = null) {