This is an automated email from the ASF dual-hosted git repository.
utkarsharma pushed a change to annotated tag 3.0.0a2
in repository https://gitbox.apache.org/repos/asf/airflow.git
*** WARNING: tag 3.0.0a2 was modified! ***
from c2cb695f536 (tag)
to a9ad3440930 (tag)
tagging 4aa1e18f3a8161f9bb541f39ff97e90e57745665 (commit)
replaces providers-celery/3.10.0
by utkarsh sharma
on Fri Feb 7 00:08:56 2025 +0530
- Log -----------------------------------------------------------------
Apache Airflow 3.0.0a2
-----BEGIN PGP SIGNATURE-----
iHUEABYKAB0WIQSdmuesjKP2JTY7shF0yp3TRIK2RAUCZ6UBxQAKCRB0yp3TRIK2
RLfSAP9qqYtKeQiH8wdVTA1TwW8e1XophFY3I9OrFdJhSjJg7gEAsbvNRIkbmb3j
ZaPnZoPdpzQ40B0T8WgT+BUmpqQqUQA=
=3MMx
-----END PGP SIGNATURE-----
-----------------------------------------------------------------------
discard 9806a9dc2d2 Temporarily disable deactivating deleted DAGs
discard f5373242135 Bump standard provider version to 0.1.0
discard a2c524d6b06 Bump celery provider version to 3.11.0
discard 040248f98c1 Fix static checks
discard 2c13a14ed00 Update RELEASE_NOTES.rst
discard 6d7e360f327 Update Airflow version to 3.0.0a2
discard 0409e41832f Update default branches for 3-0
add 09ba0b14e52 docs: clarify Gunicorn's role in webserver worker refresh
(#46371)
add 18ec6ab79f2 Allow passing empty labels in the spark kubernetes driver
config (#45864)
add e16418b6c43 SnowflakeSqlApiOperator snowflake_conn_id add to
template_fields (#46422)
add ee8d6658f86 Replace Airflow email config by connection extras in SMTP
provider (#46219)
add a9287d390c1 Integrate the SimpleAuthManager UI in dev mode (#46511)
add 12325000260 AIP-84 Remove unecessary datamodels config and
from_attributes (#46328)
add 7340b066187 Fix scheduler ServiceAccount automount for multi-executor
(#46486)
add c813c32feb3 Add update XCom endpoint in RestAPI (#46457)
add fe30f87954f Fix missing logical_date in DagRun for DMS operator tests
(#46521)
add 9951cf1f62a Update AWS auth manager to use Fastapi instead of Flask
(#46381)
add 0585b29e4c3 Rename apiServer to _apiServer to preserve it in beta
until v3 release (#46480)
add 993a009e041 Remove `ds`/`ts` etc from Template/run context when no
logical date is defined (#46522)
add 7af45717ea3 Fix task sdk client dry-run mode (#46524)
add a6024336703 Move microsoft winrm to new provider structure (#46469)
add 69b27f89e3d Adding extra links for EC2 (#46340)
add 7201469b285 Add state filter to task page. (#46465)
add 681ad5c6466 Move CNCF Kubernetes to new provider structure (#46436)
add aaaea355d3a Add dynamic task mapping into TaskSDK runtime (#46032)
new 011d357a89d Update default branches for 3-0
new 844c6811aa0 Update Airflow version to 3.0.0a2
new c85008dcc6f Update RELEASE_NOTES.rst
new b2886e38cf5 Fix static checks
new ad200003529 Bump celery provider version to 3.11.0
new 1d7176e2b27 Bump standard provider version to 0.1.0
new 4aa1e18f3a8 Bump task-sdk version
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
annotated tag are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (c2cb695f536)
\
N -- N -- N refs/tags/3.0.0a2 (a9ad3440930)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/boring-cyborg.yml | 14 +-
.pre-commit-config.yaml | 6 +-
.../api_fastapi/core_api/datamodels/dag_tags.py | 4 -
.../api_fastapi/core_api/datamodels/event_logs.py | 4 +-
.../core_api/datamodels/import_error.py | 4 +-
airflow/api_fastapi/core_api/datamodels/pools.py | 4 +-
.../core_api/datamodels/task_instances.py | 5 -
.../api_fastapi/core_api/datamodels/variables.py | 4 +-
airflow/api_fastapi/core_api/datamodels/xcom.py | 7 +
.../api_fastapi/core_api/openapi/v1-generated.yaml | 88 ++++
airflow/api_fastapi/core_api/routes/public/job.py | 9 +-
.../core_api/routes/public/task_instances.py | 11 +-
airflow/api_fastapi/core_api/routes/public/xcom.py | 46 ++
airflow/api_fastapi/execution_api/app.py | 10 +-
.../execution_api/datamodels/taskinstance.py | 23 +-
.../execution_api/routes/task_instances.py | 5 +-
airflow/api_fastapi/execution_api/routes/xcoms.py | 91 +++-
.../{ => auth/managers/simple}/ui/dev/index.html | 8 +-
airflow/auth/managers/simple/ui/package.json | 2 +-
airflow/config_templates/config.yml | 18 +-
airflow/dag_processing/manager.py | 3 +-
airflow/decorators/base.py | 16 +-
airflow/models/abstractoperator.py | 2 +-
airflow/models/baseoperator.py | 31 +-
airflow/models/dagrun.py | 6 +-
airflow/models/expandinput.py | 249 ++---------
airflow/models/mappedoperator.py | 52 +--
airflow/models/serialized_dag.py | 2 +-
airflow/models/skipmixin.py | 5 +-
airflow/models/taskinstance.py | 97 +----
airflow/models/xcom_arg.py | 102 ++++-
airflow/serialization/serialized_objects.py | 10 +-
airflow/ui/openapi-gen/queries/common.ts | 3 +
airflow/ui/openapi-gen/queries/queries.ts | 56 +++
airflow/ui/openapi-gen/requests/schemas.gen.ts | 18 +
airflow/ui/openapi-gen/requests/services.gen.ts | 36 ++
airflow/ui/openapi-gen/requests/types.gen.ts | 47 +++
airflow/ui/src/constants/stateOptions.ts | 53 +++
airflow/ui/src/pages/Dag/Runs/Runs.tsx | 21 +-
airflow/ui/src/pages/Run/TaskInstances.tsx | 29 +-
airflow/ui/src/pages/Task/Instances.tsx | 81 +++-
airflow/utils/context.py | 19 -
airflow/utils/setup_teardown.py | 4 +-
airflow/utils/task_group.py | 48 +--
chart/templates/_helpers.yaml | 4 +-
.../api-server/api-server-deployment.yaml | 122 +++---
.../api-server/api-server-networkpolicy.yaml | 10 +-
.../api-server/api-server-poddisruptionbudget.yaml | 8 +-
chart/templates/api-server/api-server-service.yaml | 18 +-
.../api-server/api-server-serviceaccount.yaml | 12 +-
chart/templates/configmaps/configmap.yaml | 2 +-
.../scheduler/scheduler-serviceaccount.yaml | 2 +-
chart/values.schema.json | 10 +-
chart/values.yaml | 8 +-
.../airflow_breeze/commands/kubernetes_commands.py | 2 +-
docs/.gitignore | 2 +
.../changelog.rst | 25 --
.../changelog.rst | 25 --
docs/apache-airflow/templates-ref.rst | 25 +-
docs/apache-airflow/tutorial/taskflow.rst | 2 +-
helm_tests/airflow_core/test_api_server.py | 68 +--
helm_tests/airflow_core/test_scheduler.py | 3 +-
helm_tests/security/test_rbac.py | 8 +-
newsfragments/42404.significant.rst | 2 +
.../cassandra => cncf/kubernetes}/README.rst | 33 +-
.../kubernetes/docs}/.latest-doc-only-change.txt | 0
.../kubernetes/docs/changelog.rst} | 0
.../cncf/kubernetes/docs}/cli-ref.rst | 0
.../cncf/kubernetes/docs}/commits.rst | 0
.../cncf/kubernetes/docs}/configurations-ref.rst | 0
.../kubernetes/docs}/connections/kubernetes.rst | 0
.../kubernetes/docs}/img/arch-diag-kubernetes.png | Bin
.../kubernetes/docs}/img/arch-diag-kubernetes2.png | Bin
.../cncf/kubernetes/docs}/img/k8s-failed-pod.png | Bin
.../cncf/kubernetes/docs}/img/k8s-happy-path.png | Bin
.../cncf/kubernetes/docs}/index.rst | 0
.../docs}/installing-providers-from-sources.rst | 0
.../docs/integration-logos}/Kubernetes.png | Bin
.../integration-logos}/Spark-On-Kubernetes.png | Bin
.../cncf/kubernetes/docs}/kubernetes_executor.rst | 6 +-
.../kubernetes/docs}/local_kubernetes_executor.rst | 0
.../cncf/kubernetes/docs}/operators.rst | 24 +-
.../cncf/kubernetes/docs}/redirects.txt | 0
.../cncf/kubernetes/docs}/security.rst | 0
.../providers => }/cncf/kubernetes/provider.yaml | 26 +-
.../mssql => cncf/kubernetes}/pyproject.toml | 47 ++-
.../src/airflow/providers/cncf/kubernetes}/LICENSE | 0
.../airflow/providers/cncf/kubernetes/__init__.py | 0
.../cncf/kubernetes/backcompat/__init__.py | 0
.../backcompat/backwards_compat_converters.py | 3 +-
.../airflow/providers/cncf/kubernetes/callbacks.py | 3 +-
.../providers/cncf/kubernetes/cli}/__init__.py | 0
.../cncf/kubernetes/cli/kubernetes_command.py | 7 +-
.../cncf/kubernetes/decorators}/__init__.py | 0
.../cncf/kubernetes/decorators/kubernetes.py | 4 +-
.../providers/cncf/kubernetes/exceptions.py | 0
.../cncf/kubernetes/executors}/__init__.py | 0
.../kubernetes/executors/kubernetes_executor.py | 7 +-
.../executors/kubernetes_executor_types.py | 0
.../executors/kubernetes_executor_utils.py | 7 +-
.../executors/local_kubernetes_executor.py | 0
.../providers/cncf/kubernetes/get_provider_info.py | 361 ++++++++++++++++
.../providers/cncf/kubernetes/hooks}/__init__.py | 0
.../providers/cncf/kubernetes/hooks/kubernetes.py | 6 +-
.../airflow/providers/cncf/kubernetes/k8s_model.py | 0
.../providers/cncf/kubernetes/kube_client.py | 0
.../providers/cncf/kubernetes/kube_config.py | 0
.../kubernetes_executor_templates}/__init__.py | 0
.../basic_template.yaml | 0
.../cncf/kubernetes/kubernetes_helper_functions.py | 2 +-
.../cncf/kubernetes/operators}/__init__.py | 0
.../kubernetes/operators/custom_object_launcher.py | 6 +-
.../providers/cncf/kubernetes/operators/job.py | 8 +-
.../providers/cncf/kubernetes/operators/kueue.py | 4 +-
.../providers/cncf/kubernetes/operators/pod.py | 10 +-
.../cncf/kubernetes/operators/resource.py | 2 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 7 +-
.../providers/cncf/kubernetes/pod_generator.py | 4 +-
.../cncf/kubernetes/pod_generator_deprecated.py | 1 +
.../pod_template_file_examples}/__init__.py | 0
.../dags_in_image_template.yaml | 0
.../dags_in_volume_template.yaml | 0
.../git_sync_template.yaml | 0
.../kubernetes/python_kubernetes_script.jinja2 | 0
.../cncf/kubernetes/python_kubernetes_script.py | 0
.../cncf/kubernetes/resource_convert}/__init__.py | 0
.../cncf/kubernetes/resource_convert/configmap.py | 0
.../kubernetes/resource_convert/env_variable.py | 3 +-
.../cncf/kubernetes/resource_convert/secret.py | 0
.../airflow/providers/cncf/kubernetes/secret.py | 3 +-
.../providers/cncf/kubernetes/sensors}/__init__.py | 0
.../cncf/kubernetes/sensors/spark_kubernetes.py | 3 +-
.../cncf/kubernetes/template_rendering.py | 2 +-
.../cncf/kubernetes/triggers}/__init__.py | 0
.../providers/cncf/kubernetes/triggers/job.py | 0
.../providers/cncf/kubernetes/triggers/pod.py | 0
.../providers/cncf/kubernetes/utils/__init__.py | 0
.../providers/cncf/kubernetes/utils/delete_from.py | 0
.../cncf/kubernetes/utils/k8s_resource_iterator.py | 3 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 9 +-
.../cncf/kubernetes/utils/xcom_sidecar.py | 0
.../providers/cncf/kubernetes/version_compat.py | 0
.../{airbyte => cncf/kubernetes}/tests/conftest.py | 0
.../kubernetes/tests/provider_tests}/__init__.py | 0
.../tests/provider_tests/cncf}/__init__.py | 0
.../provider_tests/cncf/kubernetes}/__init__.py | 0
.../cncf/kubernetes/backcompat}/__init__.py | 0
.../backcompat/test_backwards_compat_converters.py | 0
.../cncf/kubernetes/cli}/__init__.py | 0
.../cncf/kubernetes/cli/test_kubernetes_command.py | 0
.../provider_tests}/cncf/kubernetes/conftest.py | 0
.../cncf/kubernetes/data_files}/__init__.py | 0
.../kubernetes/data_files/executor}/__init__.py | 0
.../data_files/executor/basic_template.yaml | 0
.../cncf/kubernetes/data_files/kube_config | 0
.../cncf/kubernetes/data_files/pods}/__init__.py | 0
.../kubernetes/data_files/pods/generator_base.yaml | 0
.../pods/generator_base_with_secrets.yaml | 0
.../cncf/kubernetes/data_files/pods/template.yaml | 0
.../cncf/kubernetes/data_files/spark}/__init__.py | 0
.../data_files/spark/application_template.yaml | 0
.../data_files/spark/application_test.json | 0
.../data_files/spark/application_test.yaml | 0
.../application_test_with_no_name_from_config.json | 0
.../application_test_with_no_name_from_config.yaml | 0
.../cncf/kubernetes/decorators}/__init__.py | 0
.../cncf/kubernetes/decorators/test_kubernetes.py | 0
.../cncf/kubernetes/executors}/__init__.py | 0
.../executors/test_kubernetes_executor.py | 0
.../executors/test_local_kubernetes_executor.py | 0
.../cncf/kubernetes/hooks}/__init__.py | 0
.../cncf/kubernetes/hooks/test_kubernetes.py | 0
.../cncf/kubernetes/log_handlers}/__init__.py | 0
.../kubernetes/log_handlers/test_log_handlers.py | 0
.../cncf/kubernetes/models}/__init__.py | 0
.../cncf/kubernetes/models/test_secret.py | 0
.../cncf/kubernetes/operators}/__init__.py | 0
.../operators/test_custom_object_launcher.py | 28 +-
.../cncf/kubernetes/operators/test_job.py | 0
.../cncf/kubernetes/operators/test_kueue.py | 0
.../cncf/kubernetes/operators/test_pod.py | 9 +-
.../cncf/kubernetes/operators/test_resource.py | 0
.../kubernetes/operators/test_spark_kubernetes.py | 0
.../cncf/kubernetes/resource_convert}/__init__.py | 0
.../kubernetes/resource_convert/test_configmap.py | 0
.../resource_convert/test_env_variable.py | 0
.../kubernetes/resource_convert/test_secret.py | 0
.../cncf/kubernetes/sensors}/__init__.py | 0
.../kubernetes/sensors/test_spark_kubernetes.py | 0
.../cncf/kubernetes/test_callbacks.py | 0
.../provider_tests}/cncf/kubernetes/test_client.py | 0
.../kubernetes/test_kubernetes_helper_functions.py | 0
.../cncf/kubernetes/test_pod_generator.py | 0
.../cncf/kubernetes/test_template_rendering.py | 0
.../cncf/kubernetes/triggers}/__init__.py | 0
.../cncf/kubernetes/triggers/test_job.py | 0
.../cncf/kubernetes/triggers/test_pod.py | 0
.../cncf/kubernetes/utils}/__init__.py | 0
.../kubernetes/utils/test_k8s_resource_iterator.py | 0
.../cncf/kubernetes/utils/test_pod_manager.py | 3 +-
.../tests/system/cncf/kubernetes}/__init__.py | 0
.../system/cncf/kubernetes/example_kubernetes.py | 3 +-
.../cncf/kubernetes/example_kubernetes_async.py | 3 +-
.../kubernetes/example_kubernetes_decorator.py | 0
.../cncf/kubernetes/example_kubernetes_job.py | 0
.../cncf/kubernetes/example_kubernetes_kueue.py | 3 +-
.../cncf/kubernetes/example_kubernetes_resource.py | 0
.../cncf/kubernetes/example_spark_kubernetes.py | 0
.../example_spark_kubernetes_spark_pi.yaml | 0
.../system/cncf/kubernetes/spark_job_template.yaml | 0
providers/{openfaas => microsoft/winrm}/README.rst | 15 +-
.../winrm/docs}/.latest-doc-only-change.txt | 0
.../winrm/docs/changelog.rst} | 0
.../microsoft/winrm/docs}/commits.rst | 0
.../microsoft/winrm/docs}/index.rst | 0
.../docs}/installing-providers-from-sources.rst | 0
.../winrm/docs/integration-logos}/WinRM.png | Bin
.../microsoft/winrm/docs}/operators.rst | 4 +-
.../microsoft/winrm/docs}/security.rst | 0
.../providers => }/microsoft/winrm/provider.yaml | 6 +-
providers/microsoft/{psrp => winrm}/pyproject.toml | 18 +-
.../src/airflow/providers/microsoft/winrm}/LICENSE | 0
.../airflow/providers/microsoft/winrm/__init__.py | 0
.../microsoft/winrm}/get_provider_info.py | 38 +-
.../providers/microsoft/winrm/hooks}/__init__.py | 0
.../providers/microsoft/winrm/hooks/winrm.py | 5 +-
.../microsoft/winrm/operators}/__init__.py | 0
.../providers/microsoft/winrm/operators/winrm.py | 0
.../{airbyte => microsoft/winrm}/tests/conftest.py | 0
.../winrm/tests/provider_tests}/__init__.py | 0
.../tests/provider_tests/microsoft}/__init__.py | 0
.../provider_tests/microsoft/winrm}/__init__.py | 0
.../microsoft/winrm/hooks}/__init__.py | 0
.../microsoft/winrm/hooks/test_winrm.py | 0
.../microsoft/winrm/operators}/__init__.py | 0
.../microsoft/winrm/operators/test_winrm.py | 0
.../tests/system/microsoft/winrm}/__init__.py | 0
.../tests/system/microsoft/winrm/example_winrm.py | 0
.../providers/snowflake/operators/snowflake.py | 5 +
.../amazon/aws/auth_manager/aws_auth_manager.py | 53 ++-
.../amazon/aws/auth_manager/router}/__init__.py | 0
.../amazon/aws/auth_manager/router/login.py | 124 ++++++
.../amazon/aws/auth_manager/views/__init__.py | 16 -
.../amazon/aws/auth_manager/views/auth.py | 151 -------
.../amazon/aws/links/{datasync.py => ec2.py} | 33 +-
.../airflow/providers/amazon/aws/operators/ec2.py | 50 +++
.../src/airflow/providers/amazon/provider.yaml | 3 +-
.../providers/cncf/kubernetes/cli/__init__.py | 16 -
.../cncf/kubernetes/decorators/__init__.py | 17 -
.../cncf/kubernetes/executors/__init__.py | 17 -
.../providers/cncf/kubernetes/hooks/__init__.py | 16 -
.../kubernetes_executor_templates/__init__.py | 16 -
.../cncf/kubernetes/operators/__init__.py | 17 -
.../pod_template_file_examples/__init__.py | 16 -
.../cncf/kubernetes/resource_convert/__init__.py | 16 -
.../providers/cncf/kubernetes/sensors/__init__.py | 16 -
.../providers/cncf/kubernetes/triggers/__init__.py | 16 -
.../providers/microsoft/azure/operators/msgraph.py | 1 -
.../providers/microsoft/winrm/hooks/__init__.py | 17 -
.../microsoft/winrm/operators/__init__.py | 17 -
providers/src/airflow/providers/smtp/CHANGELOG.rst | 22 +
providers/src/airflow/providers/smtp/hooks/smtp.py | 22 +-
.../airflow/providers/smtp/notifications/smtp.py | 29 +-
providers/src/airflow/providers/smtp/provider.yaml | 40 --
.../standard/decorators/test_python.py | 53 +--
.../standard/operators/test_datetime.py | 14 +-
.../standard/operators/test_python.py | 42 +-
.../amazon/aws/auth_manager/router}/__init__.py | 0
.../{views/test_auth.py => router/test_login.py} | 104 ++---
.../aws/auth_manager/test_aws_auth_manager.py | 58 +--
.../amazon/aws/auth_manager/views/__init__.py | 16 -
.../aws/links/{test_batch.py => test_ec2.py} | 47 +--
providers/tests/amazon/aws/operators/test_dms.py | 26 +-
providers/tests/cncf/kubernetes/__init__.py | 17 -
.../tests/cncf/kubernetes/backcompat/__init__.py | 16 -
providers/tests/cncf/kubernetes/cli/__init__.py | 16 -
.../tests/cncf/kubernetes/data_files/__init__.py | 16 -
.../kubernetes/data_files/executor/__init__.py | 16 -
.../cncf/kubernetes/data_files/pods/__init__.py | 16 -
.../cncf/kubernetes/data_files/spark/__init__.py | 16 -
.../tests/cncf/kubernetes/decorators/__init__.py | 16 -
.../tests/cncf/kubernetes/executors/__init__.py | 16 -
providers/tests/cncf/kubernetes/hooks/__init__.py | 16 -
.../tests/cncf/kubernetes/log_handlers/__init__.py | 16 -
providers/tests/cncf/kubernetes/models/__init__.py | 17 -
.../tests/cncf/kubernetes/operators/__init__.py | 16 -
.../cncf/kubernetes/resource_convert/__init__.py | 16 -
.../kubernetes/resource_convert/test_configmap.py | 16 -
.../resource_convert/test_env_variable.py | 16 -
.../kubernetes/resource_convert/test_secret.py | 16 -
.../tests/cncf/kubernetes/sensors/__init__.py | 16 -
.../tests/cncf/kubernetes/triggers/__init__.py | 16 -
providers/tests/cncf/kubernetes/utils/__init__.py | 16 -
providers/tests/microsoft/winrm/__init__.py | 17 -
providers/tests/microsoft/winrm/hooks/__init__.py | 17 -
.../tests/microsoft/winrm/operators/__init__.py | 17 -
providers/tests/smtp/hooks/test_smtp.py | 103 ++---
providers/tests/smtp/notifications/test_smtp.py | 54 +--
providers/tests/system/cncf/kubernetes/__init__.py | 16 -
providers/tests/system/microsoft/winrm/__init__.py | 16 -
pyproject.toml | 6 +
scripts/ci/docker-compose/remove-sources.yml | 2 +
scripts/ci/docker-compose/tests-sources.yml | 2 +
scripts/ci/kubernetes/k8s_requirements.txt | 1 +
scripts/ci/pre_commit/compile_ui_assets_dev.py | 44 +-
scripts/ci/pre_commit/template_context_key_sync.py | 12 +-
task_sdk/pyproject.toml | 2 +-
task_sdk/src/airflow/sdk/__init__.py | 2 +-
task_sdk/src/airflow/sdk/api/client.py | 25 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 52 ++-
.../sdk/definitions/_internal}/expandinput.py | 195 ++++-----
.../airflow/sdk/definitions/_internal/mixins.py | 2 +-
.../airflow/sdk/definitions/_internal/templater.py | 4 +-
task_sdk/src/airflow/sdk/definitions/dag.py | 7 +
.../src/airflow/sdk/definitions/mappedoperator.py | 115 +----
task_sdk/src/airflow/sdk/definitions/param.py | 5 +-
task_sdk/src/airflow/sdk/definitions/xcom_arg.py | 144 +++----
task_sdk/src/airflow/sdk/execution_time/comms.py | 17 +
task_sdk/src/airflow/sdk/execution_time/context.py | 19 +
.../airflow/sdk/execution_time/lazy_sequence.py | 188 +++++++++
.../src/airflow/sdk/execution_time/supervisor.py | 5 +
.../src/airflow/sdk/execution_time/task_runner.py | 150 ++++---
task_sdk/src/airflow/sdk/types.py | 14 +-
task_sdk/tests/api/test_client.py | 37 +-
task_sdk/tests/conftest.py | 135 ++++++
task_sdk/tests/definitions/conftest.py | 49 +++
task_sdk/tests/definitions/test_baseoperator.py | 23 -
task_sdk/tests/definitions/test_dag.py | 34 +-
task_sdk/tests/definitions/test_mappedoperator.py | 468 +++++++++++++++++++--
task_sdk/tests/definitions/test_xcom_arg.py | 360 ++++++++++++++++
task_sdk/tests/execution_time/conftest.py | 136 ------
task_sdk/tests/execution_time/test_task_runner.py | 103 +++--
tests/always/test_project_structure.py | 33 +-
.../core_api/routes/public/test_xcom.py | 41 ++
.../api_fastapi/execution_api/routes/test_xcoms.py | 2 +-
tests/decorators/test_task_group.py | 2 +
tests/models/test_dag.py | 32 +-
tests/models/test_dagrun.py | 165 +++++---
tests/models/test_mappedoperator.py | 302 +++----------
tests/models/test_skipmixin.py | 1 +
tests/models/test_taskinstance.py | 404 +-----------------
tests/models/test_taskmap.py | 76 ++++
tests/models/test_xcom_arg_map.py | 433 -------------------
tests/serialization/test_dag_serialization.py | 28 +-
.../ti_deps/deps/test_mapped_task_upstream_dep.py | 73 ++--
tests_common/pytest_plugin.py | 20 +-
tests_common/test_utils/mock_context.py | 14 +-
tests_common/test_utils/mock_operators.py | 46 +-
tests_common/test_utils/version_compat.py | 1 +
349 files changed, 3994 insertions(+), 4152 deletions(-)
copy airflow/{ => auth/managers/simple}/ui/dev/index.html (76%)
create mode 100644 airflow/ui/src/constants/stateOptions.ts
delete mode 100644 docs/apache-airflow-providers-cncf-kubernetes/changelog.rst
delete mode 100644 docs/apache-airflow-providers-microsoft-winrm/changelog.rst
copy providers/{apache/cassandra => cncf/kubernetes}/README.rst (65%)
rename providers/{src/airflow/providers/cncf/kubernetes =>
cncf/kubernetes/docs}/.latest-doc-only-change.txt (100%)
rename providers/{src/airflow/providers/cncf/kubernetes/CHANGELOG.rst =>
cncf/kubernetes/docs/changelog.rst} (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/cli-ref.rst (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/commits.rst (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/configurations-ref.rst (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/connections/kubernetes.rst (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/img/arch-diag-kubernetes.png (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/img/arch-diag-kubernetes2.png (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/img/k8s-failed-pod.png (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/img/k8s-happy-path.png (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/index.rst (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/installing-providers-from-sources.rst (100%)
rename {docs/integration-logos/kubernetes =>
providers/cncf/kubernetes/docs/integration-logos}/Kubernetes.png (100%)
rename {docs/integration-logos/kubernetes =>
providers/cncf/kubernetes/docs/integration-logos}/Spark-On-Kubernetes.png (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/kubernetes_executor.rst (96%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/local_kubernetes_executor.rst (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/operators.rst (95%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/redirects.txt (100%)
rename {docs/apache-airflow-providers-cncf-kubernetes =>
providers/cncf/kubernetes/docs}/security.rst (100%)
rename providers/{src/airflow/providers => }/cncf/kubernetes/provider.yaml
(88%)
copy providers/{microsoft/mssql => cncf/kubernetes}/pyproject.toml (59%)
copy {chart =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes}/LICENSE (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/__init__.py (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/backcompat/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/backcompat/backwards_compat_converters.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/callbacks.py (99%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/cli}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/cli/kubernetes_command.py
(99%)
copy {airflow/api/auth =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/decorators}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/decorators/kubernetes.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/exceptions.py (100%)
copy {airflow/api/auth =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_types.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/executors/local_kubernetes_executor.py
(100%)
create mode 100644
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/get_provider_info.py
copy {airflow/api_connexion =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/hooks}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/hooks/kubernetes.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/k8s_model.py (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/kube_client.py (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/kube_config.py (100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/kubernetes_executor_templates}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/kubernetes_executor_templates/basic_template.yaml
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/kubernetes_helper_functions.py
(100%)
copy {airflow/api/auth =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/operators/custom_object_launcher.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/operators/job.py (99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/operators/kueue.py (99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/operators/pod.py (99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/operators/resource.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/pod_generator.py (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/pod_generator_deprecated.py
(99%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/pod_template_file_examples}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/pod_template_file_examples/dags_in_image_template.yaml
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/pod_template_file_examples/dags_in_volume_template.yaml
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/pod_template_file_examples/git_sync_template.yaml
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/python_kubernetes_script.jinja2
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/python_kubernetes_script.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/resource_convert}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/resource_convert/configmap.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/resource_convert/env_variable.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/resource_convert/secret.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/secret.py (99%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/sensors}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/sensors/spark_kubernetes.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/template_rendering.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/triggers}/__init__.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/triggers/job.py (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/triggers/pod.py (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/utils/__init__.py (100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/utils/delete_from.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/utils/k8s_resource_iterator.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
(99%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/utils/xcom_sidecar.py
(100%)
rename providers/{ =>
cncf/kubernetes}/src/airflow/providers/cncf/kubernetes/version_compat.py (100%)
copy providers/{airbyte => cncf/kubernetes}/tests/conftest.py (100%)
copy providers/{ => cncf/kubernetes/tests/provider_tests}/__init__.py (100%)
copy providers/{ => cncf/kubernetes/tests/provider_tests/cncf}/__init__.py
(100%)
copy {airflow/api/auth =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes}/__init__.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/backcompat}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/backcompat/test_backwards_compat_converters.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/cli}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/cli/test_kubernetes_command.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/conftest.py (100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/data_files}/__init__.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/data_files/executor}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/executor/basic_template.yaml
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/kube_config
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/data_files/pods}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/pods/generator_base.yaml
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/pods/generator_base_with_secrets.yaml
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/pods/template.yaml
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/data_files/spark}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/spark/application_template.yaml
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/spark/application_test.json
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/spark/application_test.yaml
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/spark/application_test_with_no_name_from_config.json
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/data_files/spark/application_test_with_no_name_from_config.yaml
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/decorators}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/decorators/test_kubernetes.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/executors}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/executors/test_kubernetes_executor.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/executors/test_local_kubernetes_executor.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/hooks}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/hooks/test_kubernetes.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/log_handlers}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/log_handlers/test_log_handlers.py
(100%)
copy {airflow/api/auth =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/models}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/models/test_secret.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/operators}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/operators/test_custom_object_launcher.py
(91%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/operators/test_job.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/operators/test_kueue.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/operators/test_pod.py
(99%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/operators/test_resource.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/operators/test_spark_kubernetes.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/resource_convert}/__init__.py
(100%)
copy airflow/api_connexion/__init__.py =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/resource_convert/test_configmap.py
(100%)
copy airflow/api_connexion/__init__.py =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/resource_convert/test_env_variable.py
(100%)
copy airflow/api_connexion/__init__.py =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/resource_convert/test_secret.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/sensors}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/sensors/test_spark_kubernetes.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/test_callbacks.py (100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/test_client.py (100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/test_kubernetes_helper_functions.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/test_pod_generator.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/test_template_rendering.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/triggers}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/triggers/test_job.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/triggers/test_pod.py
(100%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/provider_tests/cncf/kubernetes/utils}/__init__.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/utils/test_k8s_resource_iterator.py
(100%)
rename providers/{tests =>
cncf/kubernetes/tests/provider_tests}/cncf/kubernetes/utils/test_pod_manager.py
(99%)
copy {airflow/api_connexion =>
providers/cncf/kubernetes/tests/system/cncf/kubernetes}/__init__.py (100%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_kubernetes.py (99%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_kubernetes_async.py (99%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_kubernetes_decorator.py
(100%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_kubernetes_job.py (100%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_kubernetes_kueue.py (99%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_kubernetes_resource.py
(100%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_spark_kubernetes.py (100%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/example_spark_kubernetes_spark_pi.yaml
(100%)
rename providers/{ =>
cncf/kubernetes}/tests/system/cncf/kubernetes/spark_job_template.yaml (100%)
copy providers/{openfaas => microsoft/winrm}/README.rst (79%)
rename providers/{src/airflow/providers/microsoft/winrm =>
microsoft/winrm/docs}/.latest-doc-only-change.txt (100%)
rename providers/{src/airflow/providers/microsoft/winrm/CHANGELOG.rst =>
microsoft/winrm/docs/changelog.rst} (100%)
rename {docs/apache-airflow-providers-microsoft-winrm =>
providers/microsoft/winrm/docs}/commits.rst (100%)
rename {docs/apache-airflow-providers-microsoft-winrm =>
providers/microsoft/winrm/docs}/index.rst (100%)
rename {docs/apache-airflow-providers-microsoft-winrm =>
providers/microsoft/winrm/docs}/installing-providers-from-sources.rst (100%)
rename {docs/integration-logos/winrm =>
providers/microsoft/winrm/docs/integration-logos}/WinRM.png (100%)
rename {docs/apache-airflow-providers-microsoft-winrm =>
providers/microsoft/winrm/docs}/operators.rst (86%)
rename {docs/apache-airflow-providers-microsoft-winrm =>
providers/microsoft/winrm/docs}/security.rst (100%)
rename providers/{src/airflow/providers => }/microsoft/winrm/provider.yaml
(94%)
copy providers/microsoft/{psrp => winrm}/pyproject.toml (87%)
copy {chart =>
providers/microsoft/winrm/src/airflow/providers/microsoft/winrm}/LICENSE (100%)
rename providers/{ =>
microsoft/winrm}/src/airflow/providers/microsoft/winrm/__init__.py (100%)
copy providers/{dingding/src/airflow/providers/dingding =>
microsoft/winrm/src/airflow/providers/microsoft/winrm}/get_provider_info.py
(61%)
copy {airflow/api/auth =>
providers/microsoft/winrm/src/airflow/providers/microsoft/winrm/hooks}/__init__.py
(100%)
rename providers/{ =>
microsoft/winrm}/src/airflow/providers/microsoft/winrm/hooks/winrm.py (99%)
copy {airflow/api/auth =>
providers/microsoft/winrm/src/airflow/providers/microsoft/winrm/operators}/__init__.py
(100%)
rename providers/{ =>
microsoft/winrm}/src/airflow/providers/microsoft/winrm/operators/winrm.py (100%)
copy providers/{airbyte => microsoft/winrm}/tests/conftest.py (100%)
copy providers/{ => microsoft/winrm/tests/provider_tests}/__init__.py (100%)
copy providers/{ =>
microsoft/winrm/tests/provider_tests/microsoft}/__init__.py (100%)
copy {airflow/api/auth =>
providers/microsoft/winrm/tests/provider_tests/microsoft/winrm}/__init__.py
(100%)
copy {airflow/api/auth =>
providers/microsoft/winrm/tests/provider_tests/microsoft/winrm/hooks}/__init__.py
(100%)
rename providers/{tests =>
microsoft/winrm/tests/provider_tests}/microsoft/winrm/hooks/test_winrm.py (100%)
copy {airflow/api/auth =>
providers/microsoft/winrm/tests/provider_tests/microsoft/winrm/operators}/__init__.py
(100%)
rename providers/{tests =>
microsoft/winrm/tests/provider_tests}/microsoft/winrm/operators/test_winrm.py
(100%)
copy {airflow/api_connexion =>
providers/microsoft/winrm/tests/system/microsoft/winrm}/__init__.py (100%)
rename providers/{ =>
microsoft/winrm}/tests/system/microsoft/winrm/example_winrm.py (100%)
copy {airflow/api_connexion =>
providers/src/airflow/providers/amazon/aws/auth_manager/router}/__init__.py
(100%)
create mode 100644
providers/src/airflow/providers/amazon/aws/auth_manager/router/login.py
delete mode 100644
providers/src/airflow/providers/amazon/aws/auth_manager/views/__init__.py
delete mode 100644
providers/src/airflow/providers/amazon/aws/auth_manager/views/auth.py
copy providers/src/airflow/providers/amazon/aws/links/{datasync.py => ec2.py}
(55%)
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/cli/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/decorators/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/executors/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/hooks/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/kubernetes_executor_templates/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/operators/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/pod_template_file_examples/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/resource_convert/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/sensors/__init__.py
delete mode 100644
providers/src/airflow/providers/cncf/kubernetes/triggers/__init__.py
delete mode 100644
providers/src/airflow/providers/microsoft/winrm/hooks/__init__.py
delete mode 100644
providers/src/airflow/providers/microsoft/winrm/operators/__init__.py
copy {airflow/api_connexion =>
providers/tests/amazon/aws/auth_manager/router}/__init__.py (100%)
rename providers/tests/amazon/aws/auth_manager/{views/test_auth.py =>
router/test_login.py} (57%)
delete mode 100644 providers/tests/amazon/aws/auth_manager/views/__init__.py
copy providers/tests/amazon/aws/links/{test_batch.py => test_ec2.py} (52%)
delete mode 100644 providers/tests/cncf/kubernetes/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/backcompat/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/cli/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/data_files/__init__.py
delete mode 100644
providers/tests/cncf/kubernetes/data_files/executor/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/data_files/pods/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/data_files/spark/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/decorators/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/executors/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/hooks/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/log_handlers/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/models/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/operators/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/resource_convert/__init__.py
delete mode 100644
providers/tests/cncf/kubernetes/resource_convert/test_configmap.py
delete mode 100644
providers/tests/cncf/kubernetes/resource_convert/test_env_variable.py
delete mode 100644
providers/tests/cncf/kubernetes/resource_convert/test_secret.py
delete mode 100644 providers/tests/cncf/kubernetes/sensors/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/triggers/__init__.py
delete mode 100644 providers/tests/cncf/kubernetes/utils/__init__.py
delete mode 100644 providers/tests/microsoft/winrm/__init__.py
delete mode 100644 providers/tests/microsoft/winrm/hooks/__init__.py
delete mode 100644 providers/tests/microsoft/winrm/operators/__init__.py
delete mode 100644 providers/tests/system/cncf/kubernetes/__init__.py
delete mode 100644 providers/tests/system/microsoft/winrm/__init__.py
copy {airflow/models =>
task_sdk/src/airflow/sdk/definitions/_internal}/expandinput.py (64%)
create mode 100644 task_sdk/src/airflow/sdk/execution_time/lazy_sequence.py
create mode 100644 task_sdk/tests/definitions/conftest.py
create mode 100644 task_sdk/tests/definitions/test_xcom_arg.py
create mode 100644 tests/models/test_taskmap.py
delete mode 100644 tests/models/test_xcom_arg_map.py
