valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-08 01:18:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Pylint fix for 2014.7

Browse Source
This commit is contained in:
rallytime 2014-09-29 19:54:33 -06:00
parent 30fbcfa9ca
commit cd7787bfe4
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
salt/daemons/flo/core.py
View File

@ -892,13 +892,13 @@ class Eventer(ioflo.base.deeding.Deed):
if msg.get('tag') == 'module_refresh':
self.module_refresh.value = True
for y_name in self.event_yards.value:
if y_name not in self.uxd_stack.value.nameRemotes: # subscriber not a remote
if y_name not in self.uxd_stack.value.nameRemotes: # subscriber not a remote
rm_.append(y_name)
continue # drop msg don't publish
continue # drop msg don't publish
self.uxd_stack.value.transmit(msg,
self.uxd_stack.value.fetchUidByName(y_name))
self.uxd_stack.value.serviceAll()
for y_name in rm_: # remove missing subscribers
for y_name in rm_: # remove missing subscribers
self.event_yards.value.remove(y_name)
def action(self):
@ -908,12 +908,12 @@ class Eventer(ioflo.base.deeding.Deed):
'''
import wingdbstub
while self.event_req.value: # event subscription requests are msg with routes
while self.event_req.value: # event subscription requests are msg with routes
self._register_event_yard(
self.event_req.value.popleft()
)
while self.event.value: # events are msgs with routes
while self.event.value: # events are msgs with routes
self._forward_event(
self.event.value.popleft()
)

2
salt/utils/raetevent.py
View File

@ -32,7 +32,7 @@ class SaltEvent(object):
'''
Set up the stack and remote yard
'''
self.node = node # this is usually 'master', 'minion' or opts['id']
self.node = node # this is usually 'master', 'minion' or opts['id']
self.sock_dir = sock_dir
self.listen = listen
if opts is None: