Method sync

psycopg/psycopg/_pipeline.py:50–58

Sync the pipeline, send any pending command and receive and process all available results.

(self)

        self._lock = _DummyLock() if _no_lock else conn.lock

    def sync(self) -> None:
        """Sync the pipeline, send any pending command and receive and process
        all available results.
        """
        try:
            with self._lock:
                self._conn.wait(self._sync_gen())
        except e._NO_TRACEBACK as ex:
            raise ex.with_traceback(None)

    def __enter__(self) -> Self:
        with self._lock: