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
discard 2202b5c5b75 Bump the eslint group across 1 directory with 4 updates
add 77c29134b37 Load Java Dags from a bundle path that holds a colon
(#76432)
add 3fd90eb41c0 UI: Complete the Spanish (es) translation (#76087)
add 4ef770b91d6 Let asset watchers write asset state over the Execution
API (#76376)
add cd3ae408a1a Keep mapped tasks when clearing with run on latest version
(#76420)
add 5d70b49e9ea UI: Label the Dag bundle file table as Parsed Files and
say what it lists (#76462)
add 240e6eed65c Parametrize GCS-to-GCS wildcard and retention tests.
(#76094)
add d07cb5f727d Fix airflowctl backfill create-dry-run printing one
all-null row (#76224)
add 7b00cf0835a Add GET /triggers to list every trigger of every kind and
its status (#76260)
add 596dd41485c Stop airflowctl sending an old token to a new API URL
(#76287)
add 6920d2c25f4 Escape Rich markup in airflowctl variable and pool
commands (#76419)
add 6f2de5abe97 add stephen-bracken to fork-ci-gate (#76316)
add 0ae09c32182 Install apt-utils matching the image's apt on hardened
images (#76484)
add b2f327748b8 Restore default ELK node placement in Graph view (#76488)
add 1b792598b6d Support native asset partitions in watcher events (#74852)
add 953d7ff3d6a Hide "View error" on bundle files the user cannot read
(#76479)
add 6858cb6c3a2 Refresh expired AWS credentials in AwsDuckDBHook (#76086)
add f05c32e10e1 Lower severity of handled XCom misses (#73198)
add 94018444cdf Ship the Dag bundle permission in Airflow 3.4.1 (#76474)
add 9391e6a7a48 Remove machine-global pnpm config causing .pnpm-store dir
to be created in places (#76498)
add c52946c9c9c Clarify Dag bundle permission upgrade notes (#76499)
add a1be2c1ce30 Fix Google Cloud connection IdP extra request parameters
being ignored (#76161)
add 494f65e0f68 Fix async engine datetimes being shifted on non-UTC MySQL
servers (#76505)
add 8ee215945aa Apply timeout_seconds and connection proxies to dbt Cloud
sync requests (#74684)
add 0d5f53297a0 Add unit tests for Dataproc, GKE and Translate provider
links (#75694)
add 7ee853093ec Apply note before state in bulk Dag run update so
listeners see it (#74890)
add 1948af1fedb Add unit tests for PrestoToGCSOperator (#75559)
add 57793d01d9b Import TriggerRule from airflow.sdk in docs examples
(#76522)
add 776e9d2e78a Cache the dialect on PostgresHook and MsSqlHook (#75656)
add cc786845ad3 Build the ADBC database URI from the connection fields
(#74454)
add 31beac5deea disable external entities in SAML idp response parsing
(#71423)
add 750617c3867 Fix entry-point plugins reported as duplicates on
RHEL/Fedora venvs (#74531)
add f14247a5938 Add a general debugging guide to the troubleshooting doc
(#71457)
add ebe49645e34 Move XCom filter param models into execution API
datamodels (#76536)
add 437f6be3cec Run the durable OpenAI Agents tests in the agent framework
CI job (#76500)
add 7625b59a85e Key LLM batch and durable Strands state on the task loop
iteration (#76201)
add d46d97fa8d5 Note the unparseable-output case in OpenAIResponseOperator
XCom docs (#74519)
add b7ceab0372b Support Workload Identity Federation in Snowflake REST API
authentication (#75810)
add f82542a453a Name the caller's own MCP client and durable setup in
Common AI errors (#76495)
add 8e922e329ab Refactor isinstance dispatching with polymorphism (#74634)
add e3c21b77c97 Update French (fr) UI translations to 100% coverage
(#76460)
add dcbf21690e8 Pass AssetStateStoreAccessors into response_check_path
Callable in HttpEventTrigger (#72287)
add 6cf8ed6c63a UI: Translate the Spanish strings added since the last
pass (#76466)
add b5ab0a15174 UI: Defer React plugin compatibility runtime (#75083)
add b0581660e45 Support fail_on_reject on every LLM approval operator
(#74493)
add 24464f6d728 Keep Dag and deadline list serialization off the API
server event loop (#76525)
add 020259387b9 Support multimodal prompts with enable_hitl_review in
AgentOperator (#74389)
add c4eaf4b8399 Prepare providers release 2026-11-03 (#76490)
add 3eacdb97dfd Sanitize error message in DatabricksExecutionTrigger
(#70385)
add 8529c41db15 Add environment_variables to MWAA Serverless create/update
workflow operators (#76496)
add c8d8df3353d Add `@task.modal` to run Python functions on Modal without
Airflow in the image (#76502)
add bca1e144da1 Add raphaelauv to fork-ci-gate (#76538)
add 71a19df58c5 Write container logs to the task log in deferrable
AzureContainerInstancesOperator (#76330)
add 6bacb63888f Complete Dutch translations (2026-10-05) (#74286)
add 77762c256df Add `partition_key` to the `DagRun Finished` log line
(#76557)
add 1f4bc05aa0a Allow Human-in-the-loop tasks to be answered while still
running (#75413)
add c7fcba0106a Stop holding openai below 3 in Airflow's CI image and
constraints (#76503)
add 322c178e05b Fix duplicated asset events when name_prefix_pattern
matches all (#74816)
add 1fe65f5f13a Keep parallel tool results replayable across retries in
OpenAI Agents durable runs (#76015)
add 3204b6ebebb Fix enum names and non-ISO dates in airflowctl dags output
(#76354)
add cc1dfb94296 Remove deprecated project_id from BigQueryGetDataOperator
(#76115)
add 2e9ae2a1999 Split mixed OpenLineage tests into unit and integration
(#75642)
add 1e0e003cea8 Template conn_id and config_kwargs in @task.pyspark
(#75764)
add a04fda49d1a Mark MSGraphAsyncOperator as durable capable (#76576)
add 92fa9b36b09 Fix skill call counts and source links in the AI Model tab
(#76541)
add e10575d5479 Release the Java SDK 1.0.0 and pin its schema URL to the
published docs site (#75944)
add 48a35ccd2d8 Fix S3ToAzureBlobStorageOperator failing on S3 folder
markers (#76408)
add e0b7126d573 Let a final release override the
pending-provider-candidate guard (#76592)
add 1f764a2e118 Add Russian (ru) translation agent skill guideline (#76579)
add f90d2607dd4 Return 404 when a DagRun disappears during task API writes
(#72907)
add f5234c744a1 Harden OpenLineage task outcomes system test (#76595)
add 82b33126d3a Chart: Default airflow version to 3.4.0 (#76601)
add c2ff56eff6b UI: Complete the Portuguese translation (#76412)
add a0924b53f86 Mark Airflow 3.4.0 as the latest released version (#76602)
add f396a3b2271 Add Cloud SQL Auth Proxy v2 support to CloudSqlProxyRunner
(#73646)
add a7b8dc96928 Give the SMTP emailer its own defaults for the [smtp]
options (#76346)
add 498c1cd470c Fix CeleryExecutor failing to load with Celery 5.7 (#76591)
add c8e01650d56 Add a regression test for WITH in the asset orphanage
DELETE (#75127)
add 887f6d2b559 Keep Dag parse results tied to their source snapshot
(#74789)
add dac96bcf61c Publish Dag results and inventories through the Execution
API (#74790)
add f2edf564af4 Recover Dag processor work and expire inactive processors
(#74791)
add 2c69a21eb65 Add HTTP publication to the Dag processor manager (#74793)
add f01f7ef65d6 Make the Variable value non-nullable in the Execution API
(#76007)
add 335fd71f58f Stop AWS Glue job run when a deferred task is cleared
(#73702)
add abc3a20f080 Escape server and user text in airflowctl command messages
(#76265)
add eb62442d42c 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 (2202b5c5b75)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/eslint-e5a7eb1da6
(eb62442d42c)
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/SKILL.md | 1 +
.agents/skills/airflow-translations/locales/es.md | 34 +-
.agents/skills/airflow-translations/locales/pt.md | 26 +
.agents/skills/airflow-translations/locales/ru.md | 242 ++
.github/fork-ci-gate.toml | 2 +
.github/workflows/agent-framework-tests.yml | 2 +-
.github/workflows/release-constraints.yml | 16 +-
Dockerfile | 28 +-
Dockerfile.ci | 43 +-
README.md | 12 +-
RELEASE_NOTES.rst | 1099 ++++++-
.../administration-and-deployment/dag-bundles.rst | 43 +
.../administration-and-deployment/listeners.rst | 13 +
.../logging-monitoring/index.rst | 1 +
.../logging-monitoring/triggers.rst | 122 +
.../docs/authoring-and-scheduling/assets.rst | 2 +
.../authoring-and-scheduling/event-scheduling.rst | 13 +
.../language-sdks/java.rst | 21 +
airflow-core/docs/best-practices.rst | 4 +-
airflow-core/docs/faq.rst | 3 +-
.../docs/installation/supported-versions.rst | 2 +-
airflow-core/docs/migrations-ref.rst | 8 +-
airflow-core/docs/security/api_permissions_ref.rst | 8 +
airflow-core/docs/troubleshooting.rst | 129 +
airflow-core/newsfragments/74789.significant.rst | 12 +
airflow-core/newsfragments/76007.significant.rst | 22 +
airflow-core/newsfragments/76474.significant.rst | 15 +
.../src/airflow/api_fastapi/common/db/assets.py | 5 +-
.../airflow/api_fastapi/common/parameters/misc.py | 10 +-
.../api_fastapi/common/parameters/trigger.py | 133 +
.../api_fastapi/core_api/datamodels/assets.py | 5 +-
.../api_fastapi/core_api/datamodels/dag_bundles.py | 6 +
.../api_fastapi/core_api/datamodels/dags.py | 4 +-
.../api_fastapi/core_api/datamodels/trigger.py | 74 +
.../api_fastapi/core_api/datamodels/ui/deadline.py | 2 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 16 +
.../core_api/openapi/v2-rest-api-generated.yaml | 441 +++
.../api_fastapi/core_api/routes/public/__init__.py | 2 +
.../api_fastapi/core_api/routes/public/assets.py | 11 +-
.../core_api/routes/public/dag_bundles.py | 20 +-
.../core_api/routes/public/dag_parsing.py | 18 +
.../api_fastapi/core_api/routes/public/dags.py | 7 +-
.../api_fastapi/core_api/routes/public/hitl.py | 6 +-
.../core_api/routes/public/task_state_store.py | 5 +-
.../api_fastapi/core_api/routes/public/triggers.py | 285 ++
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 9 +-
.../api_fastapi/core_api/routes/ui/deadlines.py | 2 +-
.../src/airflow/api_fastapi/core_api/security.py | 91 +-
.../core_api/services/public/dag_run.py | 4 +-
.../core_api/services/public/import_errors.py | 76 +
.../execution_api/datamodels/dag_parsing.py | 201 ++
.../api_fastapi/execution_api/datamodels/job.py | 4 +-
.../execution_api/datamodels/variable.py | 4 +-
.../api_fastapi/execution_api/datamodels/xcom.py | 19 +
.../api_fastapi/execution_api/in_process.py | 3 +-
.../api_fastapi/execution_api/routes/__init__.py | 2 +
.../execution_api/routes/asset_state_store.py | 18 +-
.../execution_api/routes/dag_parsing.py | 630 ++++
.../api_fastapi/execution_api/routes/hitl.py | 16 +-
.../api_fastapi/execution_api/routes/jobs.py | 22 +-
.../execution_api/routes/task_state_store.py | 17 +-
.../api_fastapi/execution_api/routes/xcoms.py | 22 +-
.../airflow/api_fastapi/execution_api/security.py | 38 +-
.../api_fastapi/execution_api/versions/__init__.py | 14 +-
.../execution_api/versions/v2025_08_10.py | 2 +-
.../execution_api/versions/v2026_10_30.py | 28 +-
.../versions/v2026_10_30_xcom_params.py | 35 -
.../execution_api/versions/v2027_02_28.py | 40 +-
.../src/airflow/config_templates/config.yml | 21 +-
.../src/airflow/dag_processing/api_client.py | 115 +-
.../src/airflow/dag_processing/bundles/base.py | 21 +-
.../src/airflow/dag_processing/bundles/local.py | 1 +
.../src/airflow/dag_processing/bundles/manager.py | 30 +-
.../src/airflow/dag_processing/claims.py | 24 +-
.../src/airflow/dag_processing/collection.py | 282 +-
.../src/airflow/dag_processing/maintenance.py | 155 +
airflow-core/src/airflow/dag_processing/manager.py | 1310 ++++++--
.../src/airflow/dag_processing/processor.py | 77 +-
.../src/airflow/dag_processing/requested_work.py | 139 +
.../src/airflow/dag_processing/timeouts.py | 22 +-
.../src/airflow/jobs/scheduler_job_runner.py | 4 +
.../src/airflow/jobs/triggerer_job_runner.py | 23 +-
.../src/airflow/listeners/spec/importerrors.py | 20 +-
...54_3_5_0_add_idempotency_key_to_hitl_detail.py} | 28 +-
...55_3_5_0_add_dag_processor_publication_state.py | 78 +
.../0156_3_5_0_add_processor_work_claims.py | 74 +
airflow-core/src/airflow/models/__init__.py | 2 +
airflow-core/src/airflow/models/callback.py | 4 +
airflow-core/src/airflow/models/dag.py | 1 +
...log.py => dag_processor_publication_receipt.py} | 31 +-
...dag_favorite.py => dag_processor_work_claim.py} | 23 +-
airflow-core/src/airflow/models/dagbag.py | 16 +-
airflow-core/src/airflow/models/dagbundle.py | 3 +
airflow-core/src/airflow/models/dagcode.py | 2 +-
airflow-core/src/airflow/models/dagrun.py | 15 +-
airflow-core/src/airflow/models/dagwarning.py | 30 +-
airflow-core/src/airflow/models/errors.py | 4 +-
airflow-core/src/airflow/models/hitl.py | 43 +
airflow-core/src/airflow/models/trigger.py | 131 +-
.../src/airflow/serialization/definitions/dag.py | 2 +
.../airflow/serialization/serialized_objects.py | 18 +-
airflow-core/src/airflow/settings.py | 1 +
airflow-core/src/airflow/state/metastore.py | 5 +-
airflow-core/src/airflow/triggers/base.py | 31 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 24 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 48 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 48 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 48 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 48 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 320 +-
.../ui/openapi-gen/requests/services.gen.ts | 75 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 206 ++
airflow-core/src/airflow/ui/pnpm-lock.yaml | 36 +-
airflow-core/src/airflow/ui/public/i18n/README.md | 1 +
.../airflow/ui/public/i18n/locales/ar/browse.json | 13 +-
.../airflow/ui/public/i18n/locales/ca/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/de/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/el/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/en/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/es/admin.json | 15 +
.../airflow/ui/public/i18n/locales/es/assets.json | 5 +
.../airflow/ui/public/i18n/locales/es/browse.json | 36 +
.../airflow/ui/public/i18n/locales/es/common.json | 90 +-
.../ui/public/i18n/locales/es/components.json | 45 +-
.../src/airflow/ui/public/i18n/locales/es/dag.json | 138 +-
.../airflow/ui/public/i18n/locales/es/dags.json | 39 +-
.../ui/public/i18n/locales/es/dashboard.json | 22 +-
.../airflow/ui/public/i18n/locales/es/hitl.json | 3 +
.../airflow/ui/public/i18n/locales/fr/admin.json | 3 +
.../airflow/ui/public/i18n/locales/fr/browse.json | 9 +-
.../airflow/ui/public/i18n/locales/fr/common.json | 34 +-
.../ui/public/i18n/locales/fr/components.json | 13 +
.../src/airflow/ui/public/i18n/locales/fr/dag.json | 68 +-
.../airflow/ui/public/i18n/locales/fr/dags.json | 14 +-
.../ui/public/i18n/locales/fr/dashboard.json | 1 +
.../airflow/ui/public/i18n/locales/fr/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/he/browse.json | 7 +-
.../airflow/ui/public/i18n/locales/hi/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/ko/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/nl/admin.json | 26 +-
.../airflow/ui/public/i18n/locales/nl/assets.json | 18 +-
.../airflow/ui/public/i18n/locales/nl/browse.json | 34 +
.../airflow/ui/public/i18n/locales/nl/common.json | 227 +-
.../ui/public/i18n/locales/nl/components.json | 57 +-
.../src/airflow/ui/public/i18n/locales/nl/dag.json | 139 +-
.../airflow/ui/public/i18n/locales/nl/dags.json | 60 +-
.../ui/public/i18n/locales/nl/dashboard.json | 24 +-
.../airflow/ui/public/i18n/locales/nl/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/pl/browse.json | 9 +-
.../airflow/ui/public/i18n/locales/pt/admin.json | 33 +-
.../airflow/ui/public/i18n/locales/pt/assets.json | 39 +-
.../airflow/ui/public/i18n/locales/pt/browse.json | 60 +
.../airflow/ui/public/i18n/locales/pt/common.json | 314 +-
.../ui/public/i18n/locales/pt/components.json | 92 +-
.../src/airflow/ui/public/i18n/locales/pt/dag.json | 236 +-
.../airflow/ui/public/i18n/locales/pt/dags.json | 65 +-
.../ui/public/i18n/locales/pt/dashboard.json | 44 +-
.../airflow/ui/public/i18n/locales/pt/hitl.json | 15 +
.../ui/public/i18n/locales/zh-CN/browse.json | 5 +-
.../ui/public/i18n/locales/zh-TW/browse.json | 5 +-
.../ui/src/components/Graph/elkGraphUtils.test.ts | 14 +
.../ui/src/components/Graph/elkGraphUtils.ts | 3 -
.../ui/src/components/NeedsReviewButton.tsx | 3 +-
.../airflow/ui/src/hooks/useRequiredActionTabs.ts | 6 +-
airflow-core/src/airflow/ui/src/main.tsx | 19 +-
.../src/airflow/ui/src/mocks/handlers/assets.ts | 2 +-
.../ui/src/pages/DagBundle/BundleFiles.test.tsx | 62 +
.../airflow/ui/src/pages/DagBundle/BundleFiles.tsx | 20 +-
.../HITLTaskInstances/HITLTaskInstances.test.tsx | 11 +-
.../pages/HITLTaskInstances/HITLTaskInstances.tsx | 4 +-
.../src/airflow/ui/src/pages/ReactPlugin.test.tsx | 25 +-
.../src/airflow/ui/src/pages/ReactPlugin.tsx | 14 +-
airflow-core/src/airflow/ui/src/utils/hitl.test.ts | 48 +-
airflow-core/src/airflow/ui/src/utils/hitl.ts | 12 +-
.../src/utils/registerPluginDependencies.test.ts | 59 +
.../utils/registerPluginDependencies.ts} | 39 +-
airflow-core/src/airflow/utils/db.py | 2 +-
.../tests/unit/always/test_project_structure.py | 4 -
.../core_api/routes/public/test_assets.py | 5 +
.../core_api/routes/public/test_dag_bundles.py | 67 +
.../core_api/routes/public/test_dag_parsing.py | 118 +
.../core_api/routes/public/test_dag_run.py | 75 +
.../core_api/routes/public/test_dags.py | 18 +
.../core_api/routes/public/test_hitl.py | 46 +
.../routes/public/test_task_state_store.py | 51 +-
.../core_api/routes/public/test_triggers.py | 688 ++++
.../api_fastapi/core_api/routes/ui/test_dags.py | 30 +
.../core_api/routes/ui/test_deadlines.py | 12 +
.../execution_api/test_dag_processor_client.py | 2 +
.../api_fastapi/execution_api/test_security.py | 6 +-
.../execution_api/test_token_scope_boundaries.py | 10 +
.../versions/head/test_asset_events.py | 49 +-
.../versions/head/test_asset_state_store.py | 80 +-
.../versions/head/test_dag_parsing.py | 2137 ++++++++++++
.../execution_api/versions/head/test_hitl.py | 45 +
.../execution_api/versions/head/test_jobs.py | 56 +
.../versions/head/test_task_state_store.py | 38 +-
.../versions/v2026_10_30/test_task_state_store.py | 51 +
.../versions/v2027_02_28/test_jobs.py | 10 +
.../versions/v2027_02_28/test_variables.py | 65 +
airflow-core/tests/unit/core/test_settings.py | 44 +-
.../tests/unit/dag_processing/bundles/test_base.py | 6 +-
.../bundles/test_dag_bundle_manager.py | 48 +-
.../unit/dag_processing/bundles/test_local.py | 3 +
airflow-core/tests/unit/dag_processing/conftest.py | 67 +
.../tests/unit/dag_processing/test_api_client.py | 422 ++-
.../tests/unit/dag_processing/test_claims.py | 36 +-
.../tests/unit/dag_processing/test_collection.py | 59 +-
.../tests/unit/dag_processing/test_maintenance.py | 408 +++
.../tests/unit/dag_processing/test_manager.py | 3462 ++++++++++++++++++--
.../dag_processing/test_manager_api_failures.py | 351 ++
.../dag_processing/test_manager_api_inventory.py | 453 +++
.../dag_processing/test_manager_api_isolation.py | 206 ++
.../dag_processing/test_manager_api_results.py | 72 +
.../tests/unit/dag_processing/test_processor.py | 154 +-
.../unit/dag_processing/test_requested_work.py | 141 +
airflow-core/tests/unit/jobs/test_scheduler_job.py | 205 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 182 +-
.../tests/unit/listeners/test_importerrors.py | 85 +
.../test_0156_add_processor_work_claims.py | 165 +
airflow-core/tests/unit/models/test_cleartasks.py | 77 +
airflow-core/tests/unit/models/test_dagrun.py | 52 +-
airflow-core/tests/unit/models/test_dagwarning.py | 54 -
airflow-core/tests/unit/models/test_trigger.py | 129 +
.../unit/serialization/test_dag_serialization.py | 39 +
airflow-core/tests/unit/state/test_metastore.py | 5 +-
.../tests/unit/triggers/test_base_trigger.py | 15 +-
airflow-core/tests/unit/utils/test_db_cleanup.py | 2 +
.../airflowctl_tests/test_airflowctl_commands.py | 18 +
airflow-ctl/docs/cli-and-env-variables-ref.rst | 1 +
airflow-ctl/docs/howto/index.rst | 1 +
airflow-ctl/src/airflowctl/api/client.py | 29 +-
.../src/airflowctl/api/datamodels/generated.py | 217 +-
airflow-ctl/src/airflowctl/api/operations.py | 7 +-
.../src/airflowctl/ctl/commands/auth_command.py | 8 +-
.../src/airflowctl/ctl/commands/config_command.py | 3 +-
.../airflowctl/ctl/commands/connection_command.py | 5 +-
.../src/airflowctl/ctl/commands/dag_command.py | 15 +-
.../src/airflowctl/ctl/commands/pool_command.py | 3 +-
.../src/airflowctl/ctl/commands/task_command.py | 11 +-
.../airflowctl/ctl/commands/variable_command.py | 9 +-
airflow-ctl/src/airflowctl/ctl/utils/dag_run.py | 9 +-
airflow-ctl/tests/airflow_ctl/api/test_client.py | 86 +-
.../tests/airflow_ctl/api/test_operations.py | 24 +-
.../airflow_ctl/ctl/commands/test_auth_command.py | 69 +-
.../ctl/commands/test_config_command.py | 14 +-
.../ctl/commands/test_connections_command.py | 25 +
.../airflow_ctl/ctl/commands/test_dag_command.py | 96 +-
.../airflow_ctl/ctl/commands/test_pool_command.py | 33 +
.../airflow_ctl/ctl/commands/test_task_command.py | 48 +
.../ctl/commands/test_variable_command.py | 45 +
.../tests/airflow_ctl/ctl/utils/test_dag_run.py | 29 +
.../java-native-bundle/gradle.properties | 2 +-
.../java-test-bundle/gradle.properties | 2 +-
chart/Chart.yaml | 20 +-
chart/newsfragments/76601.significant.rst | 3 +
chart/values.schema.json | 4 +-
chart/values.yaml | 4 +-
contributing-docs/12_provider_distributions.rst | 6 +-
.../13_airflow_dependencies_and_extras.rst | 5 +
dev/README_RELEASE_AIRFLOW.md | 16 +
.../output_workflow-run_release-constraints.svg | 52 +-
.../output_workflow-run_release-constraints.txt | 2 +-
.../src/airflow_breeze/commands/release_command.py | 37 +-
.../airflow_breeze/commands/workflow_commands.py | 14 +-
.../commands/workflow_commands_config.py | 1 +
dev/breeze/src/airflow_breeze/global_constants.py | 6 +
.../airflow_breeze/utils/release_constraints.py | 67 +-
.../src/airflow_breeze/utils/verification_plan.py | 5 +
dev/breeze/tests/test_release_command.py | 77 +-
dev/breeze/tests/test_release_constraints.py | 65 +
dev/breeze/tests/test_workflow_commands.py | 21 +
.../src/tests_common/test_utils/markers.py | 19 +
docs/spelling_wordlist.txt | 29 +
generated/PYPI_README.md | 10 +-
generated/known_sdk_imports_in_core.txt | 4 +-
go-sdk/pkg/execution/client.go | 20 +-
.../pkg/execution/genmodels/discriminators.gen.go | 4 +
go-sdk/pkg/execution/genmodels/models.gen.go | 57 +-
go-sdk/schema/supervisor-schema.json | 105 +-
java-sdk/gradle.properties | 2 +-
java-sdk/sdk/build.gradle.kts | 2 +-
.../lang_sdk/java_example/gradle.properties | 2 +-
providers/.last_release_date.txt | 2 +-
providers/alibaba/README.rst | 6 +-
providers/alibaba/docs/changelog.rst | 12 +
providers/alibaba/docs/index.rst | 6 +-
providers/alibaba/provider.yaml | 3 +-
providers/alibaba/pyproject.toml | 6 +-
.../src/airflow/providers/alibaba/__init__.py | 2 +-
providers/amazon/README.rst | 10 +-
providers/amazon/docs/changelog.rst | 55 +
providers/amazon/docs/index.rst | 10 +-
providers/amazon/docs/operators/duckdb.rst | 11 +-
providers/amazon/provider.yaml | 3 +-
providers/amazon/pyproject.toml | 12 +-
.../src/airflow/providers/amazon/__init__.py | 2 +-
.../src/airflow/providers/amazon/aws/exceptions.py | 4 +
.../airflow/providers/amazon/aws/hooks/base_aws.py | 6 +-
.../airflow/providers/amazon/aws/hooks/duckdb.py | 9 +-
.../airflow/providers/amazon/aws/operators/glue.py | 51 +-
.../amazon/aws/operators/mwaa_serverless.py | 21 +
.../airflow/providers/amazon/aws/triggers/glue.py | 30 +-
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 43 +
.../tests/unit/amazon/aws/hooks/test_duckdb.py | 3 +
.../tests/unit/amazon/aws/operators/test_glue.py | 141 +-
.../amazon/aws/operators/test_mwaa_serverless.py | 52 +
.../tests/unit/amazon/aws/triggers/test_glue.py | 41 +
providers/apache/arrow/README.rst | 6 +-
providers/apache/arrow/docs/changelog.rst | 19 +
providers/apache/arrow/docs/connections/adbc.rst | 22 +-
providers/apache/arrow/docs/index.rst | 6 +-
providers/apache/arrow/provider.yaml | 15 +-
providers/apache/arrow/pyproject.toml | 6 +-
.../src/airflow/providers/apache/arrow/__init__.py | 2 +-
.../providers/apache/arrow/get_provider_info.py | 10 +-
.../airflow/providers/apache/arrow/hooks/adbc.py | 43 +-
.../tests/unit/apache/arrow/hooks/test_adbc.py | 64 +
providers/apache/hive/README.rst | 6 +-
providers/apache/hive/docs/changelog.rst | 13 +
providers/apache/hive/docs/index.rst | 6 +-
providers/apache/hive/provider.yaml | 3 +-
providers/apache/hive/pyproject.toml | 6 +-
.../src/airflow/providers/apache/hive/__init__.py | 2 +-
providers/apache/kafka/README.rst | 6 +-
providers/apache/kafka/docs/changelog.rst | 12 +
providers/apache/kafka/docs/index.rst | 6 +-
providers/apache/kafka/provider.yaml | 3 +-
providers/apache/kafka/pyproject.toml | 6 +-
.../src/airflow/providers/apache/kafka/__init__.py | 2 +-
providers/apache/spark/docs/decorators/pyspark.rst | 4 +
.../providers/apache/spark/decorators/pyspark.py | 2 +
.../unit/apache/spark/decorators/test_pyspark.py | 22 +
providers/celery/README.rst | 6 +-
providers/celery/docs/changelog.rst | 17 +
providers/celery/docs/index.rst | 6 +-
providers/celery/provider.yaml | 3 +-
providers/celery/pyproject.toml | 6 +-
.../src/airflow/providers/celery/__init__.py | 2 +-
.../celery/executors/celery_executor_utils.py | 12 +-
.../integration/celery/test_celery_executor.py | 7 +-
providers/cncf/kubernetes/README.rst | 6 +-
providers/cncf/kubernetes/docs/changelog.rst | 34 +
providers/cncf/kubernetes/docs/index.rst | 6 +-
providers/cncf/kubernetes/provider.yaml | 3 +-
providers/cncf/kubernetes/pyproject.toml | 6 +-
.../airflow/providers/cncf/kubernetes/__init__.py | 2 +-
providers/common/ai/docs/approval_gates.rst | 12 +-
providers/common/ai/docs/durable_execution.rst | 2 +-
providers/common/ai/docs/frameworks/anthropic.rst | 4 +-
.../common/ai/docs/frameworks/claude_agent_sdk.rst | 4 +-
providers/common/ai/docs/frameworks/index.rst | 28 +-
.../common/ai/docs/frameworks/openai_agents.rst | 7 +-
providers/common/ai/docs/frameworks/strands.rst | 7 +-
providers/common/ai/docs/hooks/llamaindex.rst | 6 +
providers/common/ai/docs/observability.rst | 3 +-
providers/common/ai/docs/operators/agent.rst | 7 +-
providers/common/ai/docs/operators/llm.rst | 8 +-
providers/common/ai/docs/operators/llm_batch.rst | 5 +-
providers/common/ai/docs/operators/llm_branch.rst | 4 +-
providers/common/ai/docs/stability.rst | 6 +-
providers/common/ai/docs/toolsets/skills.rst | 19 +-
providers/common/ai/docs/troubleshooting.rst | 2 +-
providers/common/ai/provider.yaml | 7 +-
providers/common/ai/pyproject.toml | 10 +-
.../src/airflow/providers/common/ai/batch/state.py | 43 +-
.../providers/common/ai/decorators/agent.py | 7 -
.../airflow/providers/common/ai/durable/journal.py | 70 +-
.../providers/common/ai/durable/openai_agents.py | 64 +-
.../airflow/providers/common/ai/durable/storage.py | 3 +-
.../airflow/providers/common/ai/durable/strands.py | 20 +-
.../src/airflow/providers/common/ai/exceptions.py | 10 +
.../providers/common/ai/get_provider_info.py | 2 +-
.../providers/common/ai/mixins/hitl_review.py | 15 +-
.../airflow/providers/common/ai/operators/agent.py | 8 -
.../airflow/providers/common/ai/operators/llm.py | 46 +-
.../providers/common/ai/operators/llm_batch.py | 8 +-
.../providers/common/ai/operators/llm_branch.py | 29 +-
.../common/ai/operators/llm_file_analysis.py | 3 +-
.../common/ai/operators/llm_schema_compare.py | 3 +-
.../providers/common/ai/operators/llm_sql.py | 7 +-
.../ai/plugins/www/src/components/ModelPanel.tsx | 2 +-
.../plugins/www/src/components/SkillsSection.tsx | 13 +-
.../common/ai/plugins/www/src/skill-source.ts | 43 +-
.../common/ai/plugins/www/tests/model.test.mjs | 36 +
.../ai/plugins/www/tests/skill-source.test.ts | 27 +-
.../ai/src/airflow/providers/common/ai/skills.py | 5 +-
.../airflow/providers/common/ai/tools/__init__.py | 28 +-
.../src/airflow/providers/common/ai/tools/adk.py | 8 +-
.../airflow/providers/common/ai/tools/anthropic.py | 14 +-
.../providers/common/ai/tools/claude_agent_sdk.py | 9 +-
.../providers/common/ai/tools/openai_agents.py | 9 +-
.../airflow/providers/common/ai/tools/strands.py | 6 +-
.../airflow/providers/common/ai/toolsets/mcp.py | 14 +-
.../airflow/providers/common/ai/toolsets/skills.py | 61 +-
.../providers/common/ai/utils/validation.py | 24 -
.../ai/tests/unit/common/ai/batch/test_state.py | 52 +
.../tests/unit/common/ai/decorators/test_agent.py | 16 +-
.../tests/unit/common/ai/durable/test_journal.py | 76 +
.../unit/common/ai/durable/test_openai_agents.py | 486 ++-
.../tests/unit/common/ai/durable/test_storage.py | 9 +-
.../tests/unit/common/ai/durable/test_strands.py | 18 +
.../tests/unit/common/ai/hooks/test_llamaindex.py | 11 +
.../unit/common/ai/mixins/test_hitl_review.py | 39 +-
.../tests/unit/common/ai/operators/test_agent.py | 30 +-
.../ai/operators/test_llamaindex_embedding.py | 8 +-
.../ai/operators/test_llamaindex_retrieval.py | 11 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 87 +
.../unit/common/ai/operators/test_llm_batch.py | 28 +-
.../unit/common/ai/operators/test_llm_branch.py | 9 +-
.../common/ai/tests/unit/common/ai/test_skills.py | 11 +
.../ai/tests/unit/common/ai/tools/test_adk.py | 6 +
.../tests/unit/common/ai/tools/test_anthropic.py | 13 +-
.../unit/common/ai/tools/test_claude_agent_sdk.py | 10 +
.../unit/common/ai/tools/test_openai_agents.py | 6 +
.../ai/tests/unit/common/ai/tools/test_strands.py | 6 +
.../ai/tests/unit/common/ai/tools/test_tools.py | 43 +-
.../ai/tests/unit/common/ai/toolsets/test_mcp.py | 8 +-
.../tests/unit/common/ai/toolsets/test_skills.py | 232 +-
.../tests/unit/common/ai/utils/test_validation.py | 32 +-
providers/common/compat/README.rst | 6 +-
providers/common/compat/docs/changelog.rst | 17 +
providers/common/compat/docs/index.rst | 6 +-
providers/common/compat/provider.yaml | 3 +-
providers/common/compat/pyproject.toml | 6 +-
.../airflow/providers/common/compat/__init__.py | 2 +-
providers/common/io/README.rst | 6 +-
providers/common/io/docs/changelog.rst | 12 +
providers/common/io/docs/index.rst | 6 +-
providers/common/io/provider.yaml | 3 +-
providers/common/io/pyproject.toml | 6 +-
.../io/src/airflow/providers/common/io/__init__.py | 2 +-
providers/common/sql/README.rst | 6 +-
providers/common/sql/docs/changelog.rst | 24 +
providers/common/sql/docs/index.rst | 6 +-
providers/common/sql/provider.yaml | 3 +-
providers/common/sql/pyproject.toml | 6 +-
.../src/airflow/providers/common/sql/__init__.py | 2 +-
providers/databricks/README.rst | 8 +-
providers/databricks/docs/changelog.rst | 15 +
providers/databricks/docs/index.rst | 8 +-
providers/databricks/provider.yaml | 3 +-
providers/databricks/pyproject.toml | 8 +-
.../src/airflow/providers/databricks/__init__.py | 2 +-
.../providers/databricks/utils/databricks.py | 20 +-
.../tests/unit/databricks/utils/test_databricks.py | 76 +
providers/dbt/cloud/README.rst | 6 +-
providers/dbt/cloud/docs/changelog.rst | 13 +
providers/dbt/cloud/docs/index.rst | 6 +-
providers/dbt/cloud/provider.yaml | 3 +-
providers/dbt/cloud/pyproject.toml | 6 +-
.../src/airflow/providers/dbt/cloud/__init__.py | 2 +-
.../src/airflow/providers/dbt/cloud/hooks/dbt.py | 8 +-
.../cloud/tests/unit/dbt/cloud/hooks/test_dbt.py | 13 +
providers/edge3/README.rst | 6 +-
providers/edge3/docs/changelog.rst | 19 +
providers/edge3/docs/index.rst | 6 +-
providers/edge3/provider.yaml | 3 +-
providers/edge3/pyproject.toml | 6 +-
.../edge3/src/airflow/providers/edge3/__init__.py | 2 +-
providers/exasol/README.rst | 6 +-
providers/exasol/docs/changelog.rst | 12 +
providers/exasol/docs/index.rst | 6 +-
providers/exasol/provider.yaml | 3 +-
providers/exasol/pyproject.toml | 6 +-
.../src/airflow/providers/exasol/__init__.py | 2 +-
providers/fab/README.rst | 6 +-
providers/fab/docs/auth-manager/access-control.rst | 8 +
providers/fab/docs/changelog.rst | 52 +-
providers/fab/docs/index.rst | 6 +-
providers/fab/provider.yaml | 3 +-
providers/fab/pyproject.toml | 6 +-
.../fab/src/airflow/providers/fab/__init__.py | 2 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 9 +-
.../unit/fab/auth_manager/test_fab_auth_manager.py | 7 +-
providers/ftp/README.rst | 6 +-
providers/ftp/docs/changelog.rst | 12 +
providers/ftp/docs/index.rst | 6 +-
providers/ftp/provider.yaml | 3 +-
providers/ftp/pyproject.toml | 6 +-
.../ftp/src/airflow/providers/ftp/__init__.py | 2 +-
.../git/src/airflow/providers/git/bundles/git.py | 51 +-
providers/git/tests/unit/git/bundles/test_git.py | 147 +-
providers/google/README.rst | 15 +-
providers/google/docs/changelog.rst | 68 +
providers/google/docs/connections/gcp_sql.rst | 55 +-
providers/google/docs/index.rst | 15 +-
providers/google/docs/operators/cloud/bigquery.rst | 4 -
providers/google/provider.yaml | 3 +-
providers/google/pyproject.toml | 26 +-
.../src/airflow/providers/google/__init__.py | 2 +-
.../providers/google/cloud/hooks/cloud_sql.py | 116 +-
.../providers/google/cloud/operators/bigquery.py | 20 -
.../google/cloud/utils/credentials_provider.py | 5 +-
.../google/cloud/utils/external_token_supplier.py | 10 +-
.../providers/google/common/hooks/base_google.py | 6 +-
.../unit/google/cloud/hooks/test_cloud_sql.py | 234 ++
.../tests/unit/google/cloud/links/test_dataproc.py | 199 ++
.../google/cloud/links/test_kubernetes_engine.py | 152 +
.../unit/google/cloud/links/test_translate.py | 212 ++
.../unit/google/cloud/transfers/test_gcs_to_gcs.py | 110 +-
.../google/cloud/transfers/test_presto_to_gcs.py | 314 ++
.../cloud/utils/test_credentials_provider.py | 14 +
.../cloud/utils/test_external_token_supplier.py | 50 +
.../unit/google/common/hooks/test_base_google.py | 23 +
providers/http/README.rst | 6 +-
providers/http/docs/changelog.rst | 13 +
providers/http/docs/index.rst | 6 +-
providers/http/docs/triggers.rst | 65 +-
providers/http/provider.yaml | 3 +-
providers/http/pyproject.toml | 6 +-
.../http/src/airflow/providers/http/__init__.py | 2 +-
.../src/airflow/providers/http/triggers/http.py | 14 +-
.../http/tests/unit/http/triggers/test_http.py | 79 +
providers/keycloak/README.rst | 6 +-
.../docs/auth-manager/manage/permissions.rst | 2 +-
providers/keycloak/docs/changelog.rst | 27 +-
providers/keycloak/docs/index.rst | 6 +-
providers/keycloak/provider.yaml | 3 +-
providers/keycloak/pyproject.toml | 6 +-
.../src/airflow/providers/keycloak/__init__.py | 2 +-
.../keycloak/auth_manager/cli/commands.py | 5 +
.../keycloak/auth_manager/cli/test_commands.py | 9 +-
providers/microsoft/azure/README.rst | 6 +-
providers/microsoft/azure/docs/changelog.rst | 18 +
providers/microsoft/azure/docs/index.rst | 6 +-
providers/microsoft/azure/provider.yaml | 3 +-
providers/microsoft/azure/pyproject.toml | 6 +-
.../airflow/providers/microsoft/azure/__init__.py | 2 +-
.../azure/operators/container_instances.py | 26 +-
.../providers/microsoft/azure/operators/msgraph.py | 4 +
.../microsoft/azure/transfers/s3_to_wasb.py | 36 +
.../azure/operators/test_container_instances.py | 143 +
.../microsoft/azure/transfers/test_s3_to_wasb.py | 59 +
providers/microsoft/mssql/README.rst | 6 +-
providers/microsoft/mssql/docs/changelog.rst | 12 +
providers/microsoft/mssql/docs/index.rst | 6 +-
providers/microsoft/mssql/provider.yaml | 3 +-
providers/microsoft/mssql/pyproject.toml | 6 +-
.../airflow/providers/microsoft/mssql/__init__.py | 2 +-
.../providers/microsoft/mssql/hooks/mssql.py | 3 +-
.../tests/unit/microsoft/mssql/hooks/test_mssql.py | 22 +
providers/modal/docs/index.rst | 13 +-
providers/modal/docs/task_decorator.rst | 179 +
providers/modal/docs/usage.rst | 13 +-
providers/modal/provider.yaml | 12 +-
providers/modal/pyproject.toml | 2 +-
.../providers/modal/decorators}/__init__.py | 0
.../airflow/providers/modal/decorators/modal.py | 308 ++
.../src/airflow/providers/modal/exceptions.py | 9 +
.../airflow/providers/modal/get_provider_info.py | 8 +-
.../src/airflow/providers/modal/hooks/modal.py | 80 +-
.../airflow/providers/modal/triggers}/__init__.py | 0
.../src/airflow/providers/modal/triggers/modal.py | 100 +
.../src/airflow/providers/modal/utils}/__init__.py | 0
.../providers/modal/utils/python_sandbox.py | 156 +
.../modal/tests/system}/__init__.py | 0
.../modal/tests/system/modal}/__init__.py | 0
.../modal/tests/system/modal/example_modal_task.py | 80 +
.../modal/tests/unit/modal/decorators}/__init__.py | 0
.../tests/unit/modal/decorators/test_modal.py | 428 +++
.../modal/tests/unit/modal/hooks/test_modal.py | 152 +
providers/modal/tests/unit/modal/local_sandbox.py | 132 +
.../modal/tests/unit/modal/test_exceptions.py | 4 +-
.../modal/tests/unit/modal/triggers}/__init__.py | 0
.../modal/tests/unit/modal/triggers/test_modal.py | 171 +
.../modal/tests/unit/modal/utils}/__init__.py | 0
.../tests/unit/modal/utils/test_python_sandbox.py | 163 +
providers/mysql/README.rst | 6 +-
providers/mysql/docs/changelog.rst | 12 +
providers/mysql/docs/index.rst | 6 +-
providers/mysql/provider.yaml | 3 +-
providers/mysql/pyproject.toml | 6 +-
.../mysql/src/airflow/providers/mysql/__init__.py | 2 +-
providers/openai/docs/.latest-doc-only-change.txt | 2 +-
.../airflow/providers/openai/operators/openai.py | 4 +-
.../tests/unit/openai/operators/test_openai.py | 29 +-
providers/openlineage/pyproject.toml | 1 +
.../example_openlineage_task_outcomes_dag.py | 4 +-
.../openlineage_task_outcomes_dag.json | 6 +-
.../tests/system/openlineage/manual_state.py | 28 +-
.../unit/openlineage/extractors/test_manager.py | 49 +-
providers/postgres/README.rst | 6 +-
providers/postgres/docs/changelog.rst | 17 +
providers/postgres/docs/index.rst | 6 +-
providers/postgres/provider.yaml | 3 +-
providers/postgres/pyproject.toml | 6 +-
.../src/airflow/providers/postgres/__init__.py | 2 +-
.../airflow/providers/postgres/hooks/postgres.py | 3 +-
.../tests/unit/postgres/hooks/test_postgres.py | 16 +
providers/presto/README.rst | 6 +-
providers/presto/docs/changelog.rst | 12 +
providers/presto/docs/index.rst | 6 +-
providers/presto/provider.yaml | 3 +-
providers/presto/pyproject.toml | 6 +-
.../src/airflow/providers/presto/__init__.py | 2 +-
providers/sendgrid/README.rst | 6 +-
providers/sendgrid/docs/changelog.rst | 12 +
providers/sendgrid/docs/index.rst | 6 +-
providers/sendgrid/provider.yaml | 3 +-
providers/sendgrid/pyproject.toml | 6 +-
.../src/airflow/providers/sendgrid/__init__.py | 2 +-
providers/smtp/README.rst | 6 +-
providers/smtp/docs/changelog.rst | 12 +
providers/smtp/docs/connections/smtp.rst | 9 +-
providers/smtp/docs/index.rst | 6 +-
providers/smtp/provider.yaml | 3 +-
providers/smtp/pyproject.toml | 6 +-
.../smtp/src/airflow/providers/smtp/__init__.py | 2 +-
.../src/airflow/providers/smtp/utils/emailer.py | 24 +-
.../smtp/tests/unit/smtp/utils/test_emailer.py | 108 +-
providers/snowflake/README.rst | 14 +-
providers/snowflake/docs/changelog.rst | 23 +
.../docs/connections/pydantic_ai_snowflake.rst | 7 +-
providers/snowflake/docs/connections/snowflake.rst | 27 +
providers/snowflake/docs/index.rst | 14 +-
.../snowflake/docs/operators/cortex_agent.rst | 7 +-
providers/snowflake/provider.yaml | 3 +-
providers/snowflake/pyproject.toml | 8 +-
.../src/airflow/providers/snowflake/__init__.py | 2 +-
.../providers/snowflake/hooks/cortex_agent.py | 11 +-
.../airflow/providers/snowflake/hooks/sql_api.py | 5 +-
.../providers/snowflake/utils/_rest_auth.py | 213 +-
.../unit/snowflake/hooks/test_cortex_agent.py | 23 +-
.../tests/unit/snowflake/hooks/test_sql_api.py | 24 +-
.../tests/unit/snowflake/utils/test__rest_auth.py | 422 ++-
providers/ssh/README.rst | 6 +-
providers/ssh/docs/changelog.rst | 12 +
providers/ssh/docs/index.rst | 6 +-
providers/ssh/provider.yaml | 3 +-
providers/ssh/pyproject.toml | 6 +-
.../ssh/src/airflow/providers/ssh/__init__.py | 2 +-
providers/standard/README.rst | 6 +-
providers/standard/docs/changelog.rst | 27 +
providers/standard/docs/index.rst | 6 +-
providers/standard/provider.yaml | 3 +-
providers/standard/pyproject.toml | 6 +-
.../src/airflow/providers/standard/__init__.py | 2 +-
providers/teradata/README.rst | 6 +-
providers/teradata/docs/changelog.rst | 13 +
providers/teradata/docs/index.rst | 6 +-
providers/teradata/provider.yaml | 3 +-
providers/teradata/pyproject.toml | 6 +-
.../src/airflow/providers/teradata/__init__.py | 2 +-
providers/trino/README.rst | 6 +-
providers/trino/docs/changelog.rst | 12 +
providers/trino/docs/index.rst | 6 +-
providers/trino/provider.yaml | 3 +-
providers/trino/pyproject.toml | 6 +-
.../trino/src/airflow/providers/trino/__init__.py | 2 +-
providers/yandex/README.rst | 6 +-
providers/yandex/docs/changelog.rst | 12 +
providers/yandex/docs/index.rst | 6 +-
providers/yandex/provider.yaml | 3 +-
providers/yandex/pyproject.toml | 6 +-
.../src/airflow/providers/yandex/__init__.py | 2 +-
pyproject.toml | 35 +-
reproducible_build.yaml | 4 +-
.../ci/prek/check_airflowctl_command_coverage.py | 1 -
scripts/ci/prek/extract_permissions.py | 2 +
scripts/ci/prek/fab_permissions_doc.py | 24 +-
scripts/ci/prek/supported_versions.py | 2 +-
scripts/docker/entrypoint_ci.sh | 20 +-
scripts/docker/install_os_dependencies.sh | 26 +-
scripts/in_container/run_agent_framework_tests.sh | 65 +-
.../tests/ci/prek/test_compile_provider_assets.py | 1 -
scripts/tests/ci/prek/test_compile_ui_assets.py | 1 -
scripts/tests/ci/prek/test_extract_permissions.py | 33 +
.../src/airflow_shared/module_loading/__init__.py | 23 +-
.../tests/module_loading/test_entry_points.py | 83 +-
.../observability/metrics/metrics_template.yaml | 24 +
task-sdk/pyproject.toml | 1 +
task-sdk/src/airflow/sdk/api/client.py | 9 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 310 +-
.../airflow/sdk/coordinators/java/coordinator.py | 95 +-
task-sdk/src/airflow/sdk/exceptions.py | 11 +
task-sdk/src/airflow/sdk/execution_time/cache.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 15 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 17 +
.../airflow/sdk/execution_time/request_handlers.py | 10 +
.../airflow/sdk/execution_time/schema/schema.json | 105 +-
.../sdk/execution_time/schema/versions/__init__.py | 7 +-
.../execution_time/schema/versions/v2027_02_28.py | 38 +-
.../sdk/execution_time/secrets/execution_api.py | 4 +-
.../src/airflow/sdk/execution_time/supervisor.py | 4 +
.../airflow/sdk/importers/yaml_importer/builder.py | 158 +-
.../airflow/sdk/importers/yaml_importer/models.py | 159 +-
task-sdk/tests/task_sdk/api/test_client.py | 71 +
.../task_sdk/coordinators/java/test_coordinator.py | 240 ++
.../tests/task_sdk/definitions/test_variables.py | 39 +-
.../execution_time/schema/test_migrator.py | 65 +-
.../task_sdk/execution_time/test_supervisor.py | 40 +-
.../importers/yaml_importer/test_parser.py | 13 +
ts-sdk/schema/supervisor-schema.json | 105 +-
ts-sdk/scripts/ci/prek/check_dag_schema.py | 1 -
ts-sdk/src/coordinator/client.ts | 8 +-
ts-sdk/src/generated/supervisor.ts | 183 +-
ts-sdk/src/sdk/client.ts | 2 +-
ts-sdk/tests/coordinator/client.test.ts | 16 +-
uv.lock | 372 +--
700 files changed, 30995 insertions(+), 3315 deletions(-)
create mode 100644 .agents/skills/airflow-translations/locales/ru.md
create mode 100644
airflow-core/docs/administration-and-deployment/logging-monitoring/triggers.rst
create mode 100644 airflow-core/newsfragments/74789.significant.rst
create mode 100644 airflow-core/newsfragments/76007.significant.rst
create mode 100644 airflow-core/newsfragments/76474.significant.rst
create mode 100644
airflow-core/src/airflow/api_fastapi/common/parameters/trigger.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/routes/public/triggers.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/services/public/import_errors.py
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/dag_parsing.py
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/routes/dag_parsing.py
delete mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2026_10_30_xcom_params.py
copy providers/standard/src/airflow/providers/standard/operators/smooth.py =>
airflow-core/src/airflow/dag_processing/claims.py (61%)
create mode 100644 airflow-core/src/airflow/dag_processing/maintenance.py
create mode 100644 airflow-core/src/airflow/dag_processing/requested_work.py
copy providers/http/src/airflow/providers/http/exceptions.py =>
airflow-core/src/airflow/dag_processing/timeouts.py (63%)
copy
airflow-core/src/airflow/migrations/versions/{0141_3_4_0_add_timetable_asset_gated_to_dagmodel.py
=> 0154_3_5_0_add_idempotency_key_to_hitl_detail.py} (61%)
create mode 100644
airflow-core/src/airflow/migrations/versions/0155_3_5_0_add_dag_processor_publication_state.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0156_3_5_0_add_processor_work_claims.py
copy airflow-core/src/airflow/models/{tasklog.py =>
dag_processor_publication_receipt.py} (51%)
copy airflow-core/src/airflow/models/{dag_favorite.py =>
dag_processor_work_claim.py} (56%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagBundle/BundleFiles.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/utils/registerPluginDependencies.test.ts
copy airflow-core/src/airflow/ui/{rules/jsonc.js =>
src/utils/registerPluginDependencies.ts} (51%)
create mode 100644
airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_triggers.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_dag_parsing.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2026_10_30/test_task_state_store.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2027_02_28/test_variables.py
create mode 100644 airflow-core/tests/unit/dag_processing/conftest.py
copy providers/google/tests/unit/google/cloud/operators/test_managed_spark.py
=> airflow-core/tests/unit/dag_processing/test_claims.py (50%)
create mode 100644 airflow-core/tests/unit/dag_processing/test_maintenance.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_failures.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_inventory.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_isolation.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_results.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_requested_work.py
create mode 100644 airflow-core/tests/unit/listeners/test_importerrors.py
create mode 100644
airflow-core/tests/unit/migrations/test_0156_add_processor_work_claims.py
create mode 100644 chart/newsfragments/76601.significant.rst
create mode 100644
providers/google/tests/unit/google/cloud/links/test_dataproc.py
create mode 100644
providers/google/tests/unit/google/cloud/links/test_kubernetes_engine.py
create mode 100644
providers/google/tests/unit/google/cloud/links/test_translate.py
create mode 100644
providers/google/tests/unit/google/cloud/transfers/test_presto_to_gcs.py
create mode 100644 providers/modal/docs/task_decorator.rst
copy {airflow-core/src/airflow/_shared =>
providers/modal/src/airflow/providers/modal/decorators}/__init__.py (100%)
create mode 100644
providers/modal/src/airflow/providers/modal/decorators/modal.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/src/airflow/providers/modal/triggers}/__init__.py (100%)
create mode 100644
providers/modal/src/airflow/providers/modal/triggers/modal.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/src/airflow/providers/modal/utils}/__init__.py (100%)
create mode 100644
providers/modal/src/airflow/providers/modal/utils/python_sandbox.py
copy {airflow-core/tests/integration =>
providers/modal/tests/system}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/system/modal}/__init__.py (100%)
create mode 100644 providers/modal/tests/system/modal/example_modal_task.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal/decorators}/__init__.py (100%)
create mode 100644 providers/modal/tests/unit/modal/decorators/test_modal.py
create mode 100644 providers/modal/tests/unit/modal/local_sandbox.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal/triggers}/__init__.py (100%)
create mode 100644 providers/modal/tests/unit/modal/triggers/test_modal.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal/utils}/__init__.py (100%)
create mode 100644
providers/modal/tests/unit/modal/utils/test_python_sandbox.py
