Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
9b9d953953 |
@ -452,7 +452,7 @@ verbose: {verbose}")
|
||||
|
||||
start = timer()
|
||||
|
||||
use_pp = False
|
||||
use_pp = True
|
||||
|
||||
if use_pp: # use dask parallel computing
|
||||
pbar = ProgressBar()
|
||||
@ -466,7 +466,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=2.0, rx_label=i,
|
||||
rtol=0.1, use_cython=True) for i in iter]
|
||||
rtol=0.1, use_cython=False) for i in iter]
|
||||
iml = dask.compute(*imls)
|
||||
iml_grid_raw.append(list(iml))
|
||||
|
||||
@ -478,7 +478,7 @@ verbose: {verbose}")
|
||||
for i in iter:
|
||||
iml_i = 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)
|
||||
IMT_max = 2.0, rx_label = i, rtol = 0.1, use_cython=False)
|
||||
iml.append(iml_i)
|
||||
logger.info(f"Estimated {imt} at rx {i} is {iml_i}")
|
||||
iml_grid_raw.append(iml)
|
||||
|
Loading…
Reference in New Issue
Block a user