From fdabc175f9ef5ee9d1e6887409be58dd44cf661d Mon Sep 17 00:00:00 2001 From: "Krzysztof A. Adamski" Date: Sat, 7 Jun 2008 16:12:03 -0400 Subject: Handle remote errors with async calls. --- func/jobthing.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) (limited to 'func') diff --git a/func/jobthing.py b/func/jobthing.py index 0e613f8..a190dff 100644 --- a/func/jobthing.py +++ b/func/jobthing.py @@ -28,6 +28,7 @@ JOB_ID_RUNNING = 0 JOB_ID_FINISHED = 1 JOB_ID_LOST_IN_SPACE = 2 JOB_ID_PARTIAL = 3 +JOB_ID_REMOTE_ERROR = 4 # how long to retain old job records in the job id database RETAIN_INTERVAL = 60 * 60 @@ -182,7 +183,11 @@ def job_status(jobid, client_class=None): client = client_class(host, noglobs=True, async=False) minion_result = client.jobs.job_status(minion_job) - (minion_interim_rc, minion_interim_result) = minion_result + if type(minion_result) != list or len(minion_result)!=2: + minion_interim_rc = JOB_ID_REMOTE_ERROR + minion_interim_result = minion_result[:3] + else: + (minion_interim_rc, minion_interim_result) = minion_result if minion_interim_rc not in [ JOB_ID_RUNNING ]: if minion_interim_rc in [ JOB_ID_LOST_IN_SPACE ]: -- cgit