valitydev/redash
14
0
Fork 0
mirror of https://github.com/valitydev/redash.git synced 2024-11-07 17:38:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

If worker forked process didn't exit cleanly, update job

Browse Source
This commit is contained in:
Arik Fraimovich 2013-11-29 20:59:48 +02:00
parent 34627f5e60
commit bcd018d8de
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
rd_service/data/worker.py
View File

@ -150,6 +150,13 @@ class Worker(threading.Thread):
else: else:
logging.info("[%s] Waiting for pid: %d", self.name, self.child_pid) logging.info("[%s] Waiting for pid: %d", self.name, self.child_pid)
_, status = os.waitpid(self.child_pid, 0) _, status = os.waitpid(self.child_pid, 0)
if status > 0:
job = Job.load(self.manager, job_id)
if not job.is_finished():
logging.info("[%s] process interrupted and job %s hasn't finished; registering interruption in job",
self.name, job_id)
job.done(None, "Interrupted/Cancelled while running.")
logging.info("[%s] Finished Processing %s (pid: %d status: %d)", logging.info("[%s] Finished Processing %s (pid: %d status: %d)",
self.name, job_id, self.child_pid, status) self.name, job_id, self.child_pid, status)