shaba/awx
1
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2024-10-31 23:51:09 +03:00
Code Releases Activity

Silence noisy supervisor tasks, adjust log rotation frequency for all

Browse Source 
supervisor tasks
This commit is contained in:
Matthew Jones 2014-09-04 13:26:32 -04:00
parent 58b71ca9f9
commit 5548cfd6a8
2 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
awx/main/management/commands/run_callback_receiver.py
View File

@ -156,7 +156,6 @@ class CallbackReceiver(object):
try: try:
if event == 'playbook_on_stats': if event == 'playbook_on_stats':
transaction.commit() transaction.commit()
print data
if verbose == 0 and 'res' in data['event_data'] and 'invocation' in data['event_data']['res'] and \ if verbose == 0 and 'res' in data['event_data'] and 'invocation' in data['event_data']['res'] and \
'module_args' in data['event_data']['res']['invocation']: 'module_args' in data['event_data']['res']['invocation']:
data['event_data']['res']['invocation']['module_args'] = "" data['event_data']['res']['invocation']['module_args'] = ""

4
awx/main/management/commands/run_task_system.py
View File

@ -199,19 +199,15 @@ def rebuild_graph(message):
# Rebuild graph # Rebuild graph
graph = SimpleDAG() graph = SimpleDAG()
for task in running_tasks: for task in running_tasks:
print("Adding running task: %s to graph" % str(task))
graph.add_node(task) graph.add_node(task)
print("Waiting Tasks: %s" % str(waiting_tasks))
for wait_task in waiting_tasks: for wait_task in waiting_tasks:
node_dependencies = [] node_dependencies = []
for node in graph: for node in graph:
if wait_task.is_blocked_by(node['node_object']): if wait_task.is_blocked_by(node['node_object']):
print("Waiting task %s is blocked by %s" % (str(wait_task), node['node_object']))
node_dependencies.append(node['node_object']) node_dependencies.append(node['node_object'])
graph.add_node(wait_task) graph.add_node(wait_task)
for dependency in node_dependencies: for dependency in node_dependencies:
graph.add_edge(wait_task, dependency) graph.add_edge(wait_task, dependency)
print("Graph Edges: %s" % str(graph.edges))
if settings.DEBUG: if settings.DEBUG:
graph.generate_graphviz_plot() graph.generate_graphviz_plot()
return graph return graph