External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-03-19 18:07:33 -02:30
Code Issues Packages Projects Releases Wiki Activity

add the name of the task to awx-manage bottleneck output

Browse Source
This commit is contained in:
Ryan Petrello
2020-06-24 09:44:39 -04:00
parent b01ac1bfa6
commit 21ea7eb5dc
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
awx/main/management/commands/bottleneck.py
View File

@@ -28,6 +28,7 @@ class Command(BaseCommand):
f''' f'''
SELECT SELECT
b.id, b.job_id, b.host_name, b.created - a.created delta, b.id, b.job_id, b.host_name, b.created - a.created delta,
b.task task,
b.event_data::json->'task_action' task_action, b.event_data::json->'task_action' task_action,
b.event_data::json->'task_path' task_path b.event_data::json->'task_path' task_path
FROM main_jobevent a JOIN main_jobevent b FROM main_jobevent a JOIN main_jobevent b
@@ -50,7 +51,7 @@ class Command(BaseCommand):
fastest = dict() fastest = dict()
for event in slowest_events: for event in slowest_events:
_id, job_id, host, duration, action, playbook = event _id, job_id, host, duration, task, action, playbook = event
playbook = playbook.rsplit('/')[-1] playbook = playbook.rsplit('/')[-1]
if ignore and action in ignore: if ignore and action in ignore:
continue continue
@@ -61,7 +62,7 @@ class Command(BaseCommand):
warned = set() warned = set()
print(f'slowest tasks (--threshold={threshold})\n---') print(f'slowest tasks (--threshold={threshold})\n---')
for event in slowest_events: for event in slowest_events:
_id, job_id, host, duration, action, playbook = event _id, job_id, host, duration, task, action, playbook = event
playbook = playbook.rsplit('/')[-1] playbook = playbook.rsplit('/')[-1]
if ignore and action in ignore: if ignore and action in ignore:
continue continue
@@ -76,7 +77,7 @@ class Command(BaseCommand):
url = f'/api/v2/jobs/{job_id}/' url = f'/api/v2/jobs/{job_id}/'
human_duration = str(duration).split('.')[0] human_duration = str(duration).split('.')[0]
print(' -- '.join([url, host, human_duration, action, playbook]) + fastest_summary) print(' -- '.join([url, host, human_duration, action, task, playbook]) + fastest_summary)
host_counts.setdefault(host, []) host_counts.setdefault(host, [])
host_counts[host].append(duration) host_counts[host].append(duration)