From 914b984e9b71156951b4efd4e44ec2ab0b6942ef Mon Sep 17 00:00:00 2001 From: Michael Kohl Date: Fri, 28 Jan 2022 11:32:25 +0700 Subject: [PATCH] Use `perform_bulk` in `Podcasts::EnqueueGetEpisodesWorker` (#16325) --- app/workers/podcasts/enqueue_get_episodes_worker.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/app/workers/podcasts/enqueue_get_episodes_worker.rb b/app/workers/podcasts/enqueue_get_episodes_worker.rb index 27a484c68..2042e006d 100644 --- a/app/workers/podcasts/enqueue_get_episodes_worker.rb +++ b/app/workers/podcasts/enqueue_get_episodes_worker.rb @@ -5,9 +5,9 @@ module Podcasts sidekiq_options queue: :medium_priority, retry: 10 def perform - Podcast.published.select(:id).find_each do |podcast| - Podcasts::GetEpisodesWorker.perform_async("podcast_id" => podcast.id, "limit" => 5) - end + # `perform_bulk` expects an array of argument arrays we need to wrap the hashes. + job_params = Podcast.published.ids.map { |id| [{ "podcast_id" => id, "limit" => 5 }] } + Podcasts::GetEpisodesWorker.perform_bulk(job_params) end end end