replay_with_mapping#
- eclypse.policies.replay.replay_with_mapping(record_source, *, target, column_mapping=None, id_mapping=None, **kwargs)[source]#
Replay records after renaming columns and external graph ids.
- Parameters:
record_source (Any) – Iterable of mapping records to replay.
target (ReplayTarget) – Replay target, either
"nodes"or"edges".column_mapping (dict[str, str] | None) – Optional mapping from input column names to replay columns.
id_mapping (dict[str, str] | None) – Optional mapping from external graph ids to local graph ids.
kwargs (Any) – Additional keyword arguments forwarded to
from_records.
- Returns:
Stateful replay policy.
- Return type: