Remove duplicated method in ScheduledTaskSubscribersRepository
[MAILPOET-5422]
This commit is contained in:
@@ -126,7 +126,7 @@ class AutomaticEmailScheduler {
|
||||
if ($queue instanceof SendingQueueEntity) {
|
||||
$this->sendingQueuesRepository->remove($queue);
|
||||
}
|
||||
$this->scheduledTaskSubscribersRepository->deleteByTask($task);
|
||||
$this->scheduledTaskSubscribersRepository->deleteByScheduledTask($task);
|
||||
// In case any of task associated SchedulesTaskSubscriberEntity was loaded we need to detach them
|
||||
foreach ($task->getSubscribers() as $taskSubscriber) {
|
||||
$this->scheduledTaskSubscribersRepository->detach($taskSubscriber);
|
||||
|
@@ -78,15 +78,6 @@ class ScheduledTaskSubscribersRepository extends Repository {
|
||||
return $subscribersIds;
|
||||
}
|
||||
|
||||
public function deleteByTask(ScheduledTaskEntity $scheduledTask): void {
|
||||
$this->entityManager->createQueryBuilder()
|
||||
->delete(ScheduledTaskSubscriberEntity::class, 'sts')
|
||||
->where('sts.task = :task')
|
||||
->setParameter('task', $scheduledTask)
|
||||
->getQuery()
|
||||
->execute();
|
||||
}
|
||||
|
||||
/**
|
||||
* @param int[] $subscriberIds
|
||||
*/
|
||||
|
Reference in New Issue
Block a user