class Sidekiq::JobRetry
def send_to_morgue(msg)
def send_to_morgue(msg) logger.info { "Adding dead #{msg["class"]} job #{msg["jid"]}" } payload = Sidekiq.dump_json(msg) DeadSet.new.kill(payload, notify_failure: false) end
def send_to_morgue(msg) logger.info { "Adding dead #{msg["class"]} job #{msg["jid"]}" } payload = Sidekiq.dump_json(msg) DeadSet.new.kill(payload, notify_failure: false) end