Commit bfcd51b8 authored by Cédric Le Ninivin's avatar Cédric Le Ninivin

Update publish recipe to work with slave instances

parent 927da9fb
...@@ -32,17 +32,22 @@ CONNECTION_PARAMETER_STRING = 'connection-' ...@@ -32,17 +32,22 @@ CONNECTION_PARAMETER_STRING = 'connection-'
class Recipe(GenericSlapRecipe): class Recipe(GenericSlapRecipe):
def _install(self): def _install(self):
slave_reference = None
publish_dict = dict() publish_dict = dict()
options = self.options.copy() options = self.options.copy()
del options['recipe'] del options['recipe']
if 'slave-reference' in options:
slave_reference = options['slave-reference']
for k, v in options.iteritems(): for k, v in options.iteritems():
publish_dict[k] = v publish_dict[k] = v
self._setConnectionDict(publish_dict) self._setConnectionDict(publish_dict, slave_reference)
return [] return []
def _setConnectionDict(self, publish_dict): def _setConnectionDict(self, publish_dict, slave_reference=None):
return self.setConnectionDict(publish_dict) if slave_reference is None:
return self.setConnectionDict(publish_dict)
else:
return self.setConnectionDict(publish_dict, slave_reference)
SERIALISED_MAGIC_KEY = '_' SERIALISED_MAGIC_KEY = '_'
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment