This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch ci-upgrade-main
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit a1d01c98e91 [main] CI: Upgrade important CI environment
add 709ca1c23ae Align helm-tests CODEOWNER with chart codeowner (#66182)
add 72382b59106 refactor: word changed from DAG to Dag in
airflow-core/src/airflow/api (#66200)
add 90bec8cb5af Fix flaky test_migration_stairway by retrying each
migration step (#66162)
add e6170ddb5b1 Fix variable access in triggerer for deferrable operators
(#63387)
add 97b0ef2f2ed Update `register_asset_change` to filter Dags based on
teams (#66168)
add 304ad37c45c Additional Chart Modifications After Airflow 2 Drop
(#66199)
add 8f5ac08c439 Fix launcher RBAC for executor class paths (#66208)
add d24784f3ab3 Add test coverage for per-set queue in default KEDA query
in Helm chart (#65486)
add da0119486b4 Update providers metadata 2026-05-02 (#66242)
add 67a889b3a29 Bump stylelint (#66224)
add 5241f388f00 Bump the auth-ui-package-updates group across 1 directory
with 12 updates (#66226)
add b3343d3b310 Add MwaaServerlessStartWorkflowRunOperator (#66046)
add 29a5adf5510 Bump the edge-ui-package-updates group across 1 directory
with 11 updates (#66227)
add 0b0c35a6608 i18n(ko): add missing translations(Apr 30) (#66163)
add ee0dc3f3867 Use SQLite for import and OpenAPI spec generation scripts
(#66209)
add cbd26985928 Bump the uv-dependency-updates group in /dev/breeze with 3
updates (#66228)
add f83f645ba8a Add pluggable retry policies for Airflow tasks (AIP-105)
(#65474)
add 1442b522d20 Add UsageLimits support to common.ai operators (#66248)
add 5dbfff59266 Fix deprecation warnings for workers.logGroomerSidecar
(#66238) (#66243)
add a52b0a23321 Fix edge3 worker deadlock regression test on Python 3.14
(#66247)
add ea349226ae0 Add Celery worker workload dispatch regression tests
(#65849)
add ac338e05ff4 refactor: word changed from DAG to Dag in
airflow-ctl-tests/ (#66113)
add 5830111c217 Add engine flag support to Dataproc ClusterGenerator and
bump google-cloud-dataproc to 5.27.0 (#65130)
add 47514c0e3f2 Fix heading level for "Alternative: legacy global install"
in breeze docs (#66252)
add 8fc246721e5 Docs: Expand Helm Chart upgrade tasks in Airflow 3
migration guide (#66118)
add 1738252d21a Enable PT007 rule to apache.kafka Provider test (#66147)
add 251fe925b54 Use contextlib.suppress instead of try-except-pass and
re-enable SIM105 (#66193)
add 4a9b5a0f70a Don't re-emit logical_date when previous data_interval is
zero-length (#66132)
add 254758d5093 Fix dag.test() to sync sibling DAGs across calls (#64884)
(#66205)
add 865718c7d97 Clarify 'Fixing released docs' section to cover failed
initial publish case (#66253)
add 8dab708863a Document airflow-site index update for providers (#66281)
add 1f84a568613 Apply AIR201-style replacements (#65197)
add 16db2488268 Remove inactive Korean translation owner (#66295)
add 9b18d230d34 fix(backfill): populate partition_date on partitioned
backfill runs (#65998)
add 170ac6ede16 Align Dag capitalization from "DAG" to "Dag" in core_api
(#66211)
add 263549590ec Breeze: make `breeze down` discover and stop every compose
project (#66311)
add e55e1086111 fix: update dependencies to fix dependabot alarms in
providers.common.ai (#66244)
add 2cde0be3bd1 Iterate file objects directly instead of calling
readlines() (#66291)
add 2d200ecfb75 docs(security): clarify Task Execution API coverage in
DAG-author-isolation chapter (#66194)
add f90f1661795 Fix flaky E2E tests with API-based setup and data
isolation (#64024)
add ffb1b8a6d22 AIP-103: Add Execution API endpoints for task and asset
states (#66073)
add 345ddb8dfb5 Fix max_active_tis_per_dag for deferred task instances
(#61769)
add 29985e78983 [main] CI: Upgrade important CI environment
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch 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 (a1d01c98e91)
\
N -- N -- N refs/heads/ci-upgrade-main (29985e78983)
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.
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 4 +-
airflow-core/docs/core-concepts/tasks.rst | 148 ++
.../docs/installation/upgrading_to_airflow3.rst | 1 +
airflow-core/docs/migrations-ref.rst | 4 +-
airflow-core/docs/security/security_model.rst | 7 +
airflow-core/pyproject.toml | 4 +-
airflow-core/src/airflow/api/common/delete_dag.py | 10 +-
airflow-core/src/airflow/api/common/mark_tasks.py | 20 +-
airflow-core/src/airflow/api/common/trigger_dag.py | 14 +-
.../auth/managers/simple/ui/package.json | 24 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 1933 +++++++++----------
.../api_fastapi/core_api/openapi/_private_ui.yaml | 2 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 52 +-
.../api_fastapi/core_api/routes/public/assets.py | 14 +-
.../core_api/routes/public/dag_parsing.py | 2 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 28 +-
.../core_api/routes/public/dag_sources.py | 2 +-
.../api_fastapi/core_api/routes/public/dag_tags.py | 2 +-
.../api_fastapi/core_api/routes/public/dags.py | 32 +-
.../core_api/routes/public/import_error.py | 32 +-
.../core_api/routes/public/task_instances.py | 2 +-
.../api_fastapi/core_api/routes/public/tasks.py | 2 +-
.../api_fastapi/core_api/routes/public/xcom.py | 6 +-
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 2 +-
.../core_api/services/public/task_instances.py | 2 +-
.../api_fastapi/core_api/services/ui/calendar.py | 10 +-
.../core_api/services/ui/dependencies.py | 2 +-
.../api_fastapi/core_api/services/ui/grid.py | 6 +-
.../api_fastapi/core_api/services/ui/task_group.py | 2 +-
.../execution_api/datamodels/asset_state.py} | 18 +-
.../execution_api/datamodels/task_state.py} | 18 +-
.../execution_api/datamodels/taskinstance.py | 2 +
.../api_fastapi/execution_api/routes/__init__.py | 4 +
.../execution_api/routes/asset_state.py | 123 ++
.../execution_api/routes/task_instances.py | 15 +-
.../api_fastapi/execution_api/routes/task_state.py | 128 ++
.../api_fastapi/execution_api/versions/__init__.py | 5 +-
.../execution_api/versions/v2026_04_17.py | 19 +-
.../versions/{v2025_09_23.py => v2026_06_16.py} | 11 +-
airflow-core/src/airflow/assets/manager.py | 95 +-
airflow-core/src/airflow/cli/hot_reload.py | 5 +-
.../src/airflow/config_templates/config.yml | 4 +
.../airflow/example_dags/example_retry_policy.py | 81 +
.../src/airflow/jobs/scheduler_job_runner.py | 21 +-
.../0113_3_3_0_add_retry_policy_fields_to_ti.py | 63 +
airflow-core/src/airflow/models/backfill.py | 1 +
airflow-core/src/airflow/models/taskinstance.py | 71 +-
.../src/airflow/models/taskinstancehistory.py | 6 +
.../serialization/definitions/baseoperator.py | 1 +
airflow-core/src/airflow/state/__init__.py | 16 +
.../src/airflow/ti_deps/dependencies_states.py | 10 +
.../airflow/ti_deps/deps/task_concurrency_dep.py | 4 +-
airflow-core/src/airflow/timetables/interval.py | 14 +
.../ui/openapi-gen/queries/ensureQueryData.ts | 28 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 28 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 56 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 28 +-
.../ui/openapi-gen/requests/services.gen.ts | 56 +-
airflow-core/src/airflow/ui/playwright.config.ts | 11 -
.../airflow/ui/public/i18n/locales/ko/common.json | 6 +
.../ui/public/i18n/locales/ko/components.json | 1 +
.../src/airflow/ui/public/i18n/locales/ko/dag.json | 12 +
.../airflow/ui/public/i18n/locales/ko/dags.json | 5 +
.../airflow/ui/tests/e2e/pages/AssetDetailPage.ts | 8 +-
.../airflow/ui/tests/e2e/pages/AssetListPage.ts | 11 +-
.../src/airflow/ui/tests/e2e/pages/BackfillPage.ts | 82 +-
.../ui/tests/e2e/pages/ConfigurationPage.ts | 5 +-
.../airflow/ui/tests/e2e/pages/ConnectionsPage.ts | 23 +-
.../src/airflow/ui/tests/e2e/pages/PluginsPage.ts | 1 +
.../airflow/ui/tests/e2e/pages/ProvidersPage.ts | 7 +-
.../ui/tests/e2e/pages/RequiredActionsPage.ts | 16 +-
.../src/airflow/ui/tests/e2e/pages/VariablePage.ts | 1 +
.../src/airflow/ui/tests/e2e/specs/asset.spec.ts | 1 -
.../airflow/ui/tests/e2e/specs/backfill.spec.ts | 73 +-
.../ui/tests/e2e/specs/configuration.spec.ts | 1 -
.../airflow/ui/tests/e2e/specs/connections.spec.ts | 309 ++--
.../src/airflow/ui/tests/e2e/specs/plugins.spec.ts | 1 -
.../src/airflow/ui/tests/e2e/specs/pools.spec.ts | 90 +-
.../airflow/ui/tests/e2e/specs/providers.spec.ts | 1 -
.../ui/tests/e2e/specs/requiredAction.spec.ts | 51 +-
.../airflow/ui/tests/e2e/specs/variable.spec.ts | 174 +-
.../src/airflow/ui/tests/e2e/utils/test-helpers.ts | 8 +-
airflow-core/src/airflow/utils/db.py | 2 +-
.../core_api/routes/public/test_assets.py | 6 +-
.../core_api/routes/public/test_dag_run.py | 6 +-
.../core_api/routes/public/test_import_error.py | 6 +-
.../core_api/routes/public/test_task_instances.py | 4 +-
.../tests/unit/api_fastapi/core_api/test_app.py | 5 +-
.../versions/head/test_asset_state.py | 183 ++
.../versions/head/test_task_instances.py | 84 +
.../execution_api/versions/head/test_task_state.py | 274 +++
airflow-core/tests/unit/assets/test_manager.py | 211 +++
.../dags/test_dag_test_with_dynamic_trigger.py | 55 +
..._existense.py => test_dag_test_with_trigger.py} | 38 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 268 +++
airflow-core/tests/unit/jobs/test_triggerer_job.py | 6 +-
.../tests/unit/migrations/test_migration_utils.py | 80 +-
airflow-core/tests/unit/models/test_backfill.py | 11 +
airflow-core/tests/unit/models/test_dag.py | 145 +-
airflow-core/tests/unit/models/test_dagrun.py | 1 -
.../tests/unit/models/test_taskinstance.py | 101 +-
.../unit/serialization/test_dag_serialization.py | 3 +
.../unit/serialization/test_serialized_objects.py | 37 +
.../unit/ti_deps/deps/test_task_concurrency.py | 13 +-
.../unit/timetables/test_interval_timetable.py | 25 +
.../tests/unit/utils/test_process_utils.py | 4 +-
airflow-ctl-tests/pyproject.toml | 2 +-
.../airflowctl_tests/test_airflowctl_commands.py | 8 +-
airflow-ctl/pyproject.toml | 2 +-
airflow-e2e-tests/pyproject.toml | 2 +-
chart/docs/index.rst | 1 +
chart/docs/upgrading-to-airflow-3.rst | 119 ++
chart/pyproject.toml | 2 +-
chart/templates/NOTES.txt | 12 +-
chart/templates/_helpers.yaml | 7 -
.../dag-processor-serviceaccount.yaml | 2 +-
chart/templates/jobs/create-user-job.yaml | 2 +-
chart/templates/rbac/job-launcher-rolebinding.yaml | 6 +-
chart/templates/rbac/pod-launcher-rolebinding.yaml | 6 +-
.../security-context-constraint-rolebinding.yaml | 2 +-
clients/python/pyproject.toml | 2 +-
dev/README_RELEASE_PROVIDERS.md | 39 +-
dev/airflow_perf/sql_queries.py | 2 +-
dev/breeze/doc/01_installation.rst | 2 +-
dev/breeze/doc/03_developer_tasks.rst | 13 +
dev/breeze/doc/images/output-commands.svg | 90 +-
dev/breeze/doc/images/output_down.svg | 67 +-
dev/breeze/doc/images/output_down.txt | 2 +-
.../airflow_breeze/commands/developer_commands.py | 59 +-
.../commands/developer_commands_config.py | 7 +
.../airflow_breeze/commands/registry_commands.py | 30 +-
.../commands/release_management_commands.py | 2 +-
dev/breeze/src/airflow_breeze/global_constants.py | 24 +-
.../utils/airflow_release_validator.py | 9 +-
.../airflow_breeze/utils/docker_command_utils.py | 79 +
.../src/airflow_breeze/utils/reproducible.py | 6 +-
dev/breeze/tests/test_docker_command_utils.py | 97 +
dev/breeze/uv.lock | 36 +-
dev/ide_setup/setup_idea.py | 9 +-
dev/mypy/pyproject.toml | 2 +-
dev/pyproject.toml | 2 +-
dev/registry/pyproject.toml | 2 +-
devel-common/src/sphinx_exts/redirects.py | 2 +-
docker-stack-docs/pyproject.toml | 2 +-
docker-tests/pyproject.toml | 2 +-
generated/provider_metadata.json | 14 +
helm-tests/pyproject.toml | 2 +-
helm-tests/tests/chart_utils/log_groomer.py | 78 +-
.../helm_tests/airflow_aux/test_airflow_common.py | 6 -
.../helm_tests/airflow_aux/test_annotations.py | 2 -
.../airflow_aux/test_basic_helm_chart.py | 3 -
.../airflow_aux/test_container_lifecycle.py | 1 -
.../helm_tests/airflow_aux/test_create_user_job.py | 5 +-
.../airflow_aux/test_job_launcher_role.py | 19 +
.../airflow_aux/test_pod_launcher_role.py | 19 +
.../airflow_aux/test_pod_template_file.py | 5 +-
.../helm_tests/airflow_aux/test_remote_logging.py | 20 +-
.../helm_tests/airflow_core/test_api_server.py | 6 +-
.../helm_tests/airflow_core/test_dag_processor.py | 103 +-
.../tests/helm_tests/airflow_core/test_env.py | 2 +-
.../helm_tests/airflow_core/test_worker_sets.py | 58 +
.../helm_tests/apiserver/test_hpa_apiserver.py | 5 +-
helm-tests/tests/helm_tests/other/test_hpa.py | 5 +-
helm-tests/tests/helm_tests/other/test_keda.py | 5 +-
.../helm_tests/security/test_fernetkey_secret.py | 6 +-
.../security/test_rbac_pod_log_reader.py | 5 +-
.../helm_tests/security/test_scc_rolebinding.py | 1 -
kubernetes-tests/pyproject.toml | 2 +-
providers-summary-docs/pyproject.toml | 2 +-
.../mwaa_serverless.rst} | 41 +-
providers/amazon/provider.yaml | 9 +
.../amazon/aws/operators/mwaa_serverless.py | 86 +
.../airflow/providers/amazon/get_provider_info.py | 11 +
.../system/amazon/aws/example_dms_serverless.py | 9 +-
.../tests/system/amazon/aws/example_http_to_s3.py | 2 +-
.../system/amazon/aws/example_mwaa_serverless.py | 157 ++
.../amazon/aws/operators/test_mwaa_serverless.py | 78 +
.../system/apache/beam/example_go_dataflow.py | 5 +-
.../system/apache/beam/example_python_dataflow.py | 5 +-
.../unit/apache/kafka/operators/test_consume.py | 6 +-
.../unit/celery/executors/test_celery_executor.py | 85 +
providers/common/ai/docs/operators/agent.rst | 5 +
providers/common/ai/docs/operators/llm.rst | 32 +
providers/common/ai/pyproject.toml | 2 +-
.../common/ai/example_dags/example_llm.py | 25 +
.../airflow/providers/common/ai/operators/agent.py | 15 +-
.../airflow/providers/common/ai/operators/llm.py | 10 +-
.../providers/common/ai/operators/llm_branch.py | 2 +-
.../common/ai/operators/llm_file_analysis.py | 2 +-
.../common/ai/operators/llm_schema_compare.py | 2 +-
.../providers/common/ai/operators/llm_sql.py | 2 +-
.../providers/common/ai/plugins/www/package.json | 3 +-
.../providers/common/ai/plugins/www/pnpm-lock.yaml | 9 +-
.../tests/unit/common/ai/decorators/test_agent.py | 4 +-
.../ai/tests/unit/common/ai/decorators/test_llm.py | 4 +-
.../unit/common/ai/decorators/test_llm_branch.py | 2 +-
.../common/ai/decorators/test_llm_file_analysis.py | 4 +-
.../unit/common/ai/decorators/test_llm_sql.py | 2 +-
.../tests/unit/common/ai/operators/test_agent.py | 44 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 21 +-
.../unit/common/ai/operators/test_llm_branch.py | 2 +-
.../common/ai/operators/test_llm_file_analysis.py | 2 +-
.../common/ai/operators/test_llm_schema_compare.py | 5 +-
.../tests/unit/common/ai/operators/test_llm_sql.py | 2 +-
providers/edge3/pyproject.toml | 2 +-
.../providers/edge3/plugins/www/package.json | 22 +-
.../providers/edge3/plugins/www/pnpm-lock.yaml | 1956 ++++++++++----------
.../edge3/tests/unit/edge3/cli/test_worker.py | 65 +-
providers/fab/pyproject.toml | 2 +-
.../fab/src/airflow/providers/fab/www/package.json | 2 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 35 +-
providers/google/README.rst | 2 +-
providers/google/docs/index.rst | 2 +-
providers/google/pyproject.toml | 2 +-
.../providers/google/cloud/operators/dataproc.py | 6 +
.../providers/google/cloud/operators/pubsub.py | 8 +-
.../example_dlp_deidentify_content.py | 3 +-
.../google/cloud/dataflow/example_dataflow_go.py | 9 +-
.../example_dataflow_native_python_async.py | 12 +-
.../example_dataflow_sensors_deferrable.py | 12 +-
.../cloud/dataproc/example_dataproc_batch.py | 3 +-
.../dataproc/example_dataproc_cluster_generator.py | 1 +
.../google/cloud/dataproc/example_dataproc_hive.py | 1 +
.../google/cloud/dataproc/example_dataproc_pig.py | 1 +
.../cloud/dataproc/example_dataproc_pyspark.py | 1 +
...ple_dataproc_metastore_hive_partition_sensor.py | 4 +-
.../cloud/datastore/example_datastore_commit.py | 10 +-
.../google/cloud/gcs/resources/transform_script.py | 2 +-
.../example_cloud_storage_transfer_service_aws.py | 33 +-
.../example_cloud_storage_transfer_service_gcp.py | 20 +-
.../example_vertex_ai_batch_prediction_job.py | 4 +-
.../cloud/vertex_ai/example_vertex_ai_endpoint.py | 2 +-
.../vertex_ai/example_vertex_ai_feature_store.py | 5 +-
.../vertex_ai/example_vertex_ai_model_service.py | 4 +-
.../example_video_intelligence.py | 7 +-
.../cloud/vision/example_vision_annotate_image.py | 3 +-
.../cloud/vision/example_vision_autogenerated.py | 17 +-
.../unit/google/cloud/operators/test_dataproc.py | 7 +
providers/mongo/tests/conftest.py | 5 +-
pyproject.toml | 4 +-
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/common_prek_utils.py | 31 +-
scripts/ci/prek/generate_openapi_spec_providers.py | 2 +-
scripts/ci/prek/newsfragments.py | 2 +-
scripts/pyproject.toml | 2 +-
shared/configuration/pyproject.toml | 2 +-
shared/dagnode/pyproject.toml | 2 +-
shared/listeners/pyproject.toml | 2 +-
shared/logging/pyproject.toml | 2 +-
shared/module_loading/pyproject.toml | 2 +-
shared/observability/pyproject.toml | 2 +-
shared/plugins_manager/pyproject.toml | 2 +-
shared/providers_discovery/pyproject.toml | 2 +-
shared/secrets_backend/pyproject.toml | 2 +-
shared/secrets_masker/pyproject.toml | 2 +-
shared/serialization/pyproject.toml | 2 +-
shared/state/pyproject.toml | 2 +-
shared/template_rendering/pyproject.toml | 2 +-
shared/timezones/pyproject.toml | 2 +-
task-sdk-integration-tests/pyproject.toml | 2 +-
task-sdk/docs/api.rst | 16 +
task-sdk/docs/index.rst | 5 +
task-sdk/pyproject.toml | 2 +-
task-sdk/src/airflow/sdk/__init__.py | 17 +
task-sdk/src/airflow/sdk/__init__.pyi | 12 +
task-sdk/src/airflow/sdk/api/client.py | 16 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 48 +-
task-sdk/src/airflow/sdk/bases/operator.py | 13 +
task-sdk/src/airflow/sdk/definitions/dag.py | 70 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 13 +
.../src/airflow/sdk/definitions/retry_policy.py | 344 ++++
task-sdk/src/airflow/sdk/execution_time/context.py | 4 +-
.../sdk/execution_time/secrets/execution_api.py | 20 +
.../src/airflow/sdk/execution_time/supervisor.py | 2 +
.../src/airflow/sdk/execution_time/task_runner.py | 82 +-
.../task_sdk/definitions/test_retry_policy.py | 405 ++++
.../tests/task_sdk/execution_time/test_secrets.py | 43 +
.../task_sdk/execution_time/test_supervisor.py | 2 +
uv.lock | 160 +-
279 files changed, 7709 insertions(+), 3503 deletions(-)
copy airflow-core/src/airflow/{example_dags/example_simplest_dag.py =>
api_fastapi/execution_api/datamodels/asset_state.py} (74%)
copy airflow-core/src/airflow/{example_dags/example_simplest_dag.py =>
api_fastapi/execution_api/datamodels/task_state.py} (74%)
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/routes/asset_state.py
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/routes/task_state.py
copy
airflow-core/src/airflow/api_fastapi/execution_api/versions/{v2025_09_23.py =>
v2026_06_16.py} (71%)
create mode 100644
airflow-core/src/airflow/example_dags/example_retry_policy.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0113_3_3_0_add_retry_policy_fields_to_ti.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_asset_state.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_task_state.py
create mode 100644
airflow-core/tests/unit/dags/test_dag_test_with_dynamic_trigger.py
copy
airflow-core/tests/unit/dags/{test_external_task_sensor_check_existense.py =>
test_dag_test_with_trigger.py} (56%)
create mode 100644 chart/docs/upgrading-to-airflow-3.rst
copy providers/amazon/docs/{transfer/http_to_s3.rst =>
operators/mwaa_serverless.rst} (50%)
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/operators/mwaa_serverless.py
create mode 100644
providers/amazon/tests/system/amazon/aws/example_mwaa_serverless.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/operators/test_mwaa_serverless.py
create mode 100644 task-sdk/src/airflow/sdk/definitions/retry_policy.py
create mode 100644 task-sdk/tests/task_sdk/definitions/test_retry_policy.py
