From 6528240021463e2ecd79c86219feb17a110f56a1 Mon Sep 17 00:00:00 2001 From: Andrei Tsaregorodtsev Date: Mon, 8 Jun 2026 22:02:51 +0200 Subject: [PATCH] fix: do not reset files for not yet submitted jobs --- .pre-commit-config.yaml | 1 + src/DIRAC/TransformationSystem/Client/WorkflowTasks.py | 4 ---- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml index 163eabb7018..f215ff022c8 100644 --- a/.pre-commit-config.yaml +++ b/.pre-commit-config.yaml @@ -57,6 +57,7 @@ repos: src/DIRAC/WorkloadManagementSystem/Utilities/PilotWrapper.py| tests/Integration/WorkloadManagementSystem/Test_GenerateAndExecutePilotWrapper.py )$ + language_version: python3.11 - repo: https://github.com/asottile/pyupgrade rev: v3.3.1 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"]: