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:
@@ -444,6 +443,8 @@ verbose: {verbose}")
         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))