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

Finish up the immediate or average rate method

Browse Source
This commit is contained in:
Alan Rominger 2021-05-03 11:32:03 -04:00
parent 70420dc3e4
commit 4b6b8f2bdd
No known key found for this signature in database
GPG Key ID: C2D7EAAA12B63559
1 changed files with 23 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
awx/main/tasks.py
View File

@ -1157,20 +1157,32 @@ class BaseTask(object):
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 (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)
should_emit = bool(
# if 30the most recent websocket message was sent over 1 second ago
cpu_time - first_window_time > 1.0
# if the very last websocket message came in over 1/30 seconds ago
or self.recent_event_timings.maxlen * (cpu_time - last_window_time) > 1.0
# if the queue is not yet full
or (len(self.recent_event_timings) != self.recent_event_timings.maxlen)
)
if should_skip:
logger.debug(
'Event {} websocket send {}, queue {}, avg rate {}, last rate {}'.format(
event_data['counter'],
should_emit,
len(self.recent_event_timings),
30.0 / (cpu_time - first_window_time),
1.0 / (cpu_time - last_window_time),
)
)
if should_emit:
self.recent_event_timings.append(cpu_time)
else:
event_data.setdefault('event_data', {})
event_data['event_data']['skip_websocket_message'] = True
else:
if self.recent_event_timings[0] == self.recent_event_timings[-1]:
logger.debug('Starting a window of event emission')
self.recent_event_timings.append(cpu_time)
elif self.recent_event_timings.maxlen:
self.recent_event_timings.append(time.time())