Skip to content

Commit e2e31a6

Browse files
authored
Merge pull request #8113 from fstagni/80_avoid_repeat_optimization
[8.0] fix: avoid repeating optimization when job goes to STAGING
2 parents aa25182 + 10589bb commit e2e31a6

2 files changed

Lines changed: 5 additions & 1 deletion

File tree

src/DIRAC/WorkloadManagementSystem/Client/JobStatus.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ def __init__(self, state):
9595
STAGING: State(4, [CHECKING, WAITING, FAILED, KILLED], defState=STAGING),
9696
SCOUTING: State(3, [CHECKING, FAILED, STALLED, KILLED], defState=SCOUTING),
9797
CHECKING: State(2, [SCOUTING, STAGING, WAITING, RESCHEDULED, FAILED, DELETED, KILLED], defState=CHECKING),
98-
RECEIVED: State(1, [SCOUTING, CHECKING, WAITING, FAILED, DELETED, KILLED], defState=RECEIVED),
98+
RECEIVED: State(1, [SCOUTING, CHECKING, STAGING, WAITING, FAILED, DELETED, KILLED], defState=RECEIVED),
9999
SUBMITTING: State(0, [RECEIVED, CHECKING, DELETED, KILLED], defState=SUBMITTING), # initial state
100100
}
101101

src/DIRAC/WorkloadManagementSystem/Executor/JobScheduling.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -591,6 +591,10 @@ def __requestStaging(self, jobState, stageLFNs):
591591
if not result["OK"]:
592592
return result
593593

594+
result = jobState.commitChanges()
595+
if not result["OK"]:
596+
self.jobLog.error("Could not save changes for job", result["Message"])
597+
594598
return S_OK(stageLFNs)
595599

596600
def __updateSharedSESites(self, jobManifest, stageSite, stagedLFNs, opData):

0 commit comments

Comments
 (0)