replay_graph#

eclypse.policies.replay.replay_graph(*, node_records=None, edge_records=None, node_id_column='node_id', source_column='source', target_column='target', time_column='time', node_value_columns=None, edge_value_columns=None, node_ids=None, node_filter=None, edge_ids=None, edge_filter=None, missing='ignore', start_step=None, cyclic=False)[source]#

Replay node and edge records as one graph policy.

Parameters:

  • node_records (Any) – Optional node replay records.

  • edge_records (Any) – Optional edge replay records.

  • 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.

  • node_value_columns (list[str] | tuple[str, ...] | None) – Optional explicit node columns to copy.

  • edge_value_columns (list[str] | tuple[str, ...] | None) – Optional explicit edge columns to copy.

  • node_ids (list[str] | None) – Optional explicit node identifiers to mutate.

  • node_filter (NodeFilter | None) – Optional predicate receiving (node_id, data).

  • 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 item.

  • start_step (int | None) – Optional starting replay step.

  • cyclic (bool) – Whether to wrap past the final available replay step.

Returns:

Stateful graph replay policy.

Return type:

UpdatePolicy

On this page