mirror of
https://github.com/saltstack/salt.git
synced 2025-04-17 10:10:20 +00:00
Revert part of 927219c
since it is not a fix
This commit is contained in:
parent
5fee7620a5
commit
9443451d9a
1 changed files with 2 additions and 14 deletions
|
@ -655,20 +655,8 @@ def _fetch_events(q):
|
|||
queue_item.task_done()
|
||||
|
||||
atexit.register(_clean_queue)
|
||||
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'),
|
||||
)
|
||||
|
||||
# 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')
|
||||
|
||||
opts = RUNTIME_VARS.RUNTIME_CONFIGS['minion']
|
||||
event = salt.utils.event.get_event('minion', sock_dir=opts['sock_dir'], opts=opts)
|
||||
while True:
|
||||
try:
|
||||
events = event.get_event(full=False)
|
||||
|
|
Loading…
Add table
Reference in a new issue