diff options
author | Adrian Likins <alikins@grimlock.devel.redhat.com> | 2008-01-23 15:56:02 -0500 |
---|---|---|
committer | Adrian Likins <alikins@grimlock.devel.redhat.com> | 2008-01-23 15:56:02 -0500 |
commit | 461fe996412ee57f49ccc1a265ac813ba14f783d (patch) | |
tree | 0e25c10d1e26b29e42c3ef0ffe97907e38eda7f4 /func/overlord/client.py | |
parent | 86195b5602040be63acda253b7f83541dc38d0b6 (diff) | |
parent | 19e4d1ba808cbbe95568271a5b0075b8422e4fb6 (diff) | |
download | func-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-x | func/overlord/client.py | 15 |
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: |