1

現在、以下のメソッドをトリガーするcronジョブを使用してsidekiqジョブを再起動しています

class RestartSidekiqJobs
  require 'sidekiq/api'

  class << self
    def restart_jobs
      Sidekiq::ScheduledSet.new.clear
      channels = Channel.all
      channels.each do |channel|
        FetchMoreDataJob.perform_later(channel: channel)
      end
    end
  end
end

ただし、これがこれを処理する最善の方法であるとは確信していないため、より良い解決策があるかどうかを確認したいと考えました.

4

0 に答える 0