ruby on rails - retries - cómo eliminar un trabajo en sidekiq

sidekiq scheduler

Question

Estoy usando sidekiq en mi aplicación de rieles. Los usuarios de mi aplicación crean informes que inician un trabajo de sidekiq. Sin embargo, a veces los usuarios desean poder cancelar informes de "procesamiento". Eliminar el informe es fácil, pero también necesito poder eliminar el trabajo de sidekiq.

Hasta ahora he podido obtener una lista de trabajadores así:

workers = Sidekiq::Workers.new

y cada trabajador tiene argumentos que incluyen un report_id para que pueda identificar qué trabajo pertenece a qué informe. Sin embargo, no estoy seguro de cómo eliminar realmente el trabajo. Se debe tener en cuenta que deseo eliminar el trabajo si actualmente está ocupado o configurarlo en reintento.

Answer 1

De acuerdo con esta página de documentación de Sidekiq para eliminar un trabajo con un solo ID, debe iterar la cola y llamar a .delete .

queue = Sidekiq::Queue.new("mailer")
queue.each do |job|
job.klass # => ''MyWorker''
job.args # => [1, 2, 3]
job.delete if job.jid == ''abcdef1234567890''
end

También hay un complemento llamado sidekiq-status que le brinda la posibilidad de cancelar un solo trabajo

scheduled_job_id = MyJob.perform_in 3600
Sidekiq::Status.cancel scheduled_job_id #=> true

Answer 2

Hay una forma sencilla de eliminar un trabajo si conoce el ID de trabajo:

job = Sidekiq::ScheduledSet.new.find_job(job_id)
begin
job.delete
rescue
Rails.logger.error "Job: (job_id: #{job_id}) not found while deleting jobs."
end

Answer 3

La forma más sencilla que encontré para hacer esto es:

Sidekiq::ScheduledSet.new.each do |_job|
next unless [online_jid, offline_jid].include? _job.jid
status = _job.delete
end

donde [job_id] es el JID que pertenece al informe. Seguido por:

job = Sidekiq::ScheduledSet.new.find_job([job_id])

No encontré la necesidad de recorrer toda la cola como se describe en otras respuestas aquí.

Answer 4

Puede eliminar el filtrado de trabajos sidekiq por clase de trabajo y argumentos:

class UserReportsWorker
include Sidekiq::Worker
def perform(report_id)
# ...
end
end
jobs = Sidekiq::ScheduledSet.new.select do |retri|
retri.klass == "UserReportsWorker" && retri.args == [42]
end
jobs.each(&:delete)

Answer 5

Si desea cancelar un trabajo programado, no estoy seguro acerca de la respuesta de @ KimiGao, pero esto es lo que adapté de la documentación de API actual de Sidekiq:

jid = MyCustomWorker.perform_async
r = Sidekiq::ScheduledSet.new
jobs = r.select{|job| job.jid == jid }
jobs.each(&:delete)

Espero eso ayude.

Answer 6

Tuve el mismo problema, pero la diferencia es que necesitaba cancelar un trabajo programado, y mi solución es:

job.delete

Answer 7

Yo tuve el mismo problema. ¡Lo resolví registrando el ID de trabajo cuando lo inicializo y creando otra función cancel! para borrarlo.

Aquí está el código:

after_enqueue do |job|
sidekiq_job = nil
queue = Sidekiq::Queue.new
sidekiq_job = queue.detect do |j|
j.item[''args''][0][''job_id''] == job.job_id
end
if sidekiq_job.nil?
scheduled = Sidekiq::ScheduledSet.new
sidekiq_job = scheduled.detect do |j|
j.item[''args''][0][''job_id''] == job.job_id
end
end
if sidekiq_job.present?
booking = job.arguments.first
booking.close_comments_jid = sidekiq_job.jid
booking.save
end
end
def perform(booking)
# do something
end
def self.cancel!(booking)
queue = Sidekiq::Queue.new
sidekiq_job = queue.find_job(booking.close_comments_jid)
if sidekiq_job.nil?
scheduled = Sidekiq::ScheduledSet.new
sidekiq_job = scheduled.find_job(booking.close_comments_jid)
end
if sidekiq_job.nil?
# Report bug in my Bug Tracking tool
else
sidekiq_job.delete
end
end