From e602154884bd4054e5e2098dfc6c3412e43c1b0f Mon Sep 17 00:00:00 2001 From: Andrei Tsaregorodtsev Date: Mon, 8 Jun 2026 22:02:51 +0200 Subject: [PATCH 1/2] fix: do not reset files for not yet submitted jobs --- src/DIRAC/TransformationSystem/Client/WorkflowTasks.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py b/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py index 0acd7f730c3..8af13c605ef 100644 --- a/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py +++ b/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py @@ -679,10 +679,6 @@ def getSubmittedFileStatus(self, fileDicts): taskNameIDs = res["Value"]["TaskNameIDs"] updateDict = {} - for jobName in noTasks: - for lfn, oldStatus in taskFiles[jobName].items(): - if oldStatus != TransformationFilesStatus.UNUSED: - updateDict[lfn] = TransformationFilesStatus.UNUSED res = self.jobMonitoringClient.getJobsStatus(list(taskNameIDs.values())) if not res["OK"]: From cab30b43a26430bafc89fc7510f5149ff49d45d4 Mon Sep 17 00:00:00 2001 From: Andrei Tsaregorodtsev Date: Wed, 28 Oct 2026 12:51:05 +0100 Subject: [PATCH 2/2] fix: removed unused variable setting --- src/DIRAC/TransformationSystem/Client/WorkflowTasks.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py b/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py index 8af13c605ef..1dbff42c69b 100644 --- a/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py +++ b/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py @@ -675,7 +675,6 @@ def getSubmittedFileStatus(self, fileDicts): if not res["OK"]: self._logWarn("Failed to obtain taskIDs for files", transID=transID, method=method) return res - noTasks = res["Value"]["NoTasks"] taskNameIDs = res["Value"]["TaskNameIDs"] updateDict = {}