Calling swmr_on()

gem · Aug 28, 2023 · 6d24c6f · 6d24c6f
1 parent ce5cdcd
commit 6d24c6f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/openquake/commonlib/calc.py b/openquake/commonlib/calc.py
@@ -398,6 +398,7 @@ def weight(rec):
         sbe = data['slice_by_event'][:]
     except KeyError:
         sbe = build_slice_by_event(data['eid'][:])
+    dstore.swmr_on()
     smap = parallel.Starmap.apply(
         task_func, (sbe, oq, ds),
         maxweight=A*10, weight=weight,