refactored Retry/Resubmission code now allows for introducing additional, flexible, delays in the retry policy executed during automatic resubmissions
|
|
|
EXIT_RETRY_POLICY = { |
|
1: {"type": "recoverable", "delay": 900, "msg": "Job failed to bootstrap CMSSW; likely a worker node issue."}, |
|
50513: {"type": "recoverable", "delay": 900, "msg": "Job did not find functioning CMSSW on worker node."}, |
|
if os.path.exists(retry_info_file): |
|
try: |
|
with open(retry_info_file, "r", encoding="utf-8") as fd: |
|
retry_info = literal_eval(fd.read()) |
|
key = str(self.dag_retry) |
|
if key in retry_info: |
|
retry_delay_until = retry_info[key].get("retry_delay_until") |
|
if retry_delay_until and currentTime < retry_delay_until: |
|
wait = int(retry_delay_until - currentTime) |
|
self.logger.info(f"Retry delay not elapsed yet. Deferring for {wait} seconds.") |
|
return True |
but when testing the delay is not applied.
Initial guess is that
|
key = str(self.dag_retry) |
points to current retry number while PostJob write the delay policy when processign the previous submission.
But an attempt change to
did not work.
Deeper "digging" is needed.
refactored Retry/Resubmission code now allows for introducing additional, flexible, delays in the retry policy executed during automatic resubmissions
CRABServer/src/python/TaskWorker/Actions/RetryJob.py
Lines 23 to 26 in 1038e05
CRABServer/src/python/TaskWorker/Actions/PreJob.py
Lines 539 to 549 in 1038e05
but when testing the delay is not applied.
Initial guess is that
CRABServer/src/python/TaskWorker/Actions/PreJob.py
Line 543 in 1038e05
points to current retry number while PostJob write the delay policy when processign the previous submission.
But an attempt change to
did not work.
Deeper "digging" is needed.