diff options
| -rw-r--r-- | app/workers/issue_due_scheduler_worker.rb | 6 | ||||
| -rw-r--r-- | spec/workers/issue_due_scheduler_worker_spec.rb | 3 |
2 files changed, 4 insertions, 5 deletions
diff --git a/app/workers/issue_due_scheduler_worker.rb b/app/workers/issue_due_scheduler_worker.rb index 9c06304bff6..16ab5d069e0 100644 --- a/app/workers/issue_due_scheduler_worker.rb +++ b/app/workers/issue_due_scheduler_worker.rb @@ -3,8 +3,8 @@ class IssueDueSchedulerWorker include CronjobQueue def perform - Issue.opened.due_tomorrow.group(:project_id).pluck(:project_id).each do |project_id| - MailScheduler::IssueDueWorker.perform_async(project_id) - end + project_ids = Issue.opened.due_tomorrow.group(:project_id).pluck(:project_id).map { |id| [id] } + + MailScheduler::IssueDueWorker.bulk_perform_async(project_ids) end end diff --git a/spec/workers/issue_due_scheduler_worker_spec.rb b/spec/workers/issue_due_scheduler_worker_spec.rb index eff5855834c..7b60835fd26 100644 --- a/spec/workers/issue_due_scheduler_worker_spec.rb +++ b/spec/workers/issue_due_scheduler_worker_spec.rb @@ -14,8 +14,7 @@ describe IssueDueSchedulerWorker do create(:issue, :closed, project: project_closed_issue, due_date: Date.tomorrow) create(:issue, :opened, project: project_issue_due_another_day, due_date: Date.today) - expect(MailScheduler::IssueDueWorker).to receive(:perform_async).with(project1.id) - expect(MailScheduler::IssueDueWorker).to receive(:perform_async).with(project2.id) + expect(MailScheduler::IssueDueWorker).to receive(:bulk_perform_async).with([[project1.id], [project2.id]]) described_class.new.perform end |