feat: the TransformationCleaningAgent forces jobs to kill

fstagni · Nov 5, 2024 · 1af2e4d · 1af2e4d
1 parent 5952ee4
commit 1af2e4d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/DIRAC/TransformationSystem/Agent/TransformationCleaningAgent.py b/src/DIRAC/TransformationSystem/Agent/TransformationCleaningAgent.py
@@ -653,7 +653,7 @@ def __removeWMSTasks(self, transJobIDs):
         jobIDs = [int(j) for j in transJobIDs if int(j)]
         allRemove = True
         for jobList in breakListIntoChunks(jobIDs, 500):
-            res = self.wmsClient.killJob(jobList)
+            res = self.wmsClient.killJob(jobList, force=True)
             if res["OK"]:
                 self.log.info(f"Successfully killed {len(jobList)} jobs from WMS")
             elif ("InvalidJobIDs" in res) and ("NonauthorizedJobIDs" not in res) and ("FailedJobIDs" not in res):