sundeep8967 opened a new pull request, #72077: URL: https://github.com/apache/airflow/pull/72077
## Problem The `DatabricksRunNowOperator(deferrable=True)` crashes during trigger polling in Airflow 3 because it attempts to lazily fetch the Databricks connection (via `self.databricks_conn`) from within an actively running `asyncio` event loop. The connection fetch path routes through `SUPERVISOR_COMMS.send` which uses `asgiref.sync.async_to_sync`, resulting in a hard `RuntimeError`. ## Solution This PR implements an async-safe mechanism for retrieving the connection (`get_a_databricks_conn`) and updates all async functions within `BaseDatabricksHook` to use it instead of the synchronous property. Fixes #71525 ## Testing - Unit tests updated and verified. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
