Vamsi-klu commented on issue #55728: URL: https://github.com/apache/airflow/issues/55728#issuecomment-5435344971
Working on a fix. Live check on current main: The 12.6.1 `await sync_to_async(self.get_connection)` hop is already gone in microsoft-azure >=12.10.3 (`#56791` — `get_async_connection`). `execute_complete` is only re-raising `event["message"]`; the stack in the original report is the trigger error, as noted above. The leftover that still matches this RuntimeError is `conn.extra_dejson` inside `AzureDataFactoryAsyncHook.get_async_conn` and `provide_targeted_factory_async`. That property can call `mask_secret` → sync send on the triggerer event loop (same class of bug `#55179` fixed for MSGraph with `json.loads(connection.extra)`). PR will: - swap those two async extras reads to `json.loads(conn.extra)` (leave the sync hook on `extra_dejson`) - same hop on `AzureSynapsePipelineAsyncHook.get_async_conn`, which still calls sync `get_connection` inside `async def` - tests that fail if `extra_dejson` is used again on the async path Not changing `execute_complete`. --- Drafted-by: Cursor Grok 4.6 (no human review before posting) -- 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]
