heart: replace nprocs by nthreads for pyrocko compatibility

Author: hvasbath

beat/covariance.py

@@ -465,7 +465,7 @@ def model_prediction_sensitivity(engine, *args, **kwargs):
         kwargs["source_params"] = args[2]
 
     request = kwargs.pop("request", None)
-    nprocs = kwargs.pop("nprocs", 1)
+    nthreads = kwargs.pop("nthreads", 1)
     source_params = kwargs.pop("source_params", None)
     h = kwargs.pop("h", None)
 
@@ -505,7 +505,7 @@ def model_prediction_sensitivity(engine, *args, **kwargs):
             ]
 
             response = engine.process(
-                sources=calc_sources, targets=request.targets, nprocs=nprocs
+                sources=calc_sources, targets=request.targets, nthreads=nthreads
             )
 
             for i_k in range(len(request.targets)):

beat/heart.py

@@ -3570,7 +3570,7 @@ def seis_synthetics(
     filterer=None,
     reference_taperer=None,
     plot=False,
-    nprocs=1,
+    nthreads=1,
     outmode="array",
     pre_stack_cut=False,
     taper_tolerance_factor=0.0,
@@ -3597,9 +3597,8 @@ def seis_synthetics(
     filterer : :class:`Filterer`
     plot : boolean
         flag for looking at traces
-    nprocs : int
-        number of processors to use for synthetics calculation
-        --> currently no effect !!!
+    nthreads : int
+        number of threads to use for synthetics calculation
     outmode : string
         output format of synthetics can be 'array', 'stacked_traces',
         'data' returns traces unstacked including post-processing,
@@ -3656,7 +3655,7 @@ def seis_synthetics(
 
     t_2 = time()
     try:
-        response = engine.process(sources=sources, targets=targets, nprocs=nprocs)
+        response = engine.process(sources=sources, targets=targets, nthreads=nthreads)
         t_1 = time()
     except IndexError:
         for source in sources:
@@ -4157,7 +4156,7 @@ def fft_transforms(
 
 
 def geo_synthetics(
-    engine, targets, sources, outmode="stacked_array", plot=False, nprocs=1
+    engine, targets, sources, outmode="stacked_array", plot=False, nthreads=1
 ):
     """
     Calculate synthetic displacements for a given static fomosto Greens
@@ -4173,9 +4172,8 @@ def geo_synthetics(
         containing :class:`pyrocko.gf.seismosizer.Target` Objects
     plot : boolean
         flag for looking at synthetics - not implemented yet
-    nprocs : int
-        number of processors to use for synthetics calculation
-        --> currently no effect !!!
+    nthreads : int
+        number of threads to use for synthetics calculation
     outmode : string
         output format of synthetics can be: 'array', 'arrays',
         'stacked_array','stacked_arrays'
@@ -4199,7 +4197,7 @@ def geo_synthetics(
         for target in targets:
             print(target)
 
-    response = engine.process(sources, targets)
+    response = engine.process(sources, targets, nthreads=nthreads)
 
     ns = len(sources)
     nt = len(targets)

beat/models/geodetic.py

@@ -716,6 +716,7 @@ def get_synthetics(self, point):
             targets=self.targets,
             sources=self.sources,
             outmode="stacked_arrays",
+            nthreads=4,
         )
 
         synths = []

beat/models/seismic.py

@@ -859,7 +859,7 @@ def get_synthetics(self, point, **kwargs):
         outmode = kwargs.pop("outmode", "stacked_traces")
         chop_bounds = kwargs.pop("chop_bounds", ["a", "d"])
         order = kwargs.pop("order", "list")
-        nprocs = kwargs.pop("nprocs", 4)
+        nthreads = kwargs.pop("nthreads", 4)
         force = kwargs.pop("force", False)
 
         self.point2sources(point)
@@ -914,7 +914,7 @@ def get_synthetics(self, point, **kwargs):
                 arrival_times=arrival_times,
                 outmode=outmode,
                 chop_bounds=chop_bounds,
-                nprocs=nprocs,
+                nthreads=nthreads,
                 # plot=True,
                 **kwargs,
             )