lib/rocket_job/sliced/input.rb
# Requeue all running slices for a server or worker that is no longer available
Requeue all running slices for a server or worker that is no longer available
Requeue all running slices for a server or worker that is no longer available
def requeue_running(worker_name)
        running.where(worker_name: /\A#{worker_name}/).update_all(
          '$unset' => {worker_name: nil, started_at: nil},
          '$set'   => {state: :queued}
        )
      end
def requeue_running ( worker_name ) running . where ( worker_name : / \A #{ worker_name } / ) . update_all ( '$unset' => { worker_name : nil , started_at : nil } , '$set' => { state : :queued } ) end
Requeue all running slices for a server or worker that is no longer available
Requeue all running slices for a server or worker that is no longer available
worker_name