remove uneeded post commit wrapper

* Since we changed the lower level method to always use post commit
message emit
This commit is contained in:
Chris Meyers
2017-02-28 13:04:21 -05:00
parent e09497108e
commit c4fb88c0d9

View File

@@ -382,7 +382,7 @@ class TaskManager():
))
task_obj.save()
_send_notification_templates(task_obj, 'failed')
connection.on_commit(lambda: task_obj.websocket_emit_status('failed'))
task_obj.websocket_emit_status('failed')
logger.error("Task %s appears orphaned... marking as failed" % task)