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

fix up log wording

Browse Source
This commit is contained in:
Alan Rominger
2021-04-29 14:18:36 -04:00
parent 01228cea02
commit faa0a6cf9a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
awx/main/tasks.py
View File

@@ -1160,7 +1160,9 @@ class BaseTask(object):
# if last 30 events came in under 1 second ago # if last 30 events came in under 1 second ago
if inverse_effective_rate < 1.0: if inverse_effective_rate < 1.0:
if self.recent_event_timings[0] != self.recent_event_timings[-1]: if self.recent_event_timings[0] != self.recent_event_timings[-1]:
logger.info('Too many events chief, not broadcasting because that would be crazy') logger.info(
'Too many events, skipping websocket {} broadcast for {} seconds'.format(self.instance.log_format, 1.0 - inverse_effective_rate)
)
# this is to smooth out jumpiness, we clear the events except for the last one # this is to smooth out jumpiness, we clear the events except for the last one
# that will enforce that we wait a full second before starting again # that will enforce that we wait a full second before starting again
self.recent_event_timings.clear() self.recent_event_timings.clear()
@@ -1169,7 +1171,7 @@ class BaseTask(object):
event_data['event_data']['skip_websocket_message'] = True event_data['event_data']['skip_websocket_message'] = True
else: else:
if self.recent_event_timings[0] == self.recent_event_timings[-1]: if self.recent_event_timings[0] == self.recent_event_timings[-1]:
logger.info('Starting a window of event emission, will pause if I see too many') logger.debug('Starting a window of event emission')
self.recent_event_timings.append(cpu_time) self.recent_event_timings.append(cpu_time)
elif self.recent_event_timings.maxlen: elif self.recent_event_timings.maxlen:
self.recent_event_timings.append(time.time()) self.recent_event_timings.append(time.time())