Avoid to use sync (with blocking io) functions into the WorkflowTrigger
#38672
Labels
affected_version:main_branch
Issues Reported for main branch
area:core
good first issue
kind:meta
High-level information important to the community
Body
After last refactoring (#36916)
airflow.triggers.external_task.WorkflowTrigger
start more actively use blocking IO - request to DB with non-async drivers.Instead of direct call sync method, it should be wrapped in one of the common practice to run sync code into async loop:
asyncio.to_thread
Python 3.9+, for backward compatible with Python 3.8 it should useasyncio.loop.run_in_executor
asgiref.sync.sync_to_async
anyio
???Committer
The text was updated successfully, but these errors were encountered: