This is an automated email from the ASF dual-hosted git repository.
dabla pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from e36e6caa344 Fix breeze k8s dev doesn't include configure-cluster test
resource (#60259)
add 9cab6fb7ef4 Add support for async callables in PythonOperator (#59087)
No new revisions were added by this update.
Summary of changes:
.../core_api/routes/public/test_task_instances.py | 58 +++---
.../providers/common/compat/standard/operators.py | 212 +++++++++++++++++++++
.../providers/common/compat/version_compat.py | 2 +
providers/standard/docs/operators/python.rst | 28 +++
.../example_dags/example_python_decorator.py | 18 ++
.../example_dags/example_python_operator.py | 19 ++
.../airflow/providers/standard/operators/python.py | 66 ++++++-
.../tests/unit/standard/decorators/test_python.py | 36 +++-
.../tests/unit/standard/operators/test_python.py | 157 ++++++++++++++-
task-sdk/docs/api.rst | 4 +-
task-sdk/docs/index.rst | 1 +
task-sdk/src/airflow/sdk/__init__.py | 10 +-
task-sdk/src/airflow/sdk/__init__.pyi | 2 +
task-sdk/src/airflow/sdk/bases/decorator.py | 53 +++++-
task-sdk/src/airflow/sdk/bases/operator.py | 55 +++++-
.../sdk/definitions/_internal/abstractoperator.py | 4 +
.../airflow/sdk/execution_time/callback_runner.py | 67 ++++++-
task-sdk/src/airflow/sdk/execution_time/comms.py | 72 +++++--
18 files changed, 800 insertions(+), 64 deletions(-)
