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

Duh. Check func.

Browse source
This commit is contained in:
Mike Place 2014-03-18 14:10:51 -06:00
parent d4738b6352
commit 2752e4b019
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
tests/eventlisten.py
View file

@ -39,6 +39,7 @@ def parse():
parser.add_option('-f',
'--func_count',
default='',
help=('Retun a count of the number of minons which have '
'replied to a job with a given func.'))
@ -78,13 +79,14 @@ def listen(sock_dir, node, id=None):
ret = event.get_event(full=True)
if ret is None:
continue
if opts.get('func_count', False):
if opts['func_count']:
data = ret.get('data', False)
if data:
if data.get('id', False) and data.get('id', False) not in found_minions:
jid_counter += 1
found_minions.append(data['id'])
print('Reply received from [{0}]. Total replies now: [{1}].'.format(ret['data']['id'], jid_counter))
if 'id' in data.keys() and data.get('id', False) not in found_minions:
if data['fun'] == opts['func_count']:
jid_counter += 1
found_minions.append(data['id'])
print('Reply received from [{0}]. Total replies now: [{1}].'.format(ret['data']['id'], jid_counter))
continue
else:
print('Event fired at {0}'.format(time.asctime()))