Log when a forked worker encounters an exception.

seomoz · Nov 3, 2016 · 9134513 · 9134513
1 parent 966ed80
commit 9134513
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/qless/workers/forking.py b/qless/workers/forking.py
@@ -82,6 +82,8 @@ def run(self):
                     os.chdir(sandbox)
                     try:
                         self.spawn(resume=resume[index], sandbox=sandbox).run()
+                    except:
+                        logger.exception('Exception in spawned worker')
                     finally:
                         os._exit(0)
 
@@ -100,6 +102,8 @@ def run(self):
                         os.chdir(sandbox)
                         try:
                            self.spawn(sandbox=sandbox).run()
+                        except:
+                            logger.exception('Exception in spawned worker')
                         finally:
                             os._exit(0)
         finally: