`prefect.server.utilities.postgres_listener`

Functions

`get_pg_notify_connection`

get_pg_notify_connection() -> Connection | None

Establishes and returns a raw asyncpg connection for LISTEN/NOTIFY. Returns None if not a PostgreSQL connection URL.

`pg_listen`

pg_listen(connection: Connection, channel_name: str, heartbeat_interval: float = 5.0) -> AsyncGenerator[str, None]

Listens to a specific Postgres channel and yields payloads. Manages adding and removing the listener on the given connection.