Skip to content

Commit 4bf7df5

Browse files
committed
trying to fix bundles
1 parent deb66a6 commit 4bf7df5

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

examples/uc/uc_ef.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88

99
""" UC """
1010
solver_name = sys.argv[1]
11-
scen_count = 3
11+
scen_count = 50
1212
scenario_names = [f"Scenario{i+1}" for i in range(scen_count)]
1313
scenario_creator_kwargs = {"path": f"{scen_count}scenarios_r1/"}
1414
options = {"solver": solver_name}

mpisppy/spbase.py

+5-2
Original file line numberDiff line numberDiff line change
@@ -179,19 +179,22 @@ def _verify_nonants(self):
179179
local_nonant_char_array = {}
180180
for k,s in self.local_scenarios.items():
181181
nlens = s._mpisppy_data.nlens
182+
name_offset = 0
183+
if self.bundling:
184+
name_offset = len(s.name)+1
182185
for node in s._mpisppy_node_list:
183186
ndn = node.name
184187
if ndn not in local_nonant_char_array:
185188
local_nonant_char_array[ndn] = {}
186189
for i, var in enumerate(node.nonant_vardata_list):
187190
if i in local_nonant_char_array[ndn]:
188-
if var.name != local_nonant_char_array[ndn][i]:
191+
if var.name[name_offset:] != local_nonant_char_array[ndn][i]:
189192
raise RuntimeError(f"[rank {self.global_rank}] Tree node {ndn} has different non-anticipative "
190193
f"variables in position {i}, scenario {s} has name "
191194
f"{var.name}, some other scenario has name "
192195
f"{local_nonant_char_array[ndn][i]}")
193196
else:
194-
local_nonant_char_array[ndn][i] = var.name
197+
local_nonant_char_array[ndn][i] = var.name[name_offset:]
195198

196199
for ndn, var_names in local_nonant_char_array.items():
197200
a = array.array("u")

0 commit comments

Comments
 (0)