You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
It appears there's nothing in this plugin that requeues jobs in the waiting_room by default. You'll need to implement something yourself.
I used the following job on a 5 minute schedule:
# Works through contents of :waiting_room queue and requeues them in their original queue.
class RequeueWaitingRoomJobs
@queue = :urgent
def self.perform
# Only process jobs currently in queue, in case we end up requeueing some of them.
queue_length = Resque.size(:waiting_room)
queue_length.times do
job = Resque.reserve(:waiting_room)
# If the job is not ready to leave the waiting room, Job#reserve will requeue it to waiting_room and return nil.
next if job.nil?
# Requeue to original queue.
Resque.enqueue(job.payload_class, *job.args)
end
end
end
some jobs get queued in the waiting room (dont know why BTW), then they never get pulled out...
The text was updated successfully, but these errors were encountered: