diff options
author | Sheldon Sandbekkhaug <sheldon.sandbekkhaug@calxeda.com> | 2013-08-05 12:46:25 -0500 |
---|---|---|
committer | Sheldon Sandbekkhaug <sheldon.sandbekkhaug@calxeda.com> | 2013-08-05 12:46:25 -0500 |
commit | 7adb81f7cc7b443c011a764f60ec0c8913d476b7 (patch) | |
tree | 02641d322a4a7fa299a5b9a7b1d0d891ac903c95 | |
parent | 2f5821b91a67499d46d76df45fc8162c5f7c12df (diff) | |
download | cxmanage-7adb81f7cc7b443c011a764f60ec0c8913d476b7.tar.gz |
Added keyword arguments to _run_on_all_nodes()
-rw-r--r-- | cxmanage_api/fabric.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/cxmanage_api/fabric.py b/cxmanage_api/fabric.py index 7fc0192..c9b633e 100644 --- a/cxmanage_api/fabric.py +++ b/cxmanage_api/fabric.py @@ -1068,11 +1068,12 @@ class Fabric(object): """ return self._run_on_all_nodes(async, "get_depth_chart") - def _run_on_all_nodes(self, async, name, *args): + def _run_on_all_nodes(self, async, name, *args, **kwargs): """Start a command on all nodes.""" tasks = {} for node_id, node in self.nodes.iteritems(): - tasks[node_id] = self.task_queue.put(getattr(node, name), *args) + tasks[node_id] = self.task_queue.put(getattr(node, name), *args, + **kwargs) if async: return tasks |