ClusterCockpit/cc-condor-sync
1
0
Fork 0
mirror of https://gitlab.cs.uni-saarland.de/hpc/cc-condor-sync.git synced 2025-09-09 19:12:59 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix up urls.

Browse Source
This commit is contained in:
Joachim Meyer
2025-09-09 10:17:10 +02:00
parent 230ecf386c
commit a2fecc327a
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
scripts/stop-jobs-no-longer-running.py
View File

@@ -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()