ClusterCockpit/cc-condor-sync
1
0
Fork 0
mirror of https://gitlab.cs.uni-saarland.de/hpc/cc-condor-sync.git synced 2024-09-20 03:27:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

Don't check outdated cc job data.

Browse Source
This commit is contained in:
Joachim Meyer 2022-11-09 11:47:59 +01:00
parent 9e96f65977
commit 9571f3cda6
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
htcondor-clustercockpit-push.py
View File

@ -198,9 +198,9 @@ class CondorSync:
print("INFO: Create job %s, user %s, name %s" % print("INFO: Create job %s, user %s, name %s" %
(job['GlobalJobId'], job['Owner'], job['JobBatchName'] if 'JobBatchName' in job else '')) (job['GlobalJobId'], job['Owner'], job['JobBatchName'] if 'JobBatchName' in job else ''))
jobId = self._jobIdToInt(job['GlobalJobId']) jobId = self._jobIdToInt(job['GlobalJobId'])
for j in self.ccData['jobs']: # for j in self.ccData['jobs']:
if j['jobId'] == jobId: # if j['jobId'] == jobId:
return # return
nodelist = [job['RemoteHost'].split('@')[1]] nodelist = [job['RemoteHost'].split('@')[1]]
@ -418,7 +418,7 @@ class CondorSync:
print("DEBUG: sync called") print("DEBUG: sync called")
print("DEBUG: jobid %s" % jobid) print("DEBUG: jobid %s" % jobid)
self._readCCData() # self._readCCData()
with tailf.Tail(self.config['htcondor']['eventlog']) as tail: with tailf.Tail(self.config['htcondor']['eventlog']) as tail:
remaining = "" remaining = ""