Use `bulk_perform_async` to schedule issue due emails

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