airflow.providers.common.compat.connection¶

Functions¶

Get an asynchronous Airflow connection that is backwards compatible.

async airflow.providers.common.compat.connection.get_async_connection(conn_id, hook=None)[source]¶

Get an asynchronous Airflow connection that is backwards compatible.

Parameters:

conn_id (str) – The provided connection ID.
hook (airflow.providers.common.compat.sdk.BaseHook | type[airflow.providers.common.compat.sdk.BaseHook] | None) – Hook (class or instance) to resolve the connection through, so a subclass override of aget_connection/get_connection is honored. Defaults to BaseHook.

Returns:

Connection

Return type:

airflow.providers.common.compat.sdk.Connection