Handle trigger calls to get_connection

airflow-core/pyproject.toml

@@ -158,6 +158,7 @@ dependencies = [
     "eventlet>=0.37.0",
     "gevent>=25.4.1",
     "greenlet>=3.1.0",
+    "greenback>=1.2.1",
 ]
 "graphviz" = [
     # The graphviz package creates friction when installing on MacOS as it needs graphviz system package to

task-sdk/src/airflow/sdk/definitions/connection.py

@@ -203,6 +203,21 @@ def get(cls, conn_id: str) -> Any:
             return _get_connection(conn_id)
         except AirflowRuntimeError as e:
             cls._handle_connection_error(e, conn_id)
+        except RuntimeError as e:
+            # The error from async_to_sync is a RuntimeError, so we have to fall back to text matching
+            if str(e).startswith("You cannot use AsyncToSync in the same thread as an async event loop"):
+                import warnings
+
+                import greenback
+
+                warnings.warn(
+                    "You should not use sync calls here -- use `await Conn.async_get` instead", stacklevel=2
+                )
+
+                return greenback.with_portal_run(cls.async_get, conn_id)
+
+            log.exception("async_to_sync failed")
+            raise
 
     @classmethod
     async def async_get(cls, conn_id: str) -> Any: