@@ -293,8 +293,8 @@ def _getDelegationIDs(self):
293
293
# Submit the POST request to get the delegation
294
294
result = self ._request ("get" , query )
295
295
if not result ["OK" ]:
296
- self .log .error ("Issue while interacting with the delegations." , result ["Message" ])
297
- return S_ERROR ( "Issue while interacting with the delegations" )
296
+ self .log .warn ("Issue while interacting with the delegations." , result ["Message" ])
297
+ return S_OK ([] )
298
298
response = result ["Value" ]
299
299
300
300
# If there is no delegation, response.json is expected to return an exception
@@ -328,7 +328,7 @@ def _getProxyFromDelegationID(self, delegationID):
328
328
# Submit the POST request to get the delegation
329
329
result = self ._request ("post" , query , params = params )
330
330
if not result ["OK" ]:
331
- self .log .error ("Issue while interacting with the delegations. " , result [" Message" ] )
331
+ self .log .error ("Issue while interacting with delegation " , f" { delegationID } : { result [' Message' ] } " )
332
332
return S_ERROR ("Issue while interacting with the delegations" )
333
333
response = result ["Value" ]
334
334
@@ -422,7 +422,7 @@ def submitJob(self, executableFile, proxy, numberOfJobs=1, inputs=None, outputs=
422
422
423
423
self .log .verbose (f"Executable file path: { executableFile } " )
424
424
425
- # Get a delegation and use the same delegation for all the jobs
425
+ # Get existing delegations
426
426
result = self ._getDelegationIDs ()
427
427
if not result ["OK" ]:
428
428
self .log .error ("Could not get delegation IDs." , result ["Message" ])
@@ -436,7 +436,7 @@ def submitJob(self, executableFile, proxy, numberOfJobs=1, inputs=None, outputs=
436
436
# Get the proxy attached to the delegationID
437
437
result = self ._getProxyFromDelegationID (delegationID )
438
438
if not result ["OK" ]:
439
- return result
439
+ continue
440
440
proxy = result ["Value" ]
441
441
442
442
if proxy .getDIRACGroup () != proxyGroup :
0 commit comments