stilt.MetStream#

class stilt.MetStream(met_id: 'MetID | str', directory: 'Path | str', file_format: 'str | None' = None, file_tres: 'pd.Timedelta | str | None' = None, n_min: 'int' = 1, source_type: 'str | None' = None, source_kwargs: 'dict[str, Any] | None' = None, backend: 'str' = 's3', subgrid_enable: 'bool' = False, subgrid_bounds=None, subgrid_buffer: 'float' = 0.2, subgrid_levels: 'int | None' = None, subgrid_dir: 'Path | None' = None)[source]#

Runtime handler that resolves and stages met files for one named met stream.

In archive mode (source_type=None) it globs an existing local directory using file_format / file_tres to discover required files.

In source mode (source_type set to an arlmet source name) it delegates file resolution and optional on-download cropping to an arlmet.MeteorologySource instance, then stages the result.

Subgridding of local archive files is handled inside _stage_files via arlmet.extract_subset, caching cropped copies in subgrid_dir.

Methods#

required_files(r_time, n_hours)

Return source met files required to cover one simulation time window.

stage_files_for_simulation(*, r_time, ...)

Resolve and stage met files into a simulation-local compute directory.