Rooba
/
rq
mirror of https://github.com/rq/rq.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Slight code reshuffle + added some comments on the construction.

This commit is contained in:
Vincent Driessen 2011-11-24 16:21:52 +01:00
parent 7cba8449d9
commit 88cbaa1df9
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
rq/worker.py
View File

@ -255,9 +255,13 @@ class Worker(object):
os.waitpid(child_pid, 0) os.waitpid(child_pid, 0)
break break
except OSError as e: except OSError as e:
if e.errno == errno.EINTR: # In case we encountered an OSError due to EINTR (which is
self.log.info('Not waiting for child.... received SIGINT.') # caused by a SIGINT signal during os.waitpid()), we simply
else: # ignore it and enter the next iteration of the loop,
# waiting for the child to end. In any other case, this is
# some other unexpected OS error, which we don't want to
# catch, so we re-raise those ones.
if e.errno != errno.EINTR:
raise raise
def perform_job(self, job): def perform_job(self, job):