Skip to content

symfonic.capabilities.memory.native_pending_claims

native_pending_claims

Private v11 claim handoff between a writer and native PG lifecycle.

The public ID-only receipt never grants ownership. The task-local claim set comes only from accepted writes, and unclaimed historical rows fail closed.

published async 

published(lifecycle: Any, claims: tuple[Claim, ...]) -> set[str]

Reconcile a retry by durable token after an earlier confirmed commit.

Source code in src/symfonic/capabilities/memory/native_pending_claims.py 
44
45
46
47
48
49
50
51
52
53
54
55
async def published(lifecycle: Any, claims: tuple[Claim, ...]) -> set[str]:
    """Reconcile a retry by durable token after an earlier confirmed commit."""
    if not claims:
        return set()
    from symfonic.capabilities.memory.graph_native_admission import exact_pg_graph

    graph = getattr(lifecycle, "graph", None)
    if not exact_pg_graph(graph):
        return set()
    from symfonic.memory.backends.postgres_pending_claims import states

    return await states(graph.pool, claims)