diff --git a/mailpoet/lib/API/JSON/v1/SendingQueue.php b/mailpoet/lib/API/JSON/v1/SendingQueue.php index c6e0a56258..688f8206a1 100644 --- a/mailpoet/lib/API/JSON/v1/SendingQueue.php +++ b/mailpoet/lib/API/JSON/v1/SendingQueue.php @@ -163,7 +163,7 @@ class SendingQueue extends APIEndpoint { $taskEntity = $this->scheduledTasksRepository->findOneById($taskModel->id); if ($taskEntity instanceof ScheduledTaskEntity) { - $subscribersCount = $this->subscribersFinder->addSubscribersToTaskFromSegments($taskEntity, $segments); + $subscribersCount = $this->subscribersFinder->addSubscribersToTaskFromSegments($taskEntity, $segments, $newsletterEntity->getFilterSegmentId()); } if (!isset($subscribersCount) || !$subscribersCount) { diff --git a/mailpoet/lib/Cron/Workers/Scheduler.php b/mailpoet/lib/Cron/Workers/Scheduler.php index ae46701374..037e29ddd7 100644 --- a/mailpoet/lib/Cron/Workers/Scheduler.php +++ b/mailpoet/lib/Cron/Workers/Scheduler.php @@ -197,7 +197,7 @@ class Scheduler { $taskModel = $queue->task(); $taskEntity = $this->scheduledTasksRepository->findOneById($taskModel->id); if ($taskEntity instanceof ScheduledTaskEntity) { - $subscribersCount = $this->subscribersFinder->addSubscribersToTaskFromSegments($taskEntity, $segments); + $subscribersCount = $this->subscribersFinder->addSubscribersToTaskFromSegments($taskEntity, $segments, $newsletter->getFilterSegmentId()); } if (empty($subscribersCount)) { @@ -318,7 +318,7 @@ class Scheduler { $taskEntity = $this->scheduledTasksRepository->findOneById($taskModel->id); if ($taskEntity instanceof ScheduledTaskEntity) { - $this->subscribersFinder->addSubscribersToTaskFromSegments($taskEntity, $segments); + $this->subscribersFinder->addSubscribersToTaskFromSegments($taskEntity, $segments, $newsletter->getFilterSegmentId()); } // update current queue