Merge pull request #581 from mgk/master

export worker id and job id as env vars to work horse
main
Selwin Ong 9 years ago
commit 73d0dda516

@ -493,6 +493,8 @@ class Worker(object):
""" """
self.set_state('busy') self.set_state('busy')
child_pid = os.fork() child_pid = os.fork()
os.environ['RQ_WORKER_ID'] = self.name
os.environ['RQ_JOB_ID'] = job.id
if child_pid == 0: if child_pid == 0:
self.main_work_horse(job) self.main_work_horse(job)
else: else:

Loading…
Cancel
Save