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