Bug correction in worker: last task was reported Failed in debug mode

pipelet/worker.py

@@ -108,16 +108,14 @@ class Worker(object):
         n = 0        
         try:
             for task in iter(self.scheduler.get_task, None):
-                if task is not None:
-                    self.work_dir = self.pipe.get_curr_dir(task.seg)
-                    task = self.execute_task(task)
-                    if task.status == "done":
-                        self.scheduler.task_done(task)
-                    else:
-                        self.scheduler.task_failed(task)
-                    n = n+1
+                self.work_dir = self.pipe.get_curr_dir(task.seg)
+                task = self.execute_task(task)
+                if task.status == "done":
+                    self.scheduler.task_done(task)
                 else:
-                    break
+                    self.scheduler.task_failed(task)
+                n = n+1
+            self.task = None
             logger.info("%d jobs completed" % n)
         except AbortError, e:
             logger.warning( "Abort after catching signal %d" % e.signal)