official-apps/SeismicHazardForecasting
10
0
Fork 1
Code Issues Pull Requests Activity

Update src/seismic_hazard_forecasting.py

Browse Source
This commit is contained in:
ftong
2025-08-21 12:21:47 +02:00
parent 1b7e9f7646
commit 3001cd7382
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/seismic_hazard_forecasting.py
View File

@@ -469,11 +469,10 @@ verbose: {verbose}")
for imt in products:
logger.info(f"Estimating {imt}")
#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=2.0, rx_label=i,
# rtol=0.1, use_cython=True) for i in iter]
imls = [dask.delayed(my_trivial_task)(i) for i in iter]
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, imt=imt, IMT_min=0.0,
IMT_max=2.0, rx_label=i, rtol=0.1, use_cython=True) for i in iter]
#imls = [dask.delayed(my_trivial_task)(i) for i in iter]
iml = dask.compute(*imls)
iml_grid_raw.append(list(iml))