diff --git a/src/DIRAC/TransformationSystem/Agent/TransformationCleaningAgent.py b/src/DIRAC/TransformationSystem/Agent/TransformationCleaningAgent.py index 51035bf8654..27b1d6a9303 100644 --- 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):