Skip to content

Commit 7bae9e3

Browse files
Bugfixes in the block update
1 parent 9c3af2f commit 7bae9e3

1 file changed

Lines changed: 12 additions & 1 deletion

File tree

lib/common/interface/mysqlstore.py

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1237,7 +1237,17 @@ def _do_update_blockreplicas(self, replica_list): #override
12371237

12381238
sites = list(set([r.site for r in replica_list])) # list of sites
12391239
datasets = list(set([r.block.dataset for r in replica_list])) # list of datasets
1240-
groups = list(set([r.block.group for r in replica_list])) # list of groups
1240+
# Load all groups - otherwise it won't pass obj.name in the make_map function if group == None.
1241+
# This must be appended separately in make_group_map
1242+
groups = []
1243+
for name, olname in self._mysql.xquery('SELECT `name`, `olevel` FROM `groups`'):
1244+
if olname == 'Dataset':
1245+
olevel = Dataset
1246+
else:
1247+
olevel = Block
1248+
1249+
group = Group(name, olevel)
1250+
groups.append(group)
12411251

12421252
site_id_map = {}
12431253
self._make_site_map(sites, site_id_map = site_id_map)
@@ -1246,6 +1256,7 @@ def _do_update_blockreplicas(self, replica_list): #override
12461256
dataset_id_map = {}
12471257
self._make_dataset_map(datasets, dataset_id_map = dataset_id_map)
12481258

1259+
block_name_to_id = {}
12491260
for dataset in datasets:
12501261
for block_id, block_name in self._mysql.xquery('SELECT `id`, `name` FROM `blocks` WHERE `dataset_id` = %s', dataset_id_map[dataset]):
12511262
block_name_to_id[Block.translate_name(block_name)] = block_id

0 commit comments

Comments
 (0)