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

Iterate over workers directly

Browse Source
This commit is contained in:
Mike Place 2015-02-10 08:36:28 -07:00
parent 716fa253cb
commit 2befd356c8
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
salt/daemons/flo/dummy.py
View File

@ -36,6 +36,8 @@ class SaltDummyPublisher(ioflo.base.deeding.Deed):
'opts': '.salt.opts', 'opts': '.salt.opts',
'publish': '.salt.var.publish', 'publish': '.salt.var.publish',
'lane_stack': '.salt.lane.manor.stack', 'lane_stack': '.salt.lane.manor.stack',
'workers': '.salt.track.workers',
# TODO import vals of workers
} }
def action(self): def action(self):
@ -43,7 +45,7 @@ class SaltDummyPublisher(ioflo.base.deeding.Deed):
pub = self.publish.value.popleft() pub = self.publish.value.popleft()
log.debug('Dummy publisher publishing: {0}'.format(pub)) log.debug('Dummy publisher publishing: {0}'.format(pub))
msg = self._fill_tmpl(pub) msg = self._fill_tmpl(pub)
self.lane_stack.value.transmit(msg, self.lane_stack.value.fetchUidByName('manor')) self.lane_stack.value.transmit(msg, self.lane_stack.value.fetchUidByName(next(self.workers.value)))
def _fill_tmpl(self, pub): def _fill_tmpl(self, pub):
''' '''