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

THIS DOES NOT WORK pass events if they fit either timing criteria

Browse Source
This commit is contained in:
Alan Rominger 2021-04-30 11:59:15 -04:00
parent 50ca2d47ce
commit 70420dc3e4
No known key found for this signature in database
GPG Key ID: C2D7EAAA12B63559
1 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
awx/main/tasks.py
View File

@ -1156,17 +1156,15 @@ class BaseTask(object):
if self.recent_event_timings:
cpu_time = time.time()
first_window_time = self.recent_event_timings[0]
last_window_time = self.recent_event_timings[-1]
inverse_effective_rate = cpu_time - first_window_time
# if last 30 events came in under 1 second ago
if inverse_effective_rate < 1.0:
if self.recent_event_timings[0] != self.recent_event_timings[-1]:
logger.debug(
'Too many events, skipping job {} websocket broadcast for {:.4f} seconds'.format(self.instance.id, 1.0 - inverse_effective_rate)
)
# 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
self.recent_event_timings.clear()
self.recent_event_timings.append(first_window_time)
# if last 30 events (which we sent websockets for) came in under 1 second ago
should_skip = bool(
inverse_effective_rate < 1.0
and self.recent_event_timings.maxlen * (cpu_time - last_window_time) < 1.0
and (len(self.recent_event_timings) == self.recent_event_timings.maxlen)
)
if should_skip:
event_data.setdefault('event_data', {})
event_data['event_data']['skip_websocket_message'] = True
else: