summaryrefslogtreecommitdiffstats
path: root/func/overlord/client.py
diff options
context:
space:
mode:
authorAdrian Likins <alikins@grimlock.devel.redhat.com>2008-01-23 15:56:02 -0500
committerAdrian Likins <alikins@grimlock.devel.redhat.com>2008-01-23 15:56:02 -0500
commit461fe996412ee57f49ccc1a265ac813ba14f783d (patch)
tree0e25c10d1e26b29e42c3ef0ffe97907e38eda7f4 /func/overlord/client.py
parent86195b5602040be63acda253b7f83541dc38d0b6 (diff)
parent19e4d1ba808cbbe95568271a5b0075b8422e4fb6 (diff)
downloadfunc-461fe996412ee57f49ccc1a265ac813ba14f783d.tar.gz
func-461fe996412ee57f49ccc1a265ac813ba14f783d.tar.xz
func-461fe996412ee57f49ccc1a265ac813ba14f783d.zip
Merge branch 'master' of ssh://git.fedoraproject.org/git/hosted/func
Conflicts: func/overlord/client.py
Diffstat (limited to 'func/overlord/client.py')
-rwxr-xr-xfunc/overlord/client.py15
1 files changed, 12 insertions, 3 deletions
diff --git a/func/overlord/client.py b/func/overlord/client.py
index c5358bb..a848cb8 100755
--- a/func/overlord/client.py
+++ b/func/overlord/client.py
@@ -22,9 +22,9 @@ from func.config import read_config, CONFIG_FILE
import sslclient
import command
-import forkbomb
import groups
-import jobthing
+import func.forkbomb as forkbomb
+import func.jobthing as jobthing
# ===================================
@@ -187,7 +187,7 @@ class Client(object):
"""
Use this to acquire status from jobs when using run with async client handles
"""
- return jobthing.job_status(jobid)
+ return jobthing.job_status(jobid, client_class=Client)
# -----------------------------------------------
@@ -221,7 +221,16 @@ class Client(object):
# we can't call "call" on s, since thats a rpc, so
# we call gettatr around it.
meth = "%s.%s" % (module, method)
+
+ # async calling signature has an "imaginary" prefix
+ # so async.abc.def does abc.def as a background task.
+ # see Wiki docs for details
+ if self.async:
+ meth = "async.%s" % meth
+
+ # this is the point at which we make the remote call.
retval = getattr(conn, meth)(*args[:])
+
if self.interactive:
print retval
except Exception, e: