summaryrefslogtreecommitdiffstats
path: root/func
diff options
context:
space:
mode:
authorSteve Salevan <ssalevan@marillion.rdu.redhat.com>2008-07-09 16:45:26 -0400
committerSteve Salevan <ssalevan@marillion.rdu.redhat.com>2008-07-09 16:45:26 -0400
commitaa36ec3991bf3e1f4e0ff7cf821b2ceba67335cd (patch)
treec95a9342572f838dd5559676cd1c4d389b5734f0 /func
parentc3888ff3a60df7363390e810f96a7bbced042a50 (diff)
downloadfunc-aa36ec3991bf3e1f4e0ff7cf821b2ceba67335cd.tar.gz
func-aa36ec3991bf3e1f4e0ff7cf821b2ceba67335cd.tar.xz
func-aa36ec3991bf3e1f4e0ff7cf821b2ceba67335cd.zip
Committing fixes to delegation/overlord client code
Diffstat (limited to 'func')
-rw-r--r--func/minion/modules/delegation.py4
-rwxr-xr-xfunc/overlord/client.py7
2 files changed, 8 insertions, 3 deletions
diff --git a/func/minion/modules/delegation.py b/func/minion/modules/delegation.py
index 7af3284..9f34d1a 100644
--- a/func/minion/modules/delegation.py
+++ b/func/minion/modules/delegation.py
@@ -27,8 +27,8 @@ class DelegationModule(func_module.FuncModule):
next_hop = delegation_path[0]
overlord = fc.Overlord(next_hop)
if len(delegation_path) == 1: #minion exists under this overlord
- meth = "%s.%s" % (module, method)
- return getattr(overlord,meth)(*args[:])
+ overlord_module = getattr(overlord,module)
+ return getattr(overlord_module,method)(*args[:])
stripped_list = delegation_path[1:len(delegation_path)]
delegation_results = overlord.delegation.run(module,method,args,stripped_list)
diff --git a/func/overlord/client.py b/func/overlord/client.py
index 760b896..572d274 100755
--- a/func/overlord/client.py
+++ b/func/overlord/client.py
@@ -343,6 +343,8 @@ class Overlord(object):
# this is the point at which we make the remote call.
if use_delegate:
retval = getattr(conn, meth)(module, method, args, delegation_path)
+ print retval
+ print spec
else:
retval = getattr(conn, meth)(*args[:])
@@ -395,7 +397,10 @@ class Overlord(object):
minions = expanded_minions.get_urls()[0]
# print minions
results = process_server(0, 0, minions)
-
+
+ if use_delegate:
+ return results[spec]
+
return results
# -----------------------------------------------