Skip to content

Commit f13f7c5

Browse files
fstagniweb-flow
authored andcommitted
sweep: DIRACGrid#8113 fix: avoid repeating optimization when job goes to STAGING
1 parent 8cfb015 commit f13f7c5

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

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
@@ -549,6 +549,10 @@ def __requestStaging(self, jobState, stageLFNs):
549549
if not result["OK"]:
550550
return result
551551

552+
result = jobState.commitChanges()
553+
if not result["OK"]:
554+
self.jobLog.error("Could not save changes for job", result["Message"])
555+
552556
return S_OK(stageLFNs)
553557

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

0 commit comments

Comments
 (0)