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 b3f2eab93f2 [main] CI: Upgrade important CI environment
add 21bbf2f40a2 Java SDK: Generate Dag and task configuration from the
serialization schema (#73595)
add 76bf88a4877 API: Translate domain ValueError in Task State Store route
(#73753)
add 1a67bf46b55 Support DagBundle based deployment for Coordinator (#70805)
add 53ca2a427ba TS SDK: add task groups to the native Dag surface (#73439)
add 5e785acfb3b Discard the task state values for a task instance when it
is cleared (#72100)
add 7938c0dbb65 Make `execute_tool` the public method `AirflowToolset`
subclasses implement (#73938)
add 6cd2f6f36d9 Remove migration tests for migrations that have already
landed. (#73953)
add 5136c6c41bf Use plain ifs to normalize configured artifact roots
(#73944)
add e15b3a66137 Retry S3Hook.delete_bucket when a late write leaves bucket
non-empty (#73930)
add acd42922f3d Filter jobs API is_alive in SQL so pagination stays
correct (#73684)
add 508301ab263 Add ADR for per-Dag source in the Lang-SDK bundle artifact
(#73948)
add 91423baf366 Fix breeze down crashing when a start-airflow container is
running (#73955)
add 8e36d6d6efd Show whether a calendar day's run was a backfill (#72782)
add 6317c63ae16 Go SDK: generate DagSpec and TaskSpec from the
serialization schema (#73936)
add f306f1848f6 Refresh HITL review details on task clear (#73235)
add 4fd2c9aabf2 Mark lineage hashes as non-security (#70999)
add f7a27633741 Fix typo in apache-airflow-providers-fab error message
(#73956)
add 8d4ab8a94db Keep OpenAPI error responses in sync with the statuses
routes raise (#71647)
add 0b6c38502ab Add runtime DagRun note updates (#69403)
add ba89738639c Fix short-circuit not skipping already expanded mapped
tasks (#73960)
add 16f974f6a35 Run the `common.ai` agent framework adapter tests in CI
(#73912)
add e364ee76483 Keep agent framework spans when worker tracing is off
(#73903)
add 2e803e58997 Add key-pair JWT authentication to Snowflake Cortex Agent
hook (#73815)
add e92147c12aa UI: Add a time-window scope to the Dags list run state
filter (#70470)
add 63a5966473b Check PyPI history before a new provider's first release
(#73887)
add ede78e095b6 Add embedding kwargs to common AI hooks and operators
(#72002)
add 64943ba6dbb Fix `run_duration` calculation in airflow dags test by
decoupling start_date (#68837)
add 9e67831f2bb Allow filtering the Dag runs list by Dag tags (#70861)
add e22c9d02b2e Add Has Events filter to Assets search (#72460)
add f31b572df18 Fix airflowctl commands crashing instead of printing their
result (#72675)
add 1559dae90ab UI: Use TeamName component for all team name displays
(#73910)
add 489316fbc72 Migrate execution API reads to async sessions (#73403)
add a8e95debbc6 Fix flaky AgentOperator durable usage budget tests (#73996)
add e33e45fe67a Add `AssetAndTimeSchedule` timetable (#58543)
add a91216d5ea9 TS SDK: serialize a native Dag to Dag JSON (#73441)
add 884e687ea77 Fix short-circuit inside a mapped task group not skipping
downstream (#73959)
add 3f19c146545 Go SDK: declare data edges with airflow.Inputs (#73895)
add 13adb691464 Close German Translation Gaps 2026-09-30 (#73980)
add d886882ac14 Let Common AI toolsets use the agent's tool retry budget
(#73957)
add 35633455ed7 Add first-class `capabilities` to Common AI
`AgentOperator` (#73984)
add adaa16f88af Parse Dag files through the Task SDK importers (#73853)
add 12127b07978 Fix check-conn-id-templated crashing on a vanishing
__pycache__ (#74016)
add 4d304d0876c Export files an agent built in a sandbox to object storage
(#73990)
add e9c552cc827 Add a vendor-neutral managed-agent hook contract to Common
AI (#73532)
add a33fe27cace Add async client to `AnthropicHook` (#73967)
add e6a9de5d832 Go SDK: bring the coordinator-protocol models back to the
supervisor schema (#73963)
add 27cd88ca74c Cache repeated agent prompts by default in AgentOperator
(#73994)
add 529f429400a Go SDK: reject a task handler and a Dag that share a
dag_id (#73876)
add bc9ca5b1227 Correctly shutdown async sessions on exit. (#73838)
add f1b36db6093 Back off between GitDagBundle bare clone attempts so a
fresh GitHub App token can propagate (#73878)
add 6b847411de1 Stop rebuilding the FAB app on every users and roles API
call (#73104)
add 56817294cdd Go SDK: add airflow.TriggerDagRun, a task that triggers a
Dag run (#74003)
add b8475094703 Fix go-sdk generated drift (#74028)
add 8f3e8466c67 Support Airflow 2.11 in the Common AI provider (#73991)
add f0cde671827 Use "Airflow versions" in user-facing docs, not "cores"
(#74045)
add 0bb09cb6ba5 Close the providers testing issue right after announcing
the release (#73890)
add 43377466a06 Release the DuckDB provider as 0.2.0 (#73888)
add 53e43f29130 Speed up CI image restores with zstd-compressed stashes
(#73997)
add e4d397f021e Bound get_schema results for very wide tables in the SQL
toolsets (#74017)
add 7d6244bf191 Clarify `max_db_retries` doc wording to avoid off-by-one
confusion (#73722)
add bb463bf9230 Correlate executor task events by attempt UUID (#73916)
add c19faf0c5ae Render the HITL review workflow as a Mermaid diagram
(#74024)
add 2aa31ae7bff Use airflow.sdk imports in Airflow 3 upgrade guide example
(#74015)
add f3532c60eda Use Task SDK TaskInstanceState in OpenSearch log handler
(#72444)
add 0ec26723858 Add GKEPodExecOperator for existing Pods (#72577)
add 740986adfce Add missing cycle assertion to test_semi_complex (#71973)
add fca1c01c73e Fix Windows UnicodeDecodeError during pytest collection
(#73536)
add 1787ef7cbba Run the deferred AWS hook configuration check as a prek
hook (#73681)
add 413ae46a045 Align timetable docs with Airflow 3 data interval and
catchup behaviour (#70658)
add 64f9f3ac784 Update issue templates now that Airflow 2 has reached end
of life (#74056)
add 6330b4de9c5 Go SDK: reject a second TaskSpec or Inputs when dag.Task
applies it (#74057)
add 383a9a87a98 Stop wiping the uv cache before every CI image build
(#74052)
add 58e987defec Fix Non-DB test collection failure in Google Stackdriver
hook test (#74066)
add 2c222151971 [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 (b3f2eab93f2)
\
N -- N -- N refs/heads/ci-upgrade-main (2c222151971)
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/ISSUE_TEMPLATE/1-airflow_bug_report.yml | 7 +-
.github/ISSUE_TEMPLATE/2-feature_request.yml | 3 +-
...-image-checks.yml => agent-framework-tests.yml} | 68 +-
.github/workflows/ci-amd.yml | 19 +
.github/workflows/ci-arm.yml | 19 +
.github/workflows/ci-image-build.yml | 8 +
.pre-commit-config.yaml | 45 ++
Dockerfile | 2 +-
Dockerfile.ci | 4 +-
airflow-core/.pre-commit-config.yaml | 6 +
.../0015-per-dag-source-in-bundle-artifact.md | 127 ++++
airflow-core/adr/lang-sdk/README.md | 1 +
.../task-and-asset-state-store.rst | 4 +
.../authoring-and-scheduling/asset-scheduling.rst | 31 +-
.../authoring-and-scheduling/language-sdks/go.rst | 22 +-
.../language-sdks/java.rst | 67 +-
.../language-sdks/typescript.rst | 70 +-
.../docs/authoring-and-scheduling/timetable.rst | 179 +++--
airflow-core/docs/core-concepts/dag-run.rst | 11 +-
airflow-core/docs/core-concepts/executor/index.rst | 23 +-
.../docs/core-concepts/resumable-tasks.rst | 75 +-
.../docs/core-concepts/task-state-store.rst | 6 +-
.../docs/installation/upgrading_to_airflow3.rst | 2 +-
airflow-core/docs/migrations-ref.rst | 4 +-
airflow-core/docs/public-airflow-interface.rst | 5 +-
airflow-core/newsfragments/58543.feature.rst | 1 +
airflow-core/newsfragments/68496.significant.rst | 4 +-
airflow-core/newsfragments/72100.significant.rst | 59 ++
airflow-core/src/airflow/api_fastapi/app.py | 2 +
.../api_fastapi/common/parameters/__init__.py | 4 +
.../airflow/api_fastapi/common/parameters/asset.py | 23 +
.../airflow/api_fastapi/common/parameters/dag.py | 46 ++
.../api_fastapi/common/parameters/dag_run.py | 35 +-
.../airflow/api_fastapi/common/parameters/misc.py | 43 ++
.../core_api/datamodels/task_instances.py | 5 +
.../api_fastapi/core_api/datamodels/ui/calendar.py | 1 +
.../api_fastapi/core_api/openapi/_private_ui.yaml | 46 ++
.../core_api/openapi/v2-rest-api-generated.yaml | 60 +-
.../core_api/routes/public/connections.py | 6 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 6 +-
.../api_fastapi/core_api/routes/public/hitl.py | 17 +-
.../api_fastapi/core_api/routes/public/job.py | 7 +-
.../api_fastapi/core_api/routes/public/log.py | 2 +-
.../core_api/routes/public/task_instances.py | 8 +
.../core_api/routes/public/task_state_store.py | 7 +-
.../core_api/routes/public/variables.py | 2 +-
.../api_fastapi/core_api/routes/ui/assets.py | 5 +
.../core_api/routes/ui/partitioned_dag_runs.py | 1 +
.../api_fastapi/core_api/routes/ui/teams.py | 2 +
.../core_api/services/public/dag_run.py | 17 +-
.../core_api/services/public/task_instances.py | 41 +
.../api_fastapi/core_api/services/ui/calendar.py | 10 +-
.../src/airflow/api_fastapi/execution_api/app.py | 2 +
.../execution_api/datamodels/taskinstance.py | 6 +
.../execution_api/routes/asset_events.py | 8 +-
.../api_fastapi/execution_api/routes/assets.py | 14 +-
.../api_fastapi/execution_api/routes/dag_runs.py | 18 +-
.../api_fastapi/execution_api/routes/hitl.py | 74 +-
.../execution_api/routes/task_instances.py | 96 ++-
.../execution_api/routes/task_reschedules.py | 6 +-
.../api_fastapi/execution_api/routes/xcoms.py | 12 +
.../api_fastapi/execution_api/versions/__init__.py | 2 +
.../execution_api/versions/v2026_10_30.py | 10 +
.../src/airflow/config_templates/config.yml | 43 +-
.../src/airflow/dag_processing/bundles/manager.py | 40 +-
.../src/airflow/dag_processing/collection.py | 21 +-
airflow-core/src/airflow/dag_processing/dagbag.py | 232 +++---
.../airflow/dag_processing/importers/__init__.py | 39 -
.../src/airflow/dag_processing/importers/base.py | 266 -------
.../dag_processing/importers/python_importer.py | 360 ---------
airflow-core/src/airflow/dag_processing/manager.py | 2 +
.../src/airflow/dag_processing/processor.py | 15 +-
.../src/airflow/executors/base_executor.py | 123 ++-
.../src/airflow/executors/local_executor.py | 13 +-
.../src/airflow/executors/workloads/task.py | 3 +-
.../src/airflow/executors/workloads/types.py | 17 +-
.../src/airflow/jobs/scheduler_job_runner.py | 256 ++++---
...3_4_0_add_timetable_asset_gated_to_dagmodel.py} | 29 +-
airflow-core/src/airflow/models/dag.py | 32 +-
airflow-core/src/airflow/models/dagcode.py | 45 +-
airflow-core/src/airflow/models/dagrun.py | 2 +-
airflow-core/src/airflow/models/serialized_dag.py | 19 +-
airflow-core/src/airflow/models/taskinstance.py | 2 +-
airflow-core/src/airflow/serialization/encoders.py | 9 +
airflow-core/src/airflow/settings.py | 14 +-
.../ti_deps/deps/not_previously_skipped_dep.py | 6 +-
airflow-core/src/airflow/timetables/assets.py | 112 ++-
airflow-core/src/airflow/timetables/base.py | 16 +
airflow-core/src/airflow/timetables/simple.py | 1 +
.../src/airflow/ui/openapi-gen/queries/common.ts | 16 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 22 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 22 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 22 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 22 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 11 +
.../ui/openapi-gen/requests/services.gen.ts | 20 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 39 +
.../airflow/ui/public/i18n/locales/ar/dags.json | 2 -
.../airflow/ui/public/i18n/locales/ca/dags.json | 4 -
.../airflow/ui/public/i18n/locales/de/browse.json | 30 +
.../airflow/ui/public/i18n/locales/de/common.json | 26 +
.../ui/public/i18n/locales/de/components.json | 5 +
.../src/airflow/ui/public/i18n/locales/de/dag.json | 5 +
.../airflow/ui/public/i18n/locales/de/dags.json | 24 +-
.../ui/public/i18n/locales/de/dashboard.json | 17 +-
.../airflow/ui/public/i18n/locales/el/dags.json | 2 -
.../airflow/ui/public/i18n/locales/en/assets.json | 1 +
.../airflow/ui/public/i18n/locales/en/common.json | 13 +-
.../src/airflow/ui/public/i18n/locales/en/dag.json | 1 +
.../airflow/ui/public/i18n/locales/en/dags.json | 7 +-
.../airflow/ui/public/i18n/locales/es/dags.json | 4 -
.../airflow/ui/public/i18n/locales/fr/dags.json | 2 -
.../airflow/ui/public/i18n/locales/he/dags.json | 2 -
.../airflow/ui/public/i18n/locales/hi/dags.json | 2 -
.../airflow/ui/public/i18n/locales/ko/dags.json | 4 -
.../airflow/ui/public/i18n/locales/pl/dags.json | 4 -
.../airflow/ui/public/i18n/locales/ru/dags.json | 2 -
.../airflow/ui/public/i18n/locales/zh-CN/dags.json | 4 -
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 4 -
.../TaskInstance/ClearGroupTaskInstanceDialog.tsx | 40 +-
.../TaskInstance/ClearTaskInstanceDialog.test.tsx | 127 ++++
.../Clear/TaskInstance/ClearTaskInstanceDialog.tsx | 23 +-
.../FilterBar/filters/RunStateFilter.tsx | 234 ++++++
.../FilterBar/filters/runStateParams.test.ts | 95 +++
.../components/FilterBar/filters/runStateParams.ts | 76 ++
.../airflow/ui/src/components/FilterBar/types.ts | 14 +-
.../src/airflow/ui/src/constants/filterConfigs.tsx | 38 +-
.../src/airflow/ui/src/constants/localStorage.ts | 1 +
.../src/airflow/ui/src/constants/searchParams.ts | 3 +
.../airflow/ui/src/hooks/useUserSettings.test.tsx | 21 +
.../src/airflow/ui/src/hooks/useUserSettings.ts | 4 +
.../src/airflow/ui/src/mocks/handlers/dag_runs.ts | 49 +-
.../src/airflow/ui/src/mocks/handlers/dags.ts | 10 +
.../ui/src/pages/AssetsList/AssetsList.test.tsx | 28 +
.../airflow/ui/src/pages/AssetsList/AssetsList.tsx | 11 +
.../ui/src/pages/Connections/Connections.tsx | 4 +
.../ui/src/pages/Dag/Calendar/CalendarCell.tsx | 31 +-
.../ui/src/pages/Dag/Calendar/CalendarLegend.tsx | 11 +
.../ui/src/pages/Dag/Calendar/CalendarTooltip.tsx | 14 +-
.../src/pages/Dag/Calendar/HourlyCalendarView.tsx | 10 +-
.../src/pages/Dag/Calendar/calendarUtils.test.ts | 22 +
.../ui/src/pages/Dag/Calendar/calendarUtils.ts | 4 +
.../src/airflow/ui/src/pages/Dag/Calendar/types.ts | 1 +
.../airflow/ui/src/pages/DagRuns/DagRuns.test.tsx | 27 +
.../src/airflow/ui/src/pages/DagRuns/DagRuns.tsx | 6 +
.../ui/src/pages/DagRuns/DagRunsFilters.tsx | 1 +
.../src/pages/DagsList/DagsFilters/DagsFilters.tsx | 3 +-
.../ui/src/pages/DagsList/DagsList.test.tsx | 41 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 5 +
.../src/airflow/ui/src/pages/Events/Events.tsx | 4 +
airflow-core/src/airflow/ui/src/pages/Jobs.tsx | 11 +-
.../src/airflow/ui/src/pages/Pools/PoolBarCard.tsx | 12 +-
.../ui/src/pages/Settings/Settings.test.tsx | 8 +
.../src/airflow/ui/src/pages/Settings/Settings.tsx | 13 +
.../TaskInstances/BulkClearTaskInstancesButton.tsx | 34 +-
.../airflow/ui/src/pages/Variables/Variables.tsx | 4 +
.../ui/src/queries/useBulkClearTaskInstances.ts | 2 +
.../src/airflow/ui/src/queries/useDags.tsx | 3 +
.../ui/src/utils/useFiltersHandler.test.tsx | 63 ++
.../src/airflow/ui/src/utils/useFiltersHandler.ts | 22 +-
.../src/airflow/ui/tests/e2e/pages/DagsPage.ts | 18 +-
airflow-core/src/airflow/utils/db.py | 4 +-
airflow-core/src/airflow/utils/file.py | 10 +
airflow-core/tests/integration/otel/test_otel.py | 2 +-
.../api_fastapi/auth/managers/simple/conftest.py | 3 +-
airflow-core/tests/unit/api_fastapi/conftest.py | 27 +-
.../core_api/routes/public/test_auth.py | 28 +-
.../core_api/routes/public/test_backfills.py | 20 +-
.../core_api/routes/public/test_connections.py | 9 +-
.../core_api/routes/public/test_dag_bundles.py | 43 +-
.../core_api/routes/public/test_dag_parsing.py | 18 +-
.../core_api/routes/public/test_dag_run.py | 134 ++--
.../core_api/routes/public/test_hitl.py | 28 +
.../api_fastapi/core_api/routes/public/test_job.py | 34 +
.../core_api/routes/public/test_task_instances.py | 228 ++++--
.../routes/public/test_task_state_store.py | 14 +
.../api_fastapi/core_api/routes/ui/test_assets.py | 23 +
.../core_api/routes/ui/test_calendar.py | 239 +++++-
.../api_fastapi/core_api/routes/ui/test_dags.py | 43 ++
.../unit/api_fastapi/execution_api/test_app.py | 84 +-
.../execution_api/versions/head/test_hitl.py | 36 +-
.../versions/head/test_task_instances.py | 167 +++-
.../{test_callbacks.py => test_dag_run_notes.py} | 10 +-
airflow-core/tests/unit/api_fastapi/test_app.py | 108 ++-
airflow-core/tests/unit/core/test_settings.py | 120 +++
.../bundles/test_dag_bundle_manager.py | 86 ++-
.../unit/dag_processing/importers/test_registry.py | 99 ---
.../tests/unit/dag_processing/test_collection.py | 86 ++-
.../tests/unit/dag_processing/test_dagbag.py | 263 ++++---
.../tests/unit/dag_processing/test_manager.py | 25 +
.../tests/unit/dag_processing/test_processor.py | 32 +-
.../tests/unit/executors/test_base_executor.py | 278 ++++++-
.../tests/unit/executors/test_local_executor.py | 10 +-
.../tests/unit/executors/test_workloads.py | 16 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 747 ++++++++++++++++--
airflow-core/tests/unit/jobs/test_triggerer_job.py | 1 +
...est_0049_remove_pickled_data_from_xcom_table.py | 237 ------
...t_0055_remove_pickled_data_from_dagrun_table.py | 143 ----
.../test_0080_deadline_callback_migration.py | 268 -------
.../test_0094_deadline_callback_migration.py | 178 -----
.../test_0117_deadline_interval_json_migration.py | 91 ---
...9_add_indexes_on_serialized_dag_and_dag_code.py | 55 --
.../migrations/test_0131_lower_case_team_names.py | 138 ----
.../test_0136_fold_task_map_into_xcom.py | 184 -----
...t_0138_allocate_pending_task_attempt_numbers.py | 448 -----------
airflow-core/tests/unit/models/test_dag.py | 31 +
airflow-core/tests/unit/models/test_dagcode.py | 39 +
.../tests/unit/models/test_taskinstance.py | 12 +
airflow-core/tests/unit/state/test_metastore.py | 9 +
.../deps/test_not_previously_skipped_dep.py | 44 ++
.../tests/unit/timetables/test_assets_timetable.py | 227 +++++-
airflow-core/tests/unit/utils/test_session.py | 18 +-
.../src/airflowctl/api/datamodels/generated.py | 7 +
airflow-ctl/src/airflowctl/api/operations.py | 2 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 12 +-
.../tests/airflow_ctl/api/test_operations.py | 19 +-
.../tests/airflow_ctl/ctl/test_cli_config.py | 34 +-
airflow-e2e-tests/pyproject.toml | 2 +-
.../airflow_e2e_tests/openlineage_tests/README.md | 2 +-
.../dags_extra/e2e_versioned_bundle.py | 4 +-
contributing-docs/30_new_language_sdk.rst | 6 +
dev/README_RELEASE_PROVIDERS.md | 87 ++-
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/doc/ci/04_selective_checks.md | 1 +
dev/breeze/doc/ci/05_workflows.md | 26 +
dev/breeze/pyproject.toml | 2 +-
.../airflow_breeze/commands/ci_image_commands.py | 4 +-
.../commands/release_management_commands.py | 2 +-
.../airflow_breeze/commands/testing_commands.py | 2 +-
dev/breeze/src/airflow_breeze/global_constants.py | 12 +-
.../airflow_breeze/utils/docker_command_utils.py | 26 +-
.../src/airflow_breeze/utils/selective_checks.py | 18 +
dev/breeze/tests/test_ci_image_commands.py | 20 +
dev/breeze/tests/test_docker_command_utils.py | 86 ++-
dev/breeze/tests/test_selective_checks.py | 56 +-
dev/breeze/uv.lock | 46 +-
devel-common/src/tests_common/pytest_plugin.py | 35 +-
devel-common/src/tests_common/test_utils/config.py | 24 +-
.../src/tests_common/test_utils/mock_executor.py | 5 +-
.../src/tests_common/test_utils/providers.py | 2 +-
docker-stack-docs/build-arg-ref.rst | 2 +-
.../customizing/add-build-essential-custom.sh | 2 +-
.../docker-examples/customizing/custom-sources.sh | 2 +-
.../customizing/pypi-dev-runtime-deps.sh | 2 +-
.../customizing/pypi-extras-and-deps.sh | 2 +-
.../customizing/pypi-selected-version.sh | 2 +-
.../restricted/restricted_environments.sh | 2 +-
docs/spelling_wordlist.txt | 2 +
generated/known_airflow_exceptions.txt | 2 +-
generated/known_sdk_imports_in_core.txt | 6 +-
go-sdk/Justfile | 4 +
go-sdk/README.md | 32 +-
go-sdk/adr/0008-native-dag-interface.md | 2 +-
go-sdk/airflow/bundle.go | 46 +-
go-sdk/airflow/bundle_test.go | 111 +++
go-sdk/airflow/dag.go | 142 +++-
go-sdk/airflow/dag_test.go | 88 ++-
go-sdk/airflow/inputs.go | 145 ++++
go-sdk/airflow/inputs_test.go | 437 +++++++++++
go-sdk/airflow/spec.gen.go | 170 +++++
go-sdk/airflow/spec.go | 115 ++-
go-sdk/airflow/spec_test.go | 71 ++
go-sdk/airflow/task_handler.go | 12 +-
go-sdk/airflow/task_option.go | 28 +-
go-sdk/airflow/trigger_dag_run.go | 177 +++++
go-sdk/airflow/trigger_dag_run_test.go | 276 +++++++
go-sdk/internal/bundle/task.go | 28 +-
go-sdk/internal/genlicense/genlicense.go | 71 ++
go-sdk/internal/genlicense/genlicense_test.go | 83 ++
go-sdk/internal/genspec/authoring.go | 470 ++++++++++++
go-sdk/internal/genspec/authoring_test.go | 329 ++++++++
go-sdk/internal/genspec/main.go | 110 +++
.../main.go => internal/genspec/main_test.go} | 23 +-
go-sdk/internal/genspec/normalize.go | 176 +++++
go-sdk/internal/genspec/normalize_test.go | 256 +++++++
go-sdk/pkg/binding/binding.go | 56 +-
go-sdk/pkg/binding/binding_test.go | 27 +
.../pkg/execution/genmodels/discriminators.gen.go | 4 +
go-sdk/pkg/execution/genmodels/gen/main.go | 49 +-
go-sdk/pkg/execution/genmodels/models.gen.go | 171 +++--
java-sdk/README.md | 19 +-
.../example/nativedag/InterfaceExample.java | 18 +-
.../org/apache/airflow/sdk/BuilderProcessor.kt | 118 ++-
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 172 ++++-
java-sdk/sdk/build.gradle.kts | 443 ++++++++++-
{ts-sdk => java-sdk/sdk}/schema/dag-schema.json | 0
.../src/main/kotlin/org/apache/airflow/sdk/Arg.kt | 18 +
.../main/kotlin/org/apache/airflow/sdk/Builder.kt | 109 ---
.../main/kotlin/org/apache/airflow/sdk/DagDef.kt | 69 +-
.../src/main/kotlin/org/apache/airflow/sdk/Deps.kt | 18 +-
.../org/apache/airflow/sdk/internal/Fields.kt | 107 +++
.../kotlin/org/apache/airflow/sdk/DagDefTest.kt | 179 +++++
providers/.pre-commit-config.yaml | 7 +
providers/amazon/README.rst | 4 +-
providers/amazon/docs/index.rst | 2 +
providers/amazon/docs/operators/bedrock.rst | 40 +
providers/amazon/pyproject.toml | 8 +-
.../airflow/providers/amazon/aws/hooks/bedrock.py | 229 +++++-
.../src/airflow/providers/amazon/aws/hooks/s3.py | 8 +-
.../tests/unit/amazon/aws/hooks/test_bedrock.py | 280 +++++++
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 19 +
.../amazon/aws/test_deferred_hook_configuration.py | 242 +-----
providers/anthropic/pyproject.toml | 2 +-
.../airflow/providers/anthropic/hooks/anthropic.py | 99 ++-
.../tests/unit/anthropic/hooks/test_anthropic.py | 141 +++-
.../unit/celery/executors/test_celery_executor.py | 4 +
.../executors/test_kubernetes_executor.py | 2 +
providers/common/ai/README.rst | 3 +-
providers/common/ai/docs/approval_gates.rst | 2 +-
providers/common/ai/docs/capabilities.rst | 137 ++++
providers/common/ai/docs/changelog.rst | 12 +
providers/common/ai/docs/code_mode.rst | 7 +-
providers/common/ai/docs/features.rst | 6 +-
providers/common/ai/docs/guardrails.rst | 66 --
providers/common/ai/docs/hitl_review.rst | 63 +-
providers/common/ai/docs/hooks/langchain.rst | 20 +-
providers/common/ai/docs/hooks/llamaindex.rst | 12 +
providers/common/ai/docs/index.rst | 5 +-
providers/common/ai/docs/installation.rst | 33 +-
providers/common/ai/docs/observability.rst | 3 +
providers/common/ai/docs/operators/agent.rst | 108 ++-
.../ai/docs/operators/llamaindex_embedding.rst | 26 +-
.../ai/docs/operators/llamaindex_retrieval.rst | 18 +-
providers/common/ai/docs/operators/llm_batch.rst | 4 +-
providers/common/ai/docs/operators/llm_branch.rst | 2 +-
providers/common/ai/docs/quickstart.rst | 3 +-
providers/common/ai/docs/redirects.txt | 1 +
providers/common/ai/docs/sandbox/backends.rst | 11 +-
providers/common/ai/docs/sandbox/configuration.rst | 59 +-
providers/common/ai/docs/sandbox/index.rst | 5 +-
providers/common/ai/docs/self_hosted_models.rst | 3 +-
providers/common/ai/docs/stability.rst | 2 +-
providers/common/ai/docs/tool_approval.rst | 5 +-
providers/common/ai/docs/toolsets/datafusion.rst | 13 +-
providers/common/ai/docs/toolsets/hook.rst | 3 +
providers/common/ai/docs/toolsets/index.rst | 77 +-
.../common/ai/docs/toolsets/managed_agent.rst | 337 ++++----
.../common/ai/docs/toolsets/object_storage.rst | 3 +
providers/common/ai/docs/toolsets/sql.rst | 45 +-
providers/common/ai/docs/troubleshooting.rst | 8 +-
providers/common/ai/pyproject.toml | 7 +-
.../ai/src/airflow/providers/common/ai/__init__.py | 4 +-
.../airflow/providers/common/ai/batch/anthropic.py | 5 +-
.../airflow/providers/common/ai/batch/openai.py | 5 +-
.../airflow/providers/common/ai/batch/results.py | 5 +-
.../providers/common/ai/decorators/agent.py | 2 +-
.../airflow/providers/common/ai/decorators/llm.py | 2 +-
.../providers/common/ai/decorators/llm_batch.py | 2 +-
.../providers/common/ai/decorators/llm_branch.py | 2 +-
.../common/ai/decorators/llm_file_analysis.py | 2 +-
.../common/ai/decorators/llm_schema_compare.py | 2 +-
.../providers/common/ai/decorators/llm_sql.py | 2 +-
.../providers/common/ai/durable/caching_model.py | 4 +-
.../providers/common/ai/durable/caching_toolset.py | 17 +-
.../providers/common/ai/durable/fingerprint.py | 12 +-
.../airflow/providers/common/ai/durable/storage.py | 7 +-
.../common/ai/durable/task_state_store.py | 4 +-
.../ai/example_dags/example_agent_capabilities.py | 27 +-
.../ai/example_dags/example_sandbox_toolset.py | 70 +-
.../src/airflow/providers/common/ai/exceptions.py | 17 +-
.../airflow/providers/common/ai/hooks/langchain.py | 30 +-
.../providers/common/ai/hooks/llamaindex.py | 25 +-
.../providers/common/ai/hooks/pydantic_ai.py | 10 +
.../providers/common/ai/managed_agents/__init__.py | 49 ++
.../providers/common/ai/managed_agents/base.py | 251 ++++++
.../providers/common/ai/managed_agents/failover.py | 145 ++++
.../airflow/providers/common/ai/mixins/approval.py | 6 +-
.../airflow/providers/common/ai/observability.py | 19 +-
.../airflow/providers/common/ai/operators/agent.py | 199 +++--
.../common/ai/operators/llamaindex_embedding.py | 15 +-
.../common/ai/operators/llamaindex_retrieval.py | 16 +-
.../airflow/providers/common/ai/operators/llm.py | 17 +-
.../airflow/providers/common/ai/sandbox/base.py | 167 +++-
.../providers/common/ai/sandbox/opensandbox.py | 71 +-
.../src/airflow/providers/common/ai/sandbox/sbx.py | 90 ++-
.../providers/common/ai/tools/_from_toolset.py | 18 +-
.../providers/common/ai/toolsets/__init__.py | 4 +-
.../providers/common/ai/toolsets/datafusion.py | 48 +-
.../airflow/providers/common/ai/toolsets/hook.py | 16 +-
.../common/ai/toolsets/langchain_bridge.py | 5 +-
.../providers/common/ai/toolsets/managed_agent.py | 368 +++++----
.../airflow/providers/common/ai/toolsets/mcp.py | 11 +-
.../providers/common/ai/toolsets/object_storage.py | 14 +-
.../providers/common/ai/toolsets/sandbox.py | 212 +++++-
.../airflow/providers/common/ai/toolsets/sql.py | 46 +-
.../airflow/providers/common/ai/utils/logging.py | 18 +-
.../providers/common/ai/utils/prompt_cache.py | 140 ++++
.../providers/common/ai/utils/query_results.py | 202 ++++-
.../providers/common/ai/utils/task_logger.py | 67 ++
.../providers/common/ai/utils/toolset_base.py | 61 +-
.../providers/common/ai/utils/usage_budget.py | 11 +-
.../ai/tests/unit/common/ai/batch/test_dispatch.py | 2 +-
.../ai/tests/unit/common/ai/batch/test_results.py | 2 +-
.../ai/tests/unit/common/ai/batch/test_state.py | 2 +-
.../common/ai/tests/unit/common/ai/conftest.py | 11 +-
.../tests/unit/common/ai/decorators/test_agent.py | 22 +-
.../unit/common/ai/decorators/test_llm_batch.py | 3 +-
.../common/ai/decorators/test_llm_file_analysis.py | 5 +-
.../ai/tests/unit/common/ai/durable/test_base.py | 2 +-
.../unit/common/ai/durable/test_caching_toolset.py | 55 ++
.../unit/common/ai/durable/test_fingerprint.py | 20 +
.../unit/common/ai/durable/test_replay_cost.py | 2 +-
.../common/ai/durable/test_replay_verification.py | 2 +-
.../tests/unit/common/ai/durable/test_storage.py | 2 +-
.../common/ai/durable/test_task_state_store.py | 2 +-
.../tests/unit/common/ai/hooks/test_langchain.py | 66 ++
.../tests/unit/common/ai/hooks/test_llamaindex.py | 72 ++
.../tests/unit/common/ai/hooks/test_pydantic_ai.py | 15 +
.../unit/common/ai/managed_agents}/__init__.py | 0
.../unit/common/ai/managed_agents/test_base.py | 137 ++++
.../unit/common/ai/managed_agents/test_failover.py | 205 +++++
.../tests/unit/common/ai/mixins/test_approval.py | 6 +-
.../tests/unit/common/ai/operators/test_agent.py | 313 +++++++-
.../common/ai/operators/test_document_loader.py | 12 +-
.../ai/operators/test_llamaindex_embedding.py | 17 +-
.../ai/operators/test_llamaindex_retrieval.py | 19 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 24 +-
.../unit/common/ai/operators/test_llm_batch.py | 3 +-
.../unit/common/ai/operators/test_llm_branch.py | 4 +-
.../common/ai/operators/test_llm_file_analysis.py | 11 +-
.../tests/unit/common/ai/operators/test_llm_sql.py | 4 +-
.../ai/tests/unit/common/ai/sandbox/test_base.py | 163 +++-
.../unit/common/ai/sandbox/test_opensandbox.py | 137 ++++
.../ai/tests/unit/common/ai/sandbox/test_sbx.py | 106 +++
.../ai/tests/unit/common/ai/test_observability.py | 19 +
.../unit/common/ai/tools/test__from_toolset.py | 33 +-
.../unit/common/ai/toolsets/test_datafusion.py | 55 +-
.../unit/common/ai/toolsets/test_managed_agent.py | 403 ++++------
.../unit/common/ai/toolsets/test_object_storage.py | 8 +-
.../unit/common/ai/toolsets/test_retry_budget.py | 98 +++
.../tests/unit/common/ai/toolsets/test_sandbox.py | 356 +++++++++
.../ai/tests/unit/common/ai/toolsets/test_sql.py | 62 +-
.../ai/tests/unit/common/ai/utils/test_logging.py | 55 +-
.../unit/common/ai/utils/test_prompt_cache.py | 209 +++++
.../unit/common/ai/utils/test_query_results.py | 167 +++-
.../tests/unit/common/ai/utils/test_task_logger.py | 82 ++
.../unit/common/ai/utils/test_tool_metrics.py | 6 +-
.../unit/common/ai/utils/test_toolset_base.py | 10 +-
.../common/compat/_set_during_execution.py | 40 +
.../src/airflow/providers/common/compat/sdk.py | 14 +-
.../common/compat/security/test_access_view.py | 8 +-
.../common/compat/test__set_during_execution.py} | 22 +-
.../compat/tests/unit/common/compat/test_sdk.py | 18 +-
providers/duckdb/README.rst | 6 +-
providers/duckdb/docs/changelog.rst | 9 +-
providers/duckdb/docs/index.rst | 6 +-
providers/duckdb/provider.yaml | 2 +-
providers/duckdb/pyproject.toml | 6 +-
.../src/airflow/providers/duckdb/__init__.py | 2 +-
providers/fab/pyproject.toml | 2 +-
.../fab/auth_manager/api_fastapi/routes/roles.py | 14 +-
.../fab/auth_manager/api_fastapi/routes/users.py | 12 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 4 +-
.../unit/fab/auth_manager/api_fastapi/conftest.py | 21 +
.../auth_manager/api_fastapi/routes/test_roles.py | 161 ++--
.../auth_manager/api_fastapi/routes/test_users.py | 128 ++--
.../git/src/airflow/providers/git/bundles/git.py | 31 +-
.../git/src/airflow/providers/git/hooks/git.py | 7 +-
providers/git/tests/unit/git/bundles/test_git.py | 44 ++
providers/git/tests/unit/git/hooks/test_git.py | 10 +
providers/google/docs/index.rst | 10 +-
.../docs/operators/cloud/kubernetes_engine.rst | 20 +
.../google/docs/operators/cloud/vertex_ai.rst | 24 +
providers/google/pyproject.toml | 6 +-
.../google/cloud/hooks/vertex_ai/agent_engine.py | 159 +++-
.../google/cloud/operators/kubernetes_engine.py | 114 +++
.../kubernetes_engine/example_kubernetes_engine.py | 105 ++-
.../unit/google/cloud/hooks/test_stackdriver.py | 2 +-
.../cloud/hooks/vertex_ai/test_agent_engine.py | 145 ++++
.../cloud/operators/test_kubernetes_engine.py | 146 +++-
providers/hashicorp/pyproject.toml | 2 +-
.../providers/opensearch/log/os_task_handler.py | 3 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 2 +-
.../snowflake/hooks/snowflake_cortex_agent.py | 42 +-
.../snowflake/hooks/test_snowflake_cortex_agent.py | 106 ++-
.../airflow/providers/standard/operators/hitl.py | 6 +-
.../tests/unit/standard/operators/test_hitl.py | 4 +-
pyproject.toml | 4 +-
.../ci/lang_sdk_serialization}/__init__.py | 0
scripts/ci/lang_sdk_serialization/compare.py | 233 ++++++
.../ci/lang_sdk_serialization/serialize_python.py | 140 ++++
scripts/ci/lang_sdk_serialization/test_dags.yaml | 166 ++++
scripts/ci/prek/check_conn_id_templated.py | 18 +-
.../ci/prek/check_deferred_hook_configuration.py | 294 +++++++
scripts/ci/prek/check_go_sdk_generated_drift.py | 187 +++++
.../ci/prek/check_openapi_exception_doc_in_sync.py | 239 ++++++
scripts/ci/prek/common_prek_utils.py | 26 +-
scripts/ci/prek/update_providers_dependencies.py | 14 +-
scripts/in_container/run_agent_framework_tests.sh | 90 +++
.../tests/ci/lang_sdk_serialization}/__init__.py | 0
.../ci/lang_sdk_serialization/test_compare.py | 245 ++++++
.../tests/ci/prek/test_check_conn_id_templated.py | 26 +-
.../prek/test_check_deferred_hook_configuration.py | 373 +++++++++
.../ci/prek/test_check_go_sdk_generated_drift.py | 172 +++++
.../test_check_openapi_exception_doc_in_sync.py | 335 ++++++++
.../observability/metrics/metrics_template.yaml | 20 +-
task-sdk/docs/api.rst | 2 +
task-sdk/src/airflow/sdk/__init__.py | 3 +
task-sdk/src/airflow/sdk/__init__.pyi | 2 +
task-sdk/src/airflow/sdk/api/client.py | 12 +
.../src/airflow/sdk/api/datamodels/_generated.py | 15 +
task-sdk/src/airflow/sdk/bases/timetable.py | 7 +
.../airflow/sdk/coordinators/_bundle_metadata.py | 33 +-
.../src/airflow/sdk/coordinators/_subprocess.py | 211 ++++-
.../sdk/coordinators/executable/coordinator.py | 17 +-
.../airflow/sdk/coordinators/java/coordinator.py | 24 +-
.../airflow/sdk/coordinators/node/coordinator.py | 21 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 4 +-
.../airflow/sdk/definitions/timetables/assets.py | 25 +
task-sdk/src/airflow/sdk/execution_time/bundles.py | 90 +++
task-sdk/src/airflow/sdk/execution_time/comms.py | 7 +
.../airflow/sdk/execution_time/request_handlers.py | 9 +
.../airflow/sdk/execution_time/schema/schema.json | 65 ++
.../sdk/execution_time/schema/versions/__init__.py | 8 +-
.../execution_time/schema/versions/v2026_10_30.py | 21 +
.../src/airflow/sdk/execution_time/supervisor.py | 8 +
.../src/airflow/sdk/execution_time/task_runner.py | 107 +--
task-sdk/src/airflow/sdk/execution_time/tracing.py | 60 ++
task-sdk/src/airflow/sdk/importers/base.py | 2 +
task-sdk/src/airflow/sdk/lineage.py | 2 +-
task-sdk/src/airflow/sdk/serde/__init__.py | 7 +-
task-sdk/src/airflow/sdk/types.py | 2 +
task-sdk/tests/task_sdk/api/test_client.py | 15 +
.../coordinators/executable/test_coordinator.py | 60 +-
.../task_sdk/coordinators/java/test_coordinator.py | 39 +
.../task_sdk/coordinators/node/test_coordinator.py | 51 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 264 ++++++-
task-sdk/tests/task_sdk/definitions/test_dag.py | 18 +-
.../tests/task_sdk/execution_time/test_bundles.py | 86 +++
.../task_sdk/execution_time/test_supervisor.py | 15 +
.../task_sdk/execution_time/test_task_runner.py | 255 +++----
.../tests/task_sdk/execution_time/test_tracing.py | 144 ++++
ts-sdk/.pre-commit-config.yaml | 14 +
ts-sdk/package.json | 3 +-
ts-sdk/pnpm-lock.yaml | 27 +-
..._lint.py => check_serialization_conformance.py} | 16 +-
ts-sdk/src/coordinator/serde.ts | 751 ++++++++++++++++++
ts-sdk/src/generated/supervisor.ts | 68 +-
ts-sdk/src/index.ts | 3 +
ts-sdk/src/sdk/dag.ts | 355 ++++++++-
ts-sdk/tests/conformance/serialize_typescript.ts | 163 ++++
ts-sdk/tests/coordinator/arg-binding.test.ts | 19 +
ts-sdk/tests/coordinator/serde.test.ts | 846 +++++++++++++++++++++
ts-sdk/tests/public-api.test.ts | 31 +-
ts-sdk/tests/sdk/dag.test.ts | 357 ++++++++-
uv.lock | 838 ++++++++++----------
546 files changed, 25949 insertions(+), 6509 deletions(-)
copy .github/workflows/{additional-ci-image-checks.yml =>
agent-framework-tests.yml} (55%)
create mode 100644
airflow-core/adr/lang-sdk/0015-per-dag-source-in-bundle-artifact.md
create mode 100644 airflow-core/newsfragments/58543.feature.rst
create mode 100644 airflow-core/newsfragments/72100.significant.rst
delete mode 100644
airflow-core/src/airflow/dag_processing/importers/__init__.py
delete mode 100644 airflow-core/src/airflow/dag_processing/importers/base.py
delete mode 100644
airflow-core/src/airflow/dag_processing/importers/python_importer.py
copy
airflow-core/src/airflow/migrations/versions/{0111_3_3_0_add_timetable_periodic_to_dag.py
=> 0141_3_4_0_add_timetable_asset_gated_to_dagmodel.py} (63%)
create mode 100644
airflow-core/src/airflow/ui/src/components/Clear/TaskInstance/ClearTaskInstanceDialog.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FilterBar/filters/RunStateFilter.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FilterBar/filters/runStateParams.test.ts
create mode 100644
airflow-core/src/airflow/ui/src/components/FilterBar/filters/runStateParams.ts
copy
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2026_10_30/{test_callbacks.py
=> test_dag_run_notes.py} (77%)
delete mode 100644
airflow-core/tests/unit/dag_processing/importers/test_registry.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0049_remove_pickled_data_from_xcom_table.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0055_remove_pickled_data_from_dagrun_table.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0080_deadline_callback_migration.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0094_deadline_callback_migration.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0117_deadline_interval_json_migration.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0129_add_indexes_on_serialized_dag_and_dag_code.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0131_lower_case_team_names.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0136_fold_task_map_into_xcom.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0138_allocate_pending_task_attempt_numbers.py
create mode 100644 go-sdk/airflow/inputs.go
create mode 100644 go-sdk/airflow/inputs_test.go
create mode 100644 go-sdk/airflow/spec.gen.go
create mode 100644 go-sdk/airflow/spec_test.go
create mode 100644 go-sdk/airflow/trigger_dag_run.go
create mode 100644 go-sdk/airflow/trigger_dag_run_test.go
create mode 100644 go-sdk/internal/genlicense/genlicense.go
create mode 100644 go-sdk/internal/genlicense/genlicense_test.go
create mode 100644 go-sdk/internal/genspec/authoring.go
create mode 100644 go-sdk/internal/genspec/authoring_test.go
create mode 100644 go-sdk/internal/genspec/main.go
copy go-sdk/{airflow/testdata/foreignitem/main.go =>
internal/genspec/main_test.go} (58%)
create mode 100644 go-sdk/internal/genspec/normalize.go
create mode 100644 go-sdk/internal/genspec/normalize_test.go
copy {ts-sdk => java-sdk/sdk}/schema/dag-schema.json (100%)
delete mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Builder.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/Fields.kt
create mode 100644 providers/common/ai/docs/capabilities.rst
delete mode 100644 providers/common/ai/docs/guardrails.rst
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/managed_agents/__init__.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/managed_agents/base.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/managed_agents/failover.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/prompt_cache.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/task_logger.py
rename {airflow-core/tests/unit/dag_processing/importers =>
providers/common/ai/tests/unit/common/ai/managed_agents}/__init__.py (100%)
create mode 100644
providers/common/ai/tests/unit/common/ai/managed_agents/test_base.py
create mode 100644
providers/common/ai/tests/unit/common/ai/managed_agents/test_failover.py
create mode 100644
providers/common/ai/tests/unit/common/ai/toolsets/test_retry_budget.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_prompt_cache.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_task_logger.py
create mode 100644
providers/common/compat/src/airflow/providers/common/compat/_set_during_execution.py
copy providers/{amazon/tests/unit/amazon/aws/cli/test_definition.py =>
common/compat/tests/unit/common/compat/test__set_during_execution.py} (52%)
copy {airflow-core/src/airflow/_shared =>
scripts/ci/lang_sdk_serialization}/__init__.py (100%)
create mode 100644 scripts/ci/lang_sdk_serialization/compare.py
create mode 100644 scripts/ci/lang_sdk_serialization/serialize_python.py
create mode 100644 scripts/ci/lang_sdk_serialization/test_dags.yaml
create mode 100755 scripts/ci/prek/check_deferred_hook_configuration.py
create mode 100755 scripts/ci/prek/check_go_sdk_generated_drift.py
create mode 100755 scripts/ci/prek/check_openapi_exception_doc_in_sync.py
create mode 100755 scripts/in_container/run_agent_framework_tests.sh
copy {airflow-core/src/airflow/_shared =>
scripts/tests/ci/lang_sdk_serialization}/__init__.py (100%)
create mode 100644 scripts/tests/ci/lang_sdk_serialization/test_compare.py
create mode 100644
scripts/tests/ci/prek/test_check_deferred_hook_configuration.py
create mode 100644 scripts/tests/ci/prek/test_check_go_sdk_generated_drift.py
create mode 100644
scripts/tests/ci/prek/test_check_openapi_exception_doc_in_sync.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/bundles.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/tracing.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_bundles.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_tracing.py
copy ts-sdk/scripts/ci/prek/{ts_sdk_lint.py =>
check_serialization_conformance.py} (67%)
create mode 100644 ts-sdk/src/coordinator/serde.ts
create mode 100644 ts-sdk/tests/conformance/serialize_typescript.ts
create mode 100644 ts-sdk/tests/coordinator/serde.test.ts
