Skip to content

Commit

Permalink
fix: update pilot status
Browse files Browse the repository at this point in the history
  • Loading branch information
arrabito committed Mar 7, 2024
1 parent 8c7c672 commit ff07c21
Showing 1 changed file with 1 addition and 9 deletions.
10 changes: 1 addition & 9 deletions src/DIRAC/WorkloadManagementSystem/Agent/SiteDirector.py
Original file line number Diff line number Diff line change
Expand Up @@ -1251,14 +1251,6 @@ def _updatePilotStatusPerQueue(self, queue, proxy):
return
pilotDict = result["Value"]

stampedPilotRefs = []
for pRef in pilotDict:
if pilotDict[pRef]["PilotStamp"]:
stampedPilotRefs.append(pRef + ":::" + pilotDict[pRef]["PilotStamp"])
else:
stampedPilotRefs = list(pilotRefs)
break

# This proxy is used for checking the pilot status and renewals
# We really need at least a few hours otherwise the renewed
# proxy may expire before we check again...
Expand All @@ -1274,7 +1266,7 @@ def _updatePilotStatusPerQueue(self, queue, proxy):
return
ce.setToken(result["Value"])

result = ce.getJobStatus(stampedPilotRefs)
result = ce.getJobStatus(pilotRefs)
if not result["OK"]:
self.log.error("Failed to get pilots status from CE", f"{ceName}: {result['Message']}")
return
Expand Down

0 comments on commit ff07c21

Please sign in to comment.