fix bug in local task

FlyPythons · Feb 5, 2018 · 9595658 · 9595658
1 parent 51cefe9
commit 9595658
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/DAGflow/do_DAG.py b/DAGflow/do_DAG.py
@@ -140,7 +140,7 @@ def update_task_status(tasks, stop_on_failure):
                 del_online_tasks()
             continue
         elif task.type == "local":
-            if not task.run_id.poll():
+            if task.run_id.poll() is not None:
                 status = task.check_done()
 
                 if not status and stop_on_failure: