​
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.