signal death when timeouterror

1 files changed, 2 insertions, 1 deletions

diff --git a/eventmq/worker.py b/eventmq/worker.py
index 69567d5..1af433e 100644
--- a/eventmq/worker.py
+++ b/eventmq/worker.py
@@ -128,7 +128,8 @@ class MultiprocessWorker(Process):
                     self.output_queue.put_nowait(
                         {'msgid': msgid,
                          'return': return_val,
-                         'death': self.job_count >= conf.MAX_JOB_COUNT,
+                         'death': self.job_count >= conf.MAX_JOB_COUNT or
+                         return_val == 'TimeoutError',
                          'pid': os.getpid(),
                          'callback': callback}
                     )