replay_nodes#
- eclypse.policies.replay.replay_nodes(record_source, *, node_id_column='node_id', time_column='time', value_columns=None, node_ids=None, node_filter=None, missing='ignore', start_step=None, cyclic=False)[source]#
Replay node attributes from time-indexed records.
- Parameters:
record_source (Any) – Iterable of mapping records to replay.
node_id_column (str) – Column containing node identifiers.
time_column (str) – Column containing replay steps.
value_columns (list[str] | tuple[str, ...] | None) – Optional explicit columns to copy from records.
node_ids (list[str] | None) – Optional explicit node identifiers to mutate.
node_filter (NodeFilter | None) – Optional predicate receiving
(node_id, data).missing (MissingPolicyBehaviour) – Behaviour when a replay record targets a missing node.
start_step (int | None) – Optional starting replay step.
cyclic (bool) – Whether to wrap past the final available replay step.
- Returns:
Stateful node replay policy.
- Return type: