This is an automated email from the ASF dual-hosted git repository.
vatsrahul1001 pushed a change to branch backport-57aedbf-v3-4-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 93d7f98c521 [v3-4-test] Reveal selected Dag folders when names contain
pipes (#75196)
add cf572db9553 [v3-4-test] CI: Upgrade important CI environment (#75313)
add 726da9b7a72 Bump the 3-4-auth-ui-package-updates group across 1
directory with 15 updates (#75290)
add b3df7d847e8 [v3-4-test] Skip inclusive-language check for non-English
UI translations (#75247) (#75249)
add da27a72a271 [v3-4-test] Fix task instance filtering for null start
dates (#75321) (#75324)
add 3e6f2d96f27 Bump the github-actions-updates group with 7 updates
(#75292)
add 99ff4e13c19 Bump the 3-4-ui-plugin-template-package-updates group
across 1 directory with 8 updates (#75283)
add 2976fe3a48e Bump the 3-4-registry-package-updates group across 1
directory with 2 updates (#75280)
add 46f3badb3df [v3-4-test] Warn about oversized task state values from
language SDK tasks (#74945) (#75299)
add 6494b4e2802 [v3-4-test] Show errors when the task clear confirmation
check fails (#75269) (#75331)
add 824fef04e72 [v3-4-test] Add missing Taiwanese Mandarin UI translations
(#75278)
add 832602523ea [v3-4-test] Enforce execution_timeout for tasks run by a
language SDK (#74869) (#75376)
add 02c43a1dd58 [v3-4-test] Fix duplicate pending Dag runs for the same
asset partition key (#71074) (#75382)
add 9cd18837534 [v3-4-test] Make Java SDK context signal-aware (#74690)
(#75386)
add d2e3c4efe38 [v3-4-test] UI: Render Arabic durations with the correct
plural form (#72604) (#75323)
add dc0c47de6bd [v3-4-test] Go SDK: Write the edge label text before the
task (#75185) (#75365)
add 906677b700e [v3-4-test] Add missing Taiwanese Mandarin translations
for Dag start/end date trigger messages (#75371) (#75372)
add 40cc196f740 [v3-4-test] Go SDK: Rewrite the user docs around Dag
definition (#74698) (#75383)
add 87081ed4621 [v3-4-test] Upgrade important CI environment (#75375)
add 0873fcdab3b [v3-4-test] TS SDK: Bump to 1.0.0-beta1 and align README
with the guide (#74693) (#75300)
add 37fcddf4c1d [v3-4-test] Show source code lines in task log tracebacks
(#75100) (#75355)
add 8f1ee9b9262 [v3-4-test] Close German Translation Gaps 2026-10-19
(#75137) (#75389)
add dafddb2220e [v3-4-test] Keep the multiselect filter pill's focus ring
visible (#75307) (#75398)
add af57a7a6a73 [v3-4-test] Wait for variable form validation before
asserting Save is enabled (#75239) (#75353)
add 65a67bb411f [v3-4-test] TS SDK: Reject blank edge labels and label
task edges into groups (#75190) (#75385)
add 78b65180b16 [v3-4-test] Fix empty audit log dag_id for DAG.cli()
subcommands (#73379) (#75388)
add 63f9ab0e144 [v3-4-test] Read a team's running task logs through the
team's executor (#75255) (#75408)
add c07dc92d5dc [v3-4-test] Fix tasks clear --task-regex matching as a
plain substring (#72941) (#75325)
add 5af4c1fc2cc [v3-4-test] Reveal selected Dag folders when names contain
pipes (#75196)
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 (93d7f98c521)
\
N -- N -- N refs/heads/backport-57aedbf-v3-4-test (5af4c1fc2cc)
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/workflows/airflow-e2e-tests.yml | 2 +-
.github/workflows/asf-allowlist-check.yml | 2 +-
.github/workflows/basic-tests.yml | 2 +-
.github/workflows/ci-amd.yml | 2 +-
.github/workflows/ci-arm.yml | 2 +-
.github/workflows/ci-image-build.yml | 8 +-
.github/workflows/ci-image-checks.yml | 2 +-
.github/workflows/codeql-analysis.yml | 8 +-
.../java-sdk-dependabot-verification-metadata.yml | 2 +-
.github/workflows/java-sdk-dependency-security.yml | 2 +-
.github/workflows/java-sdk-release-verify.yml | 4 +-
.github/workflows/k8s-tests.yml | 2 +-
.github/workflows/prod-image-build.yml | 2 +-
.github/workflows/publish-docs-to-s3.yml | 2 +-
.../scheduled-legacy-prod-image-canary.yml | 2 +-
.pre-commit-config.yaml | 2 +-
Dockerfile | 4 +-
Dockerfile.ci | 4 +-
.../authoring-and-scheduling/language-sdks/go.rst | 997 ++++++++++++---------
.../language-sdks/java.rst | 47 +
.../language-sdks/typescript.rst | 115 ++-
airflow-core/docs/core-concepts/tasks.rst | 8 +-
airflow-core/docs/migrations-ref.rst | 5 +-
.../auth/managers/simple/ui/package.json | 30 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 938 +++++++++----------
.../core_api/routes/public/task_instances.py | 14 +-
.../execution_api/datamodels/taskinstance.py | 7 +
.../execution_api/routes/task_instances.py | 11 +-
.../execution_api/services/task_instances.py | 32 +-
.../api_fastapi/execution_api/versions/__init__.py | 2 +
.../execution_api/versions/v2026_10_30.py | 14 +
airflow-core/src/airflow/assets/manager.py | 281 +++---
.../src/airflow/cli/commands/task_command.py | 12 +-
.../src/airflow/executors/executor_loader.py | 36 +
...0148_3_4_0_add_pending_partition_key_to_apdr.py | 84 ++
airflow-core/src/airflow/models/asset.py | 33 +-
.../airflow/serialization/serialized_objects.py | 9 +-
.../airflow/ui/public/i18n/locales/de/admin.json | 2 +
.../airflow/ui/public/i18n/locales/de/common.json | 4 +
.../src/airflow/ui/public/i18n/locales/de/dag.json | 24 +
.../airflow/ui/public/i18n/locales/de/dags.json | 1 +
.../ui/public/i18n/locales/zh-TW/admin.json | 2 +
.../ui/public/i18n/locales/zh-TW/common.json | 11 +
.../ui/public/i18n/locales/zh-TW/components.json | 8 +
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 43 +-
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 1 +
.../ClearTaskInstanceConfirmationDialog.test.tsx | 185 ++++
.../ClearTaskInstanceConfirmationDialog.tsx | 20 +-
.../FilterBar/filters/MultiSelectPill.tsx | 9 +-
.../ui/src/components/renderStructuredLog.test.tsx | 30 +
.../ui/src/components/renderStructuredLog.tsx | 10 +-
.../airflow/ui/src/i18n/dayjsArabicPlurals.test.ts | 126 +++
.../src/airflow/ui/src/i18n/dayjsArabicPlurals.ts | 82 ++
.../src/airflow/ui/src/i18n/dayjsLocale.test.ts | 5 +-
.../src/airflow/ui/src/i18n/dayjsLocale.ts | 4 +
.../Variables/ManageVariable/VariableForm.test.tsx | 7 +-
airflow-core/src/airflow/utils/db.py | 2 +-
.../src/airflow/utils/log/file_task_handler.py | 17 +-
.../core_api/routes/public/test_task_instances.py | 28 +
.../versions/head/test_task_instances.py | 47 +
.../versions/v2026_10_30/test_task_instances.py | 34 +
airflow-core/tests/unit/assets/test_manager.py | 283 +++++-
.../tests/unit/cli/commands/test_task_command.py | 23 +
.../tests/unit/dag_processing/test_processor.py | 2 +-
.../tests/unit/executors/test_executor_loader.py | 48 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 2 +-
.../test_0148_add_pending_partition_key_to_apdr.py | 187 ++++
.../unit/serialization/test_dag_serialization.py | 18 +
airflow-core/tests/unit/utils/test_cli_util.py | 16 +
airflow-core/tests/unit/utils/test_log_handlers.py | 30 +
.../org/apache/airflow/e2e/TestBundleBuilder.java | 33 +-
.../src/resources/dags/java_test_dags.py | 12 +
airflow-e2e-tests/pyproject.toml | 2 +-
.../airflow_e2e_tests/e2e_test_utils/clients.py | 8 +
.../java_sdk_tests/test_java_sdk_dag.py | 56 ++
dev/breeze/doc/ci/02_images.md | 4 +-
.../airflow_breeze/commands/kubernetes_commands.py | 2 +-
.../commands/release_management_commands.py | 4 +-
dev/breeze/src/airflow_breeze/global_constants.py | 4 +-
dev/breeze/uv.lock | 62 +-
.../react_plugin_template/package.json | 16 +-
.../react_plugin_template/pnpm-lock.yaml | 406 ++++-----
go-sdk/DEVELOPMENT.md | 215 +++++
go-sdk/README.md | 507 ++---------
go-sdk/adr/0008-native-dag-interface.md | 20 +-
go-sdk/airflow/conformance_test.go | 2 +-
go-sdk/airflow/dag.go | 6 +-
go-sdk/airflow/if_test.go | 2 +-
go-sdk/airflow/node.go | 240 +++--
go-sdk/airflow/node_test.go | 241 ++++-
go-sdk/airflow/serialize_test.go | 8 +-
go-sdk/airflow/task_group_test.go | 33 +-
go-sdk/example/README.md | 129 +++
go-sdk/example/native/main.go | 2 +-
go-sdk/internal/genspec/authoring.go | 2 +-
go-sdk/pkg/execution/client.go | 4 -
.../pkg/execution/genmodels/discriminators.gen.go | 8 +-
go-sdk/pkg/execution/genmodels/models.gen.go | 159 ++--
go-sdk/schema/supervisor-schema.json | 46 +-
.../main/kotlin/org/apache/airflow/sdk/Client.kt | 2 -
.../main/kotlin/org/apache/airflow/sdk/Context.kt | 50 ++
.../main/kotlin/org/apache/airflow/sdk/Server.kt | 29 +-
.../apache/airflow/sdk/execution/Cancellation.kt | 134 +++
.../org/apache/airflow/sdk/execution/Logger.kt | 4 +
.../kotlin/org/apache/airflow/sdk/ContextTest.kt | 14 +
.../kotlin/org/apache/airflow/sdk/ServerTest.kt | 292 ++++++
.../airflow/sdk/execution/CancellationTest.kt | 205 +++++
.../apache/airflow/sdk/execution/LogSenderTest.kt | 94 ++
kubernetes-tests/lang_sdk/ts_example/package.json | 2 +-
.../test_kubernetes_pod_operator.py | 2 +-
providers/amazon/README.rst | 4 +-
providers/amazon/docs/index.rst | 4 +-
providers/amazon/pyproject.toml | 4 +-
.../cncf/kubernetes/utils/xcom_sidecar.py | 2 +-
.../system/cncf/kubernetes/example_kubernetes.py | 2 +-
.../cncf/kubernetes/example_kubernetes_async.py | 2 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 6 +-
providers/hashicorp/docs/index.rst | 2 +-
providers/hashicorp/pyproject.toml | 2 +-
pyproject.toml | 2 +-
registry/package.json | 4 +-
registry/pnpm-lock.yaml | 160 ++--
scripts/tools/setup_breeze | 2 +-
.../src/airflow_shared/logging/structlog.py | 15 +-
shared/logging/tests/logging/test_structlog.py | 1 +
task-sdk/docs/ts-bundle-spec.rst | 2 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 1 +
.../src/airflow/sdk/coordinators/_subprocess.py | 35 +
task-sdk/src/airflow/sdk/definitions/dag.py | 3 +
task-sdk/src/airflow/sdk/execution_time/comms.py | 9 +-
.../airflow/sdk/execution_time/schema/schema.json | 46 +-
.../sdk/execution_time/schema/versions/__init__.py | 2 +
.../execution_time/schema/versions/v2026_10_30.py | 15 +
.../src/airflow/sdk/execution_time/supervisor.py | 33 +-
.../src/airflow/sdk/execution_time/task_runner.py | 4 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 86 ++
.../execution_time/schema/test_migrator.py | 10 +
.../task_sdk/execution_time/test_supervisor.py | 84 +-
.../task_sdk/execution_time/test_task_runner.py | 4 +-
ts-sdk/DEVELOPMENT.md | 14 +-
ts-sdk/README.md | 268 +-----
ts-sdk/api-docs/dag-authoring-api.ts | 2 +-
ts-sdk/docs/index.md | 43 +-
ts-sdk/docs/package-lock.json | 4 +-
ts-sdk/docs/package.json | 2 +-
ts-sdk/docs/tests/deployment-checks.test.mjs | 4 +-
ts-sdk/example/README.md | 80 +-
ts-sdk/example/package.json | 2 +-
ts-sdk/package.json | 2 +-
ts-sdk/schema/supervisor-schema.json | 46 +-
.../ci/prek/check_serialization_conformance.py | 2 +-
ts-sdk/src/coordinator/client.ts | 3 -
ts-sdk/src/coordinator/serde.ts | 36 +-
ts-sdk/src/generated/supervisor.ts | 42 +-
ts-sdk/src/index.ts | 2 +-
ts-sdk/src/sdk/dag-graph.ts | 19 +-
ts-sdk/src/sdk/dag.ts | 209 ++++-
ts-sdk/tests/conformance/serialize_typescript.ts | 7 +-
ts-sdk/tests/coordinator/serde.test.ts | 220 ++++-
ts-sdk/tests/public-api.test.ts | 10 +-
ts-sdk/tests/sdk/branching.test.ts | 8 +-
ts-sdk/tests/sdk/conditional.test.ts | 10 +-
ts-sdk/tests/sdk/dag.test.ts | 133 ++-
uv.lock | 882 +++++++++---------
164 files changed, 6526 insertions(+), 3171 deletions(-)
create mode 100644
airflow-core/src/airflow/migrations/versions/0148_3_4_0_add_pending_partition_key_to_apdr.py
create mode 100644
airflow-core/src/airflow/ui/src/components/Clear/TaskInstance/ClearTaskInstanceConfirmationDialog.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/i18n/dayjsArabicPlurals.test.ts
create mode 100644 airflow-core/src/airflow/ui/src/i18n/dayjsArabicPlurals.ts
create mode 100644
airflow-core/tests/unit/migrations/test_0148_add_pending_partition_key_to_apdr.py
create mode 100644 go-sdk/DEVELOPMENT.md
create mode 100644 go-sdk/example/README.md
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/execution/Cancellation.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/execution/CancellationTest.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/execution/LogSenderTest.kt
