This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from bada372 Fix stuck "queued" tasks in KubernetesExecutor (#18152)
add a9772cf Add a Docker Taskflow decorator (#15330)
No new revisions were added by this update.
Summary of changes:
airflow/decorators/__init__.py | 137 ++--------
airflow/decorators/base.py | 3 +-
airflow/decorators/python.py | 40 ++-
airflow/decorators/python_virtualenv.py | 45 ++--
...tutorial_taskflow_api_etl_docker_virtualenv.py} | 2 +-
airflow/provider.yaml.schema.json | 12 +
airflow/provider_info.schema.json | 12 +
.../providers/docker/decorators}/__init__.py | 0
airflow/providers/docker/decorators/docker.py | 289 +++++++++++++++++++++
airflow/providers/docker/operators/docker.py | 52 +++-
airflow/providers/docker/provider.yaml | 4 +
airflow/providers_manager.py | 92 ++++++-
airflow/utils/python_virtualenv_script.jinja2 | 17 +-
.../howto/create-custom-decorator.rst | 120 +++++++++
docs/apache-airflow/howto/index.rst | 1 +
docs/apache-airflow/tutorial_taskflow_api.rst | 40 ++-
.../hooks => docker/decorators}/__init__.py | 0
tests/providers/docker/decorators/test_docker.py | 121 +++++++++
18 files changed, 812 insertions(+), 175 deletions(-)
rename airflow/example_dags/{tutorial_taskflow_api_etl_virtualenv.py =>
tutorial_taskflow_api_etl_docker_virtualenv.py} (97%)
copy {tests/www/api/experimental =>
airflow/providers/docker/decorators}/__init__.py (100%)
create mode 100644 airflow/providers/docker/decorators/docker.py
create mode 100644 docs/apache-airflow/howto/create-custom-decorator.rst
copy tests/providers/{zendesk/hooks => docker/decorators}/__init__.py (100%)
create mode 100644 tests/providers/docker/decorators/test_docker.py