summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSheldon Sandbekkhaug <sheldon.sandbekkhaug@calxeda.com>2013-08-05 12:46:25 -0500
committerSheldon Sandbekkhaug <sheldon.sandbekkhaug@calxeda.com>2013-08-05 12:46:25 -0500
commit7adb81f7cc7b443c011a764f60ec0c8913d476b7 (patch)
tree02641d322a4a7fa299a5b9a7b1d0d891ac903c95
parent2f5821b91a67499d46d76df45fc8162c5f7c12df (diff)
downloadcxmanage-7adb81f7cc7b443c011a764f60ec0c8913d476b7.tar.gz
Added keyword arguments to _run_on_all_nodes()
-rw-r--r--cxmanage_api/fabric.py5
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