Function build_postgres_checkpointer

backend/app/orchestration/persistence.py:91–98

(database_url: str)

    lock = _checkpointer_setup_locks.setdefault(conn_str, asyncio.Lock())
    async with lock:
        if _checkpointer_setup_states.get(conn_str):
            return

        logger.debug(
            "ensure_postgres_checkpointer_setup: connecting to %s",
            redact_credentials(conn_str),
        )
        conn = await asyncpg.connect(conn_str)
        try:
            for statement in _BOOTSTRAP_STATEMENTS: