interpolated_replay#
- eclypse.policies.replay.interpolated_replay(record_source, *, target, node_id_column='node_id', source_column='source', target_column='target', time_column='time', value_columns=None, **kwargs)[source]#
Replay records after filling integer steps by linear interpolation.
- Parameters:
record_source (Any) – Iterable of sparse replay records.
target (ReplayTarget) – Replay target, either
"nodes"or"edges".node_id_column (str) – Column containing node identifiers.
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 numeric columns to interpolate.
kwargs (Any) – Additional keyword arguments forwarded to
from_records.
- Returns:
Stateful replay policy using interpolated records.
- Return type: