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

Disable event 4.

Browse Source
This commit is contained in:
Joachim Meyer 2022-11-08 17:27:51 +01:00
parent fe641ca357
commit 35c6ee3b47
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
htcondor-clustercockpit-push.py
View File

@ -9,6 +9,7 @@
# #
# -- Michael Schwarz <schwarz@uni-paderborn.de> # -- Michael Schwarz <schwarz@uni-paderborn.de>
import platform
import subprocess import subprocess
import json import json
import time import time
@ -71,10 +72,15 @@ class CondorSync:
config = {} config = {}
debug = False debug = False
ccapi = None ccapi = None
submit_node = ''
def __init__(self, config, debug=False): def __init__(self, config, debug=False):
self.config = config self.config = config
self.debug = debug self.debug = debug
if 'submitnode' in config['htcondor']:
self.submit_node = config['htcondor']['submitnode']
else:
self.submit_node = platform.node()
# validate config TODO # validate config TODO
if "htcondor" not in config: if "htcondor" not in config:
@ -305,8 +311,12 @@ class CondorSync:
ccjob = self.ccapi.startJob(data) ccjob = self.ccapi.startJob(data)
def _ccStopJob(self, job): def _ccStopJob(self, job):
print("INFO: Stop job %s" % job['GlobalJobId']) if 'GlobalJobID' in job:
jobId = self._jobIdToInt(job['GlobalJobId']) globalJobId = job['GlobalJobId']
else:
globalJobId = "%s#%d.%d#%d" % (self.submit_node, job['Cluster'], job['Proc'], int(time.time()))
print("INFO: Stop job %s" % globalJobId)
jobId = self._jobIdToInt(globalJobId)
# get search for the jobdata stored in CC # get search for the jobdata stored in CC
# ccjob = {} # ccjob = {}
@ -360,10 +370,11 @@ class CondorSync:
data = { data = {
'jobId': jobId, 'jobId': jobId,
'cluster': self.config['cluster'], 'cluster': self.config['cluster'],
'startTime': job['JobCurrentStartDate'],
'stopTime': job['ToE']['When'], 'stopTime': job['ToE']['When'],
'jobState': jobstate 'jobState': jobstate
} }
if 'JobCurrentStartDate' in job:
data['startTime'] = job['JobCurrentStartDate']
self.ccapi.stopJob(data) self.ccapi.stopJob(data)
@ -381,8 +392,10 @@ class CondorSync:
if event['EventTypeNumber'] == 28: # JobAdInformationEvent if event['EventTypeNumber'] == 28: # JobAdInformationEvent
if event['TriggerEventTypeNumber'] == 1: # Execute if event['TriggerEventTypeNumber'] == 1: # Execute
self._ccStartJob(event) self._ccStartJob(event)
elif event['TriggerEventTypeNumber'] == 4 or event['TriggerEventTypeNumber'] == 5 or \ # elif event['TriggerEventTypeNumber'] == 4 or
event['TriggerEventTypeNumber'] == 9: elif event['TriggerEventTypeNumber'] == 5 or \
event['TriggerEventTypeNumber'] == 9 or event['TriggerEventTypeNumber'] == 10 or \
event['TriggerEventTypeNumber'] == 12:
self._ccStopJob(event) self._ccStopJob(event)
def sync(self, limit=200, jobid=None, direction='both'): def sync(self, limit=200, jobid=None, direction='both'):