earth2mip.lagged_ensembles package#

Submodules#

earth2mip.lagged_ensembles.core module#

async earth2mip.lagged_ensembles.core.yield_lagged_ensembles(*, observations, forecast, max_lag=2, min_lag=-2, n=10)#

Yield lagged ensembles

The forecast array has shape (len(observations), n)

The ensemble consist of runs initialized with an offset of (-min_lag, … …, max_lag). The ensemble size is therefore 2*lags + = for points within the interior of the array.

Supports running in parallel using the rank and world_size flags.

Parameters:

  • max_lag (int) –

  • min_lag (int) –

  • n (int) –

Module contents#