lib/resque/worker.rb
# Called when we are done working - clears our `working_on` state
# and tells Redis we processed a job.
Called when we are done working - clears our `working_on` state
and tells Redis we processed a job.
Called when we are done working - clears our ` working_on ` state and tells Redis we processed a job .
def done_working
      with_retries do
        redis.pipelined do
          Stat << "processed"
          redis.del("worker:#{self}")
        end
      end
    end
def done_working with_retries do redis . pipelined do Stat << "processed" redis . del ( "worker:#{self}" ) end end end
Called when we are done working - clears our `working_on` state
and tells Redis we processed a job.
Called when we are done working - clears our ` working_on ` state and tells Redis we processed a job .