From 70a43d167ca9a676edecf2b1a75047bb93066908 Mon Sep 17 00:00:00 2001 From: Federico Stagni Date: Mon, 2 Nov 2026 09:40:50 +0100 Subject: [PATCH] fix: do not reset files for not yet submitted jobs (cherry picked from PR #8583, commit e602154884bd4054e5e2098dfc6c3412e43c1b0f) Co-authored-by: atsareg --- src/DIRAC/TransformationSystem/Client/WorkflowTasks.py | 5 ----- 1 file changed, 5 deletions(-) diff --git a/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py b/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py index 5bdfc1eecea..ede24fdd407 100644 --- a/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py +++ b/src/DIRAC/TransformationSystem/Client/WorkflowTasks.py @@ -648,14 +648,9 @@ 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 = {} - 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"]: