diff --git a/src/seismic_hazard_forecasting.py b/src/seismic_hazard_forecasting.py index 627168e..ce4ceec 100644 --- a/src/seismic_hazard_forecasting.py +++ b/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))