diff --git a/scripts/stop-jobs-no-longer-running.py b/scripts/stop-jobs-no-longer-running.py index f166db3..bef603a 100644 --- a/scripts/stop-jobs-no-longer-running.py +++ b/scripts/stop-jobs-no-longer-running.py @@ -70,12 +70,12 @@ def get_entered_current_status(arrayId, jobId, startTime): conduit = "conduit" if arrayId % 10 == 0 else "conduit2" condor_job_id = str(jobId >> 32) + "." + str((jobId >> 2) & 0x3FFFFFFF) historys = subprocess.run( - ["ssh", conduit + ".cs.uni-saarland.de", "condor_history", "-json", condor_job_id, "-limit", "1"], capture_output=True, text=True).stdout + ["ssh", conduit + ".hpc.uni-saarland.de", "condor_history", "-json", condor_job_id, "-limit", "1"], capture_output=True, text=True).stdout history = json.loads(historys) if len(history) > 0: return history[0]['EnteredCurrentStatus'] querys = subprocess.run( - ["ssh", conduit + ".cs.uni-saarland.de", "condor_q", "-json", condor_job_id], capture_output=True, text=True).stdout + ["ssh", conduit + ".hpc.uni-saarland.de", "condor_q", "-json", condor_job_id], capture_output=True, text=True).stdout if len(querys) > 0: query = json.loads(querys) if len(query) > 0: @@ -105,7 +105,8 @@ if __name__ == "__main__": cc = CCApi(config, args.debug) condor_jobs = subprocess.run( - ["ssh", "conduit2.cs.uni-saarland.de", "condor_q", "-json", "-all", "-glob", "-constraint", "\"JobStatus == 2\""], capture_output=True, text=True).stdout + ["ssh", "conduit2.hpc.uni-saarland.de", "condor_q", "-json", "-all", "-glob", "-constraint", "\"JobStatus == 2\""], capture_output=True, text=True).stdout + # print(condor_jobs) running_jobs = json.loads(condor_jobs) cc_jobs = cc.getJobs()