replay_events#
- eclypse.policies.replay.replay_events(record_source, *, time_column='time', policy_column='policy', start_step=None, cyclic=False)[source]#
Replay arbitrary update policies from time-indexed records.
- Parameters:
record_source (Any) – Iterable of records containing update policies.
time_column (str) – Column containing replay steps.
policy_column (str) – Column containing policy callables.
start_step (int | None) – Optional starting replay step.
cyclic (bool) – Whether to wrap past the final available replay step.
- Returns:
Stateful event replay policy.
- Return type: