diff options
| -rwxr-xr-x | utils/submit-grid-jobs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/utils/submit-grid-jobs b/utils/submit-grid-jobs index 4e3bd5b..de022e1 100755 --- a/utils/submit-grid-jobs +++ b/utils/submit-grid-jobs @@ -362,7 +362,7 @@ def remove_job(submit_file): if entry['SubmitFile'] == tail: try: log.debug("condor_remove %s" % entry['ClusterId']) - check_call(['condor_remove',entry['ClusterId']]) + check_call(['condor_remove',str(entry['ClusterId'])]) except subprocess.CalledProcessError: return -1 return 0 @@ -387,7 +387,7 @@ def release_job(submit_file): if entry['SubmitFile'] == tail: try: log.debug("condor_release %s" % entry['ClusterId']) - check_call(['condor_release',entry['ClusterId']]) + check_call(['condor_release',str(entry['ClusterId'])]) except subprocess.CalledProcessError: return -1 return 0 @@ -521,7 +521,7 @@ def main(conn, dqxx_dir, max_retries, max_jobs): log.warn("Failed to release job %i. Setting it to failed state." % id) c.execute("UPDATE state SET state = 'FAILED', message = ? WHERE id = ?", ("failed to release job",id)) else: - log.verbose("Job %i has now been retried %i times" % (nretry+1)) + log.verbose("Job %i has now been retried %i times" % (id,nretry+1)) c.execute("UPDATE state SET nretry = nretry + 1 WHERE id = ?", (id,)) else: log.warn("Job %i has failed %i times. Clearing it from the queue. Setting it to failed state." % (id,nretry)) |