saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Avoid race condition in even assertions

Browse source
This commit is contained in:
Daniel A. Wozniak 2019-04-19 04:29:39 +00:00 • committed by Pedro Algarvio
parent 9443451d9a
commit 82e9ac5b8f
No known key found for this signature in database
GPG key ID: BB36BF6584A298FF
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
tests/support/mixins.py
View file

@ -657,6 +657,14 @@ def _fetch_events(q):
atexit.register(_clean_queue)
opts = RUNTIME_VARS.RUNTIME_CONFIGS['minion']
event = salt.utils.event.get_event('minion', sock_dir=opts['sock_dir'], opts=opts)
# Wait for event bus to be connected
while not event.connect_pull(30):
time.sleep(1)
# Notify parent process that the event bus is connected
q.put('CONNECTED')
while True:
try:
events = event.get_event(full=False)