add back in alan's workflow fail detection

This commit is contained in:
Chris Meyers 2016-10-31 15:07:14 -05:00
parent ed37e68c53
commit c4a3b604f8

View File

@ -131,8 +131,10 @@ class Scheduler():
for workflow_job in workflow_jobs:
dag = WorkflowDAG(workflow_job)
if dag.is_workflow_done():
# TODO: detect if wfj failed
workflow_job.status = 'completed'
if workflow_job._has_failed():
workflow_job.status = 'failed'
else:
workflow_job.status = 'successful'
workflow_job.save()
connection.on_commit(lambda: workflow_job.websocket_emit_status(workflow_job.status))