Skip to content

Commit

Permalink
feat: PushJobAgent do not submit failover request if a problem occurs…
Browse files Browse the repository at this point in the history
… with jobReport
  • Loading branch information
aldbr committed Jan 22, 2024
1 parent fa1dcee commit b1b3287
Showing 1 changed file with 1 addition and 14 deletions.
15 changes: 1 addition & 14 deletions src/DIRAC/WorkloadManagementSystem/Agent/PushJobAgent.py
Original file line number Diff line number Diff line change
Expand Up @@ -270,20 +270,7 @@ def execute(self):
# Committing the JobReport before evaluating the result of job submission
res = self.jobReport.commit()
if not res["OK"]:
resFD = self.jobReport.generateForwardDISET()
if not resFD["OK"]:
self.log.error("Error generating ForwardDISET operation", resFD["Message"])
elif resFD["Value"]:
# Here we create the Request.
op = resFD["Value"]
request = Request()
requestName = f"jobAgent_{jobID}"
request.RequestName = requestName.replace('"', "")
request.JobID = jobID
request.SourceComponent = f"JobAgent_{jobID}"
request.addOperation(op)
# This might fail, but only a message would be printed.
self._sendFailoverRequest(request)
return result

# Check that there is enough slots locally
result = self._checkCEAvailability(self.computingElement)
Expand Down

0 comments on commit b1b3287

Please sign in to comment.