Merge pull request #457 from jlopex/block_until_horse_finishes

Make parent worker process wait until horse process finishes
10 years ago · eae2c40ea0
parent 0a0a81da6d fc5295edfc
commit eae2c40ea0
1 changed files with 2 additions and 0 deletions
--- a/rq/worker.py
+++ b/rq/worker.py
@ -473,7 +473,9 @@ class Worker(object):
            self.procline('Forked %d at %d' % (child_pid, time.time()))
            while True:
                try:
+                    self.set_state('busy')
                    os.waitpid(child_pid, 0)
+                    self.set_state('idle')
                    break
                except OSError as e:
                    # In case we encountered an OSError due to EINTR (which is