Update src/seismic_hazard_forecasting.py

src/seismic_hazard_forecasting.py

@@ -125,7 +125,6 @@ verbose: {verbose}")
 
     logger.debug(f"BASELINE CPU LOAD% {psutil.cpu_percent(interval=None, percpu=True)}")
 
-    dask.config.set(scheduler='processes')
 
     # run magnitude distribution modeling if selected by user and no magnitude pdf file provided
     if m_select and m_range[0] == None and m_pdf[0] == None:
@@ -441,9 +440,11 @@ verbose: {verbose}")
 
         start = timer()
 
-        use_pp = False
+        use_pp = True
 
         if use_pp:         # use dask parallel computing
+            #dask.config.set(scheduler='processes')
+            dask.config.set(scheduler='threads')
             pbar = ProgressBar()
             pbar.register()
             # iter = range(0,len(distances))