Make the watchdog in the build worker also requeue the current item if the worker has gone bad

2014-08-13 19:04:51 -04:00 · 2014-08-13 19:04:51 -04:00 · 728af56384
commit 728af56384
parent d1f6a815bd
1 changed files with 1 additions and 1 deletions
--- a/workers/worker.py
+++ b/workers/worker.py
@ -104,7 +104,7 @@ class Worker(object):
      self.watchdog()
    except WorkerUnhealthyException:
      logger.error('The worker has encountered an error and will not take new jobs.')
-      self.mark_current_incomplete()
+      self.mark_current_incomplete(restore_retry=True)
      self._stop.set()

  def poll_queue(self):