mirror of
https://github.com/saltstack/salt.git
synced 2025-04-17 10:10:20 +00:00
fix reactor ping test
This commit is contained in:
parent
86adb6b0fe
commit
927219ca9c
1 changed files with 8 additions and 5 deletions
|
@ -665,16 +665,19 @@ def _fetch_events(q):
|
|||
queue_item.task_done()
|
||||
|
||||
atexit.register(_clean_queue)
|
||||
|
||||
opts = RUNTIME_VARS.RUNTIME_CONFIGS['minion']
|
||||
event = salt.utils.event.get_event('minion', sock_dir=opts['sock_dir'], opts=opts)
|
||||
a_config = AdaptedConfigurationTestCaseMixin()
|
||||
event = salt.utils.event.get_event(
|
||||
'minion',
|
||||
sock_dir=a_config.get_config('minion')['sock_dir'],
|
||||
opts=a_config.get_config('minion'),
|
||||
)
|
||||
while True:
|
||||
try:
|
||||
events = event.get_event(full=False)
|
||||
except Exception:
|
||||
except Exception as exc:
|
||||
# This is broad but we'll see all kinds of issues right now
|
||||
# if we drop the proc out from under the socket while we're reading
|
||||
pass
|
||||
log.exception("Exception caught while getting events %r", exc)
|
||||
q.put(events)
|
||||
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue