netcdf_player

netcdf_player

class NetCDFPlayer(model_config: dict, validate_config=True)

Bases: TrackedModel

netcdf_tape: NetCDFTape

publish()

publishers: t.List[Publisher]

setup(state: TrackedState, schema: AttributeSchema, init_data_handler: InitDataHandler, **_)

shutdown(**_)

update(moment: Moment, **_) → Moment | None

class NetCDFTape(timeline_info: TimelineInfo | None = None)

Bases: BaseTapefile

assert_variable(var_name)

close()

data: Dict[str, ndarray]

get_data(key)

initialize(netcdf: Dataset)

netcdf: Dataset | None

time_var = 'time'

class Publisher(tape: NetCDFTape, parameter: str, target: UniformAttribute | CSRAttribute)

Bases: object

publish()

get_netcdf_tape(data_handler: InitDataHandler, name: str) → NetCDFTape

get_publish_attribute(attr: str, target_entity_group: Tuple[str, str], schema: AttributeSchema, state: TrackedState)