From b1b328714ed8afd4559be3ac6c872334d066a2bb Mon Sep 17 00:00:00 2001 From: aldbr Date: Mon, 22 Jan 2024 19:05:39 +0100 Subject: [PATCH] feat: PushJobAgent do not submit failover request if a problem occurs with jobReport --- .../Agent/PushJobAgent.py | 15 +-------------- 1 file changed, 1 insertion(+), 14 deletions(-) diff --git a/src/DIRAC/WorkloadManagementSystem/Agent/PushJobAgent.py b/src/DIRAC/WorkloadManagementSystem/Agent/PushJobAgent.py index ebb15b29238..ec9aefea635 100644 --- a/src/DIRAC/WorkloadManagementSystem/Agent/PushJobAgent.py +++ b/src/DIRAC/WorkloadManagementSystem/Agent/PushJobAgent.py @@ -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)