make `BatchFetchMediaWorker` emergency stoppable by setting `Rails.cache.write(stop_fetch_media_worker, true)`

master
multiple creatures 2019-09-17 22:24:50 -05:00
parent 7ee43869e7
commit cc32f0f50b
1 changed files with 4 additions and 0 deletions

View File

@ -7,6 +7,10 @@ class BatchFetchMediaWorker
def perform(media_attachment_ids)
media_attachment_ids.each_with_index do |attachment_id, index|
if Rails.cache.fetch('stop_fetch_media_worker', false)
Rails.cache.delete('stop_fetch_media_worker')
break
end
FetchMediaWorker.perform_async(attachment_id)
sleep(0.5 * Sidekiq::Queue.new(:bulk).size)
end