From bb630fddbc55a76c7cd1d616c701e83b6c77a4d7 Mon Sep 17 00:00:00 2001 From: Matthew Jones Date: Tue, 25 Mar 2014 15:01:18 -0400 Subject: [PATCH] Fix up error handler callback to include the task that actually failed --- awx/main/management/commands/run_task_system.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/awx/main/management/commands/run_task_system.py b/awx/main/management/commands/run_task_system.py index d44015e531..5c3b506009 100644 --- a/awx/main/management/commands/run_task_system.py +++ b/awx/main/management/commands/run_task_system.py @@ -231,7 +231,8 @@ def process_graph(graph, task_capacity): node_args = task_node['metadata'] impact = node_obj.task_impact if impact <= remaining_volume or running_impact == 0: - dependent_nodes = [{'type': graph.get_node_type(n['node_object']), 'id': n['node_object'].id} for n in graph.get_dependents(node_obj)] + dependent_nodes = [{'type': graph.get_node_type(node_obj), 'id': node_obj.id}] + \ + [{'type': graph.get_node_type(n['node_object']), 'id': n['node_object'].id} for n in graph.get_dependents(node_obj)] error_handler = handle_work_error.s(subtasks=dependent_nodes) start_status = node_obj.start(error_callback=error_handler) if not start_status: