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 8620f898963 [main] CI: Upgrade important CI environment
add 93eee4fb31d i18n(ko): Improve Korean Task terminology consistency
(#67234)
add 8388bb8f89e Deprecate implicit REMOTE_TASK_LOG registration in
OpensearchTaskHandler (#67106)
add 9ed5a08fd1f AIP-76: Add example and docs for runtime asset
partitioning (#67307)
add d02b66523f2 Fix SageMaker processing stopped state handling (#67291)
add af5af564ffa Export from_timestamp from Task SDK timezone module
(#67321)
add 11ba5ec753b Breeze: bind api-server dual-stack so http://localhost
works in Chrome/Safari (#67320)
add 8c2fa492bc1 Add `allow_global` option to asset access control (#67251)
add b64ed723421 Refactor Elasticsearch log formatter to use
timezone.from_timestamp (#67245)
add 91843291f54 Refactor Opensearch log formatter to use
timezone.from_timestamp (#66856)
add eca91dc5c2c Restore fail_fast handling when reschedule exceeds MySQL
TIMESTAMP limit (#67353)
add 0920c770c8e Add schema migration to supervisor-child comm (#67235)
add 83d8f400274 UI: Fix Expand/Collapse All on XComs and Audit Log JSON
cells (#67316)
add b1aec757ce1 Revoke JWT on /auth/logout regardless of auth manager
logout URL (#67289)
add b306f13e6d7 Bump the uv-dependency-updates group in /dev/breeze with 2
updates (#67345)
add d0f981c2ffb Deprecate implicit REMOTE_TASK_LOG registration in
ElasticsearchTaskHandler (#67105)
add 113b6fae3f9 UI: Fix /dags/{dag_id}/latest_run returning 500 instead of
400 for dag_id="~" (#67363)
add 40c9edf4563 Bump the github-actions-updates group with 2 updates
(#67351)
add 477b1482e7e Add prek hook enforcing the "example" tag on example DAGs
(#67354)
add 901a5a3c283 Add some more clarifications on edge roles (#67379)
add f13f0c17d48 Update providers metadata 2026-05-23 (#67377)
add 336a1199a1c Increment version of airflowctl for RC (#67295)
add 16ad4794f5a Add dags next execution command #66172 (#66188)
add ea7481d7d59 UI: Show DAG name in browser tab title (#67169)
add 428c5d285ac Update apache-steward snapshot to b19ac36 and drop local
SPDX header (#67412)
add f60dffae9fe [Hashicorp] Enable ADC for Vault GCP authentication
(#53801)
add b0921fe6657 Fix flaky AzureDataFactory operator test by mocking time
(#67427)
add 62845dd743b Cleanup older/outddated uv cooldown exception (#67383)
add 8af561806b9 Remove dead auth code from Airflow2 times in Edge (#67374)
add 325f3774ba6 Accept Sequence[UserContent] in common.ai TaskFlow
decorators (#67389)
add dd8c60e487f Bump @playwright/test to 1.60 to fix UI e2e install hang
on Node 24+ (#67398)
add 2def8027d7c Correctly pre-allocate `external_exeuctor_id` with
multiple executors. (#67388)
add 4189439ec00 [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 (8620f898963)
\
N -- N -- N refs/heads/ci-upgrade-main (4189439ec00)
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/skills/setup-steward/SKILL.md | 5 +-
.github/skills/setup-steward/adopt.md | 235 +-
.github/skills/setup-steward/conventions.md | 155 +-
.github/skills/setup-steward/overrides.md | 3 -
.github/skills/setup-steward/unadopt.md | 31 +-
.github/skills/setup-steward/upgrade.md | 59 +-
.github/skills/setup-steward/verify.md | 24 +-
.github/skills/setup-steward/worktree-init.md | 26 +-
.github/workflows/basic-tests.yml | 2 +-
.github/workflows/codeql-analysis.yml | 6 +-
.github/workflows/registry-backfill.yml | 2 +-
.github/workflows/registry-build.yml | 2 +-
.github/workflows/test-providers.yml | 4 +
.github/workflows/ui-e2e-tests.yml | 2 +-
.gitignore | 8 +-
.pre-commit-config.yaml | 23 +-
Dockerfile | 9 +-
Dockerfile.ci | 4 +-
.../docs/authoring-and-scheduling/assets.rst | 42 +
airflow-core/docs/migrations-ref.rst | 4 +-
airflow-core/pyproject.toml | 4 +-
.../api_fastapi/core_api/routes/public/auth.py | 9 +-
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 3 +-
.../execution_api/routes/task_instances.py | 8 +-
airflow-core/src/airflow/assets/manager.py | 10 +-
.../src/airflow/dag_processing/collection.py | 12 +-
.../airflow/example_dags/example_asset_alias.py | 8 +-
.../example_asset_alias_with_no_taskflow.py | 8 +-
.../example_dags/example_asset_allow_teams.py | 12 +-
.../example_dags/example_asset_decorator.py | 2 +-
.../example_dags/example_asset_partition.py | 65 +-
.../example_dags/example_asset_with_watchers.py | 1 +
.../src/airflow/example_dags/example_assets.py | 17 +-
.../airflow/example_dags/example_branch_labels.py | 1 +
.../example_dags/example_dynamic_task_mapping.py | 6 +-
...amic_task_mapping_with_no_taskflow_operators.py | 1 +
.../example_dags/example_inlet_event_extra.py | 4 +-
.../example_dags/example_kubernetes_executor.py | 2 +-
.../example_latest_only_with_trigger.py | 2 +-
.../example_local_kubernetes_executor.py | 2 +-
.../example_dags/example_outlet_event_extra.py | 6 +-
.../airflow/example_dags/example_simplest_dag.py | 2 +-
.../src/airflow/jobs/scheduler_job_runner.py | 6 +-
...rol_columns_to_dag_schedule_asset_reference.py} | 10 +-
airflow-core/src/airflow/models/asset.py | 3 +
airflow-core/src/airflow/ui/package.json | 2 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 26 +-
.../airflow/ui/public/i18n/locales/ko/admin.json | 2 +-
.../airflow/ui/public/i18n/locales/ko/assets.json | 4 +-
.../airflow/ui/public/i18n/locales/ko/common.json | 20 +-
.../ui/public/i18n/locales/ko/components.json | 16 +-
.../src/airflow/ui/public/i18n/locales/ko/dag.json | 40 +-
.../airflow/ui/public/i18n/locales/ko/dags.json | 20 +-
.../airflow/ui/public/i18n/locales/ko/hitl.json | 2 +-
.../airflow/ui/public/i18n/locales/ko/tasks.json | 2 +-
.../src/components/MonacoEditor/configureMonaco.ts | 10 +-
.../ui/src/components/RenderedJsonField.tsx | 22 +-
.../src/airflow/ui/src/layouts/BaseLayout.tsx | 5 -
airflow-core/src/airflow/ui/src/pages/Dag/Dag.tsx | 4 +-
airflow-core/src/airflow/ui/src/utils/index.ts | 1 +
.../{useContainerWidth.ts => useDocumentTitle.ts} | 29 +-
airflow-core/src/airflow/ui/src/vite-env.d.ts | 5 +
airflow-core/src/airflow/ui/vite.config.ts | 16 +-
.../core_api/routes/public/test_auth.py | 24 +
.../api_fastapi/core_api/routes/ui/test_dags.py | 7 +
.../versions/head/test_task_instances.py | 55 +
airflow-core/tests/unit/assets/test_manager.py | 57 +-
.../tests/unit/dag_processing/test_collection.py | 10 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 38 +-
airflow-ctl-tests/pyproject.toml | 2 +-
.../airflowctl_tests/test_airflowctl_commands.py | 1 +
airflow-ctl/docs/images/command_hashes.txt | 2 +-
airflow-ctl/docs/images/output_dags.svg | 126 +-
airflow-ctl/pyproject.toml | 2 +-
airflow-ctl/src/airflowctl/__init__.py | 2 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 9 +
.../src/airflowctl/ctl/commands/dag_command.py | 31 +
.../airflow_ctl/ctl/commands/test_dag_command.py | 72 +
airflow-e2e-tests/pyproject.toml | 2 +-
chart/pyproject.toml | 2 +-
clients/python/pyproject.toml | 2 +-
dev/breeze/doc/ci/02_images.md | 4 +-
dev/breeze/pyproject.toml | 2 +-
.../airflow_breeze/commands/kubernetes_commands.py | 2 +-
.../commands/release_management_commands.py | 4 +-
dev/breeze/src/airflow_breeze/global_constants.py | 2 +-
dev/breeze/uv.lock | 188 +-
dev/mypy/pyproject.toml | 2 +-
dev/pyproject.toml | 2 +-
dev/registry/pyproject.toml | 2 +-
docker-stack-docs/pyproject.toml | 2 +-
docker-tests/pyproject.toml | 2 +-
docs/spelling_wordlist.txt | 1 +
generated/provider_metadata.json | 176 +
kubernetes-tests/pyproject.toml | 2 +-
.../test_kubernetes_pod_operator.py | 16 +-
providers-summary-docs/pyproject.toml | 2 +-
.../providers/amazon/aws/operators/sagemaker.py | 2 +-
.../aws/operators/test_sagemaker_processing.py | 28 +
providers/common/ai/docs/operators/agent.rst | 28 +
providers/common/ai/docs/operators/llm.rst | 12 +
providers/common/ai/docs/operators/llm_branch.rst | 4 +
.../ai/docs/operators/llm_schema_compare.rst | 4 +
providers/common/ai/docs/operators/llm_sql.rst | 4 +
providers/common/ai/pyproject.toml | 2 +-
.../providers/common/ai/decorators/agent.py | 13 +-
.../airflow/providers/common/ai/decorators/llm.py | 13 +-
.../providers/common/ai/decorators/llm_branch.py | 6 +-
.../common/ai/decorators/llm_file_analysis.py | 5 +
.../common/ai/decorators/llm_schema_compare.py | 6 +-
.../providers/common/ai/decorators/llm_sql.py | 13 +-
.../common/ai/example_dags/example_agent.py | 12 +-
.../ai/example_dags/example_agent_durable.py | 4 +-
.../ai/example_dags/example_document_loader.py | 10 +-
.../ai/example_dags/example_langchain_hook.py | 8 +-
.../example_dags/example_langchain_tool_agent.py | 2 +-
.../ai/example_dags/example_llamaindex_hook.py | 8 +-
.../ai/example_dags/example_llamaindex_rag.py | 7 +-
.../common/ai/example_dags/example_llm.py | 14 +-
.../example_dags/example_llm_analysis_pipeline.py | 2 +-
.../common/ai/example_dags/example_llm_branch.py | 8 +-
.../ai/example_dags/example_llm_classification.py | 2 +-
.../ai/example_dags/example_llm_file_analysis.py | 10 +-
.../ai/example_dags/example_llm_schema_compare.py | 10 +-
.../common/ai/example_dags/example_llm_sql.py | 12 +-
.../ai/example_dags/example_llm_survey_agentic.py | 2 +-
.../ai/example_dags/example_llm_survey_analysis.py | 4 +-
.../common/ai/example_dags/example_mcp.py | 4 +-
.../ai/example_dags/example_pydantic_ai_hook.py | 6 +-
.../airflow/providers/common/ai/mixins/approval.py | 9 +
.../airflow/providers/common/ai/operators/agent.py | 8 +
.../airflow/providers/common/ai/operators/llm.py | 8 +
.../providers/common/ai/operators/llm_sql.py | 8 +
.../providers/common/ai/utils/validation.py | 91 +
.../tests/unit/common/ai/decorators/test_agent.py | 50 +-
.../ai/tests/unit/common/ai/decorators/test_llm.py | 45 +-
.../unit/common/ai/decorators/test_llm_branch.py | 37 +-
.../ai/decorators/test_llm_schema_compare.py | 35 +-
.../unit/common/ai/decorators/test_llm_sql.py | 45 +-
.../tests/unit/common/ai/mixins/test_approval.py | 5 +
.../tests/unit/common/ai/operators/test_agent.py | 27 +
.../ai/tests/unit/common/ai/operators/test_llm.py | 27 +
.../tests/unit/common/ai/operators/test_llm_sql.py | 26 +
.../tests/unit/common/ai/utils/test_validation.py | 129 +
.../common/sql/example_dags/example_analytics.py | 2 +-
providers/edge3/docs/architecture.rst | 1 +
providers/edge3/docs/ui_plugin.rst | 3 +-
providers/edge3/pyproject.toml | 2 +-
.../providers/edge3/example_dags/win_notepad.py | 2 +-
.../providers/edge3/example_dags/win_test.py | 2 +-
.../src/airflow/providers/edge3/worker_api/auth.py | 8 -
.../providers/edge3/worker_api/datamodels.py | 24 +-
providers/elasticsearch/docs/changelog.rst | 8 +
providers/elasticsearch/docs/logging/index.rst | 93 +
.../elasticsearch/log/es_json_formatter.py | 20 +-
.../providers/elasticsearch/log/es_task_handler.py | 25 +
.../providers/elasticsearch/version_compat.py | 8 +-
.../tests/unit/elasticsearch/log/conftest.py | 52 +
providers/fab/pyproject.toml | 2 +-
.../hashicorp/_internal_client/vault_client.py | 50 +-
.../src/airflow/providers/hashicorp/hooks/vault.py | 8 +-
.../airflow/providers/hashicorp/secrets/vault.py | 2 +-
.../_internal_client/test_vault_client.py | 198 +-
.../tests/unit/hashicorp/hooks/test_vault.py | 28 +-
.../microsoft/azure/operators/test_data_factory.py | 20 +-
providers/opensearch/docs/changelog.rst | 8 +
providers/opensearch/docs/logging/index.rst | 36 +-
.../providers/opensearch/log/os_json_formatter.py | 20 +-
.../providers/opensearch/log/os_task_handler.py | 25 +
.../airflow/providers/opensearch/version_compat.py | 2 +
.../tests/unit/opensearch/log/conftest.py | 52 +
.../oracle/example_dags/example_oracle.py | 1 +
.../example_dags/example_bash_decorator.py | 2 +-
.../example_external_task_marker_dag.py | 4 +-
.../standard/example_dags/example_latest_only.py | 2 +-
pyproject.toml | 21 +-
scripts/ci/prek/check_example_dag_tags.py | 137 +
.../ci/prek/check_supervisor_schemas_versions.py | 204 +
scripts/ci/prek/dump_supervisor_schemas.py | 55 +
.../prek/generate_supervisor_schemas_snapshot.py | 104 +
.../docker/install_from_docker_context_files.sh | 7 +-
scripts/in_container/bin/generate_mprocs_config.py | 14 +-
scripts/in_container/bin/run_tmux | 9 +-
.../in_container/install_airflow_and_providers.py | 15 +-
scripts/pyproject.toml | 2 +-
.../tests/ci/prek/test_check_example_dag_tags.py | 109 +
scripts/tools/setup_breeze | 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/.pre-commit-config.yaml | 1 +
task-sdk/pyproject.toml | 2 +-
.../airflow/sdk/execution_time/schema/AGENTS.md | 122 +
.../airflow/sdk/execution_time/schema/__init__.py | 128 +
.../airflow/sdk/execution_time/schema/migrator.py | 215 +
.../airflow/sdk/execution_time/schema/schema.json | 6131 ++++++++++++++++++++
.../execution_time/schema/versions}/__init__.py | 9 +-
.../src/airflow/sdk/execution_time/supervisor.py | 52 +-
task-sdk/src/airflow/sdk/timezone.py | 2 +
.../task_sdk/execution_time/schema}/__init__.py | 0
.../execution_time/schema/_mock_version_bundle.py | 189 +
.../execution_time/schema/test_integration.py | 338 ++
.../execution_time/schema/test_migrator.py | 336 ++
uv.lock | 1940 ++++---
216 files changed, 11874 insertions(+), 1754 deletions(-)
rename
airflow-core/src/airflow/migrations/versions/{0114_3_3_0_add_allow_producer_teams_to_dag_schedule_asset_reference.py
=> 0114_3_3_0_add_access_control_columns_to_dag_schedule_asset_reference.py}
(79%)
copy airflow-core/src/airflow/ui/src/utils/{useContainerWidth.ts =>
useDocumentTitle.ts} (62%)
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/validation.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_validation.py
create mode 100644
providers/elasticsearch/tests/unit/elasticsearch/log/conftest.py
create mode 100644 providers/opensearch/tests/unit/opensearch/log/conftest.py
create mode 100755 scripts/ci/prek/check_example_dag_tags.py
create mode 100755 scripts/ci/prek/check_supervisor_schemas_versions.py
create mode 100755 scripts/ci/prek/dump_supervisor_schemas.py
create mode 100755 scripts/ci/prek/generate_supervisor_schemas_snapshot.py
create mode 100644 scripts/tests/ci/prek/test_check_example_dag_tags.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/schema/AGENTS.md
create mode 100644 task-sdk/src/airflow/sdk/execution_time/schema/__init__.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/schema/migrator.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/schema/schema.json
copy {dev/mypy/src/airflow_mypy =>
task-sdk/src/airflow/sdk/execution_time/schema/versions}/__init__.py (86%)
copy {airflow-core/src/airflow/_shared =>
task-sdk/tests/task_sdk/execution_time/schema}/__init__.py (100%)
create mode 100644
task-sdk/tests/task_sdk/execution_time/schema/_mock_version_bundle.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/schema/test_integration.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/schema/test_migrator.py
