NEDAS.core.updator module

class NEDAS.core.updator.Updator(c: Context)[source]

Bases: ABC

Base class for updators of the model restart files

increment: dict = {}
update(c: Context) None[source]

Top-level routine to apply the analysis increments to the original model restart files (as initial conditions for the next forecast)

init_all_file_locks(c: Context) None[source]

Prepare file locks for asynchronous io, needed for blocking write (e.g. in netcdf without parallel support)

abstractmethod compute_increment(c: Context) None[source]
abstractmethod update_files(c: Context, mem_id: Annotated[int, 'member id'], rec_id: Annotated[int, 'field record id']) None[source]