diff --git a/src/seismic_hazard_forecasting.py b/src/seismic_hazard_forecasting.py index d653038..5e3614c 100644 --- a/src/seismic_hazard_forecasting.py +++ b/src/seismic_hazard_forecasting.py @@ -52,7 +52,7 @@ def main(catalog_file, mc_file, pdf_file, m_file, m_select, mag_label, mc, m_max from math import ceil, floor, isnan import numpy as np import dask - from dask.diagnostics import ProgressBar # use Dask progress bar + #from dask.diagnostics import ProgressBar # use Dask progress bar import kalepy as kale import utm from skimage.transform import resize @@ -453,8 +453,8 @@ verbose: {verbose}") if use_pp: # use dask parallel computing mp.set_start_method("fork", force=True) - pbar = ProgressBar() - pbar.register() + #pbar = ProgressBar() + #pbar.register() iter = indices iml_grid_raw = [] # raw ground motion grids for imt in products: @@ -468,7 +468,7 @@ verbose: {verbose}") imls = [dask.delayed(compute_IMT_exceedance)(rx_lat[i], rx_lon[i], distances[i].flatten(), fr, p, lambdas, forecast_len, lambdas_perc, m_range, m_pdf, m_cdf, model, log_level=logging.DEBUG, imt=imt, IMT_min=0.0, IMT_max=IMT_max, rx_label=i, - rtol=0.1, use_cython=False) for i in iter] + rtol=0.1, use_cython=True) for i in iter] iml = dask.compute(*imls) iml_grid_raw.append(list(iml))