Skip to content

Commit 9595658

Browse files
committed
fix bug in local task
1 parent 51cefe9 commit 9595658

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

DAGflow/do_DAG.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ def update_task_status(tasks, stop_on_failure):
140140
del_online_tasks()
141141
continue
142142
elif task.type == "local":
143-
if not task.run_id.poll():
143+
if task.run_id.poll() is not None:
144144
status = task.check_done()
145145

146146
if not status and stop_on_failure:

0 commit comments

Comments
 (0)