This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch fork-ci-6-reconciler-followups
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 8196f7a25de Close fork CI pull requests that change the fork CI gate
discard a0b3cbd97ed Attribute fork CI runs to the right pull request in the
tampering check
discard 5b0355627df Keep fork CI pull requests sharing a head commit across
bases for a maintainer
discard c243b4503d8 Ignore fork-only workflows that skipped every job in the
fork CI tampering check
discard 65577250594 Retry the fork CI push-again nudge when posting it fails
discard fc720e5253a Document fork CI for contributors and maintainers
discard 2296029eebb Add breeze ci audit for the fork CI setup
discard 9c0975d413c Add the fork CI reconciler and its scheduled monitor
discard 62a84c89c05 Run fork pushes with pull-request selective checks
discard e9a403c678e Gate project CI for external pull requests in ci-amd.yml
discard ba6ef405505 Add fork CI eligibility function and configuration
discard b3d1c09e7d4 Trust fork CI only for pull requests that cannot change it
discard 4e848bf021a Close gaps in the fork CI design found in review
discard 57d0dce0e16 Let volunteer contributors opt in to a fork CI pilot
discard 3be2eade032 Close gated pull requests that tamper with the fork CI gate
discard 6b83a911778 Add design and ADR for running CI in contributor forks
(AIP-120)
add a23aa81c62e Fix flaky static checks crashing on ts-sdk node_modules
during editable build (#74117)
add d6d425da028 Declare pyarrow for Parquet output of SqlToS3Operator
(#74691)
add 8317410ef7d Do not warn about bare postgresql:// metadata DB URLs
(#74863)
add 23f4aee0239 Fix Dag version diff max-changes border, limit wording and
duplicate count (#74818)
add 0795688f863 Bump swagger-ui-dist from 5.33.1 to 5.33.2 in /registry
(#74872)
add 7acab3c3b02 Bump the ui-plugin-template-package-updates group across 1
directory with 7 updates (#74877)
add e009c1167eb Bump the edge-ui-package-updates group across 1 directory
with 13 updates (#74879)
add b9aa889577c Cover long-running jobs in the deferrable BigQuery check
system test (#74356)
add f54d32d969b Cap the workers of the SFTP concurrent directory transfer
test (#74888)
add 3ce8d152d0d Keep queued connection tests from overwriting newer
connections (#74837)
add 20ccfcd7457 Match camelCase keys against sensitive field names in
masker (#74840)
add c7cec687bb6 Cap `pydantic-ai-skills` below 2 for the Common AI skills
extra (#74899)
add 91937288435 Bump the core-ui-package-updates group across 1 directory
with 16 updates (#74881)
add f8b42cf2f41 Bump happy-dom from 20.14.5 to 21.0.1 in
/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui (#74876)
add 7178a785947 Bump the ts-sdk-package-updates group across 1 directory
with 3 updates (#74874)
add 1f4fe796933 Keep the pydantic-ai first-run banner out of Common AI
task logs (#74900)
add b1ce1cac7f5 Fix Common AI Model tab not loading on Airflow 3.4 (#74898)
add 0eab1db3d2b Replay an OpenAI Agents SDK agent's completed calls when
Airflow retries its task (#74770)
add f5038e67834 Fix dynamically mapped tasks never running on scheduled
Dag runs (#74861)
add bd0aedee6eb Bump the typescript group across 1 directory with 4
updates (#74878)
add 6e16f26400f Bump the auth-ui-package-updates group across 1 directory
with 8 updates (#74875)
add 47c1c416525 Bump happy-dom from 20.14.5 to 21.0.1 in
/airflow-core/src/airflow/ui (#74882)
add 47b092846cc Bump the uv-dependency-updates group across 1 directory
with 4 updates (#74509)
add f3784d2e9e1 Cancel the BigQuery job when BigQueryToGCSOperator is
killed (#74564)
add ed5496fe78d Remove unreachable break in get_bagged_dag (#72332)
add bfe64b1991e Add AthenaSparkSensor (#72229)
add a6af7e5a08e Show the actual value in two breeze and CI script error
messages (#74894)
add db1397a1e89 Reject duplicate durable toolset ids and fail deferred
tools with `UnsupportedToolDeferralError` (#74902)
add 4eda1ee76ea Make Common AI example Dags reach the behaviour they show
(#74901)
add dba55d8728a Add password grant type to Snowflake OAuth token requests
(#74804)
add 5caec465d3d Stop the OpenLineage execution timeout test flaking on
busy CI runners (#74927)
add 3fbf0134fde Remove redundant Snowflake prefixes from Cortex Agent and
SQL API modules (#74300)
add a5c28069af8 Cancel the Dataflow job when a user kills the deferred
task (#69586)
add c35db24a38c Fix Cloud Function invoke operator docs link (#69226)
add d5aed746ad9 Avoid Vertex AI Feature Store system Dag import timeout
(#69823)
add 6a925a8fbe6 Resolve loop iterations through family and path columns on
dynamic regions (#74892)
add a1dbc930726 Stop holding `typesafe-sdk` and `boat-sdk` back in the uv
lock (#74903)
add 79ce98f1101 Prepare ad-hoc providers release 2026-10-17 (#74933)
add 70363ba55e6 Fix stale Common AI docs and add a guide to writing a
toolset (#74904)
add 4b464ee29ba Clear language SDK task XComs in the coordinator when a
try starts (#74221)
add c0e61578a82 Add the Common AI docs fixes to the 1.0.0 changelog
(#74937)
add 76943ec8e44 Fix Celery result backend compatibility with PgBouncer
(#74841)
add 0266cae0e24 Keep the custom-toolset example's version from changing
the PyPI path (#74939)
add 4bc581aab21 Allow GKE Autopilot clusters without node pools and stop
GKE pod trigger reviving should_delete_pod (#69876)
add a9440be98a9 Update providers metadata 2026-10-18 (#74942)
add 5dc96d65dd3 Fail publishing provider docs when a provider is missing
from the site index (#74941)
add fd4654dce4f Fall back for empty console domain (#70067)
add 7644e35f8b7 Add retry-safe batch_id_prefix to
DataprocCreateBatchOperator (#69855)
add b00cfeb11f0 Drain result_queue before dispatch in LocalExecutor to
prevent runtime dispatch deadlock (#70545)
add c3cc5573b80 Batch triggerer unused trigger cleanup deletes (#70961)
add 3f03b18920f Document that use_job_schedule also stops asset-triggered
Dag runs (#73952)
add b59f7489cd8 Make ZIP_REGEX case-insensitive to match .ZIP archives
(#74269)
add 4fbbcddf022 Reduce db clean batch probe overhead (#74455)
add b8987f0356c UI: Open nav sidebar menus on hover and add a Dags menu
(#74745)
add 113bc123a6b Warn when ignore_unknown_values is a no-op in
GCSToBigQueryOperator (#71675)
add 0f8d6f88b0e UI: Keep unnamed columns out of the table columns menu
(#74774)
add 912bbe58050 Fix Dag list run badges and counters not refreshing after
completion (#74734)
add 71e74bc9554 Add deadline callback log visibility to the Dag Run view
in UI (#73580)
add a1e66b1f1d3 Check hooks before cancelling BigQuery jobs in on_kill
(#74946)
add ae8c970f12d Fix Discord embed author name length validation using
wrong limit (#74940)
add 34ffab8e4a4 Fix GKEStartPodOperator ignoring execution_timeout when
deferrable (#71528)
add 4bda61c8c3d Keep the HTTPError when a Dataprep error body is not JSON
(#71702)
add 7bf4936bd79 Bump prettier from 3.9.9 to 3.9.10 in
/providers/fab/src/airflow/providers/fab/www (#74765)
add 675b02a2f9b Make airflow-core typing hold for SQLAlchemy 2.0 and 2.1
(#74629)
add 099c03e4435 Fix SqlToS3Operator failing for every format when df_type
is polars (#74692)
add 7896826a0d0 Specify a minimum python version for hooks (#74995)
add d2c41b8c202 Resolve async connections off the event loop before
Airflow 3.3.2 (#74766)
add 4c4b9c2d330 Raise a clear error when SqlToS3Operator has no Parquet
engine (#74817)
add 9ad8d78c277 Close SubprocessHook stdout pipe after command completes
(#74780)
add ee47d191279 Replace the empty breeze verify table with a one-line hint
(#74778)
add 2fab09576de Require Python 3.11+ for permission doc generators and
fail on parse errors (#74654)
add eddc34c4b44 Fail the local yml mounts prek hook when synchronization
fails (#73785)
add e5c2ea9b3d1 Ask agents to measure performance-sensitive components
(#74579)
add 986066e53d1 Record lessons from the October 2026 providers waves in
the release docs (#75006)
add fb6752829ad Clarify when to add a newsfragment (#74589)
add a27f8e74da3 Let XCom backends tell loop iterations apart through
store_value (#74858)
add 7d9e14b1663 Exclude the current unreleased branch version from the
providers compatibility matrix (#74997)
add a48c5b99af4 Fix tag-providers --dry-run failing to find the push
remote (#71303)
add 515533c9db3 Ensure explicit UTF-8 encoding in prek scripts for Windows
compatibility (#73679)
add 19f1d581c70 Clarify sensitive data handling in security model (#70424)
add 4969b1aeda4 Bump the github-actions-updates group with 10 updates
(#74880)
add a5e5e1a74be Reduce K8s test resource usage with single-node Kind
clusters (#73998)
add 6b42e65a8ea Run shared distribution tests in a single CI job (#74566)
add 3d5c533cccc Redact secrets written through RedactedIO.writelines()
(#72063)
add e7369d04c45 Clarify backfill reprocessing options (#72590)
add fefb87a6035 Run the Kerberos renewer without metadata database checks
(#75000)
add 8143b8d93dc Guard register_at_fork in shared stats for Windows
compatibility (#73680)
add 04e68bf6247 Keep .airflowignore rules when the Dags folder symlink is
switched (#74853)
add 7dd91f20652 Add missing zh-CN translations for new UI strings (#73943)
add 3eab3f2be63 Use one ResumableJobMixin fallback from common.compat in
providers (#74673)
add 40a97a34ca7 Make the PowerBI refresh and MSGraph operators durable
(#74675)
add 935bac04f06 Add AzureAISearchHook to the Microsoft Azure provider
(#74290)
add 777bf9b1888 TS SDK: Add edge labels with label() (#74494)
add a785a717c10 Add documentation for the new YAML Dag format (#74748)
add 3b0388815f0 Centralize EKS kubeconfig and credential setup in EksHook
(#74775)
add 5087893ab02 Add missing Taiwanese Mandarin translations for new UI
strings (#75061)
add 2be399f1418 Fix wrong command and API wording in airflowctl docs and
help (#75058)
add 26395211972 Document running multiple Airflow instances on the same
host (#75056)
add 923a096ee5d Validate connection ports in core model (#74461)
add 48a0f8e22be Push LLMOperator's token usage and cost to XCom (#74355)
add d01d3510589 Make the scheduler Dag cache size and TTL configurable
(#71816)
add b107f602438 Render XCom values on the API server without rebuilding
objects (#74829)
add 8942dd49831 Scope asset-wide queued event deletion to editable Dags
(#74839)
add 6f358052a42 Send task inlets and outlets as JSON lists in OpenLineage
facet (#74666)
add e0c54d330d0 Clean up deleted worktrees' Breeze resources automatically
(#74282)
add 27c8cd7059c Reserve graph header width for loop-group iteration badge
(#75076)
add 7cae03be33f Speed up API server requests by keeping JWT checks off the
event loop (#74856)
add cffe6dfdcf1 Fix flaky LocalExecutor concurrent result refill test
(#75030)
add a26f9f9926c Fix missing and incorrect endpoints in the API permission
reference (#74871)
add 5ce21c5ad74 Fix mypy errors from SQLAlchemy 2.1 typing in fab sorting
and standard sensor_helper (#75075)
add 1d66775efcb Limit Glue retry task UUID scan (#71546)
add 57fb394afe8 Validate CallbackTrigger callback path before running the
callback (#74842)
add 325360c2b92 Reject reserved serialization keys in Dag run conf (#74834)
add 99f2b8618df Scope asset Dag and task references to readable Dags
(#74836)
add a1109f86030 Mask provider-declared sensitive connection extras on
every connection type (#73794)
add 6f408e1715b Scope upstream asset events of a Dag run to assets and
Dags the caller may read (#72924)
add fa83bd029cb Remove unused type: ignore comments in airflow-core
(#75078)
add 46ff76ec9c2 Fix the @asset example in the asset state store docs
(#75070)
add cae1728f127 Add EmrServerlessStopSessionOperator to Amazon provider
(#74870)
add ab1acec7aa8 Open the Dags menu from the Dags nav button instead of
navigating (#75092)
add d2a8457e768 Run the lang-SDK conformance serializer in its own
virtualenv (#75085)
add 233f9c3fc78 Decode deadline callback kwargs where the callback runs
(#74830)
add bfa23909190 Mask registered secrets at any nesting depth (#73793)
add a26eb122498 Mask XCom values in the audit log (#73791)
add b0239d215e1 Only rebuild built-in value types when converting
next_kwargs for older workers (#73577)
add 11174724838 Add the resume event to stored next_kwargs without
decoding them (#73576)
add a7ac9379cf9 Read XCom without object reconstruction during dependency
evaluation (#72718)
add e26dcc0e005 Fix Hive invalid-port tests after core connection port
validation (#75119)
add 486f8368e21 Pass runtime values to example Dag shell commands through
env (#73787)
add 173442e7951 Add non serializable asset's extra to openlineage e2e
tests (#75094)
add e3110a3092d Fix `Trigger.clean_unused` rejecting a caller-provided
session (#75096)
add 9a62eadd2e3 Update providers metadata 2026-10-19 (#75120)
add 7fbcfeea272 UI: Replace stacked Dag header banners with inline status
(#74516)
add a27cd335152 Count declared integrations in the Registry homepage
Integrations stat (#74862)
add edcd4a50335 Hide assets the caller may not read from the UI
dependencies graph (#73008)
add f04f123b2cc Prevent Dag processor crashes with AWS CloudWatch when its
log directory is outside `base_log_folder` (#74929)
add 33e6b5f1fa9 Mock the simple auth manager in the upstream asset events
permission test (#75126)
add 604b23bb206 Document that the HITL operator body is rendered as
Markdown (#75130)
add 941316b4640 Stop UI unit tests from leaking requests to the network
(#75084)
add ac0c20c6ae3 Mock the simple auth manager in permission tests and guard
against the base-class patch (#75138)
add f20ff2cfa7a Add a Duplicate action to the Connections list (#75110)
add 4bbe5f56ce8 Mask CLI secrets in the audit log by parsed argument, not
argv position (#72650)
add c1b25527a41 Keep parent DAG folders collapsed after one click (#75079)
add c581c186987 Keep DAG folder selection distinct across bundle names
(#75080)
add b8db2af9cd6 Fix 500 when ordering the Dag list by state or start_date
(#75025)
add 3134ac232fa Add AwsEksExecutor to the Amazon provider (#74399)
add 5a64dfcc78e Java SDK: Add edge labels to native Dags (#74523)
add 51411acb7e5 Fix empty audit log dag_id for DAG.cli() subcommands
(#73379)
add 11ed2049e12 Fix stale-session assertion in mapped placeholder
promotion test (#75175)
add 99b90b0e4a4 Update Magpie floor to 0.9.0.dev202610192305 (#75174)
add c6e4d52f61b Complete Hindi (hi) UI translations (#75057)
add 9091cd0c7b0 Java SDK: Send log timestamps in UTC (#74783)
add 3e69e05f0d3 Unexclude Vespa on Python 3.14 (#75062)
add 94ce2c9f998 TS SDK: Collect dag_dependencies in the tasks pass (#75032)
add bd29fed01b6 Fix breeze translation key sorting to match the UI ESLint
rule (#75065)
add 0a4b5d8e495 [main] Upgrade important CI environment (#73822)
add 6aee277d4a9 Fix log template sync failing when a custom SQL Alchemy
schema is configured (#70793)
add 7126d336e94 Log the retry reason in airflowctl API client retries
(#75059)
add 1c4af038874 Java SDK: Reject IDs that collide with task group join
nodes (#74781)
add eaefdf9c160 Fix duplicate pyvespa block in uv.lock (#75200)
add 249e5cbcbc1 Fix Modal contract test importing a private class from its
old location (#75188)
add 347dd398d62 Require uv 0.13.1 (#75201)
add 31bb7edc69c Add emit_message_history to record an agent transcript
without seeding it (#74811)
add b7b69d70389 Skip or fail ECS tasks correctly when their CloudWatch log
stream is missing (#74730)
add 1d63c9cbedb Exclude minimal and ECS Amazon Linux AMIs in
get_latest_ami_id (#75171)
add b0cfa1e1b1b Stop the EKS executor concurrency test from starving its
own builders (#75197)
add 12df3270b84 Clean up unused mypy suppressions in standard provider
tests (#75210)
add 359d361de93 Base CI and PROD images on hardened Python images (#73038)
add 1bd0a764d34 Distinguish invalid Dag access control from FAB backend
failures (#74788)
add 99eff4608f9 Keep the token cookie set by a route in
JWTRefreshMiddleware (#75217)
add 31994976b54 Add emailer utilities to the SMTP provider (#74623)
add 8a5212c855e Fix Dag run filtering for null start dates (#71654)
add 4ab76ad9d1f Make KubernetesPodOperator event logging best-effort and
optional (#75016)
add 6639577b61e Put the PROD build virtualenv before /usr/python/bin on
PATH (#75236)
add 5fa997cf002 Add YAML Dag schema publishing infra (#75055)
add 9f1be063d49 Skip inclusive-language check for non-English UI
translations (#75247)
add 6d8a58bff74 Exempt Google Cloud link modules from provider test-file
check (#74924)
add 4ca5754ade4 UI: Show a label instead of a broken link for hidden
assets (#75178)
add 57ed6e7bcb6 UI: Add regression tests for Dags list rows remounting on
refresh (#75005)
add 89ce7a4ff70 Fix SMTP email backend documentation link (#75243)
add 0cde487d422 Stop parallel prek hooks racing on __pycache__ cleanup
(#73823)
add a8c55b78f0e Number task loop iterations from one instead of zero
(#74773)
add 05981d3e2aa Fix task Clear and callback bundles after code-only Dag
changes (#73915)
add ca6499d83b8 Reject blank pool names and variable keys in the REST API
(#74896)
add 165f5ad9054 UI: Preload base React plugin bundles with the page
(#74777)
add 30d7663297b Add time range filtering to the Gantt view (#73555)
add d39d8d54c8c Document the Dag run timeout exception to leaf-state rules
(#74809)
add fa510cdf1e8 Remove unused mypy suppressions in common providers
(#75257)
add 8cc830d4ef9 Fix Kubernetes TCP keepalive not being applied with
urllib3 2.x (#74921)
add 6ebc8d5e038 Use common.compat mask_secret in MCPHook (#75064)
add 25c93b71c4b Re-enable Dependabot and the scheduled upgrade check for
v3-4-test (#75276)
add eccdab540cf Warn about oversized task state values from language SDK
tasks (#74945)
add c57e23956e3 Update minium uv version to 0.13.4 to address
untrustworthy intermediate CA (#75296)
add f3cf550b94b TS SDK: Bump to 1.0.0-beta1 and align README with the
guide (#74693)
add e6a2c9f4e78 Expose task instance loop pass and expansion size to
listeners (#75132)
add b1728b99f60 Add latest-package-managers flag to breeze ci upgrade and
upgrade check CI (#75298)
add 745bdbfb9bc UI: Add match-anywhere toggle to the tags filter (#73616)
add 7e0c1acb426 Bump certifi to 2026.10.19 to drop the compromised emSign
ECC Root CA - G3 (#75302)
add 6aa6db263b1 Bump uv used for release sdist checks to 0.13.4 (#75305)
add b3e91e8442c Bump markdown-it (#75306)
add 4c29b3beb43 Fix outdated commands and references in contributing docs
(#75294)
add e6aa11feff8 Bump the github-actions-updates group with 7 updates
(#75293)
add a9c7f5726be Bump the registry-package-updates group across 1 directory
with 2 updates (#75282)
add be056c2ead2 Fix ruff formatting in the upgrade important versions test
(#75314)
add 57aedbf8c97 Reveal selected Dag folders when names contain pipes
(#75196)
add 5c021ce5442 Clean up Dag Version Tab UX (#75244)
add e5bd3ba9aa4 Bump the react group across 1 directory with 2 updates
(#75281)
add 7d94a66507e Reject non-positive max_active_runs when creating a
backfill (#75071)
add b32158ccdab Bump the fab-ui-package-updates group across 1 directory
with 2 updates (#75234)
add 4425e1bbff8 Bump the auth-ui-package-updates group across 1 directory
with 6 updates (#75286)
add 4fb12b3af09 Include DMS stop reason in DmsTaskBaseSensor failure
message (#75240)
add a571ed0cb60 Add missing Taiwanese Mandarin UI translations (#75277)
add 80702895deb UI: Render Arabic durations with the correct plural form
(#72604)
add b99f4a9b3f8 Fix task instance filtering for null start dates (#75321)
add aee2d4d5122 Fix tasks clear --task-regex matching as a plain substring
(#72941)
add 27b075b9488 Prepare providers release 2026-10-20 (#75209)
add dcfaae090a6 Show errors when the task clear confirmation check fails
(#75269)
add a3a4c138a08 UI: Drop Arabic plural test cases that no longer go
through dayjs (#75330)
add 90f064fa244 Allow BedrockBatchInferenceOperator to wait until the job
is scheduled (#75230)
add 5dd712998d0 Report HTTP errors from binary downloads in
example_emr_eks (#75246)
add ed6344d9dda Deprecate deferrable overriding wait_for_completion in
Comprehend (#75226)
add 3ec479258c9 Link the durable and deferrable operators page from
Registry stats (#75322)
add 35e8183358a Add EKS operator for commands in existing Pods (#72542)
add ebe476eb127 Treat in-progress Bedrock batch inference jobs as
scheduled (#75264)
add 38193762bcf Wait for MWAA Serverless run to stop before deleting
workflow (#75349)
add e02acc44f4e Close German Translation Gaps 2026-10-19 (#75137)
add 92a9e5aad39 Wait for variable form validation before asserting Save is
enabled (#75239)
add 5472d642898 Fix Snowflake connections ignoring region with
`snowflake-connector-python` 5 (#75334)
add c81ca3c4c9e UI: Warn when the logical date is outside the Dag's dates
(#75223)
add 79d3afc82b5 Show source code lines in task log tracebacks (#75100)
add 6db0df87d7f Bump eslint-plugin-unicorn from 77.0.0 to 78.0.0 in
/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui (#75287)
add c16474e39a6 Bump the edge-ui-package-updates group across 1 directory
with 11 updates (#75291)
add 599d7539369 Bump the ui-plugin-template-package-updates group across 1
directory with 8 updates (#75288)
add 66701706142 Bump eslint in /ts-sdk in the ts-sdk-package-updates group
(#75285)
add 9ce42121d0c Bump aiohttp in
/providers/informatica/dev/informatica_simulator (#75187)
add afb1ce5396b Fix ``DbApiHook.inspector`` keeping a database connection
open until process exit (#75327)
add 70b95a24582 Go SDK: Write the edge label text before the task (#75185)
add 0c43149e1b4 Bump vite (#75357)
add 6c8902b1ac5 Document per-set volumes for Celery workers (#74913)
add ab9a2facf76 Add missing Taiwanese Mandarin translations for Dag
start/end date trigger messages (#75371)
add 3fbc2639a12 Fix Google Cloud Logging task log reads before Airflow 3.4
(#74923)
add 597aff10d71 Enforce execution_timeout for tasks run by a language SDK
(#74869)
add 7483c23e9b7 Fix Edge workers not reporting the final state of deadline
callbacks (#74784)
add bf022cc64f2 Fix duplicate pending Dag runs for the same asset
partition key (#71074)
add b3db4d5201a Go SDK: Rewrite the user docs around Dag definition
(#74698)
add c558f4a60f3 TS SDK: Reject blank edge labels and label task edges into
groups (#75190)
add eda782f76ea Make Java SDK context signal-aware (#74690)
add 0fb5bfc4df1 Fill scheduler task batches after concurrency rejection
(#70307)
add 469800c11d2 Keep the multiselect filter pill's focus ring visible
(#75307)
add fc9c4b0b003 Java SDK: Let a native Java Dag set one queue for all its
tasks (#74538)
add a3cd2a59c23 Add an async upload to S3Hook: aload_bytes (#75242)
add 1e3a23293b8 Read a team's running task logs through the team's
executor (#75255)
add 4db39e4d7ea Fix breeze ci_group crash when the title is skipped in
GitHub Actions (#75401)
add e5d8cbbe679 Make JWTRefreshMiddleware extensible via
BaseAuthManager.get_jwt_refresh_middleware() (#70783)
add c510e4dab4c Let plugins add their own actions to Dag, run and task
instance rows (#75229)
add 3b6f02efd81 Migrate airflow-core to `httpx2` (#74244)
add c01a68cb1e3 Show secondary states of mapped tasks in Grid view (#74883)
add 40b5d3647df Revert "Make Java SDK context signal-aware (#74690)"
(#75421)
add 24a809533ba Fix lost transaction in SnowflakeHook when
`session_parameters` is set (#75425)
add f92b7c33851 Run full CI on release branches on a schedule instead of
every push (#75420)
add 5798f1f9ee0 Allow asking for human input from inside a Python task
(#75358)
add f1883a4829c Add missing Amazon provider unit tests (#73169)
add 0abd1616919 Run team tasks on the team executor when named by class or
path (#75362)
add 7ac92c98ce6 Add Databricks agent invocation operator and hook (#74386)
add a419633896d Java SDK: Rewrite the user docs around Dag definition
(#74701)
add 29bb1401c83 Show Dag version diff occurrence count on the path (#75433)
add 01907e047f5 fix stat timing (#72553)
add af76df38634 Allow TypeScript SDK releases from core release branches
(#75447)
add 52237589d0f Java SDK: register the Scala Spark example as task
handlers (#75444)
add ccbd215ff29 TypeScript SDK: take the task state store retention in
seconds (#75445)
add 09fafbcec98 Fix upgrade guide sections showing as separate pages in
the docs sidebar (#75468)
add 763cb20ddc1 Fix SageMaker credential failures being reported as
timeouts (#74867)
add e71a6fb4790 Disable branch protection on v3-4-stable (#75473)
add d977d20aae3 Bump sphinx-airflow-theme to 0.3.15 for a more readable
docs sidebar (#75471)
add 1a50a18a3c6 Go SDK: fail a task whose return-value XCom push fails
(#75443)
add 06130cdc7fe Re-enable branch protection on v3-4-stable (#75477)
add b7dfaf64261 Fix docs pages listing their sections as separate pages in
the sidebar (#75478)
add 719a685079c Add consolidated Language SDK compatibility matrix (#71757)
add 2fc4238b326 Add missing zh-TW translations for Dag version path
tooltips (#75450)
add 2846242adad Show states of task groups as stacked cards in Grid view
(#75442)
add a5160a97038 Remove the gap above docs pages left from the old site
banner (#75485)
add 99bdeabe3db Show the filtered task count in the Dag Tasks tab heading
(#75448)
add a0be43d3b00 Link task instances of task loops to their own page
(#75458)
add d41a7c8e400 Bump sphinx-airflow-theme to 0.3.16 to align the docs' On
this page list (#75491)
add 6570b8282f2 Skip S3 keys that map to the local sync directory (#74322)
add d12021da679 Allow ECS exit codes to fail tasks without retrying
(#73885)
add d613e999dee Limit the CLI reference's page contents to top-level
commands (#75483)
add d81ba9c7f4e Complete German UI translations (#75301)
add b43705cccee Decide min_one_success trigger rules per index in mapped
task groups (#75417)
add e14449953fd Fix deferral paths in task lifecycle diagram (#75428)
add a7066062a13 Fix pulling `AgentOperator` output for list, marker and
function types (#74729)
add 7e02d460c8a Bump swagger-ui-dist from 5.33.3 to 5.34.0 in /registry
(#75509)
add 89e5d07a07e Bump typescript-eslint in /ts-sdk in the
ts-sdk-package-updates group (#75512)
add 46348732ca3 Bump @tanstack/react-query from 5.104.3 to 5.104.4 in
/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui (#75505)
add b9c657b3bcd Make Dags sidebar button a link and move Dag Runs and Task
Instances to Browse (#75422)
add 1159db91258 Deprecate deferrable implying wait in no-wait-default AWS
operators (#75361)
add a9ba9b1791f Deprecate deferrable overriding wait_for_completion in AWS
operators (#75360)
add 90efd88e2c1 Fix BedrockBatchInferenceSensor sharing success states
across tasks (#75265)
add 8aa1cf26ea3 Let each team's KubernetesExecutor connect to its own
cluster (#75251)
add 9ef5f3d463f Add XCom read access to deadline callbacks run by
executors (#74779)
add 34c72c5e53a Allow excluding datasets from OpenLineage events by
pattern and hook (#71312)
add e9a89e25eb0 Fix Common AI's AI Model tab for tasks inside a task loop
(#75518)
add 5d1c1d42328 Load Common AI plugin tabs when the browser reaches
Airflow on another origin (#75522)
add 57a4751c967 Add an LLM task loop example that stops on a dollar or
token budget (#75516)
add 4639f244f84 Remove info tooltip from Dag version comparison (#75526)
add 602e150aace Allow building docs with a local sphinx_airflow_theme
checkout (#75001)
add 829759749df Add missing German Dag trigger translations (#75519)
add e025c334a56 Allow jason810496 to publish docs to S3 (#75548)
add a5af91d2c52 Enable auto-merge, gated on a dedicated CI passed check
(#75142)
add 9761167313d Go SDK: stop log attributes from displacing standard log
fields (#73820)
add a9dc0d6a486 Add design and ADR for running CI in contributor forks
(AIP-120)
add 6ea6c402832 Close gated pull requests that tamper with the fork CI gate
add e7b8f8610d3 Let volunteer contributors opt in to a fork CI pilot
add 8352dfeb24c Close gaps in the fork CI design found in review
add f8a92a7c09c Trust fork CI only for pull requests that cannot change it
add 57b25a4b734 Add fork CI eligibility function and configuration
add b3b298bce82 Gate project CI for external pull requests in ci-amd.yml
add 5d7e472cd04 Address review of the fork CI gate
add b4e450fd9d8 Anchor the canonical push branches on the pull request
filter
add f70e6aba52f Set PYTHONPYCACHEPREFIX for the fork CI gate config hook
add 54d174ab523 Add the fork CI gate to the needs of CI passed
add 37af68bcdad Describe the fork CI gate in the CI passed docs as in place
add 642730fb2e9 Skip the scheduled ARM canary in forks
add 1207707233a Run fork pushes with pull-request selective checks
add 62d3ae638ea Read pull request labels and the merge base for fork pushes
add db249eb0e58 Match the fork pull request by base when reading its labels
add 7d0df31abbb Add the fork CI reconciler and its scheduled monitor
add 3c52418609f Report CI passed from fork CI and address reconciler review
add e59524da5be Do not count jobs every gated run starts as gate tampering
add 136cfa473da Count only jobs a runner picked up as fork CI gate
tampering
add 31f24b06423 Add breeze ci audit for the fork CI setup
add 7a5e28706bc Address review of breeze ci audit
add 82cba2a4f4d Classify only public apache members as committers in
breeze ci audit
add 754beea6a0e Treat only a 404 as not an apache member in breeze ci audit
add 1c8c15df59c Document fork CI for contributors and maintainers
add 4e474720836 Say when fork CI applies in the contributor docs
add 92727b78a98 Describe apache/airflow push runs after release-branch CI
moved to a schedule
add b5da0ea000d Fix the fork CI section title level and label wording in
the contributor docs
add 720e7d969dc Retry the fork CI push-again nudge when posting it fails
add 1fe0803c6e4 Ignore fork-only workflows that skipped every job in the
fork CI tampering check
add 056c058ab79 Keep fork CI pull requests sharing a head commit across
bases for a maintainer
add 99bb8b7bb8d Attribute fork CI runs to the right pull request in the
tampering check
add bd9f1646757 Close fork CI pull requests that change the fork CI gate
add 5e243b880af Count only started jobs of fork-only workflows as project
CI work
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 (8196f7a25de)
\
N -- N -- N refs/heads/fork-ci-6-reconciler-followups
(5e243b880af)
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-java-sdk/SKILL.md | 9 +-
.agents/skills/airflow-pr-draft-summary/SKILL.md | 6 +-
.agents/skills/airflow-publish-changes/SKILL.md | 9 +-
.../references/performance-sensitive-components.md | 30 +
.../prepare-providers-documentation/SKILL.md | 15 +
.../release-management-config.md | 9 +
.apache-magpie.lock | 6 +-
.asf.yaml | 65 +-
.../actions/build_ci_image_with_cache/action.yml | 10 +-
.github/dependabot.yml | 21 -
.github/workflows/airflow-e2e-tests.yml | 6 +-
.github/workflows/asf-allowlist-check.yml | 2 +-
.github/workflows/basic-tests.yml | 63 +-
.github/workflows/check-newsfragment-pr-number.yml | 2 +-
.github/workflows/ci-amd.yml | 270 +-
.github/workflows/ci-arm.yml | 218 +-
.github/workflows/ci-duration-monitor.yml | 2 +-
.github/workflows/ci-image-build.yml | 35 +-
.github/workflows/ci-image-checks.yml | 33 +-
.github/workflows/ci-notification.yml | 4 +-
.github/workflows/codeql-analysis.yml | 8 +-
.github/workflows/e2e-flaky-tests-report.yml | 2 +-
.github/workflows/finalize-tests.yml | 2 +-
.github/workflows/generate-constraints.yml | 2 +-
.github/workflows/helm-tests.yml | 2 +-
.../java-sdk-dependabot-verification-metadata.yml | 2 +-
.github/workflows/java-sdk-dependency-security.yml | 2 +-
.github/workflows/java-sdk-release-verify.yml | 6 +-
.github/workflows/k8s-tests.yml | 8 +-
.github/workflows/kustomize-overlays-tests.yml | 6 +-
.github/workflows/mirror-hardened-base-images.yml | 80 +
.github/workflows/notify-uv-lock-conflicts.yml | 2 +-
.github/workflows/openlineage-e2e-compat-tests.yml | 2 +-
.github/workflows/prod-image-build.yml | 17 +-
.github/workflows/publish-docs-to-s3.yml | 41 +-
.github/workflows/push-image-cache.yml | 6 +-
.github/workflows/refresh-image-registry-cache.yml | 11 +-
.github/workflows/registry-backfill.yml | 2 +-
.github/workflows/registry-build.yml | 4 +-
.github/workflows/registry-tests.yml | 2 +-
.github/workflows/release-branch-ci.yml | 161 +
.github/workflows/release-constraints.yml | 2 +-
.../workflows/release_single_dockerhub_image.yml | 4 +-
.../scheduled-legacy-prod-image-canary.yml | 262 +
.../scheduled-upgrade-check-v3-4-test.yml | 9 +-
.../scheduled-verify-release-calendar.yml | 2 +-
.github/workflows/ts-sdk-release.yml | 22 +-
.github/workflows/ui-e2e-tests.yml | 6 +-
.../update-constraints-on-push-stable.yml | 2 +-
.github/workflows/update-constraints-on-push.yml | 2 +-
.github/workflows/upgrade-check.yml | 1 +
.pre-commit-config.yaml | 386 +-
AGENTS.md | 2 +-
Dockerfile | 451 +-
Dockerfile.ci | 443 +-
airflow-core/.pre-commit-config.yaml | 62 +
.../dag-importers.rst | 25 +-
.../dagfile-processing.rst | 12 +-
.../logging-monitoring/metrics.rst | 2 +-
.../docs/administration-and-deployment/plugins.rst | 50 +
.../docs/authoring-and-scheduling/index.rst | 1 +
.../authoring-and-scheduling/language-sdks/go.rst | 998 +--
.../language-sdks/index.rst | 251 +
.../language-sdks/java.rst | 1693 ++---
.../language-sdks/typescript.rst | 142 +-
.../docs/authoring-and-scheduling/loops.rst | 64 +-
.../docs/authoring-and-scheduling/yaml-dags.rst | 454 ++
airflow-core/docs/best-practices.rst | 2 +-
airflow-core/docs/cli-and-env-variables-ref.rst | 3 +
.../docs/core-concepts/asset-state-store.rst | 4 +-
airflow-core/docs/core-concepts/backfill.rst | 10 +-
airflow-core/docs/core-concepts/dag-run.rst | 4 +
airflow-core/docs/core-concepts/debug.rst | 2 +-
airflow-core/docs/core-concepts/tasks.rst | 8 +-
airflow-core/docs/core-concepts/xcoms.rst | 21 +-
airflow-core/docs/faq.rst | 52 +-
.../docs/howto/create-custom-decorator.rst | 2 +-
airflow-core/docs/howto/custom-action-plugin.rst | 348 +
airflow-core/docs/howto/custom-view-plugin.rst | 22 +-
airflow-core/docs/howto/customize-ui.rst | 12 +-
airflow-core/docs/howto/deadline-alerts.rst | 3 +
airflow-core/docs/howto/index.rst | 1 +
airflow-core/docs/howto/notifications.rst | 2 +-
airflow-core/docs/howto/run-behind-proxy.rst | 32 +
airflow-core/docs/howto/set-config.rst | 2 +-
.../docs/img/diagram_task_lifecycle.md5sum | 2 +-
airflow-core/docs/img/diagram_task_lifecycle.png | Bin 671852 -> 643516
bytes
airflow-core/docs/img/diagram_task_lifecycle.py | 18 +-
.../docs/installation/upgrading_to_airflow3.rst | 6 +-
airflow-core/docs/migrations-ref.rst | 7 +-
airflow-core/docs/security/api_permissions_ref.rst | 60 +-
airflow-core/docs/security/security_model.rst | 15 +-
airflow-core/docs/troubleshooting.rst | 2 +
airflow-core/docs/tutorial/hitl.rst | 28 +
airflow-core/newsfragments/71816.feature.rst | 1 +
airflow-core/newsfragments/73038.significant.rst | 31 +
airflow-core/newsfragments/73577.significant.rst | 5 +
airflow-core/newsfragments/73791.improvement.rst | 1 +
airflow-core/newsfragments/73793.improvement.rst | 1 +
airflow-core/newsfragments/73794.improvement.rst | 1 +
airflow-core/newsfragments/74830.significant.rst | 10 +
airflow-core/newsfragments/74834.bugfix.rst | 1 +
airflow-core/newsfragments/74836.bugfix.rst | 1 +
airflow-core/newsfragments/74837.bugfix.rst | 1 +
airflow-core/newsfragments/74839.bugfix.rst | 1 +
airflow-core/newsfragments/74840.bugfix.rst | 1 +
airflow-core/newsfragments/74842.improvement.rst | 1 +
airflow-core/newsfragments/74896.bugfix.rst | 1 +
.../task-loops-custom-backends.significant.rst | 28 +
airflow-core/pyproject.toml | 13 +-
.../src/airflow/api/client/local_client.py | 6 +-
airflow-core/src/airflow/api_fastapi/app.py | 18 +
.../api_fastapi/auth/managers/base_auth_manager.py | 21 +-
.../auth/managers/simple/ui/package.json | 28 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 1005 ++-
.../managers/simple/ui/src/alert/ErrorAlert.tsx | 4 +-
.../api_fastapi/auth/middlewares/refresh_token.py | 222 +-
.../src/airflow/api_fastapi/auth/tokens.py | 4 +-
.../airflow/api_fastapi/common/parameters/range.py | 39 +-
airflow-core/src/airflow/api_fastapi/compat.py | 2 +-
.../src/airflow/api_fastapi/core_api/app.py | 36 +-
.../api_fastapi/core_api/datamodels/assets.py | 19 +-
.../api_fastapi/core_api/datamodels/backfills.py | 10 +-
.../api_fastapi/core_api/datamodels/common.py | 14 +
.../api_fastapi/core_api/datamodels/connections.py | 57 +
.../api_fastapi/core_api/datamodels/dag_run.py | 8 +-
.../api_fastapi/core_api/datamodels/plugins.py | 58 +-
.../api_fastapi/core_api/datamodels/pools.py | 6 +-
.../core_api/datamodels/task_instances.py | 2 +-
.../api_fastapi/core_api/datamodels/ui/deadline.py | 7 +
.../api_fastapi/core_api/datamodels/variables.py | 7 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 224 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 116 +-
.../api_fastapi/core_api/routes/public/assets.py | 67 +-
.../core_api/routes/public/connections.py | 4 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 57 +-
.../api_fastapi/core_api/routes/public/dags.py | 2 +-
.../core_api/routes/public/extra_links.py | 5 +-
.../api_fastapi/core_api/routes/public/pools.py | 4 +-
.../core_api/routes/public/task_instances.py | 39 +-
.../api_fastapi/core_api/routes/public/xcom.py | 23 +-
.../api_fastapi/core_api/routes/ui/assets.py | 9 +-
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 2 +-
.../api_fastapi/core_api/routes/ui/deadlines.py | 75 +-
.../api_fastapi/core_api/routes/ui/dependencies.py | 20 +-
.../api_fastapi/core_api/routes/ui/gantt.py | 24 +-
.../core_api/services/public/connections.py | 12 +-
.../core_api/services/ui/dependencies.py | 80 +-
.../api_fastapi/core_api/services/ui/grid.py | 4 +-
.../api_fastapi/execution_api/datamodels/dagrun.py | 8 +-
.../execution_api/datamodels/taskinstance.py | 54 +-
.../api_fastapi/execution_api/in_process.py | 1 -
.../api_fastapi/execution_api/routes/__init__.py | 2 +-
.../execution_api/routes/connection_tests.py | 7 +-
.../execution_api/routes/task_instances.py | 62 +-
.../api_fastapi/execution_api/routes/xcoms.py | 110 +-
.../execution_api/services/task_instances.py | 32 +-
.../api_fastapi/execution_api/versions/__init__.py | 4 +
.../execution_api/versions/v2025_08_10.py | 2 +-
.../execution_api/versions/v2025_10_27.py | 2 +-
.../execution_api/versions/v2025_11_05.py | 2 +-
.../execution_api/versions/v2026_04_06.py | 240 +-
.../execution_api/versions/v2026_06_30.py | 14 +-
.../execution_api/versions/v2026_10_30.py | 36 +-
.../src/airflow/api_fastapi/logging/decorators.py | 16 +
airflow-core/src/airflow/assets/manager.py | 281 +-
airflow-core/src/airflow/cli/cli_config.py | 8 +-
.../src/airflow/cli/commands/kerberos_command.py | 2 +-
.../src/airflow/cli/commands/task_command.py | 12 +-
.../src/airflow/config_templates/config.yml | 64 +-
airflow-core/src/airflow/configuration.py | 29 +-
airflow-core/src/airflow/dag_processing/manager.py | 2 +-
.../src/airflow/dag_processing/processor.py | 9 +-
.../airflow/example_dags/example_dag_decorator.py | 24 +-
.../src/airflow/example_dags/example_task_loops.py | 10 +-
.../src/airflow/executors/base_executor.py | 8 +
.../src/airflow/executors/executor_loader.py | 36 +
.../src/airflow/executors/local_executor.py | 1 +
.../src/airflow/executors/workloads/callback.py | 6 +
.../src/airflow/jobs/scheduler_job_runner.py | 242 +-
.../src/airflow/jobs/triggerer_job_runner.py | 47 +-
.../0143_3_4_0_add_dynamic_region_storage.py | 6 +
..._add_commit_allows_update_to_connection_test.py | 51 +
...0148_3_4_0_add_pending_partition_key_to_apdr.py | 84 +
..._job.py => 0149_3_5_0_add_session_id_to_job.py} | 4 +-
airflow-core/src/airflow/models/asset.py | 33 +-
airflow-core/src/airflow/models/backfill.py | 9 +-
airflow-core/src/airflow/models/callback.py | 52 +-
airflow-core/src/airflow/models/connection.py | 44 +-
airflow-core/src/airflow/models/connection_test.py | 26 +-
airflow-core/src/airflow/models/dag.py | 7 +-
airflow-core/src/airflow/models/dag_version.py | 22 +-
airflow-core/src/airflow/models/dagrun.py | 9 +-
airflow-core/src/airflow/models/deadline.py | 33 +-
airflow-core/src/airflow/models/dynamic_region.py | 249 +-
airflow-core/src/airflow/models/pool.py | 2 +-
airflow-core/src/airflow/models/serialized_dag.py | 10 +-
.../src/airflow/models/task_coordinates.py | 96 +-
airflow-core/src/airflow/models/taskinstance.py | 47 +-
airflow-core/src/airflow/models/trigger.py | 171 +-
airflow-core/src/airflow/models/xcom.py | 50 +-
airflow-core/src/airflow/plugins_manager.py | 109 +-
airflow-core/src/airflow/serialization/decoders.py | 89 +-
.../serialization/definitions/mappedoperator.py | 2 +-
.../serialization/definitions/operatorlink.py | 14 +-
airflow-core/src/airflow/serialization/encoders.py | 68 +-
.../airflow/serialization/serialized_objects.py | 9 +-
.../src/airflow/serialization/stringify.py | 82 +-
.../ti_deps/deps/not_previously_skipped_dep.py | 66 +-
.../src/airflow/ti_deps/deps/prev_dagrun_dep.py | 14 +
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 44 +-
airflow-core/src/airflow/timetables/simple.py | 2 +-
airflow-core/src/airflow/triggers/callback.py | 27 +
airflow-core/src/airflow/ui/dev/index.html | 3 +
airflow-core/src/airflow/ui/index.html | 3 +
.../src/airflow/ui/openapi-gen/queries/common.ts | 21 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 45 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 45 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 45 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 45 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 188 +-
.../ui/openapi-gen/requests/services.gen.ts | 59 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 96 +-
airflow-core/src/airflow/ui/package.json | 46 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 1151 +--
.../src/airflow/ui/public/i18n/locales/ca/dag.json | 7 -
.../airflow/ui/public/i18n/locales/de/admin.json | 2 +
.../airflow/ui/public/i18n/locales/de/common.json | 4 +
.../ui/public/i18n/locales/de/components.json | 6 +
.../src/airflow/ui/public/i18n/locales/de/dag.json | 31 +-
.../airflow/ui/public/i18n/locales/de/dags.json | 1 +
.../src/airflow/ui/public/i18n/locales/el/dag.json | 7 -
.../airflow/ui/public/i18n/locales/en/admin.json | 2 +
.../airflow/ui/public/i18n/locales/en/common.json | 2 +
.../ui/public/i18n/locales/en/components.json | 6 +
.../src/airflow/ui/public/i18n/locales/en/dag.json | 34 +-
.../src/airflow/ui/public/i18n/locales/fr/dag.json | 7 -
.../src/airflow/ui/public/i18n/locales/he/dag.json | 3 -
.../airflow/ui/public/i18n/locales/hi/admin.json | 15 +-
.../airflow/ui/public/i18n/locales/hi/assets.json | 16 +-
.../airflow/ui/public/i18n/locales/hi/browse.json | 32 +
.../airflow/ui/public/i18n/locales/hi/common.json | 150 +-
.../ui/public/i18n/locales/hi/components.json | 45 +-
.../src/airflow/ui/public/i18n/locales/hi/dag.json | 130 +-
.../airflow/ui/public/i18n/locales/hi/dags.json | 54 +-
.../ui/public/i18n/locales/hi/dashboard.json | 17 +-
.../src/airflow/ui/public/i18n/locales/ko/dag.json | 7 -
.../src/airflow/ui/public/i18n/locales/pl/dag.json | 7 -
.../ui/public/i18n/locales/zh-CN/browse.json | 18 +-
.../ui/public/i18n/locales/zh-CN/common.json | 21 +
.../ui/public/i18n/locales/zh-CN/components.json | 1 +
.../airflow/ui/public/i18n/locales/zh-CN/dag.json | 4 +
.../airflow/ui/public/i18n/locales/zh-CN/dags.json | 4 +-
.../ui/public/i18n/locales/zh-CN/dashboard.json | 17 +-
.../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 | 54 +-
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 1 +
.../ui/src/components/AdvancedSearchToggle.tsx | 6 +-
.../components/AssetExpression/AssetNode.test.tsx | 52 +
.../src/components/AssetExpression/AssetNode.tsx | 13 +-
.../components/BackfillInProgressBadge.test.tsx | 68 +
.../ui/src/components/BackfillInProgressBadge.tsx | 63 +
.../src/components/Banner/BackfillBanner.test.tsx | 94 -
.../ui/src/components/Banner/BackfillBanner.tsx | 150 -
.../src/components/Banner/DrainingBanner.test.tsx | 88 -
.../ui/src/components/Banner/DrainingBanner.tsx | 68 -
.../ClearTaskInstanceConfirmationDialog.test.tsx | 185 +
.../ClearTaskInstanceConfirmationDialog.tsx | 20 +-
.../TaskInstance/ClearTaskInstanceDialog.test.tsx | 152 +-
.../Clear/TaskInstance/ClearTaskInstanceDialog.tsx | 9 +-
...Banner.test.tsx => DagDeactivatedChip.test.tsx} | 35 +-
...eactivatedBanner.tsx => DagDeactivatedChip.tsx} | 43 +-
.../ui/src/components/DagImportErrorModal.tsx | 27 +-
.../DataTable/DataTable.columnVisibility.test.tsx | 20 +
.../DataTable/DataTable.expanding.test.tsx | 74 +
.../ui/src/components/DataTable/DataTable.tsx | 35 +-
.../ui/src/components/DataTable/TableList.tsx | 32 +-
.../ui/src/components/DataTable/features.ts | 5 +-
.../ui/src/components/DrainingBadge.test.tsx | 72 +
.../airflow/ui/src/components/DrainingBadge.tsx | 59 +-
.../FilterBar/filters/MultiSelectPill.tsx | 24 +-
.../FilterBar/filters/TagsFilter.test.tsx | 143 +
.../components/FilterBar/filters/TagsFilter.tsx | 3 +
.../airflow/ui/src/components/FilterBar/types.ts | 4 +-
.../ui/src/components/Graph/elkGraphUtils.ts | 5 +
.../src/airflow/ui/src/components/HeaderCard.tsx | 8 +-
.../ui/src/components/JsonPreviewBadges.tsx | 42 +-
.../airflow/ui/src/components/NeedsReviewBadge.tsx | 18 +-
.../ui/src/components/NeedsReviewButton.tsx | 58 +-
.../src/components/NeedsReviewIndicator.test.tsx | 58 +
.../ui/src/components/NeedsReviewIndicator.tsx | 71 +
.../airflow/ui/src/components/NotePreview.test.tsx | 8 +-
.../PluginActions/PluginActionBoundary.tsx | 63 +
.../PluginActionIcon.tsx} | 34 +-
.../PluginActions/PluginActions.test.tsx | 431 ++
.../src/components/PluginActions/PluginActions.tsx | 90 +
.../PluginActions/PluginActionsContext.tsx | 45 +
.../components/PluginActions/PluginLinkAction.tsx | 96 +
.../components/PluginActions/PluginReactAction.tsx | 98 +
.../{Banner/index.tsx => PluginActions/index.ts} | 6 +-
.../PluginActions/pluginActionContext.test.ts | 138 +
.../PluginActions/pluginActionContext.ts | 97 +
.../ui/src/components/PluginActions/types.ts | 82 +
.../ui/src/components/RenderedJsonField.test.tsx | 19 +
.../ui/src/components/RenderedJsonField.tsx | 36 +-
.../src/airflow/ui/src/components/StatusChip.tsx | 67 +
.../components/TriggerDag/TriggerDAGForm.test.tsx | 46 +
.../src/components/TriggerDag/TriggerDAGForm.tsx | 43 +-
.../ui/src/components/renderStructuredLog.test.tsx | 48 +-
.../ui/src/components/renderStructuredLog.tsx | 13 +-
.../src/airflow/ui/src/constants/filterConfigs.tsx | 1 +
.../airflow/ui/src/hooks/usePluginActions.test.ts | 142 +
.../src/airflow/ui/src/hooks/usePluginActions.ts | 50 +
.../src/airflow/ui/src/hooks/usePluginTabs.tsx | 13 +-
.../airflow/ui/src/hooks/useScopedPluginViews.ts | 14 +-
.../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 +
.../ui/src/layouts/Details/DagBreadcrumb.test.tsx | 4 +
.../ui/src/layouts/Details/DetailsLayout.tsx | 12 +-
.../ui/src/layouts/Details/Gantt/Gantt.test.tsx | 133 +
.../airflow/ui/src/layouts/Details/Gantt/Gantt.tsx | 9 +-
.../layouts/Details/Gantt/GanttTimeline.test.tsx | 2 +-
.../ui/src/layouts/Details/Grid/GridTI.test.tsx | 117 +-
.../airflow/ui/src/layouts/Details/Grid/GridTI.tsx | 47 +-
.../ui/src/layouts/Details/Grid/constants.ts | 2 +-
.../ui/src/layouts/Details/GridFilters.test.tsx | 79 +
.../airflow/ui/src/layouts/Details/GridFilters.tsx | 24 +-
.../ui/src/layouts/Details/PanelButtons.tsx | 2 +-
.../src/airflow/ui/src/layouts/Nav/AdminButton.tsx | 20 +-
.../ui/src/layouts/Nav/BrowseButton.test.tsx | 83 +
.../airflow/ui/src/layouts/Nav/BrowseButton.tsx | 52 +-
.../airflow/ui/src/layouts/Nav/DagsButton.test.tsx | 75 +
.../Nav/DagsButton.tsx} | 30 +-
.../src/airflow/ui/src/layouts/Nav/DocsButton.tsx | 56 +-
.../src/airflow/ui/src/layouts/Nav/Nav.tsx | 11 +-
.../airflow/ui/src/layouts/Nav/NavButton.test.tsx | 18 -
.../src/airflow/ui/src/layouts/Nav/NavButton.tsx | 17 +-
.../airflow/ui/src/layouts/Nav/NavMenu.test.tsx | 90 +
.../src/airflow/ui/src/layouts/Nav/NavMenu.tsx | 170 +
.../src/airflow/ui/src/layouts/Nav/PluginMenus.tsx | 44 +-
.../airflow/ui/src/layouts/Nav/SecurityButton.tsx | 26 +-
.../ui/src/layouts/Nav/UserSettingsButton.tsx | 190 +-
.../ui/src/mocks/handlers/{assets.ts => admin.ts} | 38 +-
.../src/airflow/ui/src/mocks/handlers/app.ts | 57 +
.../src/airflow/ui/src/mocks/handlers/assets.ts | 8 +
.../src/airflow/ui/src/mocks/handlers/dag.ts | 53 +
.../src/airflow/ui/src/mocks/handlers/dag_runs.ts | 23 +
.../src/airflow/ui/src/mocks/handlers/dags.ts | 3 +
.../src/airflow/ui/src/mocks/handlers/index.ts | 6 +
.../ui/src/mocks/handlers/task_instances.test.ts | 43 +
.../ui/src/mocks/handlers/task_instances.ts | 100 +
.../src/airflow/ui/src/mocks/server.ts | 31 +-
.../Asset/AssetStateStore/AssetStateStore.tsx | 1 +
.../ui/src/pages/AssetsList/AssetsList.test.tsx | 15 +-
.../ui/src/pages/Connections/Connections.tsx | 3 +
.../Connections/DuplicateConnectionButton.test.tsx | 114 +
.../Connections/DuplicateConnectionButton.tsx | 101 +
.../ui/src/pages/Dag/Backfills/Backfills.test.tsx | 64 +
.../ui/src/pages/Dag/Backfills/Backfills.tsx | 97 +-
.../airflow/ui/src/pages/Dag/DagHeader.test.tsx | 14 +-
.../src/airflow/ui/src/pages/Dag/Header.tsx | 20 +-
.../ui/src/pages/Dag/RequiredActionsRoute.test.tsx | 14 +-
.../airflow/ui/src/pages/Dag/Tasks/Tasks.test.tsx | 15 +-
.../src/airflow/ui/src/pages/Dag/Tasks/Tasks.tsx | 2 +-
.../Dag/Versions/DiffUnavailableAlert.tsx} | 34 +-
.../ui/src/pages/Dag/Versions/DiffValue.tsx | 60 +
.../pages/Dag/Versions/MaxChangesField.test.tsx | 71 +
.../ui/src/pages/Dag/Versions/MaxChangesField.tsx | 119 +
.../airflow/ui/src/pages/Dag/Versions/MonoText.tsx | 33 +-
.../airflow/ui/src/pages/Dag/Versions/PathText.tsx | 78 +
.../pages/Dag/Versions/SelectedVersionsDiff.tsx | 81 +
.../ui/src/pages/Dag/Versions/VersionDiff.test.tsx | 106 +-
.../ui/src/pages/Dag/Versions/VersionDiff.tsx | 122 +-
.../ui/src/pages/Dag/Versions/Versions.test.tsx | 6 +
.../airflow/ui/src/pages/Dag/Versions/Versions.tsx | 89 +-
.../ui/src/pages/DagBundles/DagBundles.test.tsx | 15 +-
.../src/airflow/ui/src/pages/DagRuns/DagRuns.tsx | 59 +-
.../src/airflow/ui/src/pages/DagsList/DagCard.tsx | 2 +-
.../ui/src/pages/DagsList/DagCardActions.tsx | 2 +
.../DagsList/DagFolderTree/DagFolderTree.test.tsx | 107 +-
.../pages/DagsList/DagFolderTree/DagFolderTree.tsx | 8 +-
.../DagsList/DagFolderTree/buildFolderTree.ts | 3 +-
.../DagsList/DagsFilters/DagsFilters.test.tsx | 13 +-
.../ui/src/pages/DagsList/DagsList.test.tsx | 92 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 185 +-
.../DagsList/DagsListColumns.test.tsx} | 25 +-
.../ui/src/pages/DagsList/DagsListColumns.tsx | 15 +-
airflow-core/src/airflow/ui/src/pages/Iframe.tsx | 28 +-
.../src/airflow/ui/src/pages/ReactPlugin.test.tsx | 10 +
.../src/airflow/ui/src/pages/ReactPlugin.tsx | 7 +-
.../airflow/ui/src/pages/Run/CallbackLogs.test.tsx | 85 +
.../src/airflow/ui/src/pages/Run/CallbackLogs.tsx | 189 +
.../airflow/ui/src/pages/Run/Callbacks.test.tsx | 142 +
.../src/airflow/ui/src/pages/Run/Callbacks.tsx | 161 +
.../src/airflow/ui/src/pages/Run/Header.tsx | 10 +-
.../src/airflow/ui/src/pages/Run/Run.test.tsx | 81 +
airflow-core/src/airflow/ui/src/pages/Run/Run.tsx | 35 +-
.../ui/src/pages/TaskInstance/ExtraLinks.tsx | 14 +-
.../ui/src/pages/TaskInstance/Header.test.tsx | 31 +-
.../airflow/ui/src/pages/TaskInstance/Header.tsx | 53 +-
.../ui/src/pages/TaskInstance/stateReason.ts | 8 +-
.../ui/src/pages/TaskInstances/TaskInstances.tsx | 37 +-
.../ui/src/pages/TaskStateStore/TaskStateStore.tsx | 1 +
.../Variables/ManageVariable/VariableForm.test.tsx | 7 +-
.../airflow/ui/src/pages/Variables/Variables.tsx | 1 +
.../src/airflow/ui/src/pages/XCom/XCom.test.tsx | 14 +-
.../src/airflow/ui/src/pages/XCom/XCom.tsx | 1 +
.../airflow/ui/src/pages/XCom/XComEntry.test.tsx | 8 +-
.../ui/src/queries/useDagRunStateCounts.tsx | 2 +-
.../airflow/ui/src/queries/useDagTagsInfinite.ts | 15 +-
.../src/airflow/ui/src/queries/useDags.test.tsx | 96 +
.../src/airflow/ui/src/queries/useDags.tsx | 2 +-
.../src/airflow/ui/src/queries/useLogs.tsx | 45 +-
.../ui/src/queries/useLoopFilterOptions.test.ts | 10 +-
.../airflow/ui/src/queries/useTogglePause.test.tsx | 10 +-
airflow-core/src/airflow/ui/src/router.tsx | 2 +
.../src/airflow/ui/src/utils/links.test.ts | 218 +-
airflow-core/src/airflow/ui/src/utils/links.ts | 168 +-
.../airflow/ui/src/utils/pluginAppliesTo.test.ts | 41 +
.../src/airflow/ui/src/utils/pluginAppliesTo.ts | 54 +-
.../src/airflow/ui/src/utils/pluginIcon.test.ts | 59 +
.../DrainingBadge.tsx => utils/pluginIcon.ts} | 37 +-
.../airflow/ui/src/utils/pluginTemplate.test.ts | 72 +
.../src/airflow/ui/src/utils/pluginTemplate.ts | 54 +
.../airflow/ui/tests/e2e/specs/backfill.spec.ts | 12 +-
airflow-core/src/airflow/ui/testsSetup.ts | 37 +-
airflow-core/src/airflow/utils/cli.py | 393 +-
.../src/airflow/utils/cli_action_loggers.py | 2 +-
airflow-core/src/airflow/utils/db.py | 16 +-
airflow-core/src/airflow/utils/db_cleanup.py | 6 +-
airflow-core/src/airflow/utils/file.py | 2 +-
.../src/airflow/utils/log/file_task_handler.py | 17 +-
.../src/airflow/utils/log/path_log_reader.py | 98 +
.../src/airflow/utils/log/task_log_address.py | 10 +-
airflow-core/src/airflow/utils/memray_utils.py | 2 +
airflow-core/src/airflow/utils/retries.py | 2 +-
airflow-core/src/airflow/utils/sqlalchemy.py | 12 +-
airflow-core/tests/unit/always/test_connection.py | 8 +
.../tests/unit/always/test_project_structure.py | 59 +-
.../auth/managers/test_base_auth_manager.py | 55 +
.../auth/middlewares/test_refresh_token.py | 473 +-
.../tests/unit/api_fastapi/auth/test_tokens.py | 10 +-
.../unit/api_fastapi/common/test_parameters.py | 19 +
.../core_api/datamodels/test_connections.py | 60 +
.../core_api/datamodels/test_dag_run.py | 66 +-
.../core_api/routes/public/test_assets.py | 177 +-
.../core_api/routes/public/test_auth.py | 4 +-
.../core_api/routes/public/test_backfills.py | 55 +
.../core_api/routes/public/test_connections.py | 154 +
.../core_api/routes/public/test_dag_run.py | 134 +-
.../core_api/routes/public/test_dag_sources.py | 2 +-
.../core_api/routes/public/test_dags.py | 12 +
.../core_api/routes/public/test_event_logs.py | 8 +-
.../core_api/routes/public/test_execution.py | 4 +-
.../core_api/routes/public/test_extra_links.py | 9 +-
.../core_api/routes/public/test_plugins.py | 64 +
.../core_api/routes/public/test_pools.py | 48 +
.../core_api/routes/public/test_task_instances.py | 168 +-
.../core_api/routes/public/test_variables.py | 44 +-
.../core_api/routes/public/test_xcom.py | 106 +-
.../api_fastapi/core_api/routes/ui/test_assets.py | 42 +-
.../api_fastapi/core_api/routes/ui/test_dags.py | 12 +
.../core_api/routes/ui/test_deadlines.py | 125 +-
.../core_api/routes/ui/test_dependencies.py | 189 +-
.../api_fastapi/core_api/routes/ui/test_gantt.py | 123 +-
.../api_fastapi/core_api/routes/ui/test_grid.py | 58 +-
.../tests/unit/api_fastapi/core_api/test_app.py | 98 +-
.../versions/head/test_connection_tests.py | 33 +
.../execution_api/versions/head/test_dag_runs.py | 21 +
.../execution_api/versions/head/test_hitl.py | 11 +-
.../versions/head/test_task_instances.py | 148 +-
.../execution_api/versions/head/test_xcoms.py | 205 +-
.../versions/v2026_04_06/test_task_instances.py | 339 +
.../versions/v2026_10_30/test_task_instances.py | 34 +
.../unit/api_fastapi/logging/test_decorators.py | 15 +
airflow-core/tests/unit/api_fastapi/test_app.py | 26 +
airflow-core/tests/unit/assets/test_manager.py | 283 +-
.../tests/unit/cli/commands/test_dag_command.py | 2 +-
.../unit/cli/commands/test_kerberos_command.py | 36 +
.../unit/cli/commands/test_plugins_command.py | 33 +
.../tests/unit/cli/commands/test_task_command.py | 23 +
airflow-core/tests/unit/cli/test_cli_parser.py | 13 +
airflow-core/tests/unit/core/test_configuration.py | 24 +
.../tests/unit/dag_processing/test_manager.py | 6 +-
.../tests/unit/dag_processing/test_processor.py | 25 +-
.../tests/unit/executors/test_base_executor.py | 6 +-
.../tests/unit/executors/test_executor_loader.py | 48 +-
.../tests/unit/executors/test_local_executor.py | 105 +
.../tests/unit/executors/test_workloads.py | 6 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 430 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 176 +-
.../test_0143_add_dynamic_region_storage.py | 10 +-
.../test_0144_rename_stored_map_index.py | 12 +-
.../test_0148_add_pending_partition_key_to_apdr.py | 187 +
.../unit/migrations/test_migration_patterns.py | 2 +-
airflow-core/tests/unit/models/conftest.py | 7 +-
airflow-core/tests/unit/models/test_callback.py | 200 +-
airflow-core/tests/unit/models/test_cleartasks.py | 42 +-
airflow-core/tests/unit/models/test_connection.py | 29 +
.../tests/unit/models/test_connection_test.py | 34 +-
airflow-core/tests/unit/models/test_dag_version.py | 8 +-
airflow-core/tests/unit/models/test_dagbag.py | 57 +
airflow-core/tests/unit/models/test_dagrun.py | 107 +-
airflow-core/tests/unit/models/test_deadline.py | 167 +-
.../tests/unit/models/test_dynamic_region.py | 302 +-
.../tests/unit/models/test_mappedoperator.py | 108 +-
.../tests/unit/models/test_task_coordinates.py | 82 +
.../tests/unit/models/test_taskinstance.py | 49 +-
airflow-core/tests/unit/models/test_trigger.py | 326 +-
airflow-core/tests/unit/models/test_xcom.py | 90 +
.../tests/unit/plugins/test_plugins_manager.py | 321 +-
.../unit/serialization/test_dag_serialization.py | 18 +
.../tests/unit/serialization/test_operatorlink.py | 21 +
.../unit/serialization/test_serialized_objects.py | 86 +-
.../tests/unit/serialization/test_stringify.py | 91 +-
.../deps/test_not_previously_skipped_dep.py | 311 +
.../unit/ti_deps/deps/test_trigger_rule_dep.py | 64 +-
airflow-core/tests/unit/triggers/test_callback.py | 114 +-
.../tests/unit/utils/log/test_path_log_reader.py | 76 +
airflow-core/tests/unit/utils/test_cli_util.py | 762 +-
airflow-core/tests/unit/utils/test_db.py | 50 +-
airflow-core/tests/unit/utils/test_db_cleanup.py | 22 +
airflow-core/tests/unit/utils/test_db_manager.py | 2 +-
airflow-core/tests/unit/utils/test_file.py | 16 +-
airflow-core/tests/unit/utils/test_log_handlers.py | 30 +
airflow-core/tests/unit/utils/test_sqlalchemy.py | 20 +
airflow-ctl-tests/.pre-commit-config.yaml | 4 +
airflow-ctl/.pre-commit-config.yaml | 8 +
airflow-ctl/README.md | 2 +-
airflow-ctl/docs/cli-and-env-variables-ref.rst | 3 +
airflow-ctl/docs/howto/index.rst | 2 +-
airflow-ctl/docs/images/command_hashes.txt | 4 +-
airflow-ctl/docs/images/output_auth.svg | 86 +-
airflow-ctl/docs/images/output_auth_login.svg | 104 +-
airflow-ctl/pyproject.toml | 2 +-
airflow-ctl/src/airflowctl/api/client.py | 4 +-
.../airflowctl/api/datamodels/auth_generated.py | 2 +-
.../src/airflowctl/api/datamodels/generated.py | 67 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 10 +-
airflow-ctl/tests/airflow_ctl/api/test_client.py | 31 +
airflow-e2e-tests/.pre-commit-config.yaml | 2 +
airflow-e2e-tests/docker/Dockerfile.java | 23 +-
.../apache/airflow/e2e/NativeBundleBuilder.java | 36 +-
.../airflow/e2e/nativedag/AnnotationDag.java | 25 +-
.../apache/airflow/e2e/nativedag/DynamicDags.java | 5 +-
.../apache/airflow/e2e/nativedag/TargetDag.java | 5 +-
airflow-e2e-tests/pyproject.toml | 2 +-
.../java_sdk_tests/test_java_sdk_native_dag.py | 17 +-
chart/.pre-commit-config.yaml | 28 +
chart/docs/customizing-workers.rst | 46 +
contributing-docs/05_pull_requests.rst | 15 +-
contributing-docs/11_documentation_building.rst | 11 +
contributing-docs/18_contribution_workflow.rst | 83 +-
.../20_debugging_airflow_components.rst | 14 +-
contributing-docs/25_maintainer_pr_triage.md | 16 +-
.../26_migration_round_trip_check.rst | 4 +-
contributing-docs/30_new_language_sdk.rst | 183 +-
contributing-docs/testing/k8s_tests.rst | 9 +-
contributing-docs/testing/unit_tests.rst | 2 +-
dev/.pre-commit-config.yaml | 2 +
dev/README_AIRFLOW3_DEV.md | 49 +-
dev/README_RELEASE_AIRFLOW.md | 59 +-
dev/README_RELEASE_AIRFLOWCTL.md | 12 +-
dev/README_RELEASE_PROVIDERS.md | 165 +-
dev/breeze/doc/01_installation.rst | 4 +
dev/breeze/doc/03_developer_tasks.rst | 41 +-
dev/breeze/doc/04_troubleshooting.rst | 5 +-
dev/breeze/doc/05_test_commands.rst | 2 +-
dev/breeze/doc/09_release_management_tasks.rst | 38 +-
...19-isolate-docker-resources-per-git-worktree.md | 154 +
...0-run-ci-for-external-contributions-in-forks.md | 16 +-
dev/breeze/doc/ci/02_images.md | 24 +-
dev/breeze/doc/ci/04_selective_checks.md | 69 +-
dev/breeze/doc/ci/05_workflows.md | 80 +-
.../doc/ci/08_fork_ci_for_external_contributors.md | 192 +-
dev/breeze/doc/images/output_build-docs.svg | 52 +-
dev/breeze/doc/images/output_build-docs.txt | 2 +-
dev/breeze/doc/images/output_ci-image_build.svg | 94 +-
dev/breeze/doc/images/output_ci-image_build.txt | 2 +-
.../doc/images/output_ci_selective-check.svg | 54 +-
.../doc/images/output_ci_selective-check.txt | 2 +-
dev/breeze/doc/images/output_ci_upgrade.svg | 92 +-
dev/breeze/doc/images/output_ci_upgrade.txt | 2 +-
dev/breeze/doc/images/output_prod-image_build.svg | 164 +-
dev/breeze/doc/images/output_prod-image_build.txt | 2 +-
.../doc/images/output_release-management.svg | 38 +-
.../doc/images/output_release-management.txt | 2 +-
...utput_release-management_mirror-base-images.svg | 116 +
...utput_release-management_mirror-base-images.txt | 1 +
...ut_release-management_publish-schemas-to-s3.svg | 34 +-
...ut_release-management_publish-schemas-to-s3.txt | 2 +-
dev/breeze/doc/images/output_setup.svg | 14 +-
dev/breeze/doc/images/output_setup.txt | 2 +-
.../output_setup_check-all-params-in-groups.svg | 20 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
dev/breeze/doc/images/output_setup_config.svg | 100 +-
dev/breeze/doc/images/output_setup_config.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 2 +-
.../output_setup_regenerate-command-images.txt | 2 +-
.../images/output_workflow-run_publish-docs.svg | 28 +-
.../images/output_workflow-run_publish-docs.txt | 2 +-
dev/breeze/pyproject.toml | 13 +-
.../src/airflow_breeze/commands/ci_commands.py | 88 +-
.../airflow_breeze/commands/ci_commands_config.py | 3 +
.../airflow_breeze/commands/ci_image_commands.py | 4 -
.../commands/ci_image_commands_config.py | 1 -
.../commands/common_image_options.py | 10 +
.../airflow_breeze/commands/developer_commands.py | 42 +-
.../commands/developer_commands_config.py | 1 +
.../airflow_breeze/commands/kubernetes_commands.py | 12 +-
.../commands/production_image_commands.py | 4 +
.../commands/production_image_commands_config.py | 1 +
.../commands/release_management_commands.py | 118 +-
.../commands/release_management_commands_config.py | 10 +
.../src/airflow_breeze/commands/setup_commands.py | 28 +-
.../commands/setup_commands_config.py | 1 +
.../src/airflow_breeze/commands/ui_commands.py | 65 +-
.../src/airflow_breeze/commands/verify_commands.py | 17 +-
.../airflow_breeze/commands/workflow_commands.py | 170 +-
.../commands/workflow_commands_config.py | 1 +
dev/breeze/src/airflow_breeze/global_constants.py | 42 +-
.../src/airflow_breeze/params/build_prod_params.py | 11 +
.../airflow_breeze/params/common_build_params.py | 6 +-
.../src/airflow_breeze/params/shell_params.py | 13 +-
.../airflow_breeze/utils/check_release_files.py | 2 +-
dev/breeze/src/airflow_breeze/utils/ci_audit.py | 138 +-
dev/breeze/src/airflow_breeze/utils/ci_group.py | 22 +-
.../airflow_breeze/utils/docker_command_utils.py | 89 +-
.../src/airflow_breeze/utils/fork_ci_gate.py | 25 +-
.../src/airflow_breeze/utils/fork_ci_github.py | 36 +-
.../src/airflow_breeze/utils/fork_ci_messages.py | 37 +-
.../src/airflow_breeze/utils/fork_ci_reconcile.py | 216 +-
.../src/airflow_breeze/utils/fork_compare.py | 84 +-
dev/breeze/src/airflow_breeze/utils/git_remotes.py | 12 +-
dev/breeze/src/airflow_breeze/utils/github.py | 2 +-
.../src/airflow_breeze/utils/kubernetes_utils.py | 34 +-
dev/breeze/src/airflow_breeze/utils/path_utils.py | 82 +-
.../src/airflow_breeze/utils/publish_docs_to_s3.py | 6 +-
.../src/airflow_breeze/utils/selective_checks.py | 90 +-
.../src/airflow_breeze/utils/worktree_watcher.py | 168 +
dev/breeze/tests/conftest.py | 16 +
dev/breeze/tests/test_build_prod_params.py | 82 +
dev/breeze/tests/test_ci_audit.py | 140 +-
dev/breeze/tests/test_ci_commands.py | 166 +
.../dagrun.py => dev/breeze/tests/test_ci_group.py | 33 +-
dev/breeze/tests/test_ci_upgrade.py | 5 +
dev/breeze/tests/test_developer_commands.py | 150 +-
dev/breeze/tests/test_docker_command_utils.py | 196 +-
dev/breeze/tests/test_environment_check.py | 2 +-
dev/breeze/tests/test_fork_ci_gate.py | 37 +-
dev/breeze/tests/test_fork_ci_github.py | 25 +-
dev/breeze/tests/test_fork_ci_messages.py | 44 +-
dev/breeze/tests/test_fork_ci_reconcile.py | 352 +-
dev/breeze/tests/test_fork_compare.py | 58 +-
dev/breeze/tests/test_git_remotes.py | 20 +
dev/breeze/tests/test_git_worktree.py | 123 +-
.../tests/test_kubernetes_lang_sdk_commands.py | 45 +
dev/breeze/tests/test_kubernetes_utils.py | 86 +
dev/breeze/tests/test_mirror_base_images.py | 98 +
dev/breeze/tests/test_path_utils.py | 51 +
dev/breeze/tests/test_pr_info.py | 2 +-
.../tests/test_release_management_commands.py | 28 +
dev/breeze/tests/test_selective_check_command.py | 73 -
dev/breeze/tests/test_selective_checks.py | 112 +-
dev/breeze/tests/test_shell_params.py | 45 +-
dev/breeze/tests/test_ui_commands.py | 28 +-
dev/breeze/tests/test_verify_commands.py | 18 +
dev/breeze/tests/test_workflow_commands.py | 205 +
dev/breeze/tests/test_worktree_watcher.py | 193 +
dev/breeze/uv.lock | 1233 +--
dev/mypy/.pre-commit-config.yaml | 4 +
dev/mypy/pyproject.toml | 2 +-
.../react_plugin_template/package.json | 22 +-
.../react_plugin_template/pnpm-lock.yaml | 652 +-
dev/skill-evals/last-eval-hash.txt | 2 +-
devel-common/pyproject.toml | 6 +-
devel-common/sphinx_design/static/custom.css | 12 +-
devel-common/src/docs/utils/conf_constants.py | 1 +
.../docs_build/third_party_inventories.py | 1 +
devel-common/src/tests_common/pytest_plugin.py | 95 +-
.../src/tests_common/test_utils/mock_context.py | 1 +
.../src/tests_common/test_utils/xcom_backends.py | 17 +-
docker-stack-docs/build-arg-ref.rst | 30 +-
docker-stack-docs/build.rst | 128 +-
docker-stack-docs/changelog.rst | 43 +
.../customizing/add-build-essential-custom.sh | 4 +-
.../docker-examples/customizing/custom-sources.sh | 4 +-
.../customizing/pypi-dev-runtime-deps.sh | 4 +-
.../customizing/pypi-extras-and-deps.sh | 4 +-
.../customizing/pypi-selected-version.sh | 4 +-
.../extending/add-providers/Dockerfile | 4 +-
.../restricted/restricted_environments.sh | 4 +-
docker-tests/.pre-commit-config.yaml | 2 +
docs/README.md | 4 +-
docs/spelling_wordlist.txt | 9 +
generated/known_airflow_exceptions.txt | 2 +-
generated/known_sdk_imports_in_core.txt | 6 +-
generated/provider_metadata.json | 20 +
go-sdk/.pre-commit-config.yaml | 14 +
go-sdk/DEVELOPMENT.md | 215 +
go-sdk/README.md | 603 +-
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/capabilities.yaml | 153 +-
go-sdk/example/README.md | 129 +
go-sdk/example/native/main.go | 2 +-
go-sdk/internal/bundle/task.go | 58 +-
go-sdk/internal/bundle/task_test.go | 116 +-
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 | 175 +-
go-sdk/pkg/execution/logger.go | 36 +-
go-sdk/pkg/execution/logger_test.go | 38 +
go-sdk/schema/supervisor-schema.json | 143 +-
java-sdk/{README.md => DEVELOPMENT.md} | 139 +-
java-sdk/README.md | 870 +--
java-sdk/capabilities.yaml | 153 +-
java-sdk/example/README.md | 107 +
.../example/nativedag/AnnotationExample.java | 6 +-
.../example/nativedag/InterfaceExample.java | 7 +-
.../airflow/example/nativedag/TargetExample.java | 1 +
java-sdk/gradle/verification-metadata.xml | 13 -
.../org/apache/airflow/sdk/AirflowProcessor.kt | 21 +-
.../org/apache/airflow/sdk/AirflowProcessorTest.kt | 255 +-
.../apache/airflow/example/ScalaSparkExample.scala | 33 +-
.../ci/prek/check_serialization_conformance.py | 2 +-
java-sdk/scripts/ci/verify-source-release.sh | 2 +-
java-sdk/sdk/build.gradle.kts | 29 +-
java-sdk/sdk/module.md | 177 +-
.../main/kotlin/org/apache/airflow/sdk/Client.kt | 2 -
.../main/kotlin/org/apache/airflow/sdk/DagDef.kt | 101 +-
.../src/main/kotlin/org/apache/airflow/sdk/Deps.kt | 69 +-
.../main/kotlin/org/apache/airflow/sdk/Label.kt | 93 +
.../kotlin/org/apache/airflow/sdk/TaskGroupRef.kt | 13 +-
.../kotlin/org/apache/airflow/sdk/TriggerDagRun.kt | 1 +
.../org/apache/airflow/sdk/execution/Logger.kt | 16 +-
.../org/apache/airflow/sdk/execution/Serde.kt | 62 +-
.../org/apache/airflow/sdk/internal/Fields.kt | 22 +-
.../kotlin/org/apache/airflow/sdk/internal/Ids.kt | 13 +
.../kotlin/org/apache/airflow/sdk/DagDefTest.kt | 28 +
.../kotlin/org/apache/airflow/sdk/EdgeLabelTest.kt | 323 +
.../kotlin/org/apache/airflow/sdk/TaskGroupTest.kt | 98 +
.../airflow/sdk/conformance/SerializeJava.kt | 6 +-
.../org/apache/airflow/sdk/execution/LogTest.kt | 62 +
.../org/apache/airflow/sdk/execution/SerdeTest.kt | 64 +
kubernetes-tests/.pre-commit-config.yaml | 2 +
kubernetes-tests/lang_sdk/Dockerfile.runtimes | 23 +-
kubernetes-tests/lang_sdk/ts_example/package.json | 2 +-
providers/.last_release_date.txt | 2 +-
providers/.pre-commit-config.yaml | 62 +-
providers/alibaba/README.rst | 6 +-
providers/alibaba/docs/changelog.rst | 11 +
providers/alibaba/docs/index.rst | 6 +-
providers/alibaba/provider.yaml | 3 +-
providers/alibaba/pyproject.toml | 6 +-
.../src/airflow/providers/alibaba/__init__.py | 2 +-
.../alibaba/cloud/log/oss_task_handler.py | 2 +-
providers/amazon/.pre-commit-config.yaml | 2 +
providers/amazon/README.rst | 19 +-
providers/amazon/docs/changelog.rst | 42 +
providers/amazon/docs/executors/eks-executor.rst | 223 +
providers/amazon/docs/executors/general.rst | 6 +-
providers/amazon/docs/executors/index.rst | 4 +
providers/amazon/docs/index.rst | 19 +-
.../amazon/docs/operators/athena/athena_spark.rst | 25 +-
providers/amazon/docs/operators/bedrock.rst | 3 +
providers/amazon/docs/operators/ecs.rst | 36 +
providers/amazon/docs/operators/eks.rst | 30 +
.../amazon/docs/operators/emr/emr_serverless.rst | 14 +
providers/amazon/docs/operators/glue.rst | 4 +-
providers/amazon/docs/transfer/sql_to_s3.rst | 4 +
providers/amazon/provider.yaml | 45 +-
providers/amazon/pyproject.toml | 18 +-
.../src/airflow/providers/amazon/__init__.py | 2 +-
.../amazon/aws/executors/eks}/__init__.py | 5 +
.../amazon/aws/executors/eks/_client_factory.py | 170 +
.../amazon/aws/executors/eks/eks_executor.py | 189 +
.../providers/amazon/aws/executors/eks/utils.py | 36 +-
.../airflow/providers/amazon/aws/hooks/athena.py | 7 +
.../src/airflow/providers/amazon/aws/hooks/dms.py | 24 +-
.../src/airflow/providers/amazon/aws/hooks/eks.py | 32 +
.../src/airflow/providers/amazon/aws/hooks/s3.py | 56 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 16 +-
.../providers/amazon/aws/log/s3_task_handler.py | 2 +-
.../providers/amazon/aws/operators/batch.py | 5 +-
.../providers/amazon/aws/operators/bedrock.py | 77 +-
.../providers/amazon/aws/operators/comprehend.py | 13 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 57 +-
.../airflow/providers/amazon/aws/operators/eks.py | 235 +-
.../airflow/providers/amazon/aws/operators/emr.py | 170 +-
.../airflow/providers/amazon/aws/operators/glue.py | 83 +-
.../providers/amazon/aws/operators/glue_crawler.py | 11 +-
.../amazon/aws/operators/glue_databrew.py | 8 +-
.../amazon/aws/operators/kinesis_analytics.py | 15 +-
.../amazon/aws/operators/lambda_function.py | 7 +-
.../airflow/providers/amazon/aws/operators/mwaa.py | 8 +-
.../providers/amazon/aws/operators/neptune.py | 13 +-
.../amazon/aws/operators/neptune_analytics.py | 43 +-
.../providers/amazon/aws/operators/quicksight.py | 7 +-
.../airflow/providers/amazon/aws/operators/rds.py | 33 +-
.../amazon/aws/operators/redshift_cluster.py | 17 +-
.../amazon/aws/operators/redshift_data.py | 36 +-
.../providers/amazon/aws/operators/sagemaker.py | 19 +-
.../aws/operators/sagemaker_unified_studio.py | 7 +-
.../operators/sagemaker_unified_studio_notebook.py | 8 +-
.../airflow/providers/amazon/aws/operators/ssm.py | 9 +-
.../providers/amazon/aws/sensors/athena_spark.py | 84 +
.../providers/amazon/aws/sensors/bedrock.py | 13 +-
.../airflow/providers/amazon/aws/sensors/dms.py | 11 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 48 +-
.../airflow/providers/amazon/aws/triggers/eks.py | 44 +-
.../airflow/providers/amazon/aws/triggers/emr.py | 48 +
.../providers/amazon/aws/triggers/sagemaker.py | 9 +-
.../airflow/providers/amazon/aws/utils/deferral.py | 41 +
.../providers/amazon/aws/utils/eks_get_token.py | 17 +-
.../providers/amazon/aws/utils/task_log_fetcher.py | 24 +-
.../providers/amazon/aws/waiters/bedrock.json | 2 +-
.../amazon/aws/waiters/emr-serverless.json | 19 +
.../airflow/providers/amazon/get_provider_info.py | 39 +-
.../src/airflow/providers/amazon/version_compat.py | 2 +
.../system/amazon/aws/example_athena_spark.py | 25 +-
.../amazon/aws/example_eks_with_nodegroups.py | 89 +-
.../tests/system/amazon/aws/example_emr_eks.py | 28 +-
.../amazon/aws/example_emr_serverless_session.py | 10 +
.../system/amazon/aws/example_mwaa_serverless.py | 13 +
.../amazon/tests/system/amazon/aws/utils/ec2.py | 29 +-
.../tests/unit/amazon/aws/bundles/test_s3.py | 18 +
.../aws/executors/batch/test_batch_executor.py | 16 +
.../unit/amazon/aws/executors/eks}/__init__.py | 0
.../aws/executors/eks/test__client_factory.py | 264 +
.../amazon/aws/executors/eks/test_eks_executor.py | 238 +
.../unit/amazon/aws/executors/eks/test_utils.py | 20 +-
.../aws/executors/utils/test_base_config_keys.py | 34 +-
.../amazon/tests/unit/amazon/aws/hooks/test_dms.py | 6 +
.../amazon/tests/unit/amazon/aws/hooks/test_eks.py | 84 +
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 128 +
.../amazon/aws/log/test_cloudwatch_task_handler.py | 15 +
.../tests/unit/amazon/aws/operators/test_batch.py | 10 +-
.../unit/amazon/aws/operators/test_bedrock.py | 100 +-
.../unit/amazon/aws/operators/test_comprehend.py | 17 +-
.../tests/unit/amazon/aws/operators/test_ecs.py | 104 +-
.../tests/unit/amazon/aws/operators/test_eks.py | 397 +-
.../amazon/aws/operators/test_emr_add_steps.py | 51 +-
.../amazon/aws/operators/test_emr_containers.py | 11 +-
.../amazon/aws/operators/test_emr_serverless.py | 58 +-
.../aws/operators/test_emr_serverless_session.py | 115 +-
.../tests/unit/amazon/aws/operators/test_glue.py | 164 +-
.../unit/amazon/aws/operators/test_glue_crawler.py | 27 +-
.../amazon/aws/operators/test_glue_databrew.py | 16 +
.../amazon/aws/operators/test_kinesis_analytics.py | 11 +-
.../amazon/aws/operators/test_lambda_function.py | 10 +-
.../tests/unit/amazon/aws/operators/test_mwaa.py | 11 +-
.../unit/amazon/aws/operators/test_neptune.py | 26 +-
.../amazon/aws/operators/test_neptune_analytics.py | 65 +-
.../unit/amazon/aws/operators/test_quicksight.py | 6 +-
.../tests/unit/amazon/aws/operators/test_rds.py | 57 +-
.../amazon/aws/operators/test_redshift_cluster.py | 47 +-
.../amazon/aws/operators/test_redshift_data.py | 18 -
.../aws/operators/test_sagemaker_endpoint.py | 11 +-
.../aws/operators/test_sagemaker_pipeline.py | 21 +-
.../amazon/aws/operators/test_sagemaker_tuning.py | 11 +-
.../aws/operators/test_sagemaker_unified_studio.py | 9 +-
.../test_sagemaker_unified_studio_notebook.py | 9 +-
.../tests/unit/amazon/aws/operators/test_ssm.py | 6 +-
.../unit/amazon/aws/sensors/test_athena_spark.py | 175 +
.../tests/unit/amazon/aws/sensors/test_bedrock.py | 21 +
.../tests/unit/amazon/aws/sensors/test_dms.py | 37 +-
.../unit/amazon/aws/transfers/test_sql_to_s3.py | 155 +-
.../tests/unit/amazon/aws/triggers/test_eks.py | 29 +
.../tests/unit/amazon/aws/triggers/test_emr.py | 60 +
.../unit/amazon/aws/triggers/test_sagemaker.py | 65 +-
.../tests/unit/amazon/aws/utils/test_deferral.py | 53 +
.../unit/amazon/aws/utils/test_eks_get_token.py | 53 +-
.../unit/amazon/aws/utils/test_task_log_fetcher.py | 8 +
.../tests/unit/amazon/aws/waiters/test_bedrock.py | 11 +-
.../anthropic/docs/.latest-doc-only-change.txt | 2 +-
providers/apache/hdfs/README.rst | 6 +-
providers/apache/hdfs/docs/changelog.rst | 11 +
providers/apache/hdfs/docs/index.rst | 6 +-
providers/apache/hdfs/provider.yaml | 3 +-
providers/apache/hdfs/pyproject.toml | 6 +-
.../src/airflow/providers/apache/hdfs/__init__.py | 2 +-
.../providers/apache/hdfs/log/hdfs_task_handler.py | 2 +-
.../hive/tests/unit/apache/hive/hooks/test_hive.py | 10 +-
providers/apache/livy/README.rst | 8 +-
providers/apache/livy/docs/changelog.rst | 11 +
providers/apache/livy/docs/index.rst | 8 +-
providers/apache/livy/provider.yaml | 3 +-
providers/apache/livy/pyproject.toml | 8 +-
.../src/airflow/providers/apache/livy/__init__.py | 2 +-
.../providers/apache/livy/operators/livy.py | 40 +-
.../tests/unit/apache/livy/operators/test_livy.py | 18 -
providers/apache/spark/README.rst | 8 +-
providers/apache/spark/docs/changelog.rst | 16 +
providers/apache/spark/docs/index.rst | 8 +-
providers/apache/spark/provider.yaml | 3 +-
providers/apache/spark/pyproject.toml | 8 +-
.../src/airflow/providers/apache/spark/__init__.py | 2 +-
.../apache/spark/operators/spark_submit.py | 35 +-
.../apache/spark/operators/test_spark_submit.py | 17 -
providers/apache/tinkerpop/README.rst | 6 +-
providers/apache/tinkerpop/docs/changelog.rst | 17 +
providers/apache/tinkerpop/docs/index.rst | 6 +-
providers/apache/tinkerpop/provider.yaml | 3 +-
providers/apache/tinkerpop/pyproject.toml | 6 +-
.../airflow/providers/apache/tinkerpop/__init__.py | 2 +-
providers/celery/README.rst | 6 +-
providers/celery/docs/celery_executor.rst | 17 +
providers/celery/docs/changelog.rst | 16 +
providers/celery/docs/index.rst | 6 +-
providers/celery/provider.yaml | 5 +-
providers/celery/pyproject.toml | 6 +-
.../src/airflow/providers/celery/__init__.py | 2 +-
.../providers/celery/executors/default_celery.py | 30 +-
.../airflow/providers/celery/get_provider_info.py | 2 +-
.../unit/celery/executors/test_celery_executor.py | 7 +-
.../unit/celery/executors/test_default_celery.py | 175 +
providers/cncf/kubernetes/README.rst | 8 +-
providers/cncf/kubernetes/docs/changelog.rst | 29 +
providers/cncf/kubernetes/docs/index.rst | 8 +-
.../cncf/kubernetes/docs/kubernetes_executor.rst | 44 +
providers/cncf/kubernetes/docs/operators.rst | 37 +
providers/cncf/kubernetes/provider.yaml | 19 +-
providers/cncf/kubernetes/pyproject.toml | 15 +-
.../airflow/providers/cncf/kubernetes/__init__.py | 2 +-
.../providers/cncf/kubernetes/cli/definition.py | 35 +-
.../cncf/kubernetes/cli/kubernetes_command.py | 79 +-
.../kubernetes/executors/kubernetes_executor.py | 39 +-
.../executors/kubernetes_executor_utils.py | 19 +-
.../providers/cncf/kubernetes/get_provider_info.py | 4 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 19 +-
.../providers/cncf/kubernetes/kube_client.py | 175 +-
.../providers/cncf/kubernetes/operators/pod.py | 20 +-
.../providers/cncf/kubernetes/triggers/pod.py | 68 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 52 +-
.../cncf/kubernetes/cli/test_kubernetes_command.py | 219 +-
.../executors/test_kubernetes_executor.py | 119 +-
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 38 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 54 +
.../tests/unit/cncf/kubernetes/test_client.py | 203 +-
.../tests/unit/cncf/kubernetes/test_kube_client.py | 124 +-
.../unit/cncf/kubernetes/triggers/test_pod.py | 47 +
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 69 +
providers/common/ai/.pre-commit-config.yaml | 6 +
providers/common/ai/README.rst | 10 +-
providers/common/ai/docs/changelog.rst | 83 +-
providers/common/ai/docs/durable_execution.rst | 6 +-
providers/common/ai/docs/examples.rst | 4 +
providers/common/ai/docs/features.rst | 7 +-
providers/common/ai/docs/frameworks/adk.rst | 2 +-
providers/common/ai/docs/frameworks/anthropic.rst | 11 +-
.../common/ai/docs/frameworks/openai_agents.rst | 72 +-
.../common/ai/docs/frameworks/pydantic_ai.rst | 6 +
providers/common/ai/docs/frameworks/strands.rst | 2 +-
providers/common/ai/docs/index.rst | 12 +-
providers/common/ai/docs/message_history.rst | 10 +-
providers/common/ai/docs/observability.rst | 43 +-
providers/common/ai/docs/operators/agent.rst | 3 +
providers/common/ai/docs/operators/llm.rst | 8 +
providers/common/ai/docs/retry_policies.rst | 4 +-
providers/common/ai/docs/stability.rst | 7 +-
providers/common/ai/docs/structured_output.rst | 48 +-
providers/common/ai/docs/supported_services.rst | 10 +-
providers/common/ai/docs/toolsets/custom.rst | 173 +
providers/common/ai/docs/toolsets/datafusion.rst | 7 +-
providers/common/ai/docs/toolsets/index.rst | 4 +-
providers/common/ai/docs/troubleshooting.rst | 6 +-
providers/common/ai/docs/use_cases/index.rst | 4 +
.../use_cases/refine_a_draft_within_a_budget.rst | 202 +
providers/common/ai/provider.yaml | 5 +-
providers/common/ai/pyproject.toml | 15 +-
.../ai/src/airflow/providers/common/ai/__init__.py | 2 +-
.../providers/common/ai/durable/openai_agents.py | 479 ++
.../airflow/providers/common/ai/durable/strands.py | 4 +-
.../common/ai/example_dags/example_adk_agent.py | 8 +-
.../ai/example_dags/example_agent_capabilities.py | 2 +-
.../ai/example_dags/example_agent_loop_budget.py | 141 +
.../ai/example_dags/example_agent_tool_approval.py | 2 +-
.../example_dags/example_anthropic_tool_runner.py | 7 +-
.../ai/example_dags/example_custom_toolset.py | 160 +
.../ai/example_dags/example_llm_retry_policy.py | 19 +-
.../example_dags/example_openai_agents_durable.py | 90 +
.../ai/example_dags/example_sandbox_toolset.py | 2 +-
.../ai/example_dags/example_strands_agent.py | 6 +-
.../providers/common/ai/get_provider_info.py | 2 +
.../src/airflow/providers/common/ai/hooks/mcp.py | 12 +-
.../providers/common/ai/hooks/pydantic_ai.py | 5 +
.../airflow/providers/common/ai/operators/agent.py | 125 +-
.../airflow/providers/common/ai/operators/llm.py | 119 +-
.../providers/common/ai/plugins/_plugin_urls.py | 13 +-
.../providers/common/ai/plugins/model_panel.py | 2 +-
.../providers/common/ai/plugins/www/package.json | 3 +-
.../providers/common/ai/plugins/www/pnpm-lock.yaml | 464 +-
.../providers/common/ai/plugins/www/src/api.ts | 7 +-
.../ai/plugins/www/src/components/ChatPage.tsx | 2 +-
.../ai/plugins/www/src/components/ModelPanel.tsx | 24 +-
.../ai/plugins/www/src/hooks/useModelInfo.ts | 44 +-
.../common/ai/plugins/www/src/hooks/useSession.ts | 3 +-
.../providers/common/ai/plugins/www/src/main.tsx | 9 +-
.../common/ai/plugins/www/src/model-api.ts | 17 +-
.../providers/common/ai/plugins/www/src/model.tsx | 38 +-
.../providers/common/ai/plugins/www/src/region.ts | 49 +
.../common/ai/plugins/www/tests/main.test.mjs | 2 +-
.../common/ai/plugins/www/tests/model-api.test.ts | 68 +
.../common/ai/plugins/www/tests/model.test.mjs | 121 +
.../common/ai/plugins/www/tests/region.test.ts | 45 +
.../airflow/providers/common/ai/policies/retry.py | 5 +-
.../airflow/providers/common/ai/tools/strands.py | 2 +-
.../airflow/providers/common/ai/toolsets/skills.py | 16 +-
.../airflow/providers/common/ai/utils/decision.py | 2 +-
.../providers/common/ai/utils/sql_validation.py | 12 +-
.../ai/tests/unit/common/ai/decorators/test_llm.py | 10 +-
.../unit/common/ai/durable/test_fingerprint.py | 6 +-
.../unit/common/ai/durable/test_openai_agents.py | 521 ++
.../tests/unit/common/ai/hooks/test_pydantic_ai.py | 20 +-
.../tests/unit/common/ai/mixins/test_approval.py | 2 +-
.../tests/unit/common/ai/operators/test_agent.py | 465 +-
.../ai/operators/test_agent_tool_approval.py | 1 -
.../ai/operators/test_llamaindex_embedding.py | 2 +-
.../ai/operators/test_llamaindex_retrieval.py | 2 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 284 +-
.../unit/common/ai/operators/test_llm_branch.py | 2 +-
.../common/ai/operators/test_llm_schema_compare.py | 2 +-
.../unit/common/ai/plugins/test__plugin_urls.py | 22 +-
.../unit/common/ai/plugins/test_hitl_review.py | 16 +-
.../unit/common/ai/plugins/test_model_panel.py | 18 +-
.../tests/unit/common/ai/policies/test_decision.py | 2 +-
.../ai/tests/unit/common/ai/policies/test_retry.py | 59 +-
.../ai/tests/unit/common/ai/sandbox/test_base.py | 4 +-
.../ai/tests/unit/common/ai/sandbox/test_modal.py | 5 +-
.../ai/tests/unit/common/ai/sandbox/test_sbx.py | 2 +-
.../tests/unit/common/ai/test_provider_metadata.py | 19 +-
.../ai/tests/unit/common/ai/tools/test_strands.py | 2 +-
.../unit/common/ai/toolsets/test_managed_agent.py | 2 +-
.../tests/unit/common/ai/toolsets/test_skills.py | 17 +
.../unit/common/ai/utils/test_prompt_cache.py | 38 +-
.../unit/common/ai/utils/test_sql_validation.py | 4 +-
providers/common/compat/.pre-commit-config.yaml | 2 +
providers/common/compat/README.rst | 6 +-
providers/common/compat/docs/changelog.rst | 19 +
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 +-
.../common/compat/_resumable_job_mixin.py | 58 +
.../providers/common/compat/connection/__init__.py | 35 +-
.../src/airflow/providers/common/compat/sdk.py | 7 +
.../common/compat/connection/test_connection.py | 64 +
.../common/compat/test__resumable_job_mixin.py | 95 +
.../tests/unit/common/compat/test__retry_policy.py | 4 +-
providers/common/io/README.rst | 8 +-
providers/common/io/docs/changelog.rst | 28 +
providers/common/io/docs/index.rst | 8 +-
providers/common/io/provider.yaml | 3 +-
providers/common/io/pyproject.toml | 8 +-
.../io/src/airflow/providers/common/io/__init__.py | 2 +-
.../airflow/providers/common/io/xcom/backend.py | 75 +-
.../common/io/example_file_transfer_local_to_s3.py | 2 +-
.../io/tests/unit/common/io/xcom/test_backend.py | 55 +
providers/common/sql/README.rst | 8 +-
providers/common/sql/docs/changelog.rst | 12 +
providers/common/sql/docs/index.rst | 8 +-
providers/common/sql/provider.yaml | 3 +-
providers/common/sql/pyproject.toml | 8 +-
.../src/airflow/providers/common/sql/__init__.py | 2 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 7 +-
.../sql/tests/unit/common/sql/hooks/test_sql.py | 33 +
.../unit/common/sql/operators/test_analytics.py | 2 +-
providers/databricks/README.rst | 11 +-
providers/databricks/docs/changelog.rst | 32 +
providers/databricks/docs/index.rst | 13 +-
providers/databricks/docs/operators/agent.rst | 210 +
providers/databricks/provider.yaml | 7 +-
providers/databricks/pyproject.toml | 13 +-
.../src/airflow/providers/databricks/__init__.py | 2 +-
.../src/airflow/providers/databricks/exceptions.py | 8 +
.../providers/databricks/get_provider_info.py | 12 +-
.../airflow/providers/databricks/hooks/agent.py | 464 ++
.../providers/databricks/operators/agent.py | 208 +
.../providers/databricks/operators/databricks.py | 42 +-
.../airflow/providers/databricks/triggers/agent.py | 99 +
.../system/databricks/example_databricks_agent.py | 112 +
.../tests/system/databricks/resources}/__init__.py | 0
.../databricks/resources/agent_server/README.md | 79 +
.../databricks/resources/agent_server}/__init__.py | 0
.../databricks/resources/agent_server/app.yaml} | 3 +
.../resources/agent_server/hello_agent.py | 34 +-
.../resources/agent_server/requirements.txt} | 3 +
.../tests/unit/databricks/hooks/test_agent.py | 1113 +++
.../tests/unit/databricks/operators/test_agent.py | 362 +
.../unit/databricks/operators/test_databricks.py | 18 -
.../tests/unit/databricks/triggers/test_agent.py | 115 +
providers/dbt/cloud/README.rst | 14 +-
providers/dbt/cloud/docs/changelog.rst | 11 +
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 +-
providers/discord/README.rst | 6 +-
providers/discord/docs/changelog.rst | 11 +
providers/discord/docs/index.rst | 6 +-
providers/discord/provider.yaml | 3 +-
providers/discord/pyproject.toml | 6 +-
.../src/airflow/providers/discord/__init__.py | 2 +-
.../providers/discord/hooks/discord_webhook.py | 2 +-
.../unit/discord/hooks/test_discord_webhook.py | 2 +-
providers/edge3/.pre-commit-config.yaml | 12 +
providers/edge3/README.rst | 6 +-
providers/edge3/docs/changelog.rst | 20 +
providers/edge3/docs/index.rst | 6 +-
providers/edge3/provider.yaml | 3 +-
providers/edge3/pyproject.toml | 6 +-
.../edge3/src/airflow/providers/edge3/__init__.py | 2 +-
.../src/airflow/providers/edge3/cli/worker.py | 25 +-
.../edge3/example_dags/integration_test.py | 5 +-
.../providers/edge3/plugins/www/package.json | 36 +-
.../providers/edge3/plugins/www/pnpm-lock.yaml | 1183 +--
.../providers/edge3/worker_api/routes/logs.py | 35 +-
.../edge3/worker_api/v2-edge-generated.yaml | 12 +
.../edge3/tests/unit/edge3/cli/test_worker.py | 54 +
.../unit/edge3/worker_api/routes/test_logs.py | 95 +-
providers/elasticsearch/README.rst | 6 +-
providers/elasticsearch/docs/changelog.rst | 16 +
providers/elasticsearch/docs/index.rst | 6 +-
providers/elasticsearch/provider.yaml | 3 +-
providers/elasticsearch/pyproject.toml | 6 +-
.../airflow/providers/elasticsearch/__init__.py | 2 +-
.../providers/elasticsearch/log/es_task_handler.py | 5 +-
.../unit/elasticsearch/log/test_es_task_handler.py | 3 +
providers/fab/.pre-commit-config.yaml | 12 +
providers/fab/README.rst | 6 +-
providers/fab/docs/auth-manager/access-control.rst | 60 +-
providers/fab/docs/changelog.rst | 33 +
providers/fab/docs/index.rst | 6 +-
providers/fab/provider.yaml | 3 +-
providers/fab/pyproject.toml | 6 +-
.../fab/src/airflow/providers/fab/__init__.py | 2 +-
.../fab/auth_manager/api_fastapi/sorting.py | 3 +-
.../fab/auth_manager/security_manager/override.py | 10 +-
.../fab/src/airflow/providers/fab/www/package.json | 6 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 253 +-
.../tests/unit/fab/auth_manager/test_security.py | 39 +-
providers/google/README.rst | 26 +-
providers/google/docs/changelog.rst | 55 +
providers/google/docs/index.rst | 26 +-
providers/google/docs/operators/cloud/dataproc.rst | 13 +
.../google/docs/operators/cloud/functions.rst | 26 +
.../google/docs/operators/cloud/vertex_ai.rst | 5 +
providers/google/provider.yaml | 3 +-
providers/google/pyproject.toml | 26 +-
.../src/airflow/providers/google/__init__.py | 2 +-
.../providers/google/cloud/hooks/dataprep.py | 16 +-
.../google/cloud/hooks/kubernetes_engine.py | 4 +-
.../google/cloud/hooks/vertex_ai/feature_store.py | 31 +-
.../google/cloud/log/cloud_logging_task_handler.py | 76 +-
.../providers/google/cloud/log/gcs_task_handler.py | 4 +-
.../providers/google/cloud/operators/bigquery.py | 46 +-
.../providers/google/cloud/operators/dataflow.py | 37 +-
.../providers/google/cloud/operators/dataproc.py | 52 +-
.../providers/google/cloud/operators/functions.py | 2 +-
.../google/cloud/operators/kubernetes_engine.py | 26 +-
.../cloud/operators/vertex_ai/feature_store.py | 17 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 13 +
.../google/cloud/transfers/gcs_to_bigquery.py | 44 +-
.../providers/google/cloud/triggers/dataflow.py | 101 +-
.../google/cloud/triggers/kubernetes_engine.py | 3 +-
.../providers/google/common/hooks/base_google.py | 3 +-
.../bigquery/example_bigquery_queries_async.py | 54 +-
.../cloud/dataproc/example_dataproc_batch.py | 22 +
.../kubernetes_engine/example_kubernetes_engine.py | 2 +-
.../example_kubernetes_engine_async.py | 5 +-
.../example_kubernetes_engine_job.py | 5 +-
.../example_kubernetes_engine_kueue.py | 2 +-
.../example_kubernetes_engine_ray.py | 6 -
.../example_kubernetes_engine_resource.py | 5 +-
.../vertex_ai/example_vertex_ai_feature_store.py | 36 +-
.../tests/unit/google/cloud/hooks/test_dataprep.py | 31 +
.../google/cloud/hooks/test_kubernetes_engine.py | 2 +-
.../cloud/hooks/vertex_ai/test_feature_store.py | 40 +-
.../tests/unit/google/cloud/links/test_alloy_db.py | 62 -
.../unit/google/cloud/links/test_managed_kafka.py | 79 -
.../cloud/log/test_cloud_logging_task_handler.py | 265 +-
.../unit/google/cloud/openlineage/test_mixins.py | 3 +-
.../unit/google/cloud/operators/test_bigquery.py | 30 +-
.../unit/google/cloud/operators/test_dataflow.py | 116 +
.../unit/google/cloud/operators/test_dataproc.py | 170 +
.../cloud/operators/test_kubernetes_engine.py | 98 +-
.../google/cloud/transfers/test_bigquery_to_gcs.py | 53 +
.../google/cloud/transfers/test_gcs_to_bigquery.py | 124 +
.../unit/google/cloud/triggers/test_dataflow.py | 224 +-
.../cloud/triggers/test_kubernetes_engine.py | 20 +-
.../unit/google/common/hooks/test_base_google.py | 16 +
providers/hashicorp/README.rst | 8 +-
providers/hashicorp/docs/changelog.rst | 11 +
providers/hashicorp/docs/index.rst | 8 +-
providers/hashicorp/provider.yaml | 3 +-
providers/hashicorp/pyproject.toml | 8 +-
.../src/airflow/providers/hashicorp/__init__.py | 2 +-
.../dev/informatica_simulator/requirements.txt | 2 +-
providers/keycloak/.pre-commit-config.yaml | 4 +
providers/keycloak/README.rst | 6 +-
providers/keycloak/docs/changelog.rst | 12 +
providers/keycloak/docs/index.rst | 6 +-
providers/keycloak/provider.yaml | 3 +-
providers/keycloak/pyproject.toml | 6 +-
.../src/airflow/providers/keycloak/__init__.py | 2 +-
providers/microsoft/azure/README.rst | 17 +-
providers/microsoft/azure/docs/changelog.rst | 26 +
.../azure/docs/connections/azure_ai_search.rst | 92 +
providers/microsoft/azure/docs/index.rst | 17 +-
.../microsoft/azure/docs/operators/ai_search.rst | 121 +
.../microsoft/azure/docs/operators/msgraph.rst | 12 +
.../microsoft/azure/docs/operators/powerbi.rst | 10 +
providers/microsoft/azure/provider.yaml | 51 +-
providers/microsoft/azure/pyproject.toml | 13 +-
.../airflow/providers/microsoft/azure/__init__.py | 2 +-
.../providers/microsoft/azure/exceptions.py | 4 +
.../providers/microsoft/azure/get_provider_info.py | 48 +
.../providers/microsoft/azure/hooks/ai_search.py | 355 +
.../providers/microsoft/azure/hooks/msgraph.py | 31 +-
.../microsoft/azure/log/wasb_task_handler.py | 2 +-
.../providers/microsoft/azure/operators/msgraph.py | 158 +-
.../providers/microsoft/azure/operators/powerbi.py | 89 +-
.../providers/microsoft/azure/triggers/powerbi.py | 7 +-
.../microsoft/azure/example_azure_ai_search.py | 175 +
.../unit/microsoft/azure/hooks/test_ai_search.py | 394 +
.../unit/microsoft/azure/hooks/test_msgraph.py | 29 +
.../unit/microsoft/azure/operators/test_msgraph.py | 162 +-
.../unit/microsoft/azure/operators/test_powerbi.py | 288 +-
.../unit/microsoft/azure/triggers/test_powerbi.py | 33 +
providers/openai/README.rst | 8 +-
providers/openai/docs/changelog.rst | 16 +
providers/openai/docs/index.rst | 8 +-
providers/openai/provider.yaml | 3 +-
providers/openai/pyproject.toml | 8 +-
.../src/airflow/providers/openai/__init__.py | 2 +-
providers/openlineage/README.rst | 6 +-
providers/openlineage/docs/changelog.rst | 32 +
providers/openlineage/docs/emission_policy.rst | 147 +-
providers/openlineage/docs/index.rst | 6 +-
providers/openlineage/provider.yaml | 3 +-
providers/openlineage/pyproject.toml | 6 +-
.../src/airflow/providers/openlineage/__init__.py | 2 +-
.../airflow/providers/openlineage/api/datasets.py | 11 +
.../providers/openlineage/api/emission_policy.py | 26 +-
.../src/airflow/providers/openlineage/api/sql.py | 4 +-
.../providers/openlineage/extractors/manager.py | 69 +-
.../providers/openlineage/utils/emission_policy.py | 312 +-
.../openlineage/utils/sql_hook_lineage.py | 16 +-
.../airflow/providers/openlineage/utils/utils.py | 19 +
.../example_openlineage_base_complex_dag.py | 15 +-
.../openlineage_base_complex_dag__af2.json | 68 +-
.../openlineage_base_complex_dag__af3.json | 70 +-
.../openlineage_base_simple_dag__af2.json | 4 +
.../openlineage_base_simple_dag__af3.json | 4 +
.../openlineage_custom_operator_failure_dag.json | 2 +
.../openlineage_manual_lineage_dag.json | 4 +
.../openlineage_taskflow_simple_dag.json | 4 +
.../tests/unit/openlineage/api/test_datasets.py | 28 +
.../unit/openlineage/api/test_emission_policy.py | 29 +
.../tests/unit/openlineage/api/test_sql.py | 25 +-
.../unit/openlineage/extractors/test_manager.py | 167 +-
.../unit/openlineage/plugins/test_execution.py | 9 +-
.../unit/openlineage/utils/test_emission_policy.py | 253 +
.../openlineage/utils/test_sql_hook_lineage.py | 28 +
.../tests/unit/openlineage/utils/test_utils.py | 102 +-
providers/opensearch/README.rst | 6 +-
providers/opensearch/docs/changelog.rst | 16 +
providers/opensearch/docs/index.rst | 6 +-
providers/opensearch/provider.yaml | 3 +-
providers/opensearch/pyproject.toml | 6 +-
.../src/airflow/providers/opensearch/__init__.py | 2 +-
.../providers/opensearch/log/os_task_handler.py | 5 +-
.../unit/opensearch/log/test_os_task_handler.py | 3 +
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 4 +
providers/smtp/README.rst | 6 +-
providers/smtp/docs/changelog.rst | 16 +
providers/smtp/docs/email-backend.rst | 35 +
providers/smtp/docs/index.rst | 7 +-
providers/smtp/docs/redirects.txt | 4 +
providers/smtp/provider.yaml | 6 +-
providers/smtp/pyproject.toml | 6 +-
.../smtp/src/airflow/providers/smtp/__init__.py | 2 +-
.../airflow/providers/smtp/get_provider_info.py | 1 +
.../src/airflow/providers/smtp/utils}/__init__.py | 0
.../src/airflow/providers/smtp/utils/emailer.py | 340 +
.../smtp/tests/unit/smtp/utils}/__init__.py | 0
.../smtp/tests/unit/smtp/utils/test_emailer.py | 525 ++
providers/snowflake/README.rst | 11 +-
providers/snowflake/docs/changelog.rst | 47 +
providers/snowflake/docs/connections/snowflake.rst | 11 +-
providers/snowflake/docs/index.rst | 9 +-
...snowflake_cortex_agent.rst => cortex_agent.rst} | 8 +-
.../hooks/__init__.py => docs/redirects.txt} | 2 +
providers/snowflake/provider.yaml | 23 +-
providers/snowflake/pyproject.toml | 13 +-
.../src/airflow/providers/snowflake/__init__.py | 2 +-
.../providers/snowflake/get_provider_info.py | 17 +-
.../airflow/providers/snowflake/hooks/__init__.py | 19 +
.../{snowflake_cortex_agent.py => cortex_agent.py} | 0
.../airflow/providers/snowflake/hooks/snowflake.py | 108 +-
.../hooks/{snowflake_sql_api.py => sql_api.py} | 0
.../providers/snowflake/operators/__init__.py | 14 +
.../{snowflake_cortex_agent.py => cortex_agent.py} | 2 +-
.../providers/snowflake/operators/snowflake.py | 38 +-
.../snowflake/triggers/snowflake_trigger.py | 2 +-
.../providers/snowflake/utils/openlineage.py | 4 +-
.../snowflake/example_snowflake_cortex_agent.py | 4 +-
...wflake_cortex_agent.py => test_cortex_agent.py} | 27 +-
.../tests/unit/snowflake/hooks/test_snowflake.py | 336 +-
.../{test_snowflake_sql_api.py => test_sql_api.py} | 4 +-
...wflake_cortex_agent.py => test_cortex_agent.py} | 4 +-
.../unit/snowflake/operators/test_snowflake.py | 32 +-
.../{test_snowflake_sql.py => test_sql.py} | 0
.../unit/snowflake/triggers/test_snowflake.py | 8 +-
.../tests/unit/snowflake/utils/test_openlineage.py | 14 +-
providers/ssh/README.rst | 6 +-
providers/ssh/docs/changelog.rst | 11 +
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 | 23 +
providers/standard/docs/index.rst | 6 +-
providers/standard/docs/operators/hitl.rst | 71 +
providers/standard/provider.yaml | 3 +-
providers/standard/pyproject.toml | 6 +-
.../src/airflow/providers/standard/__init__.py | 2 +-
.../example_dags/example_bash_decorator.py | 17 +-
.../standard/example_dags/example_bash_operator.py | 13 +-
.../example_dags/example_hitl_request_input.py | 43 +
.../airflow/providers/standard/hooks/subprocess.py | 28 +-
.../airflow/providers/standard/operators/hitl.py | 261 +-
.../airflow/providers/standard/operators/python.py | 46 +
.../src/airflow/providers/standard/utils/hitl.py | 153 +
.../providers/standard/utils/sensor_helper.py | 31 +-
.../airflow/providers/standard/version_compat.py | 2 +
.../tests/unit/standard/decorators/test_bash.py | 2 +-
.../tests/unit/standard/decorators/test_python.py | 12 +-
.../unit/standard/decorators/test_short_circuit.py | 2 +-
.../tests/unit/standard/hooks/test_subprocess.py | 63 +-
.../standard/operators/test_hitl_request_input.py | 795 ++
.../unit/standard/operators/test_latest_only.py | 2 +-
.../unit/standard/sensors/test_external_task.py | 12 +-
.../tests/unit/standard/sensors/test_time_delta.py | 4 +-
.../tests/unit/standard/sensors/test_weekday.py | 2 +-
.../tests/unit/standard/utils/test_hitl.py | 97 +
providers/vespa/README.rst | 17 +-
providers/vespa/docs/changelog.rst | 16 +
providers/vespa/docs/index.rst | 15 +-
providers/vespa/provider.yaml | 6 +-
providers/vespa/pyproject.toml | 12 +-
.../vespa/src/airflow/providers/vespa/__init__.py | 2 +-
pyproject.toml | 54 +-
registry/package.json | 4 +-
registry/pnpm-lock.yaml | 168 +-
registry/src/_data/statsData.js | 15 +-
registry/src/index.njk | 2 +-
registry/src/stats.njk | 6 +
scripts/.pre-commit-config.yaml | 2 +
scripts/ci/analyze_e2e_flaky_tests.py | 19 +-
scripts/ci/docker-compose/backend-mysql.yml | 2 +
scripts/ci/docker-compose/backend-postgres.yml | 2 +
scripts/ci/docker-compose/base.yml | 2 +
.../ci/docker-compose/integration-cassandra.yml | 2 +
scripts/ci/docker-compose/integration-celery.yml | 3 +
scripts/ci/docker-compose/integration-drill.yml | 2 +
.../docker-compose/integration-elasticsearch.yml | 2 +
scripts/ci/docker-compose/integration-kafka.yml | 1 +
scripts/ci/docker-compose/integration-kerberos.yml | 2 +
scripts/ci/docker-compose/integration-keycloak.yml | 1 +
.../ci/docker-compose/integration-localstack.yml | 1 +
scripts/ci/docker-compose/integration-mongo.yml | 2 +
scripts/ci/docker-compose/integration-mssql.yml | 2 +
.../ci/docker-compose/integration-openlineage.yml | 2 +
.../ci/docker-compose/integration-opensearch.yml | 2 +
scripts/ci/docker-compose/integration-otel.yml | 4 +
scripts/ci/docker-compose/integration-pinot.yml | 1 +
scripts/ci/docker-compose/integration-qdrant.yml | 1 +
scripts/ci/docker-compose/integration-redis.yml | 3 +
scripts/ci/docker-compose/integration-statsd.yml | 3 +
.../ci/docker-compose/integration-tinkerpop.yml | 2 +
scripts/ci/docker-compose/integration-trino.yml | 2 +
scripts/ci/docker-compose/integration-ydb.yml | 1 +
scripts/ci/docker-compose/local-all-sources.yml | 2 +
scripts/ci/docker-compose/local.yml | 2 +
.../mount-sphinx-airflow-theme.yml} | 23 +-
scripts/ci/install_breeze.sh | 2 +-
scripts/ci/kubernetes/kind-cluster-conf.yaml | 5 +-
scripts/ci/lang_sdk_serialization/compare.py | 13 +-
scripts/ci/prek/AGENTS.md | 4 +
scripts/ci/prek/check_auth_manager_mock_targets.py | 88 +
scripts/ci/prek/check_ci_gate_needs.py | 70 +
scripts/ci/prek/check_ci_workflows_in_sync.py | 125 +-
.../ci/prek/check_example_dag_shell_commands.py | 266 +
scripts/ci/prek/check_fork_ci_gate_config.py | 20 +-
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/check_prek_hooks_pycache_prefix.py | 76 +
scripts/ci/prek/check_shared_mypy_hooks.py | 2 +
scripts/ci/prek/extract_permissions.py | 63 +-
scripts/ci/prek/fab_permissions_doc.py | 27 +-
scripts/ci/prek/generate_yaml_importer_schema.py | 1 +
scripts/ci/prek/lang_sdk_compat_matrix.py | 326 +-
scripts/ci/prek/local_yml_mounts.py | 2 +
scripts/ci/prek/ruff_format.py | 2 +-
scripts/ci/prek/sync_java_sdk_docs.py | 148 +
scripts/ci/prek/update_docker_gpg_keys.py | 2 +
scripts/ci/prek/update_go_sdk_readme_matrix.py | 6 +-
scripts/ci/prek/update_java_sdk_readme_matrix.py | 6 +-
scripts/ci/prek/update_lang_sdk_central_matrix.py | 152 +
scripts/ci/prek/update_ts_sdk_readme_matrix.py | 6 +-
scripts/ci/prek/upgrade_important_versions.py | 89 +-
scripts/ci/testing/summarize_captured_warnings.py | 2 +-
scripts/docker/common.sh | 16 +-
scripts/docker/entrypoint_ci.sh | 5 +-
scripts/docker/install_mssql.sh | 4 +-
scripts/docker/install_mysql.sh | 17 +-
scripts/docker/install_os_dependencies.sh | 353 +-
scripts/docker/install_postgres.sh | 2 +-
scripts/docker/keys/microsoft-2025.asc | 29 +
scripts/in_container/run_ci_tests.sh | 11 +-
scripts/in_container/run_docs_build.sh | 6 +
scripts/tests/ci/prek/conftest.py | 55 +
.../prek/test_check_auth_manager_mock_targets.py | 88 +
scripts/tests/ci/prek/test_check_ci_gate_needs.py | 60 +
.../prek/test_check_example_dag_shell_commands.py | 137 +
.../ci/prek/test_check_fork_ci_gate_config.py | 1 +
.../prek/test_check_prek_hooks_pycache_prefix.py | 40 +-
scripts/tests/ci/prek/test_extract_permissions.py | 199 +-
.../tests/ci/prek/test_lang_sdk_compat_matrix.py | 330 +-
scripts/tests/ci/prek/test_local_yml_mounts.py | 79 +
scripts/tests/ci/prek/test_sync_java_sdk_docs.py | 119 +
.../ci/prek/test_update_go_sdk_readme_matrix.py | 25 +-
.../ci/prek/test_update_java_sdk_readme_matrix.py | 27 +-
.../ci/prek/test_update_lang_sdk_central_matrix.py | 148 +
.../ci/prek/test_update_ts_sdk_readme_matrix.py | 27 +-
.../ci/prek/test_upgrade_important_versions.py | 112 +
scripts/tests/ci/test_analyze_e2e_flaky_tests.py | 16 +
scripts/tools/setup_breeze | 2 +-
shared/configuration/.pre-commit-config.yaml | 2 +
shared/dagnode/.pre-commit-config.yaml | 2 +
shared/listeners/.pre-commit-config.yaml | 2 +
shared/logging/.pre-commit-config.yaml | 2 +
.../logging/src/airflow_shared/logging/remote.py | 16 +-
.../src/airflow_shared/logging/structlog.py | 15 +-
shared/logging/tests/logging/test_structlog.py | 1 +
shared/module_loading/.pre-commit-config.yaml | 2 +
.../module_loading/file_discovery.py | 11 +-
.../tests/module_loading/test_file_discovery.py | 18 +
shared/observability/.pre-commit-config.yaml | 2 +
.../observability/metrics/metrics_registry.py | 6 +-
.../observability/metrics/metrics_template.yaml | 8 +
.../airflow_shared/observability/metrics/stats.py | 3 +-
shared/plugins_manager/.pre-commit-config.yaml | 2 +
.../src/airflow_shared/plugins_manager/__init__.py | 2 +
.../plugins_manager/plugins_manager.py | 31 +
shared/providers_discovery/.pre-commit-config.yaml | 2 +
shared/secrets_backend/.pre-commit-config.yaml | 2 +
shared/secrets_masker/.pre-commit-config.yaml | 2 +
.../secrets_masker/secrets_masker.py | 34 +-
.../tests/secrets_masker/test_secrets_masker.py | 66 +-
shared/serialization/.pre-commit-config.yaml | 2 +
shared/state/.pre-commit-config.yaml | 2 +
shared/template_rendering/.pre-commit-config.yaml | 2 +
shared/timezones/.pre-commit-config.yaml | 2 +
task-sdk-integration-tests/.pre-commit-config.yaml | 2 +
task-sdk/.pre-commit-config.yaml | 6 +
task-sdk/docs/api.rst | 2 +
task-sdk/docs/ts-bundle-spec.rst | 2 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 10 +-
task-sdk/src/airflow/sdk/bases/xcom.py | 383 +-
.../src/airflow/sdk/coordinators/_subprocess.py | 76 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 3 +
.../sdk/definitions/decorators/__init__.pyi | 8 +
.../sdk/execution_time/callback_supervisor.py | 79 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 9 +-
.../airflow/sdk/execution_time/lazy_sequence.py | 4 +-
task-sdk/src/airflow/sdk/execution_time/loop.py | 25 +-
.../airflow/sdk/execution_time/schema/schema.json | 143 +-
.../sdk/execution_time/schema/versions/__init__.py | 4 +
.../execution_time/schema/versions/v2026_10_30.py | 29 +
.../src/airflow/sdk/execution_time/supervisor.py | 67 +-
.../src/airflow/sdk/execution_time/task_runner.py | 91 +-
.../airflow/sdk/importers/yaml_importer/builder.py | 155 +-
.../sdk/importers/yaml_importer/importer.py | 20 +-
.../sdk/importers/yaml_importer/schema.json | 3 +-
task-sdk/src/airflow/sdk/types.py | 13 +
task-sdk/tests/task_sdk/bases/test_xcom.py | 379 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 265 +-
.../execution_time/schema/test_migrator.py | 15 +
.../execution_time/test_callback_supervisor.py | 173 +-
.../task_sdk/execution_time/test_lazy_sequence.py | 27 +
.../tests/task_sdk/execution_time/test_loop.py | 100 +-
.../task_sdk/execution_time/test_supervisor.py | 206 +-
.../task_sdk/execution_time/test_task_runner.py | 103 +-
.../importers/yaml_importer/test_importer.py | 139 +-
ts-sdk/.pre-commit-config.yaml | 14 +
ts-sdk/DEVELOPMENT.md | 19 +-
ts-sdk/README.md | 364 +-
ts-sdk/api-docs/dag-authoring-api.ts | 1 +
ts-sdk/capabilities.yaml | 172 +-
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/example/src/main.ts | 2 +-
ts-sdk/package.json | 2 +-
ts-sdk/pnpm-lock.yaml | 349 +-
ts-sdk/schema/supervisor-schema.json | 143 +-
.../ci/prek/check_serialization_conformance.py | 2 +-
ts-sdk/src/coordinator/client.ts | 35 +-
ts-sdk/src/coordinator/operator-runner.ts | 4 +-
ts-sdk/src/coordinator/serde.ts | 76 +-
ts-sdk/src/generated/supervisor.ts | 56 +-
ts-sdk/src/hitl/operator.ts | 2 +-
ts-sdk/src/index.ts | 2 +-
ts-sdk/src/sdk/client-types.ts | 10 +-
ts-sdk/src/sdk/client.ts | 6 +-
ts-sdk/src/sdk/dag-graph.ts | 19 +-
ts-sdk/src/sdk/dag.ts | 243 +-
ts-sdk/src/sdk/operator.ts | 8 +-
ts-sdk/tests/conformance/serialize_typescript.ts | 7 +-
ts-sdk/tests/coordinator/client.test.ts | 28 +-
ts-sdk/tests/coordinator/operator-runner.test.ts | 8 +-
ts-sdk/tests/coordinator/serde.test.ts | 229 +
ts-sdk/tests/public-api.test.ts | 10 +-
ts-sdk/tests/sdk/branching.test.ts | 10 +
ts-sdk/tests/sdk/conditional.test.ts | 23 +
ts-sdk/tests/sdk/dag.test.ts | 209 +
uv.lock | 7858 +++++++++++---------
1544 files changed, 71250 insertions(+), 19344 deletions(-)
create mode 100644
.agents/skills/airflow-publish-changes/references/performance-sensitive-components.md
create mode 100644 .github/workflows/mirror-hardened-base-images.yml
create mode 100644 .github/workflows/release-branch-ci.yml
create mode 100644 .github/workflows/scheduled-legacy-prod-image-canary.yml
create mode 100644 airflow-core/docs/authoring-and-scheduling/yaml-dags.rst
create mode 100644 airflow-core/docs/howto/custom-action-plugin.rst
create mode 100644 airflow-core/newsfragments/71816.feature.rst
create mode 100644 airflow-core/newsfragments/73038.significant.rst
create mode 100644 airflow-core/newsfragments/73577.significant.rst
create mode 100644 airflow-core/newsfragments/73791.improvement.rst
create mode 100644 airflow-core/newsfragments/73793.improvement.rst
create mode 100644 airflow-core/newsfragments/73794.improvement.rst
create mode 100644 airflow-core/newsfragments/74830.significant.rst
create mode 100644 airflow-core/newsfragments/74834.bugfix.rst
create mode 100644 airflow-core/newsfragments/74836.bugfix.rst
create mode 100644 airflow-core/newsfragments/74837.bugfix.rst
create mode 100644 airflow-core/newsfragments/74839.bugfix.rst
create mode 100644 airflow-core/newsfragments/74840.bugfix.rst
create mode 100644 airflow-core/newsfragments/74842.improvement.rst
create mode 100644 airflow-core/newsfragments/74896.bugfix.rst
create mode 100644
airflow-core/newsfragments/task-loops-custom-backends.significant.rst
create mode 100644
airflow-core/src/airflow/migrations/versions/0147_3_4_0_add_commit_allows_update_to_connection_test.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0148_3_4_0_add_pending_partition_key_to_apdr.py
rename
airflow-core/src/airflow/migrations/versions/{0147_3_5_0_add_session_id_to_job.py
=> 0149_3_5_0_add_session_id_to_job.py} (97%)
create mode 100644
airflow-core/src/airflow/ui/src/components/AssetExpression/AssetNode.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/BackfillInProgressBadge.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/BackfillInProgressBadge.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/components/Banner/BackfillBanner.test.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/components/Banner/BackfillBanner.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/components/Banner/DrainingBanner.test.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/components/Banner/DrainingBanner.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/Clear/TaskInstance/ClearTaskInstanceConfirmationDialog.test.tsx
rename
airflow-core/src/airflow/ui/src/components/{DagDeactivatedBanner.test.tsx =>
DagDeactivatedChip.test.tsx} (79%)
rename airflow-core/src/airflow/ui/src/components/{DagDeactivatedBanner.tsx =>
DagDeactivatedChip.tsx} (66%)
create mode 100644
airflow-core/src/airflow/ui/src/components/DataTable/DataTable.expanding.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/DrainingBadge.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FilterBar/filters/TagsFilter.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/NeedsReviewIndicator.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/NeedsReviewIndicator.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/PluginActionBoundary.tsx
copy airflow-core/src/airflow/ui/src/components/{DrainingBadge.tsx =>
PluginActions/PluginActionIcon.tsx} (51%)
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/PluginActions.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/PluginActions.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/PluginActionsContext.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/PluginLinkAction.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/PluginReactAction.tsx
rename airflow-core/src/airflow/ui/src/components/{Banner/index.tsx =>
PluginActions/index.ts} (79%)
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/pluginActionContext.test.ts
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/pluginActionContext.ts
create mode 100644
airflow-core/src/airflow/ui/src/components/PluginActions/types.ts
create mode 100644 airflow-core/src/airflow/ui/src/components/StatusChip.tsx
create mode 100644
airflow-core/src/airflow/ui/src/hooks/usePluginActions.test.ts
create mode 100644 airflow-core/src/airflow/ui/src/hooks/usePluginActions.ts
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/src/airflow/ui/src/layouts/Details/Gantt/Gantt.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Details/GridFilters.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Nav/BrowseButton.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Nav/DagsButton.test.tsx
copy airflow-core/src/airflow/ui/src/{components/DrainingBadge.tsx =>
layouts/Nav/DagsButton.tsx} (56%)
create mode 100644 airflow-core/src/airflow/ui/src/layouts/Nav/NavMenu.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/layouts/Nav/NavMenu.tsx
copy airflow-core/src/airflow/ui/src/mocks/handlers/{assets.ts => admin.ts}
(50%)
create mode 100644 airflow-core/src/airflow/ui/src/mocks/handlers/app.ts
create mode 100644
airflow-core/src/airflow/ui/src/mocks/handlers/task_instances.test.ts
create mode 100644
airflow-core/src/airflow/ui/src/mocks/handlers/task_instances.ts
copy ts-sdk/api-docs/dag-authoring-api.ts =>
airflow-core/src/airflow/ui/src/mocks/server.ts (60%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Connections/DuplicateConnectionButton.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Connections/DuplicateConnectionButton.tsx
copy airflow-core/src/airflow/ui/src/{components/DrainingBadge.tsx =>
pages/Dag/Versions/DiffUnavailableAlert.tsx} (52%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dag/Versions/DiffValue.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dag/Versions/MaxChangesField.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dag/Versions/MaxChangesField.tsx
copy ts-sdk/api-docs/dag-authoring-api.ts =>
airflow-core/src/airflow/ui/src/pages/Dag/Versions/MonoText.tsx (65%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dag/Versions/PathText.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dag/Versions/SelectedVersionsDiff.tsx
copy airflow-core/src/airflow/ui/src/{components/DataTable/features.ts =>
pages/DagsList/DagsListColumns.test.tsx} (59%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Run/CallbackLogs.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/pages/Run/CallbackLogs.tsx
create mode 100644 airflow-core/src/airflow/ui/src/pages/Run/Callbacks.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/pages/Run/Callbacks.tsx
create mode 100644 airflow-core/src/airflow/ui/src/pages/Run/Run.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/queries/useDags.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/utils/pluginIcon.test.ts
copy airflow-core/src/airflow/ui/src/{components/DrainingBadge.tsx =>
utils/pluginIcon.ts} (53%)
create mode 100644 airflow-core/src/airflow/ui/src/utils/pluginTemplate.test.ts
create mode 100644 airflow-core/src/airflow/ui/src/utils/pluginTemplate.ts
create mode 100644 airflow-core/src/airflow/utils/log/path_log_reader.py
create mode 100644
airflow-core/tests/unit/migrations/test_0148_add_pending_partition_key_to_apdr.py
create mode 100644 airflow-core/tests/unit/utils/log/test_path_log_reader.py
create mode 100644
dev/breeze/doc/adr/0019-isolate-docker-resources-per-git-worktree.md
create mode 100644
dev/breeze/doc/images/output_release-management_mirror-base-images.svg
create mode 100644
dev/breeze/doc/images/output_release-management_mirror-base-images.txt
create mode 100644 dev/breeze/src/airflow_breeze/utils/worktree_watcher.py
create mode 100644 dev/breeze/tests/test_build_prod_params.py
create mode 100644 dev/breeze/tests/test_ci_commands.py
copy airflow-core/src/airflow/api_fastapi/execution_api/datamodels/dagrun.py
=> dev/breeze/tests/test_ci_group.py (55%)
create mode 100644 dev/breeze/tests/test_kubernetes_utils.py
create mode 100644 dev/breeze/tests/test_mirror_base_images.py
create mode 100644 dev/breeze/tests/test_path_utils.py
delete mode 100644 dev/breeze/tests/test_selective_check_command.py
create mode 100644 dev/breeze/tests/test_worktree_watcher.py
copy scripts/ci/prek/local_yml_mounts.py =>
devel-common/src/tests_common/test_utils/xcom_backends.py (70%)
mode change 100755 => 100644
create mode 100644 go-sdk/DEVELOPMENT.md
create mode 100644 go-sdk/example/README.md
copy java-sdk/{README.md => DEVELOPMENT.md} (81%)
create mode 100644 java-sdk/example/README.md
create mode 100644 java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Label.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/EdgeLabelTest.kt
create mode 100644 providers/amazon/docs/executors/eks-executor.rst
copy providers/{snowflake/src/airflow/providers/snowflake/operators =>
amazon/src/airflow/providers/amazon/aws/executors/eks}/__init__.py (84%)
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/executors/eks/_client_factory.py
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/executors/eks/eks_executor.py
copy scripts/ci/prek/check_imports_in_providers.py =>
providers/amazon/src/airflow/providers/amazon/aws/executors/eks/utils.py (59%)
mode change 100755 => 100644
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/sensors/athena_spark.py
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/utils/deferral.py
copy {airflow-core/src/airflow/_shared =>
providers/amazon/tests/unit/amazon/aws/executors/eks}/__init__.py (100%)
create mode 100644
providers/amazon/tests/unit/amazon/aws/executors/eks/test__client_factory.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/executors/eks/test_eks_executor.py
copy scripts/ci/prek/local_yml_mounts.py =>
providers/amazon/tests/unit/amazon/aws/executors/eks/test_utils.py (62%)
mode change 100755 => 100644
copy scripts/ci/prek/check_imports_in_providers.py =>
providers/amazon/tests/unit/amazon/aws/executors/utils/test_base_config_keys.py
(60%)
mode change 100755 => 100644
create mode 100644
providers/amazon/tests/unit/amazon/aws/sensors/test_athena_spark.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/utils/test_deferral.py
create mode 100644
providers/celery/tests/unit/celery/executors/test_default_celery.py
create mode 100644 providers/common/ai/docs/toolsets/custom.rst
create mode 100644
providers/common/ai/docs/use_cases/refine_a_draft_within_a_budget.rst
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/openai_agents.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_agent_loop_budget.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_custom_toolset.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_openai_agents_durable.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/src/region.ts
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/tests/model-api.test.ts
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/tests/model.test.mjs
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/tests/region.test.ts
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_openai_agents.py
create mode 100644
providers/common/compat/src/airflow/providers/common/compat/_resumable_job_mixin.py
create mode 100644
providers/common/compat/tests/unit/common/compat/test__resumable_job_mixin.py
create mode 100644 providers/databricks/docs/operators/agent.rst
create mode 100644
providers/databricks/src/airflow/providers/databricks/hooks/agent.py
create mode 100644
providers/databricks/src/airflow/providers/databricks/operators/agent.py
create mode 100644
providers/databricks/src/airflow/providers/databricks/triggers/agent.py
create mode 100644
providers/databricks/tests/system/databricks/example_databricks_agent.py
copy {airflow-core/src/airflow/_shared =>
providers/databricks/tests/system/databricks/resources}/__init__.py (100%)
create mode 100644
providers/databricks/tests/system/databricks/resources/agent_server/README.md
copy {airflow-core/src/airflow/_shared =>
providers/databricks/tests/system/databricks/resources/agent_server}/__init__.py
(100%)
copy providers/{snowflake/src/airflow/providers/snowflake/hooks/__init__.py =>
databricks/tests/system/databricks/resources/agent_server/app.yaml} (94%)
copy scripts/ci/prek/ruff_format.py =>
providers/databricks/tests/system/databricks/resources/agent_server/hello_agent.py
(55%)
mode change 100755 => 100644
copy providers/{snowflake/src/airflow/providers/snowflake/hooks/__init__.py =>
databricks/tests/system/databricks/resources/agent_server/requirements.txt}
(94%)
create mode 100644
providers/databricks/tests/unit/databricks/hooks/test_agent.py
create mode 100644
providers/databricks/tests/unit/databricks/operators/test_agent.py
create mode 100644
providers/databricks/tests/unit/databricks/triggers/test_agent.py
delete mode 100644
providers/google/tests/unit/google/cloud/links/test_alloy_db.py
delete mode 100644
providers/google/tests/unit/google/cloud/links/test_managed_kafka.py
create mode 100644
providers/microsoft/azure/docs/connections/azure_ai_search.rst
create mode 100644 providers/microsoft/azure/docs/operators/ai_search.rst
create mode 100644
providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/ai_search.py
create mode 100644
providers/microsoft/azure/tests/system/microsoft/azure/example_azure_ai_search.py
create mode 100644
providers/microsoft/azure/tests/unit/microsoft/azure/hooks/test_ai_search.py
create mode 100644 providers/smtp/docs/email-backend.rst
create mode 100644 providers/smtp/docs/redirects.txt
copy {airflow-core/src/airflow/_shared =>
providers/smtp/src/airflow/providers/smtp/utils}/__init__.py (100%)
create mode 100644 providers/smtp/src/airflow/providers/smtp/utils/emailer.py
copy {airflow-core/src/airflow/_shared =>
providers/smtp/tests/unit/smtp/utils}/__init__.py (100%)
create mode 100644 providers/smtp/tests/unit/smtp/utils/test_emailer.py
rename providers/snowflake/docs/operators/{snowflake_cortex_agent.rst =>
cortex_agent.rst} (91%)
copy providers/snowflake/{src/airflow/providers/snowflake/hooks/__init__.py =>
docs/redirects.txt} (92%)
rename
providers/snowflake/src/airflow/providers/snowflake/hooks/{snowflake_cortex_agent.py
=> cortex_agent.py} (100%)
rename
providers/snowflake/src/airflow/providers/snowflake/hooks/{snowflake_sql_api.py
=> sql_api.py} (100%)
rename
providers/snowflake/src/airflow/providers/snowflake/operators/{snowflake_cortex_agent.py
=> cortex_agent.py} (99%)
rename
providers/snowflake/tests/unit/snowflake/hooks/{test_snowflake_cortex_agent.py
=> test_cortex_agent.py} (97%)
rename
providers/snowflake/tests/unit/snowflake/hooks/{test_snowflake_sql_api.py =>
test_sql_api.py} (99%)
rename
providers/snowflake/tests/unit/snowflake/operators/{test_snowflake_cortex_agent.py
=> test_cortex_agent.py} (98%)
rename
providers/snowflake/tests/unit/snowflake/operators/{test_snowflake_sql.py =>
test_sql.py} (100%)
create mode 100644
providers/standard/src/airflow/providers/standard/example_dags/example_hitl_request_input.py
create mode 100644
providers/standard/src/airflow/providers/standard/utils/hitl.py
create mode 100644
providers/standard/tests/unit/standard/operators/test_hitl_request_input.py
create mode 100644 providers/standard/tests/unit/standard/utils/test_hitl.py
copy scripts/ci/{kubernetes/kind-cluster-conf.yaml =>
docker-compose/mount-sphinx-airflow-theme.yml} (69%)
create mode 100755 scripts/ci/prek/check_auth_manager_mock_targets.py
create mode 100755 scripts/ci/prek/check_ci_gate_needs.py
create mode 100755 scripts/ci/prek/check_example_dag_shell_commands.py
create mode 100755 scripts/ci/prek/check_prek_hooks_pycache_prefix.py
create mode 100755 scripts/ci/prek/sync_java_sdk_docs.py
create mode 100755 scripts/ci/prek/update_lang_sdk_central_matrix.py
create mode 100644 scripts/docker/keys/microsoft-2025.asc
create mode 100644
scripts/tests/ci/prek/test_check_auth_manager_mock_targets.py
create mode 100644 scripts/tests/ci/prek/test_check_ci_gate_needs.py
create mode 100644
scripts/tests/ci/prek/test_check_example_dag_shell_commands.py
copy
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2025_10_27.py =>
scripts/tests/ci/prek/test_check_prek_hooks_pycache_prefix.py (50%)
create mode 100644 scripts/tests/ci/prek/test_local_yml_mounts.py
create mode 100644 scripts/tests/ci/prek/test_sync_java_sdk_docs.py
create mode 100644 scripts/tests/ci/prek/test_update_lang_sdk_central_matrix.py
