diff --git a/src/DIRAC/DataManagementSystem/Agent/FTS3Agent.py b/src/DIRAC/DataManagementSystem/Agent/FTS3Agent.py index 9cd0470f895..70e95042e90 100644 --- a/src/DIRAC/DataManagementSystem/Agent/FTS3Agent.py +++ b/src/DIRAC/DataManagementSystem/Agent/FTS3Agent.py @@ -291,7 +291,7 @@ def _monitorJobCallback(returnedValue): :param returnedValue: value returned by the _monitorJob method (ftsJob, standard dirac return struct) """ - if not isinstance(returnedValue, tuple) or len(returnedValue) != 2: + if isinstance(returnedValue, tuple) and len(returnedValue) == 2: ftsJob, res = returnedValue log = gLogger.getLocalSubLogger(f"_monitorJobCallback/{ftsJob.jobID}") if not res["OK"]: @@ -299,6 +299,7 @@ def _monitorJobCallback(returnedValue): else: log.debug("Successfully updated job status") else: + log = gLogger.getLocalSubLogger("_monitorJobCallback") log.error("Invalid return value when monitoring job", f"{returnedValue!r}") def monitorJobsLoop(self): @@ -385,6 +386,7 @@ def _treatOperationCallback(returnedValue): else: log.debug("Successfully treated operation") else: + log = gLogger.getLocalSubLogger("_treatOperationCallback") log.error("Invalid return value when treating operation", f"{returnedValue!r}") def _treatOperation(self, operation):