The GitHub Actions job "Tests" on airflow.git/fix/databricks-async-to-sync-triggerer has failed. Run started by GitHub user techcodie (triggered by eladkal).
Head commit for run: 267b8741b1419cf3e4599a9863796afd26057b5e / Ansh <[email protected]> fix(databricks): avoid AsyncToSync in triggerer for deferrable operators When DatabricksExecutionTrigger runs inside the triggerer's async event loop, accessing the databricks_conn cached_property triggers a sync get_connection() call which internally uses async_to_sync() — raising: RuntimeError: You cannot use AsyncToSync in the same thread as an async event loop - just await the async function directly. Add _a_get_databricks_conn() that uses _async_get_connection() (the existing async-safe path) and eagerly call it at the top of _a_do_api_call() so the cached_property is populated before any sync attribute access (e.g. self.databricks_conn.port in _endpoint_url). Fixes deferrable=True for DatabricksTaskOperator and all other operators that create a DatabricksExecutionTrigger in Airflow 3. Report URL: https://github.com/apache/airflow/actions/runs/23177723368 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
