Repository navigation

Add support for async callables in PythonOperator - #59087

Merged

dabla merged 199 commits into

apache:mainfrom

dabla:feature/async-python-operator

Jan 8, 2026

Commits on Dec 5, 2025
- refactor: Implemented AsyncPythonOperator
  dabla
  committed
  56b51a3
- refactor: Refactored SFTPHookAsync and added SFTPClientPool
  dabla
  committed
  05ff087
- refactor: Reformatted files
  dabla
  committed
  a31bc50
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  b3c8f4c
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  743a48a
- refactor: Fixed mypy issues
  dabla
  committed
  8d2c241
- refactor: Moved default is_async property from BaseOperator to AbstractOperator
  dabla
  committed
  71ab2f3
- refactor: Reformatted PythonAsyncOperator
  dabla
  committed
  1f2ac8c
- refactor: Fixed typing in retrieve_file method of SFTPHookAsync
  dabla
  committed
  4325015
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  29579b3
- refactor: Fixed mypy in sftp
  dabla
  committed
  bb5278b
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  5a24eca
Commits on Dec 6, 2025
- refactor: Reformatted constructor SFTPClientPool
  dabla
  committed
  405cbb8
- refactor: Fixed types for SFTHookAsync
  dabla
  committed
  dd2bd9e
- refactor: Added return type for get_sftp_client
  dabla
  committed
  ecc8f04
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  3231cbd
Commits on Dec 7, 2025
- refactor: Added docstring PythonAsyncOperator
  dabla
  committed
  eb0e959
- refactor: Fixed callable in is_async_callable
  dabla
  committed
  06cdc85
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  d3af2e0
Commits on Dec 8, 2025
Commits on Dec 9, 2025
Commits on Dec 10, 2025
Commits on Dec 11, 2025
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  8843302
- refactor: Fixed SFTP tests
  dabla
  committed
  1d2ff36
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  d61b7eb
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  c1db81e
Commits on Dec 12, 2025
Commits on Dec 15, 2025
Commits on Dec 16, 2025
- refactor: Capture get_connection and aget_connection separately
  dabla
  committed
  7bb1f7b
- refactor: Inversed mock capture order
  dabla
  committed
  0f27eac
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  a406791
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  6e1ec10
- refactor: Reverted changes to SFTP provider
  dabla
  committed
  138525d
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  a3ffdc7
- refactor: Removed self keyword from tests
  dabla
  committed
  b28988f
- refactor: Fixed unit test for python_task
  dabla
  committed
  eb2ad0f
- refactor: Added some asserts in unit test for python_task
  dabla
  committed
  5272fb4
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  1098223
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  972db41
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  92404d4
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  31db814
- refactor: Only run new python tests if Airflow 3.2 or higher
  dabla
  committed
  ba3cfc0
Commits on Dec 17, 2025
Commits on Dec 19, 2025
- doc:s Fixed spelling in Async Python functions
  dabla
  committed
  fd6e55c
- refactor: Fixed task name conflict with decorator
  dabla
  committed
  06a68d9
- refactor: Fixed mypy issue in is_async_callable helper function
  dabla
  committed
  1c4407e
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  ab30da3
- refactor: Moved import of AsyncExecutionCallableRunner directly under type checking block
  dabla
  committed
  5e2b21c
- refactor: Reformatted imports
  dabla
  committed
  4149c36
- refactor: Fixed assertion on task_id due to refactoring
  dabla
  committed
  1c85713
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  34ac0d0
Commits on Dec 21, 2025
- Update task-sdk/src/airflow/sdk/execution_time/callback_runner.py
  
  dabla
  and
  jason810496
  authored
  bbc2155
- docs: Explicitly mention async operators are executed on the worker
  dabla
  committed
  9eb1909
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  3a2f9aa
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  01be17d
- refactor: Make BaseAsyncOperator available through common compat
  dabla
  committed
  1792903
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  e1a363f
- refactor: Added use next version to common compat dependency in standard providers
  dabla
  committed
  7f57235
- refactor: Re-added is_async_callable in sdk decorator
  dabla
  committed
  c28f186
- refactor: Make is_async_callable available via common compat
  dabla
  committed
  cda5f7b
- refactor: Import BaseAsyncOperator via common compat in PythonOperator
  dabla
  committed
  58bf04e
- refactor: Fix import of BaseOperator
  dabla
  committed
  1444bb0
- refactor: Removed unused import of functools
  dabla
  committed
  599f6a9
- refactor: Reformatted common compat operators module
  dabla
  committed
  92f997d
Commits on Dec 22, 2025
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  f27e703
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  48d0a7a
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  5c85171
Commits on Dec 24, 2025
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  0c061cb
- refactor: Try redefining AsyncExecutionCallableRunner in common compat and resolve imports according to Airflow version
  dabla
  committed
  cff1568
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  4e87262
- refactor: Reformatted common compat operators module
  dabla
  committed
  2b4ecc2
- refactor: Moved import Logger into type checking block
  dabla
  committed
  c92328d
- refactor: Changed import of old TaskDecorator
  dabla
  committed
  bbd13a5
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  3a7a527
- refactor: Fixed import for Metadata
  dabla
  committed
  9809281
- refactor: Reformatted imports
  dabla
  committed
  77223ca
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  612ae66
- refactor: Fix import _TaskDecorator when older Airflow version
  dabla
  committed
  628d986
- refactor: Fixed backward compatible import of _TaskDecorator
  dabla
  committed
  916b0bc
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  6515140
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  4e3a15d
Commits on Dec 25, 2025
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  e765671
Commits on Dec 26, 2025
Commits on Dec 27, 2025
Commits on Dec 28, 2025
Commits on Dec 31, 2025
Commits on Jan 4, 2026
Commits on Jan 5, 2026
Commits on Jan 6, 2026
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  2e19f28
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  65f9ef3
Commits on Jan 7, 2026
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  ff45276
- refactor: Fixed assertions due to added tasks in example DAG's
  dabla
  committed
  a8ec0bf
- refactor: Changed assertion of test_run_async_task
  dabla
  committed
  9e2962b
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  164df41
- refactor: Removed unused import of AIRFLOW_V_3_2_PLUS
  dabla
  committed
  d242a8a
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  a4e9a19
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  4fafbc2
Commits on Jan 8, 2026
- refactor: Fixed duplicate logger type
  dabla
  committed
  818c4c7
- refactor: Fixed comments due to changed values
  dabla
  committed
  f2edc16
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  29e6df8
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  8409d30
- Merge branch 'main' into feature/async-python-operator
  dabla
  authored
  7151a90

Commits

Commits on Dec 5, 2025

Commits on Dec 6, 2025

Commits on Dec 7, 2025

Commits on Dec 8, 2025

Commits on Dec 9, 2025

Commits on Dec 10, 2025

Commits on Dec 11, 2025

Commits on Dec 12, 2025

Commits on Dec 15, 2025

Commits on Dec 16, 2025

Commits on Dec 17, 2025

Commits on Dec 19, 2025

Commits on Dec 21, 2025