mirror of
https://github.com/ansible/awx.git
synced 2026-03-28 22:35:08 -02:30
send notification when recifiying celery jobs
This commit is contained in:
@@ -346,6 +346,7 @@ class TaskManager():
|
|||||||
'Celery, so it has been marked as failed.',
|
'Celery, so it has been marked as failed.',
|
||||||
))
|
))
|
||||||
task_obj.save()
|
task_obj.save()
|
||||||
|
_send_notification_templates(task_obj, 'failed')
|
||||||
connection.on_commit(lambda: task_obj.websocket_emit_status('failed'))
|
connection.on_commit(lambda: task_obj.websocket_emit_status('failed'))
|
||||||
|
|
||||||
logger.error("Task %s appears orphaned... marking as failed" % task)
|
logger.error("Task %s appears orphaned... marking as failed" % task)
|
||||||
|
|||||||
Reference in New Issue
Block a user