This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/ui/eslint-e5a7eb1da6
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit dd373c85d45 Bump the eslint group across 1 directory with 4 updates
add 82456dd938a Report failing fork job statuses only when the failure
persists (#76185)
add 9d4cdd7802a UI: Reduce initial JavaScript payload (#74663)
add 1367f021657 Fix env var names in AWS ECS and Lambda executor setup
docs (#76155)
add f721cac5e5c Fix scheduler refusing to start when [scheduler] only_idle
is enabled (#76262)
add b45f859d718 Complete the missing zh-TW UI translations (#76398)
add 5e903931b2a Enable DMS task logging in example_dms system test (#76336)
add d7711340f84 Run the dependency upgrade summary beside the tests
instead of after them (#76251)
add 6ca7a3be6b9 Build the PROD packages beside the CI image and
constraints (#76261)
add 47c02d36015 Upgrade the Airflow version to 3.5.0 and Task SDK version
to 1.5.0 (#76388)
add 45edb1750f1 Use only the configured auth type when creating tokens in
the FAB auth manager (#76231)
add 5afb353fd08 Add script to remove constraints for unsupported Python
versions (#75333)
add 1631eccfc2d Fix retry policy docs and the example Dag's
`ConnectionError` rules (#76313)
add f34cae8fa6f Suggest common model providers in the pydanticai
connection form (#76053)
add 4495e92002c Decode state store vals through backend; treat null as
missing (#76009)
add 2ab01dae67f Java SDK: Read the Dag run conf into a class with typed
fields (#75542)
add 5308480f2ee Fix airflowctl list pagination when the server caps the
page size (#76268)
add aa0d6506b4a Build CI and release images on pinned OS-dependencies
images (#76225)
add 0c69d652a89 Build CI and release images on pinned OS-dependencies
images (#76225)
add 76f290f3f80 Implement Python task handler and support it in YAML Dags
(#75405)
add 7badc9f42a1 Include table names in db clean progress output (#74243)
add 575d8af602f Keep the audit log off the API server event loop (#76416)
add bd8cad6b729 Let non task callers set and delete variables over
execution API (#76375)
add 671be47b20e Note that the API server uses a second database connection
pool (#76430)
add b503e692da0 Fix `SSHRemoteJobOperator` on Windows hosts (#73352)
add fc172d09a5b Add deferrable mode to `SqlSensor` (#76270)
add 2aa4ae811d8 Rewrite the OpenAI Agents SDK guide to stand on its own
(#76340)
add a427286b8d2 Add screenshots and a review loop example to the task
loops docs (#76435)
add 6e6e0f7ae9b Document how to create a TypeScript SDK project (#76374)
add 31b0dfef865 Fix docs build on Task SDK task handler page ref (#76440)
add cf5017be3c1 UI: Complete the Italian translation (#76411)
add 37d4d9395f7 UI: Fix task groups not expanding when localStorage is
full (#76302)
add 11baedfd86c Add OpenLineage e2e tests for manual state changes, clears
and failures (#75908)
add 629729a9913 Describe where the dependency upgrade summary runs now
(#76439)
add caf26246c1c Stop pydantic-ai providers that models cannot use from
failing the common.ai vendor check (#76312)
add bcfe0128623 Bump UI dependencies and fix log tests for react-virtual
(#76444)
add 2202b5c5b75 Bump the eslint group across 1 directory with 4 updates
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 (dd373c85d45)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/eslint-e5a7eb1da6
(2202b5c5b75)
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:
.agents/skills/airflow-translations/locales/it.md | 65 +-
.github/workflows/ci-amd.yml | 37 +-
.github/workflows/ci-arm.yml | 37 +-
.github/workflows/ci-image-build.yml | 8 +
.github/workflows/dependency-upgrade-summary.yml | 104 +
.github/workflows/finalize-tests.yml | 60 -
.github/workflows/mirror-hardened-base-images.yml | 173 +-
.github/workflows/prod-image-build.yml | 104 +-
.github/workflows/prod-packages-build.yml | 129 +
.github/workflows/upgrade-check.yml | 5 +-
Dockerfile | 171 +-
Dockerfile.ci | 111 +-
.../task-and-asset-state-store.rst | 2 +
.../language-sdks/java.rst | 29 +
.../language-sdks/typescript.rst | 42 +-
.../docs/authoring-and-scheduling/loops.rst | 155 +-
.../docs/authoring-and-scheduling/yaml-dags.rst | 23 +-
airflow-core/docs/core-concepts/tasks.rst | 33 +-
airflow-core/docs/img/ui-dark/loops_clear.png | Bin 0 -> 271661 bytes
airflow-core/docs/img/ui-dark/loops_decision.png | Bin 0 -> 73779 bytes
airflow-core/docs/img/ui-dark/loops_graph.png | Bin 0 -> 77163 bytes
airflow-core/docs/img/ui-dark/loops_iterations.png | Bin 0 -> 191319 bytes
.../docs/img/ui-dark/loops_iterations_tab.png | Bin 0 -> 156522 bytes
airflow-core/docs/img/ui-dark/loops_mapped.png | Bin 0 -> 179885 bytes
airflow-core/docs/img/ui-dark/loops_review.png | Bin 0 -> 244676 bytes
airflow-core/docs/img/ui-light/loops_clear.png | Bin 0 -> 268407 bytes
airflow-core/docs/img/ui-light/loops_decision.png | Bin 0 -> 72201 bytes
airflow-core/docs/img/ui-light/loops_graph.png | Bin 0 -> 78174 bytes
.../docs/img/ui-light/loops_iterations.png | Bin 0 -> 189121 bytes
.../docs/img/ui-light/loops_iterations_tab.png | Bin 0 -> 155523 bytes
airflow-core/docs/img/ui-light/loops_mapped.png | Bin 0 -> 177810 bytes
airflow-core/docs/img/ui-light/loops_review.png | Bin 0 -> 243231 bytes
airflow-core/newsfragments/76430.significant.rst | 11 +
airflow-core/pyproject.toml | 4 +-
airflow-core/src/airflow/__init__.py | 2 +-
.../execution_api/routes/asset_state_store.py | 10 +-
.../execution_api/routes/task_state_store.py | 5 +-
.../api_fastapi/execution_api/routes/variables.py | 3 +
.../airflow/api_fastapi/execution_api/security.py | 11 +
.../execution_api/versions/v2026_10_30.py | 2 +-
.../src/airflow/api_fastapi/logging/decorators.py | 36 +-
airflow-core/src/airflow/cli/cli_config.py | 10 +-
.../src/airflow/cli/commands/scheduler_command.py | 17 +-
.../src/airflow/config_templates/config.yml | 1 +
.../airflow/example_dags/example_retry_policy.py | 13 +-
.../src/airflow/example_dags/example_task_loops.py | 4 +-
airflow-core/src/airflow/ui/package.json | 50 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 783 ++---
.../airflow/ui/public/i18n/locales/en/common.json | 1 +
.../airflow/ui/public/i18n/locales/it/admin.json | 55 +-
.../airflow/ui/public/i18n/locales/it/assets.json | 46 +-
.../airflow/ui/public/i18n/locales/it/browse.json | 86 +-
.../airflow/ui/public/i18n/locales/it/common.json | 352 ++-
.../ui/public/i18n/locales/it/components.json | 115 +-
.../src/airflow/ui/public/i18n/locales/it/dag.json | 267 +-
.../airflow/ui/public/i18n/locales/it/dags.json | 69 +-
.../ui/public/i18n/locales/it/dashboard.json | 47 +-
.../airflow/ui/public/i18n/locales/it/hitl.json | 18 +-
.../ui/public/i18n/locales/zh-TW/browse.json | 2 +
.../ui/public/i18n/locales/zh-TW/common.json | 11 +-
.../ui/public/i18n/locales/zh-TW/components.json | 5 +
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 4 +-
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 1 +
.../ui/public/i18n/locales/zh-TW/dashboard.json | 1 +
.../ui/src/context/groups/GroupsProvider.test.tsx | 34 +-
.../ui/src/context/groups/GroupsProvider.tsx | 45 +-
.../src/airflow/ui/src/layouts/BaseLayout.test.tsx | 23 +-
.../src/airflow/ui/src/layouts/BaseLayout.tsx | 18 +-
.../ui/src/pages/Asset/AssetEventsFilters.test.tsx | 6 +-
.../src/airflow/ui/src/pages/Asset/Header.test.tsx | 6 +-
.../ui/src/pages/AssetsList/AssetsList.test.tsx | 6 +-
.../Dag/Backfills/BackfillsDateFilter.test.tsx | 6 +-
.../ui/src/pages/Dag/RequiredActionsRoute.test.tsx | 6 +-
.../ui/src/pages/DagBundles/DagBundles.test.tsx | 6 +-
.../airflow/ui/src/pages/DagRuns/DagRuns.test.tsx | 6 +-
.../DagsList/DagsFilters/DagsFilters.test.tsx | 26 +-
.../ui/src/pages/DagsList/DagsList.test.tsx | 6 +-
.../src/airflow/ui/src/pages/Error.test.tsx | 100 +
airflow-core/src/airflow/ui/src/pages/Error.tsx | 13 +
.../airflow/ui/src/pages/Run/CallbackLogs.test.tsx | 1 +
.../airflow/ui/src/pages/Run/Callbacks.test.tsx | 1 +
.../ui/src/pages/TaskInstance/Logs/Logs.test.tsx | 6 +
.../pages/TaskInstance/Logs/LogsSelection.test.tsx | 6 +
.../TaskInstances/TaskInstancesFilter.test.tsx | 6 +-
.../src/airflow/ui/src/pages/XCom/XCom.test.tsx | 6 +-
.../airflow/ui/src/pages/documentTitle.test.tsx | 62 +-
airflow-core/src/airflow/ui/src/router.test.tsx | 71 +-
airflow-core/src/airflow/ui/src/router.tsx | 316 +-
.../src/airflow/ui/src/utils/AppWrapper.tsx | 16 +-
.../src/airflow/ui/src/utils/routeModule.ts | 45 +
airflow-core/src/airflow/utils/db_cleanup.py | 25 +-
.../tests/unit/api_fastapi/core_api/conftest.py | 24 +-
.../core_api/routes/public/test_execution.py | 1 +
.../api_fastapi/execution_api/test_security.py | 98 +-
.../versions/head/test_asset_state_store.py | 19 +-
.../versions/head/test_task_state_store.py | 22 +
.../unit/api_fastapi/logging/test_decorators.py | 45 +-
.../tests/unit/cli/commands/test_dag_command.py | 8 +-
.../unit/cli/commands/test_scheduler_command.py | 38 +
airflow-core/tests/unit/cli/test_cli_parser.py | 21 +
airflow-core/tests/unit/state/test_metastore.py | 7 +
airflow-core/tests/unit/utils/test_db_cleanup.py | 93 +-
airflow-ctl/src/airflowctl/api/operations.py | 18 +-
.../tests/airflow_ctl/api/test_operations.py | 42 +
airflow-e2e-tests/docker/openlineage.yml | 69 +-
.../tests/airflow_e2e_tests/conftest.py | 5 +
.../dags_extra/openlineage_inlet_assets_dag.py | 64 +
.../airflow_e2e_tests/openlineage_tests/harness.py | 256 +-
.../openlineage_tests/prepare_dags.py | 2 +-
.../openlineage_tests/remove_unused_providers.py | 89 +
.../openlineage_tests/test_openlineage_e2e.py | 13 +-
dev/breeze/doc/09_release_management_tasks.rst | 72 +
.../doc/adr/0021-pin-os-dependencies-images.md | 123 +
dev/breeze/doc/ci/02_images.md | 46 +
dev/breeze/doc/ci/04_selective_checks.md | 12 +-
dev/breeze/doc/ci/05_workflows.md | 20 +-
.../doc/ci/08_fork_ci_for_external_contributors.md | 11 +-
dev/breeze/doc/images/output_ci-image_build.svg | 178 +-
dev/breeze/doc/images/output_ci-image_build.txt | 2 +-
dev/breeze/doc/images/output_prod-image_build.svg | 238 +-
dev/breeze/doc/images/output_prod-image_build.txt | 2 +-
.../doc/images/output_release-management.svg | 48 +-
.../doc/images/output_release-management.txt | 2 +-
...put_release-management_build-os-deps-images.svg | 146 +
...put_release-management_build-os-deps-images.txt | 1 +
...t_release-management_publish-os-deps-images.svg | 136 +
...t_release-management_publish-os-deps-images.txt | 1 +
.../output_setup_check-all-params-in-groups.svg | 66 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 76 +-
.../output_setup_regenerate-command-images.txt | 2 +-
.../output_workflow-run_mirror-base-images.svg | 30 +-
.../output_workflow-run_mirror-base-images.txt | 2 +-
.../src/airflow_breeze/commands/ci_commands.py | 1 +
.../airflow_breeze/commands/ci_image_commands.py | 4 +
.../commands/ci_image_commands_config.py | 1 +
.../commands/common_image_options.py | 8 +
.../commands/production_image_commands.py | 4 +
.../commands/production_image_commands_config.py | 1 +
.../commands/release_management_commands.py | 346 +++
.../commands/release_management_commands_config.py | 23 +
.../airflow_breeze/commands/workflow_commands.py | 15 +-
.../commands/workflow_commands_config.py | 1 +
.../files/hardened_os_deps_image_digests.json | 1 +
dev/breeze/src/airflow_breeze/global_constants.py | 65 +
.../src/airflow_breeze/params/build_ci_params.py | 2 +
.../src/airflow_breeze/params/build_prod_params.py | 26 +
.../airflow_breeze/params/common_build_params.py | 37 +
.../src/airflow_breeze/utils/fork_ci_reconcile.py | 47 +-
.../src/airflow_breeze/utils/gh_workflow_utils.py | 8 +-
.../src/airflow_breeze/utils/selective_checks.py | 18 +
dev/breeze/tests/test_ci_upgrade.py | 1 +
dev/breeze/tests/test_dependency_upgrade_report.py | 4 +-
dev/breeze/tests/test_fork_ci_reconcile.py | 60 +-
dev/breeze/tests/test_gh_workflow_utils.py | 6 +-
dev/breeze/tests/test_mirror_base_images.py | 36 +-
dev/breeze/tests/test_os_deps_images.py | 732 +++++
dev/breeze/tests/test_selective_checks.py | 50 +
dev/breeze/tests/test_workflow_commands.py | 19 +-
dev/remove_unsupported_python_constraints.py | 300 ++
devel-common/src/sphinx_exts/exampleinclude.py | 47 +-
.../src/tests_common/test_utils/asserts.py | 12 +-
docker-stack-docs/README.md | 10 +-
docker-stack-docs/build-arg-ref.rst | 14 +
docker-stack-docs/build.rst | 12 +
.../extending/add-airflow-configuration/Dockerfile | 2 +-
.../extending/add-apt-packages/Dockerfile | 2 +-
.../add-build-essential-extend/Dockerfile | 2 +-
.../extending/add-providers/Dockerfile | 2 +-
.../add-pypi-packages-constraints/Dockerfile | 2 +-
.../extending/add-pypi-packages-uv/Dockerfile | 2 +-
.../extending/add-pypi-packages/Dockerfile | 2 +-
.../extending/add-python-venv/Dockerfile | 2 +-
.../extending/add-requirement-packages/Dockerfile | 2 +-
.../extending/custom-providers/Dockerfile | 2 +-
.../extending/embedding-dags/Dockerfile | 2 +-
.../extending/writable-directory/Dockerfile | 2 +-
docker-stack-docs/entrypoint.rst | 14 +-
.../main/kotlin/org/apache/airflow/sdk/Context.kt | 66 +-
.../org/apache/airflow/sdk/internal/ConfBinding.kt | 184 ++
.../kotlin/org/apache/airflow/sdk/ContextTest.kt | 311 ++
providers/amazon/docs/executors/ecs-executor.rst | 4 +-
.../amazon/docs/executors/lambda-executor.rst | 2 +-
.../amazon/tests/system/amazon/aws/example_dms.py | 31 +
.../common/ai/docs/connections/pydantic_ai.rst | 4 +
.../common/ai/docs/frameworks/openai_agents.rst | 629 +++-
providers/common/ai/provider.yaml | 18 +-
.../ai/example_dags/example_llm_review_loop.py | 81 +
.../example_openai_agents_data_access.py | 101 +
.../providers/common/ai/get_provider_info.py | 19 +-
.../tests/unit/common/ai/hooks/test_pydantic_ai.py | 14 +-
.../tests/unit/common/ai/test_provider_metadata.py | 130 +-
providers/common/sql/docs/operators.rst | 47 +
.../airflow/providers/common/sql/sensors/sql.py | 86 +-
.../airflow/providers/common/sql/sensors/sql.pyi | 10 +-
.../airflow/providers/common/sql/triggers/sql.py | 85 +-
.../airflow/providers/common/sql/triggers/sql.pyi | 26 +-
.../airflow/providers/common/sql/version_compat.py | 2 +
.../tests/system/common/sql/example_sql_sensor.py} | 41 +-
.../sql/tests/unit/common/sql/sensors/test_sql.py | 200 +-
.../sql/tests/unit/common/sql/triggers/test_sql.py | 94 +-
providers/fab/docs/changelog.rst | 5 +
.../providers/fab/auth_manager/fab_auth_manager.py | 35 +-
.../unit/fab/auth_manager/test_fab_auth_manager.py | 34 +-
.../tests/system/openlineage/constants.py | 6 +
.../openlineage/example_openlineage_clear_dag.py | 169 ++
.../example_openlineage_edge_labels_dag.py | 16 +-
.../example_openlineage_manual_lineage_dag.py | 17 +-
.../example_openlineage_manual_state_dag.py | 274 ++
.../example_openlineage_mapped_simple_dag.py | 7 +-
.../example_openlineage_policy_conf_locked_dag.py | 59 -
...le_openlineage_policy_dag_events_trigger_dag.py | 6 +-
...xample_openlineage_policy_full_task_info_dag.py | 57 -
...ample_openlineage_schedule_asset_or_time_dag.py | 2 +-
.../example_openlineage_schedule_cron_dag.py | 2 +-
...openlineage_schedule_list_complex_assets_dag.py | 2 +-
...penlineage_schedule_list_multiple_assets_dag.py | 2 +-
...e_openlineage_schedule_list_single_asset_dag.py | 2 +-
...ple_openlineage_schedule_multiple_assets_dag.py | 2 +-
...xample_openlineage_schedule_single_asset_dag.py | 2 +-
.../example_openlineage_schedule_timetable_dag.py | 2 +-
.../example_openlineage_short_circuit_dag.py | 4 +-
.../example_openlineage_task_groups_dag.py | 4 +-
.../example_openlineage_task_loop_dag.py | 4 +-
.../example_openlineage_task_loop_groups_dag.py | 4 +-
.../example_openlineage_task_loop_state_dag.py | 240 ++
.../example_openlineage_task_outcomes_dag.py | 285 ++
.../example_openlineage_task_states_dag.py | 8 +-
.../openlineage/example_openlineage_trigger_dag.py | 74 +-
.../example_openlineage_trigger_dag_deferrable.py | 65 +-
.../example_openlineage_trigger_failed_dag.py | 11 +-
.../openlineage_all_facets_dag.json | 1 +
.../openlineage_base_complex_dag__af3.json | 114 +-
.../openlineage_base_simple_dag__af3.json | 12 +-
.../expected_events/openlineage_clear_dag.json | 1268 ++++++++
.../openlineage_custom_operator_failure_dag.json | 16 +-
...openlineage_custom_operator_ol_methods_dag.json | 1 +
.../openlineage_defer_simple_dag__af2.json | 13 +-
.../openlineage_defer_simple_dag__af3.json | 1 +
...openlineage_defer_simple_dag__af3_2_2_plus.json | 1 +
.../expected_events/openlineage_docs_file_dag.json | 26 +
.../expected_events/openlineage_hitl_dag.json | 83 +
.../openlineage_manual_lineage_dag.json | 171 +-
.../openlineage_manual_state_dag.json | 1195 ++++++++
.../openlineage_mapped_simple_dag.json | 13 +-
.../openlineage_policy_conf_locked_dag.json | 26 -
.../openlineage_policy_full_task_info_dag.json | 38 -
.../openlineage_sensor_reschedule_dag.json | 8 +-
.../openlineage_sensor_reschedule_dag__af3_0.json | 8 +-
.../openlineage_setup_teardown_dag__af3.json | 104 +
.../openlineage_short_circuit_dag.json | 50 +-
.../openlineage_task_groups_dag.json | 29 +
.../openlineage_task_loop_state_dag.json | 3062 ++++++++++++++++++++
.../openlineage_task_outcomes_dag.json | 1164 ++++++++
.../openlineage_task_states_dag.json | 30 +
.../openlineage_task_states_dag__af3_0.json | 30 +
.../openlineage_taskflow_simple_dag.json | 12 +-
.../expected_events/openlineage_trigger_dag.json | 309 ++
.../openlineage_trigger_dag__af3_3_plus.json | 309 ++
.../openlineage_trigger_dag_deferrable.json | 61 +-
...lineage_trigger_dag_deferrable__af3_3_plus.json | 61 +-
.../openlineage_trigger_failed_dag.json | 87 +-
...openlineage_trigger_failed_dag__af3_3_plus.json | 87 +-
.../openlineage_versioned_dag__af3.json | 14 +-
.../tests/system/openlineage/manual_state.py | 438 +++
.../tests/system/openlineage/operator.py | 79 +-
.../tests/system/openlineage/triggers.py | 34 +-
providers/ssh/docs/operators/ssh_remote_job.rst | 23 +-
.../providers/ssh/operators/ssh_remote_job.py | 6 +-
.../src/airflow/providers/ssh/utils/remote_job.py | 174 +-
.../ssh/tests/unit/ssh/utils/test_remote_job.py | 227 +-
pyproject.toml | 6 +-
scripts/ci/prek/upgrade_important_versions.py | 103 +-
scripts/docker/install_os_dependencies.sh | 66 +
.../ci/prek/test_upgrade_important_versions.py | 114 +-
scripts/tests/ci/test_prek_cache_optimizations.py | 2 +-
shared/state/src/airflow_shared/state/__init__.py | 30 +-
shared/state/tests/state/test_state.py | 45 +
task-sdk/docs/api.rst | 2 +
task-sdk/docs/index.rst | 1 +
task-sdk/docs/task-handler.rst | 127 +
task-sdk/pyproject.toml | 2 +-
task-sdk/src/airflow/sdk/__init__.py | 5 +-
task-sdk/src/airflow/sdk/__init__.pyi | 2 +
.../src/airflow/sdk/coordinators/_subprocess.py | 29 +-
task-sdk/src/airflow/sdk/coordinators/python.py | 212 ++
.../sdk/definitions/task_handlers/__init__.py | 38 +-
.../sdk/definitions/task_handlers/binding.py | 79 +
.../sdk/definitions/task_handlers/declaration.py | 79 +
.../sdk/definitions/task_handlers/loader.py | 115 +
.../sdk/definitions/task_handlers/registry.py | 65 +
task-sdk/src/airflow/sdk/execution_time/bundles.py | 29 +-
.../src/airflow/sdk/execution_time/coordinator.py | 127 +-
.../src/airflow/sdk/execution_time/supervisor.py | 3 +-
.../src/airflow/sdk/execution_time/task_runner.py | 124 +-
.../airflow/sdk/importers/yaml_importer/builder.py | 62 +-
task-sdk/tests/task_sdk/conftest.py | 53 +
.../coordinators/executable/test_coordinator.py | 2 +-
.../task_sdk/coordinators/java/test_coordinator.py | 2 +-
.../task_sdk/coordinators/node/test_coordinator.py | 2 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 16 +-
.../definitions/task_handlers/test_loader.py | 164 ++
.../task_handlers/test_task_handlers.py | 143 +
.../task_sdk/execution_time/test_coordinator.py | 7 +-
.../execution_time/test_python_coordinator.py | 156 +
.../execution_time/test_run_task_handler.py | 149 +
.../task_sdk/execution_time/test_task_runner.py | 4 +-
.../yaml_importer/test_builder_validation.py | 182 ++
uv.lock | 130 +-
309 files changed, 21191 insertions(+), 2553 deletions(-)
create mode 100644 .github/workflows/dependency-upgrade-summary.yml
create mode 100644 .github/workflows/prod-packages-build.yml
create mode 100644 airflow-core/docs/img/ui-dark/loops_clear.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_decision.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_graph.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_iterations.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_iterations_tab.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_mapped.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_review.png
create mode 100644 airflow-core/docs/img/ui-light/loops_clear.png
create mode 100644 airflow-core/docs/img/ui-light/loops_decision.png
create mode 100644 airflow-core/docs/img/ui-light/loops_graph.png
create mode 100644 airflow-core/docs/img/ui-light/loops_iterations.png
create mode 100644 airflow-core/docs/img/ui-light/loops_iterations_tab.png
create mode 100644 airflow-core/docs/img/ui-light/loops_mapped.png
create mode 100644 airflow-core/docs/img/ui-light/loops_review.png
create mode 100644 airflow-core/newsfragments/76430.significant.rst
create mode 100644 airflow-core/src/airflow/ui/src/pages/Error.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/utils/routeModule.ts
copy providers/fab/tests/unit/fab/www/test_app.py =>
airflow-core/tests/unit/api_fastapi/core_api/conftest.py (60%)
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/openlineage_tests/dags_extra/openlineage_inlet_assets_dag.py
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/openlineage_tests/remove_unused_providers.py
create mode 100644 dev/breeze/doc/adr/0021-pin-os-dependencies-images.md
create mode 100644
dev/breeze/doc/images/output_release-management_build-os-deps-images.svg
create mode 100644
dev/breeze/doc/images/output_release-management_build-os-deps-images.txt
create mode 100644
dev/breeze/doc/images/output_release-management_publish-os-deps-images.svg
create mode 100644
dev/breeze/doc/images/output_release-management_publish-os-deps-images.txt
create mode 100644
dev/breeze/src/airflow_breeze/files/hardened_os_deps_image_digests.json
create mode 100644 dev/breeze/tests/test_os_deps_images.py
create mode 100755 dev/remove_unsupported_python_constraints.py
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/ConfBinding.kt
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_review_loop.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_openai_agents_data_access.py
copy providers/{opsgenie/tests/system/opsgenie/example_opsgenie_notifier.py =>
common/sql/tests/system/common/sql/example_sql_sensor.py} (55%)
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_clear_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_manual_state_dag.py
delete mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_conf_locked_dag.py
delete mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_full_task_info_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_task_loop_state_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_task_outcomes_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_clear_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_manual_state_dag.json
delete mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_conf_locked_dag.json
delete mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_full_task_info_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_loop_state_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_outcomes_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/manual_state.py
copy airflow-core/tests/unit/listeners/asset_listener.py =>
providers/openlineage/tests/system/openlineage/triggers.py (60%)
create mode 100644 task-sdk/docs/task-handler.rst
create mode 100644 task-sdk/src/airflow/sdk/coordinators/python.py
copy providers/google/tests/unit/google/cloud/utils/test_datafusion.py =>
task-sdk/src/airflow/sdk/definitions/task_handlers/__init__.py (55%)
create mode 100644
task-sdk/src/airflow/sdk/definitions/task_handlers/binding.py
create mode 100644
task-sdk/src/airflow/sdk/definitions/task_handlers/declaration.py
create mode 100644 task-sdk/src/airflow/sdk/definitions/task_handlers/loader.py
create mode 100644
task-sdk/src/airflow/sdk/definitions/task_handlers/registry.py
create mode 100644 task-sdk/tests/task_sdk/conftest.py
create mode 100644
task-sdk/tests/task_sdk/definitions/task_handlers/test_loader.py
create mode 100644
task-sdk/tests/task_sdk/definitions/task_handlers/test_task_handlers.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/test_python_coordinator.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/test_run_task_handler.py
create mode 100644
task-sdk/tests/task_sdk/importers/yaml_importer/test_builder_validation.py
