Skip to content

Commit ff07c21

Browse files
committed
fix: update pilot status
1 parent 8c7c672 commit ff07c21

File tree

1 file changed

+1
-9
lines changed

1 file changed

+1
-9
lines changed

src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1251,14 +1251,6 @@ def _updatePilotStatusPerQueue(self, queue, proxy):
12511251
return
12521252
pilotDict = result["Value"]
12531253

1254-
stampedPilotRefs = []
1255-
for pRef in pilotDict:
1256-
if pilotDict[pRef]["PilotStamp"]:
1257-
stampedPilotRefs.append(pRef + ":::" + pilotDict[pRef]["PilotStamp"])
1258-
else:
1259-
stampedPilotRefs = list(pilotRefs)
1260-
break
1261-
12621254
# This proxy is used for checking the pilot status and renewals
12631255
# We really need at least a few hours otherwise the renewed
12641256
# proxy may expire before we check again...
@@ -1274,7 +1266,7 @@ def _updatePilotStatusPerQueue(self, queue, proxy):
12741266
return
12751267
ce.setToken(result["Value"])
12761268

1277-
result = ce.getJobStatus(stampedPilotRefs)
1269+
result = ce.getJobStatus(pilotRefs)
12781270
if not result["OK"]:
12791271
self.log.error("Failed to get pilots status from CE", f"{ceName}: {result['Message']}")
12801272
return

0 commit comments

Comments
 (0)