Skip to content

Commit 59b4cce

Browse files
authored
Merge pull request #8228 from chaen/v9.0_removal_fix
V9.0 removal fix
2 parents fddfcf9 + 53205bd commit 59b4cce

File tree

2 files changed

+9
-6
lines changed

2 files changed

+9
-6
lines changed

consistency_check/consistency.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,8 @@ def compare_checksum(
131131
# Make a single DF with both info, and only keep pfn in both
132132
joined = pd.concat([fc_dump, se_dump], axis=1)
133133
joined = joined[joined.index.isin(in_both)]
134+
if joined.empty:
135+
raise ValueError("Could not join properly, is something wrong with the files format ?")
134136

135137
# Filter on non matching checksum
136138
non_matching = joined.loc[joined["fc_cks"] != joined["se_cks"]][["seName", "lfn", "fc_cks", "se_cks"]]

src/DIRAC/DataManagementSystem/Agent/RequestOperations/RemoveFile.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,17 +4,17 @@
44
# Date: 2013/03/25 07:44:19
55
########################################################################
66

7-
""" :mod: RemoveFile
7+
""":mod: RemoveFile
88
9-
================
9+
================
1010
11-
.. module: RemoveFile
11+
.. module: RemoveFile
1212
13-
:synopsis: removeFile operation handler
13+
:synopsis: removeFile operation handler
1414
15-
.. moduleauthor:: [email protected]
15+
.. moduleauthor:: [email protected]
1616
17-
removeFile operation handler
17+
removeFile operation handler
1818
"""
1919
# #
2020
# @file RemoveFile.py
@@ -132,6 +132,7 @@ def __call__(self):
132132
self.rmsMonitoringReporter.addRecord(
133133
self.createRMSRecord("Successful", len(toRemoveDict) - len(bulkRemoval["Value"]))
134134
)
135+
toRemoveDict = bulkRemoval["Value"]
135136

136137
# # 2nd step - single file removal
137138
for lfn, opFile in toRemoveDict.items():

0 commit comments

Comments
 (0)