In the way that we user resubmissions and retries now, it makes no sense to add time spend in previous submissions in order to check for job having exceeded MAX_WALLTIME.
In particular we want to automatically increase walltime request in subsequent resubmissions.
This part must be reviewed
|
total_job_time = self.report['steps']['cmsRun']['performance']['cpu']['TotalJobTime'] |
|
try: |
|
total_job_time = float(total_job_time) |
|
except ValueError: |
|
return |
|
integrated_job_time = 0 |
|
for ad in self.ads: |
|
if 'RemoteWallClockTime' in ad: |
|
integrated_job_time += ad['RemoteWallClockTime'] |
|
self.integrated_job_time = integrated_job_time |
|
if total_job_time > self.MAX_WALLTIME: |
|
exitMsg = "Not retrying a long running job (job ran for %d hours)" % (total_job_time / 3600) |
|
self.create_fake_fjr(exitMsg, 50664) # this raises FatalError |
|
if integrated_job_time > (1.5 * self.MAX_WALLTIME): |
|
exitMsg = "Not retrying a job because the integrated time (across all retries) is %d hours." % (integrated_job_time / 3600) |
|
self.create_fake_fjr(exitMsg, 50664) # this raises FatalError |
In the way that we user resubmissions and retries now, it makes no sense to add time spend in previous submissions in order to check for job having exceeded MAX_WALLTIME.
In particular we want to automatically increase walltime request in subsequent resubmissions.
This part must be reviewed
CRABServer/src/python/TaskWorker/Actions/RetryJob.py
Lines 375 to 390 in 872622c
integrated_job_timeCommitted* ad