Fix bug by using cancel_flag.

This commit is contained in:
Aaron Tan
2016-11-02 17:36:23 -04:00
parent 3778914aa9
commit 3c0d60075c
3 changed files with 7 additions and 6 deletions

View File

@@ -130,8 +130,11 @@ class TaskManager():
def process_finished_workflow_jobs(self, workflow_jobs):
for workflow_job in workflow_jobs:
dag = WorkflowDAG(workflow_job)
if workflow_job.status == 'canceled':
if workflow_job.cancel_flag:
workflow_job.status = 'canceled'
workflow_job.save()
dag.bfs_nodes_to_cancel()
connection.on_commit(lambda: workflow_job.websocket_emit_status(workflow_job.status))
elif dag.is_workflow_done():
if workflow_job._has_failed():
workflow_job.status = 'failed'