This is an automated email from the ASF dual-hosted git repository.
kaxil pushed a change to branch commonai-hook-pinned-arguments
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard a24ccdee6c5 Let HookToolset pin arguments the model must not choose
discard a1cd3621c1e Add ObjectStorageToolset for reading files on object
storage
discard 2ad375c4573 Rework common.ai Strands support into a plugin and add
Google ADK
discard e0963432fdd Mask secrets in tool results before they reach the model
omit 10178177593 Mark experimental common.ai features ahead of 1.0
add 84f75158120 Require `common.sql` 2.2.0 for common.ai's SQL extras
(#73867)
add 3f60fa9e2c7 Fix Firefox and WebKit UI e2e runs failing at login
(#73872)
add ac88accf4ed Add bundle_name tag to missing dag processor metrics
(#73717)
add 7afece8efb0 Update providers metadata 2026-09-29 (#73884)
add 4b6606543fd Distinguish OpenAI batch timeout and cancellation in
deferrable tasks (#72149)
add 8b3d4d315fa Surface the retry policy decision on task instances page
(#73030)
add bc28bb0804c Go SDK: Fix the mixed language task handler binding
semantic (#73648)
add 9ebc2644741 Revert "Secrets backends order updated (#70681)" (#73891)
add 4e23910701b Go SDK: check Go naming conventions with staticcheck
(#73874)
add 0768924a0cd Automatically isolate `breeze testing` for each git
worktree in a totally isolated project. (#73836)
add 3e8318969e1 Add ADR for Lang SDK Dag and mixed-language Task
processing flow (#71929)
add e8d43932077 Add ADR for supporting Dynamic Dag Generation across
Language SDKs (#73518)
add 8d815efdbc3 Own the BaseAsyncOperator event loop through
asyncio.Runner (#73560)
add 647add72afe Mark experimental `common.ai` features ahead of 1.0
(#73896)
add 672de6cf0fc Mask secrets in tool results before they reach the model
add a291ac4df70 Rework common.ai Strands support into a plugin and add
Google ADK
add 04645c4f8a7 Add ObjectStorageToolset for reading files on object
storage
add cef8491ffe8 Let HookToolset pin arguments the model must not choose
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 (a24ccdee6c5)
\
N -- N -- N refs/heads/commonai-hook-pinned-arguments
(cef8491ffe8)
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:
.../0007-taskflow-across-language-boundary.md | 39 ++
.../adr/lang-sdk/0010-native-dag-processing.md | 212 ++++++++
.../lang-sdk/0011-mixed-language-dag-processing.md | 245 +++++++++
.../adr/lang-sdk/0012-lang-sdk-parse-protocol.md | 233 ++++++++
.../0013-persisted-task-handler-bindings.md | 593 +++++++++++++++++++++
.../0014-bundle-metadata-and-cache-digest.md | 122 +++++
airflow-core/adr/lang-sdk/README.md | 5 +
.../security/secrets/secrets-backend/index.rst | 23 +-
airflow-core/newsfragments/70681.significant.rst | 7 -
.../core_api/datamodels/task_instance_history.py | 19 +-
.../core_api/datamodels/task_instances.py | 18 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 107 +---
.../core_api/openapi/v2-rest-api-generated.yaml | 18 +
.../api_fastapi/core_api/routes/ui/config.py | 45 +-
.../src/airflow/config_templates/config.yml | 34 --
airflow-core/src/airflow/configuration.py | 7 +-
airflow-core/src/airflow/dag_processing/manager.py | 19 +-
airflow-core/src/airflow/secrets/__init__.py | 4 +-
airflow-core/src/airflow/secrets/base_secrets.py | 5 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 6 -
.../ui/openapi-gen/queries/ensureQueryData.ts | 10 -
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 10 -
.../src/airflow/ui/openapi-gen/queries/queries.ts | 10 -
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 10 -
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 24 +
.../ui/openapi-gen/requests/services.gen.ts | 24 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 37 +-
.../airflow/ui/public/i18n/locales/en/admin.json | 2 -
.../airflow/ui/public/i18n/locales/en/common.json | 5 +
.../src/airflow/ui/src/components/StatsCard.tsx | 2 +-
.../ui/src/pages/TaskInstance/Details.test.tsx | 137 +++++
.../airflow/ui/src/pages/TaskInstance/Details.tsx | 16 +
.../ui/src/pages/TaskInstance/Header.test.tsx | 54 ++
.../airflow/ui/src/pages/TaskInstance/Header.tsx | 20 +
.../TaskInstance/stateReason.ts} | 35 +-
.../ui/src/pages/Variables/BackendsOrderCard.tsx | 45 --
.../ui/src/pages/Variables/BackendsOrderModal.tsx | 64 ---
.../airflow/ui/src/pages/Variables/Variables.tsx | 2 -
.../src/airflow/ui/tests/e2e/global-setup.ts | 14 +-
airflow-core/tests/unit/always/test_secrets.py | 121 -----
.../core_api/routes/public/test_hitl.py | 1 +
.../core_api/routes/public/test_task_instances.py | 93 ++++
.../api_fastapi/core_api/routes/ui/test_config.py | 62 ---
.../tests/unit/dag_processing/test_manager.py | 92 +++-
.../src/airflowctl/api/datamodels/generated.py | 14 +
.../go_sdk_tests/test_go_sdk_taskflow_binding.py | 72 ++-
dev/breeze/doc/03_developer_tasks.rst | 44 +-
dev/breeze/doc/04_troubleshooting.rst | 11 +
dev/breeze/doc/05_test_commands.rst | 14 +
dev/breeze/doc/images/output-commands.svg | 165 +++---
dev/breeze/doc/images/output_cleanup.svg | 2 +-
dev/breeze/doc/images/output_cleanup.txt | 2 +-
dev/breeze/doc/images/output_down.svg | 48 +-
dev/breeze/doc/images/output_down.txt | 2 +-
dev/breeze/doc/images/output_run.svg | 45 +-
dev/breeze/doc/images/output_run.txt | 2 +-
dev/breeze/doc/images/output_shell.svg | 285 +++++-----
dev/breeze/doc/images/output_shell.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 237 ++++----
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
.../doc/images/output_testing_core-tests.svg | 145 ++---
.../doc/images/output_testing_core-tests.txt | 2 +-
.../doc/images/output_testing_providers-tests.svg | 161 +++---
.../doc/images/output_testing_providers-tests.txt | 2 +-
.../src/airflow_breeze/commands/common_options.py | 10 +-
.../airflow_breeze/commands/developer_commands.py | 52 +-
.../commands/developer_commands_config.py | 2 +-
.../src/airflow_breeze/commands/main_command.py | 23 +-
.../airflow_breeze/commands/testing_commands.py | 12 +-
.../commands/testing_commands_config.py | 5 +-
dev/breeze/src/airflow_breeze/global_constants.py | 15 +-
.../src/airflow_breeze/params/shell_params.py | 9 +-
.../airflow_breeze/utils/docker_command_utils.py | 236 +++++---
dev/breeze/src/airflow_breeze/utils/path_utils.py | 10 +-
dev/breeze/tests/test_developer_commands.py | 38 +-
dev/breeze/tests/test_docker_command_utils.py | 417 ++++++++++++---
dev/breeze/tests/test_shell_params.py | 54 ++
generated/provider_metadata.json | 496 ++++++++++-------
go-sdk/.pre-commit-config.yaml | 7 +
go-sdk/README.md | 14 +-
go-sdk/adr/0006-cross-language-argument-binding.md | 15 +-
.../adr/0007-mixed-lang-task-handler-interface.md | 6 +-
go-sdk/airflow/bundle.go | 20 +-
go-sdk/airflow/task_handler.go | 10 +-
go-sdk/airflow/task_handler_test.go | 6 +-
.../cmd/airflow-go-pack/pack_integration_test.go | 4 +-
go-sdk/dags/go_examples.py | 28 +-
.../bundle/concurrentxcom/concurrentxcom_test.go | 2 +-
go-sdk/example/bundle/main.go | 14 +-
.../bundle/taskflowbinding/taskflowbinding.go | 61 ++-
.../bundle/taskflowbinding/taskflowbinding_test.go | 44 +-
go-sdk/internal/bundle/task.go | 2 +-
go-sdk/pkg/binding/binding.go | 56 +-
go-sdk/pkg/binding/binding_test.go | 106 +++-
go-sdk/pkg/execution/client.go | 22 +-
go-sdk/pkg/execution/client_test.go | 6 +-
go-sdk/pkg/execution/comms.go | 13 +-
go-sdk/pkg/execution/comms_test.go | 10 +-
go-sdk/pkg/execution/integration_test.go | 14 +-
go-sdk/pkg/execution/messages.go | 6 +-
go-sdk/pkg/execution/messages_test.go | 4 +-
go-sdk/sdk/sdk.go | 4 +-
providers/common/ai/README.rst | 4 +-
providers/common/ai/docs/index.rst | 4 +-
providers/common/ai/docs/retry_policies.rst | 55 +-
providers/common/ai/pyproject.toml | 4 +-
.../ai/example_dags/example_classifier_model.py | 8 +-
providers/openai/docs/changelog.rst | 19 +
.../src/airflow/providers/openai/exceptions.py | 11 +
.../src/airflow/providers/openai/hooks/openai.py | 50 +-
.../airflow/providers/openai/operators/openai.py | 63 ++-
.../airflow/providers/openai/triggers/openai.py | 19 +-
.../openai/tests/unit/openai/hooks/test_openai.py | 36 ++
.../tests/unit/openai/operators/test_openai.py | 114 +++-
.../openai/tests/unit/openai/test_exceptions.py | 15 +-
.../tests/unit/openai/triggers/test_openai.py | 47 +-
scripts/ci/docker-compose/backend-mysql.yml | 6 +
scripts/ci/docker-compose/backend-postgres.yml | 8 +-
scripts/ci/docker-compose/base.yml | 9 +
.../ci/docker-compose/integration-cassandra.yml | 5 +
scripts/ci/docker-compose/integration-celery.yml | 8 +
scripts/ci/docker-compose/integration-drill.yml | 5 +
.../docker-compose/integration-elasticsearch.yml | 5 +
scripts/ci/docker-compose/integration-kafka.yml | 2 +
scripts/ci/docker-compose/integration-kerberos.yml | 7 +
scripts/ci/docker-compose/integration-keycloak.yml | 2 +
.../ci/docker-compose/integration-localstack.yml | 2 +
scripts/ci/docker-compose/integration-mongo.yml | 5 +
scripts/ci/docker-compose/integration-mssql.yml | 5 +
.../ci/docker-compose/integration-openlineage.yml | 5 +
.../ci/docker-compose/integration-opensearch.yml | 5 +
scripts/ci/docker-compose/integration-otel.yml | 11 +
scripts/ci/docker-compose/integration-pinot.yml | 2 +
scripts/ci/docker-compose/integration-qdrant.yml | 2 +
scripts/ci/docker-compose/integration-redis.yml | 7 +
scripts/ci/docker-compose/integration-statsd.yml | 8 +
.../ci/docker-compose/integration-tinkerpop.yml | 5 +
scripts/ci/docker-compose/integration-trino.yml | 5 +
scripts/ci/docker-compose/integration-ydb.yml | 2 +
scripts/ci/docker-compose/local-all-sources.yml | 6 +
scripts/ci/docker-compose/local.yml | 6 +
.../configuration/secrets_backends.py | 88 ---
.../observability/metrics/metrics_template.yaml | 5 +-
task-sdk/src/airflow/sdk/bases/operator.py | 69 ++-
task-sdk/src/airflow/sdk/configuration.py | 10 +-
.../airflow/sdk/execution_time/secrets/__init__.py | 9 +-
.../src/airflow/sdk/execution_time/supervisor.py | 3 +-
.../src/airflow/sdk/execution_time/task_runner.py | 8 +-
task-sdk/tests/task_sdk/bases/test_operator.py | 171 ++++++
.../tests/task_sdk/execution_time/test_context.py | 13 +-
.../tests/task_sdk/execution_time/test_secrets.py | 3 +-
.../task_sdk/execution_time/test_task_runner.py | 24 +
152 files changed, 4774 insertions(+), 1972 deletions(-)
create mode 100644 airflow-core/adr/lang-sdk/0010-native-dag-processing.md
create mode 100644
airflow-core/adr/lang-sdk/0011-mixed-language-dag-processing.md
create mode 100644 airflow-core/adr/lang-sdk/0012-lang-sdk-parse-protocol.md
create mode 100644
airflow-core/adr/lang-sdk/0013-persisted-task-handler-bindings.md
create mode 100644
airflow-core/adr/lang-sdk/0014-bundle-metadata-and-cache-digest.md
delete mode 100644 airflow-core/newsfragments/70681.significant.rst
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskInstance/Details.test.tsx
copy airflow-core/src/airflow/ui/src/{components/StateBadge.tsx =>
pages/TaskInstance/stateReason.ts} (54%)
delete mode 100644
airflow-core/src/airflow/ui/src/pages/Variables/BackendsOrderCard.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/pages/Variables/BackendsOrderModal.tsx
delete mode 100644
shared/configuration/src/airflow_shared/configuration/secrets_backends.py
