External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-01-20 06:01:25 -03:30
Code Issues Packages Projects Releases Wiki Activity

minor refactoring of awx-manage bottleneck

Browse Source
This commit is contained in:
Ryan Petrello 2020-06-24 10:17:10 -04:00
parent ce65f994dc
commit dd42f6351b
No known key found for this signature in database
GPG Key ID: F2AA5F2122351777
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -21,9 +21,6 @@ class Command(BaseCommand):
threshold = options['threshold']
history = options['history']
ignore = options['ignore']
colorize = True
if options.get('no_color') is True:
colorize = False
print('## ' + JobTemplate.objects.get(pk=jt).name + f' (last {history} runs)\n')
with connection.cursor() as cursor:
@ -70,20 +67,20 @@ class Command(BaseCommand):
for event in slowest_events:
_id, job_id, host, duration, task, action, playbook = event
playbook = playbook.rsplit('/')[-1]
if ignore and action in ignore:
continue
if duration.total_seconds() < threshold:
break
playbook = playbook.rsplit('/')[-1]
human_duration = format_td(duration)
fastest_summary = ''
fastest_match = fastest.get((action, playbook))
if fastest_match[2] != format_td(duration) and (host, action, playbook) not in warned:
if fastest_match[2] != human_duration and (host, action, playbook) not in warned:
warned.add((host, action, playbook))
fastest_summary = ' ' + self.style.WARNING(f'{fastest_match[1]} ran this in {fastest_match[2]}s at /api/v2/job_events/{fastest_match[0]}/')
url = f'/api/v2/jobs/{job_id}/'
human_duration = format_td(duration)
print(' -- '.join([url, host, human_duration, action, task, playbook]) + fastest_summary)
host_counts.setdefault(host, [])
host_counts[host].append(duration)