From 0ea33375bcabf12f707044b9e66016ed502c01b3 Mon Sep 17 00:00:00 2001 From: aldbr Date: Tue, 10 Oct 2023 10:00:33 +0200 Subject: [PATCH] sweep: #7219 fix: AREX delegation not found --- src/DIRAC/Resources/Computing/AREXComputingElement.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/DIRAC/Resources/Computing/AREXComputingElement.py b/src/DIRAC/Resources/Computing/AREXComputingElement.py index 9d1365b309c..deef3dc58c1 100755 --- a/src/DIRAC/Resources/Computing/AREXComputingElement.py +++ b/src/DIRAC/Resources/Computing/AREXComputingElement.py @@ -285,8 +285,8 @@ def _getDelegationIDs(self): # Submit the POST request to get the delegation result = self._request("get", query) if not result["OK"]: - self.log.error("Issue while interacting with the delegations.", result["Message"]) - return S_ERROR("Issue while interacting with the delegations") + self.log.warn("Issue while interacting with the delegations.", result["Message"]) + return S_OK([]) response = result["Value"] # If there is no delegation, response.json is expected to return an exception @@ -320,7 +320,7 @@ def _getProxyFromDelegationID(self, delegationID): # Submit the POST request to get the delegation result = self._request("post", query, params=params) if not result["OK"]: - self.log.error("Issue while interacting with the delegations.", result["Message"]) + self.log.error("Issue while interacting with delegation ", f"{delegationID}: {result['Message']}") return S_ERROR("Issue while interacting with the delegations") response = result["Value"] @@ -414,7 +414,7 @@ def submitJob(self, executableFile, proxy, numberOfJobs=1, inputs=None, outputs= self.log.verbose(f"Executable file path: {executableFile}") - # Get a delegation and use the same delegation for all the jobs + # Get existing delegations result = self._getDelegationIDs() if not result["OK"]: self.log.error("Could not get delegation IDs.", result["Message"]) @@ -428,7 +428,7 @@ def submitJob(self, executableFile, proxy, numberOfJobs=1, inputs=None, outputs= # Get the proxy attached to the delegationID result = self._getProxyFromDelegationID(delegationID) if not result["OK"]: - return result + continue proxy = result["Value"] if proxy.getDIRACGroup() != proxyGroup: