Skip to content

symfonic.capabilities.memory.phases.deep_native_graph_pg_port

deep_native_graph_pg_port

Concrete PostgreSQL adapter staging guarded native graph writes in a cycle.

PostgresNativeGraphMutationPort 

PostgresNativeGraphMutationPort(graph: Any, journal: Any)

Bases: NativeGraphMutationPort

Stage writes against the exact graph, replayed in the receipt transaction.

Source code in src/symfonic/capabilities/memory/phases/deep_native_graph_pg_port.py 
17
18
19
20
21
22
23
def __init__(self, graph: Any, journal: Any) -> None:
    super().__init__(graph, journal)
    self._neighbors: dict[tuple[str, str, int], set[str]] = {}
    self._plan_length = 0
    self._plan_tail: Any = None
    self.applied_edges = 0
    self.skipped_edges = 0