File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -128,6 +128,7 @@ def work(interval = 5.0, &block)
128
128
129
129
if not paused? and job = reserve
130
130
log "got: #{ job . inspect } "
131
+ job . worker = self
131
132
run_hook :before_fork , job
132
133
working_on job
133
134
@@ -160,6 +161,7 @@ def work(interval = 5.0, &block)
160
161
def process ( job = nil , &block )
161
162
return unless job ||= reserve
162
163
164
+ job . worker = self
163
165
working_on job
164
166
perform ( job , &block )
165
167
ensure
@@ -388,7 +390,6 @@ def unregister_worker
388
390
# Given a job, tells Redis we're working on it. Useful for seeing
389
391
# what workers are doing and when.
390
392
def working_on ( job )
391
- job . worker = self
392
393
data = encode \
393
394
:queue => job . queue ,
394
395
:run_at => Time . now . strftime ( "%Y/%m/%d %H:%M:%S %Z" ) ,
You can’t perform that action at this time.
0 commit comments