diff --git a/awx/main/scheduler/task_manager.py b/awx/main/scheduler/task_manager.py index 5532bef89b..6c25fbef4a 100644 --- a/awx/main/scheduler/task_manager.py +++ b/awx/main/scheduler/task_manager.py @@ -235,7 +235,7 @@ class TaskManager(): else: if type(task) is WorkflowJob: task.status = 'running' - task.send_notification_templates('running') + connection.on_commit(lambda: task.send_notification_templates('running')) logger.debug('Transitioning %s to running status.', task.log_format) schedule_task_manager() elif not task.supports_isolation() and rampart_group.controller_id: