Merge pull request #8923 from gem/cond-gmf

Disable multiprocessing when working with conditioned GMFs
gem · Aug 7, 2023 · d03a7d0 · d03a7d0
2 parents cdb3628 + 3f1d27a
commit d03a7d0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/openquake/baselib/performance.py b/openquake/baselib/performance.py
@@ -446,6 +446,7 @@ def compile(sigstr):
 @compile(["int64[:, :](uint8[:])",
           "int64[:, :](uint16[:])",
           "int64[:, :](uint32[:])",
+          "int64[:, :](int32[:])",
           "int64[:, :](int64[:])"])
 def idx_start_stop(integers):
     # given an array of integers returns an array int64 of shape (n, 3)

diff --git a/openquake/calculators/event_based.py b/openquake/calculators/event_based.py
@@ -376,6 +376,8 @@ class EventBasedCalculator(base.HazardCalculator):
     accept_precalc = ['event_based', 'ebrisk', 'event_based_risk']
 
     def init(self):
+        if 'station_data' in self.oqparam.inputs:
+            os.environ['OQ_DISTRIBUTE'] = 'no'
         if self.oqparam.cross_correl.__class__.__name__ == 'GodaAtkinson2009':
             logging.warning(
                 'The truncation_level param is ignored with GodaAtkinson2009')