Module graph_storage 

Functions

count_edges_for_data

Count provenance edge rows for a specific (data_id, dataset_id) pair.

count_nodes_for_data

Count provenance node rows for a specific (data_id, dataset_id) pair.

delete_edges_by_data

delete_edges_by_dataset

Delete all provenance edge rows for a given dataset.

delete_edges_for_data

Delete provenance edge rows for a specific (data_id, dataset_id) pair.

delete_nodes_by_data

delete_nodes_by_dataset

Delete all provenance node rows for a given dataset.

delete_nodes_for_data

Delete provenance node rows for a specific (data_id, dataset_id) pair.

get_edges_by_data

Get all provenance edges for a specific (data_id, dataset_id) pair.

get_edges_by_dataset

get_edges_since

Return edges for dataset_id created strictly after since, ordered by created_at ascending and limited to limit rows. Used by Stage 4 of improve() for incremental graph→session synchronisation.

get_nodes_by_data

Get all provenance nodes for a specific (data_id, dataset_id) pair.

get_nodes_by_dataset

get_nodes_by_ids

Batch-fetch nodes by their string IDs (hex form). Used by Stage 4 to resolve edge endpoints to full node metadata for JSON-line rendering.

get_unique_edges_for_data

Return edges belonging to (data_id, dataset_id) whose slug does NOT appear in any other row within the same dataset with a different data_id.

get_unique_nodes_for_data

Return nodes belonging to (data_id, dataset_id) whose slug does NOT appear in any other row within the same dataset with a different data_id.

upsert_edges

upsert_nodes