diff --git a/workers/worker.py b/workers/worker.py
index 12bd4d243..e7750c232 100644
--- 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):