This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/auth-ui-security-updates-0f025de440
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit aae43e3a968 Bump happy-dom
add 5f213c70e2c Make the celery visibility_timeout redelivery docs
version-conditional (#75373)
add 4c4a1d94280 Fix cron mixin DST tests failing with tzdata 2026f (#76112)
add 95ba43c0347 Keep RunsOn runners off the Spot pools reclaimed most
often (#76084)
add 1cbcc306be6 Stop BigQueryStreamingBufferEmptySensor reporting empty
too early (#69118)
add 9c164b5891f Fix airflowctl required-option test broken by concurrent
merges (#76092)
add 2cdc403cd19 Convert BigQueryAsyncHook.get_records to async method
(#72286)
add 89ab81f6f41 Report airflowctl response validation errors instead of a
traceback (#76120)
add 03b0af96e50 Write common.io state store values in chunks instead of
one bytes copy (#76108)
add a8c80c88b8c Remove deprecated client property from Yandex DataprocHook
(#76128)
add 4e02d39e16b Remove deprecated cleanup_stuck_queued_tasks from Celery
and Kubernetes executors (#76129)
add ecc79a45970 Remove deprecated get_hook property from OSSKeySensor
(#76127)
add f3b4fec993a Let airflowctl and its integration tests use a non-default
API server port (#76124)
add 956d8cd2d6b Keep airflowctl dags pause/unpause/drain output parseable
(#76133)
add 1bb64c55b6e Stop airflowctl timing out after 5 seconds on slow API
servers (#76125)
add 81976d301f2 Stop triggerer tests leaking runner processes (#76139)
add 2e8f6f983b4 Report missing and invalid fields in airflowctl
connections import (#76090)
add 6086dac8b61 Remove deprecated TimeDeltaSensorAsync (#76131)
add 924b52eb08b Remove types-protobuf from google provider runtime
dependencies (#73775)
add 161cff0d95e Normalize empty project id in credential config file
branch (#73886)
add 3e63200b81c Lowercase the fork's image name in the PROD image example
tests (#76143)
add 841d51e3636 Enforce execution_timeout in deferrable
DataprocSubmitJobOperator (#72030)
add 615068e7cfb Remove deprecated get_pandas_df methods from SQL hooks
(#76130)
add a3567e948eb Show fork CI progress sooner and gate rebased pilot pull
requests (#76148)
add c67fbcb8e9b Fix airflowctl sending ids with URL special characters to
the wrong path (#76147)
add 9b66db8c54b Update the Go SDK doc for schema hooks that now run on
every commit (#76144)
add 58ad621c274 Keep retrying CI image downloads through artifact egress
throttling (#76150)
add 165e5ec69bc Do not draft fork CI pull requests while their fork run is
in progress (#76151)
add 44e8ff3e44f [main] Upgrade important CI environment (#75270)
add 35b6e857c19 Make the CI test segfault fallback find the JUnit XML
report (#74280)
add 468ab0a5834 Spend fewer GitHub writes on fork CI job statuses and
watch the limits (#76154)
add 4616b88380c TS-SDK: inherit the Dag queue when a task passes queue
undefined (#76123)
add 2d68f1a769a Remove the certifi cooldown bypass (#76164)
add fe579ea0752 Keep Java SDK snapshot docs out of the published
documentation (#76165)
add 2e62fd86037 Mount the checkout read-only in the hadolint and RAT prek
hooks (#76162)
add d9dbe635255 Report Kubernetes API 403 errors from the deferrable pod
trigger (#76081)
add b95498cd566 Restore the on_operator_resuming callback in
KubernetesPodOperator (#76035)
add 7b47022bf69 Document all Google Cloud connection fields (#76160)
add 77d15dc2c62 Prepare Common AI 1.1.0 RC3 for 2026-10-31 (#76169)
add c30f6c9ea0f Run docs publishing and provider registry workflows on
self-hosted runners (#76168)
add 9b114c8deee Reuse locked CI dependencies across workspace source
changes (#74466)
add ca6861474f1 Run dependency explanations separately from main AMD
canaries (#74311)
add bf177e29485 Accelerate CI image materialization with same-run
snapshots (#74173)
add 6230b32fa06 Fix flaky first test of the Docker decorator tests on
fresh CI runners (#76179)
add f7e28eec730 Fix stale cursor descriptions between SnowflakeHook runs
(#76163)
add 152e5344ef1 Handle connection and request timeouts in airflowctl
(#76132)
add 283ab98d659 Keep airflowctl auth token stdout limited to the token
(#76134)
add 122f7b43fd7 Report invalid variables in airflowctl variables import as
readable errors (#76174)
add 26448b2341d Refresh the Magpie reconciliation stamp (#76197)
add 72d752a00c1 Install OS dependencies on hardened images after dhi.io
renumbering (#76200)
add a96c3273868 Warn agents against loading the serialized Dag on hot
paths (#75932)
add 9cde6aa11db Stop airflowctl updates from resetting omitted bool fields
(#74383)
add 4eba3515cee Report invalid pools in airflowctl pools import as
readable errors (#76173)
add 117f1151872 Show square brackets in airflowctl table and plain output
as typed (#76175)
add 24b8db04adc Add tests for airflowctl dag run selector resolution
(#75609)
add 71617c77bb2 Record that StrictBaseModel is for request bodies only
(#75639)
add bdcb7eddd85 Skip Kubernetes volume internals when discovering Dag and
plugin files (#76186)
add b32439ef253 Derive the expected CI image name from the branch in
Breeze CI image tests (#76206)
add 84719cfb009 Fix airflowctl tracebacks on an unusable credentials file
(#72468)
add 0d2f7490e53 UI: Keep Dag card columns aligned across cards (#76004)
add 9c038c1d483 Add airflowctl tasks get and list operations (#76145)
add 1d1d17bb718 Fix LocalExecutor deadlock when a workload put blocks
(#75086)
add 8400915021a Mask the whole secret when another secret is its prefix
(#76142)
add 77609e83c22 Align Snowflake Cortex Agent hook with the Common AI
managed-agent contract (#74672)
add c82f0ee58a3 Add airflowctl tasks logs command for retrieving task
instance logs (#71763)
add cf4525db121 Report CI run started for release branches that do not run
ci-amd.yml (#76226)
add 2ebb8dd5d7b Verify S3 TLS certificates by default in
S3ToAzureBlobStorageOperator (#76222)
add e54a6af12d6 Scope asset event created Dag runs to readable Dags
(#76234)
add bee3b030be7 Fix formatting in chart/NOTICE file (#76237)
add bee03ecccb9 Run the RunsOn jobs on the Flex stack in all three
us-east-2 zones (#76239)
add d88ca3109e0 Update providers metadata 2026-11-01 (#76242)
add ce01a733e93 Fix scheduler memory spike when a Dag run has a large conf
(#73907)
add 7831e8e6ae2 Format the RunsOn label constants in the selective checks
tests (#76246)
add a7c481d84cc Keep executor loader tests patched after another test
reloads the module (#76233)
add a5ab822160c Skip scheduled workflows in forks that enable Actions
(#76243)
add e109bfdb45e Skip CI runs deleted while the Spot interruption notices
handle them (#76249)
add 8b178f59feb Record trigger failures and owner on its row; tag metrics
by kind (#76101)
add 5d886dd7414 Build only required prek hook environments in CI jobs on a
cache miss (#76111)
add 0cc7842e6d9 Start the whole test matrix at once on the RunsOn runners
(#76250)
add 7bfc8d32dbb Update provider metadata for Common AI 1.1.0 (#76257)
add eb47cc9f154 Add --json output to breeze ui
check-translation-completeness (#75831)
add a1f1a491db1 Return null from Java SDK getVariable for missing
Variables (#75920)
add 1c3252e5805 Add `callback` and `source` to context to differentiate
between Dag and task callbacks (#76110)
add 5444dabe85f Redact non-string values when the key name is sensitive
(#71279)
add 85bf28f1660 Move Snowflake trigger tests to match the trigger module
name (#73760)
add 1b43dce4466 Mask sensitive values in airflow config update dry-run
output (#73265)
add 92e42ed8ab1 Stop the provider registry from publishing unreleased
providers (#76109)
add 5b4f23b1c8f Go SDK: fail tasks that return non-JSON values instead of
hanging (#75601)
add 9afb30c5a09 Go SDK: Keep nested Conf validation test compatible across
Go versions (#75971)
add 27b8c82f54d Restore "Nothing to clear." in airflow tasks clear (#76277)
add 1d3d8f533fb Catch lazy timetable errors when starting queued runs
(#76288)
add 336cd40a863 Rename TypeScript SDK npm package to
@apache-airflow/ts-sdk (#75959)
add 1ab249327b5 Speed up trigger cleanup callback lookups (#75228)
add d7b830037e4 Bump TypeScript SDK to 1.0.0-beta2 (#76299)
add bbe441e75dc Render only the returned value in TaskFlow decorators that
template it (#76244)
add 4c110e645d0 Stop labelling fork CI PRs that change CI files for
workflow approval (#76289)
add 1d5644d9de2 Check that the fork's GitHub Actions can run in breeze ci
audit (#76136)
add ffbf25e4375 Stop encoding whole state store values to check the size
warning (#76107)
add ffd9a2d126a Keep masked Variable values when saving an edited Variable
(#76012)
add 19d80a886bf Use one chips editor for all simple array params (#76018)
add 7a7935754ed Stop airflowctl auth commands sending the stored token to
--api-url (#76280)
add 3318b88ba4c Exit non-zero when airflowctl connections test fails
(#76281)
add cfbd70b66d1 [main] Upgrade important CI environment (#76278)
add 88e5c356eaa Fix layout of CI diagram for clarity and consistency
(#76272)
add 3e20d9054d7 Log the AWS identity used by AwsDuckDBHook (#75997)
add f942cca74d7 Send the Python task's execution_timeout to the supervisor
(#75387)
add 31b558a6076 Fix Dag id collision in the Java SDK example bundle
(#76019)
add a9ad129058a Skip allowlisted non-PEP 440 docs versions when publishing
docs to S3 (#76020)
add d80672e6d06 Close German Translation Gaps 2026-11-02 (#76324)
add 51140809d2a Load Java Dags from a bundle path that contains a colon
(#76314)
add 4df59b9a03f Add AssetEventSensor to standard provider (#70225)
add 43ec43ac877 Refresh the Magpie reconciliation stamp (#76333)
add 8693c0854fe Retry fork CI job listings in smaller pages (#76327)
add c8ebaa8c8e9 Remove unused Spark application expectation helper (#75877)
add fdeff70fc0b Add on_kill support to SageMakerTrainingOperator (#76033)
add 50a2f28840c Use bulk ingest in AdbcHook.insert_rows when
fast_executemany is set (#76363)
add 9a6ef0a4217 Inline the masked Variable merge and drop unused merge
depth args (#76306)
add 36aee53a46e Show the external services each provider reaches in the
registry (#72940)
add ff22d7313ca Add tests for airflowctl utils helpers and module loading
(#76271)
add 6f7cb34ea42 Keep airflowctl stdout parseable when a request is retried
or fails (#76347)
add 5040171c3e6 Give Dag bundles their own read permission (#76329)
add 29368e8ac5a Fix airflowctl dagrun list ignoring --start-date and
--end-date (#76348)
add cdd3de5ecd0 Add code owners for the cncf.kubernetes provider (#76371)
add 5936c8d87a2 Revert "Load Java Dags from a bundle path that contains a
colon (#76314)" (#76350)
add 3a524716f84 Use standard iso format for dates in the Kafka
EventProducer plugin messages (#76052)
add 6aae6784031 Allow deleting queued partitioned asset events via REST
API (#73119)
add ab39e956969 Escape error text in airflowctl safe_call_command messages
(#76264)
add 1e27518c2de Run Kerberos worker sidecars as Kubernetes native sidecars
(#72555)
add eea312fc7cf Allow selecting loop tasks in the Grid view (#76291)
add be2829b9175 Show which skills an agent was offered and used in the AI
Model tab (#76309)
add 9612ea5846d Document the Dag Versions comparison tab in the UI
overview (#76387)
add 8df64a7dd3c UI: Refresh Dag cards after Dag run changes (#76274)
add 3edd0521b6c Hold back only build-info changes in fork CI and stop
drafting them (#76282)
add d3e29e1c6dd Add Git-Sync to GitDagBundle migration guide for the Helm
chart (#73082)
add bb50310d823 Cache FTPS connections only after setup succeeds (#74183)
add 5b8d2065934 Bump the typescript group across 1 directory with 4
updates (#76054)
add 82456dd938a Report failing fork job statuses only when the failure
persists (#76185)
add 9d4cdd7802a UI: Reduce initial JavaScript payload (#74663)
add 1367f021657 Fix env var names in AWS ECS and Lambda executor setup
docs (#76155)
add f721cac5e5c Fix scheduler refusing to start when [scheduler] only_idle
is enabled (#76262)
add b45f859d718 Complete the missing zh-TW UI translations (#76398)
add 5e903931b2a Enable DMS task logging in example_dms system test (#76336)
add d7711340f84 Run the dependency upgrade summary beside the tests
instead of after them (#76251)
add 6ca7a3be6b9 Build the PROD packages beside the CI image and
constraints (#76261)
add 47c02d36015 Upgrade the Airflow version to 3.5.0 and Task SDK version
to 1.5.0 (#76388)
add 45edb1750f1 Use only the configured auth type when creating tokens in
the FAB auth manager (#76231)
add 5afb353fd08 Add script to remove constraints for unsupported Python
versions (#75333)
add 1631eccfc2d Fix retry policy docs and the example Dag's
`ConnectionError` rules (#76313)
add f34cae8fa6f Suggest common model providers in the pydanticai
connection form (#76053)
add 4495e92002c Decode state store vals through backend; treat null as
missing (#76009)
add 2ab01dae67f Java SDK: Read the Dag run conf into a class with typed
fields (#75542)
add 5308480f2ee Fix airflowctl list pagination when the server caps the
page size (#76268)
add aa0d6506b4a Build CI and release images on pinned OS-dependencies
images (#76225)
add 0c69d652a89 Build CI and release images on pinned OS-dependencies
images (#76225)
add 76f290f3f80 Implement Python task handler and support it in YAML Dags
(#75405)
add 7badc9f42a1 Include table names in db clean progress output (#74243)
add 575d8af602f Keep the audit log off the API server event loop (#76416)
add bd8cad6b729 Let non task callers set and delete variables over
execution API (#76375)
add 671be47b20e Note that the API server uses a second database connection
pool (#76430)
add b503e692da0 Fix `SSHRemoteJobOperator` on Windows hosts (#73352)
add fc172d09a5b Add deferrable mode to `SqlSensor` (#76270)
add 2aa4ae811d8 Rewrite the OpenAI Agents SDK guide to stand on its own
(#76340)
add a427286b8d2 Add screenshots and a review loop example to the task
loops docs (#76435)
add 6e6e0f7ae9b Document how to create a TypeScript SDK project (#76374)
add 31b0dfef865 Fix docs build on Task SDK task handler page ref (#76440)
add cf5017be3c1 UI: Complete the Italian translation (#76411)
add 37d4d9395f7 UI: Fix task groups not expanding when localStorage is
full (#76302)
add 11baedfd86c Add OpenLineage e2e tests for manual state changes, clears
and failures (#75908)
add 629729a9913 Describe where the dependency upgrade summary runs now
(#76439)
add caf26246c1c Stop pydantic-ai providers that models cannot use from
failing the common.ai vendor check (#76312)
add bcfe0128623 Bump UI dependencies and fix log tests for react-virtual
(#76444)
add 77c29134b37 Load Java Dags from a bundle path that holds a colon
(#76432)
add 3fd90eb41c0 UI: Complete the Spanish (es) translation (#76087)
add 4ef770b91d6 Let asset watchers write asset state over the Execution
API (#76376)
add cd3ae408a1a Keep mapped tasks when clearing with run on latest version
(#76420)
add 5d70b49e9ea UI: Label the Dag bundle file table as Parsed Files and
say what it lists (#76462)
add 240e6eed65c Parametrize GCS-to-GCS wildcard and retention tests.
(#76094)
add d07cb5f727d Fix airflowctl backfill create-dry-run printing one
all-null row (#76224)
add 7b00cf0835a Add GET /triggers to list every trigger of every kind and
its status (#76260)
add 596dd41485c Stop airflowctl sending an old token to a new API URL
(#76287)
add 6920d2c25f4 Escape Rich markup in airflowctl variable and pool
commands (#76419)
add 6f2de5abe97 add stephen-bracken to fork-ci-gate (#76316)
add 0ae09c32182 Install apt-utils matching the image's apt on hardened
images (#76484)
add b2f327748b8 Restore default ELK node placement in Graph view (#76488)
add 1b792598b6d Support native asset partitions in watcher events (#74852)
add 953d7ff3d6a Hide "View error" on bundle files the user cannot read
(#76479)
add 6858cb6c3a2 Refresh expired AWS credentials in AwsDuckDBHook (#76086)
add f05c32e10e1 Lower severity of handled XCom misses (#73198)
add 94018444cdf Ship the Dag bundle permission in Airflow 3.4.1 (#76474)
add 9391e6a7a48 Remove machine-global pnpm config causing .pnpm-store dir
to be created in places (#76498)
add c52946c9c9c Clarify Dag bundle permission upgrade notes (#76499)
add a1be2c1ce30 Fix Google Cloud connection IdP extra request parameters
being ignored (#76161)
add 494f65e0f68 Fix async engine datetimes being shifted on non-UTC MySQL
servers (#76505)
add 8ee215945aa Apply timeout_seconds and connection proxies to dbt Cloud
sync requests (#74684)
add 0d5f53297a0 Add unit tests for Dataproc, GKE and Translate provider
links (#75694)
add 7ee853093ec Apply note before state in bulk Dag run update so
listeners see it (#74890)
add 1948af1fedb Add unit tests for PrestoToGCSOperator (#75559)
add 57793d01d9b Import TriggerRule from airflow.sdk in docs examples
(#76522)
add 776e9d2e78a Cache the dialect on PostgresHook and MsSqlHook (#75656)
add cc786845ad3 Build the ADBC database URI from the connection fields
(#74454)
add 31beac5deea disable external entities in SAML idp response parsing
(#71423)
add 750617c3867 Fix entry-point plugins reported as duplicates on
RHEL/Fedora venvs (#74531)
add f14247a5938 Add a general debugging guide to the troubleshooting doc
(#71457)
add ebe49645e34 Move XCom filter param models into execution API
datamodels (#76536)
add 437f6be3cec Run the durable OpenAI Agents tests in the agent framework
CI job (#76500)
add 7625b59a85e Key LLM batch and durable Strands state on the task loop
iteration (#76201)
add d46d97fa8d5 Note the unparseable-output case in OpenAIResponseOperator
XCom docs (#74519)
add b7ceab0372b Support Workload Identity Federation in Snowflake REST API
authentication (#75810)
add f82542a453a Name the caller's own MCP client and durable setup in
Common AI errors (#76495)
add 8e922e329ab Refactor isinstance dispatching with polymorphism (#74634)
add e3c21b77c97 Update French (fr) UI translations to 100% coverage
(#76460)
add dcbf21690e8 Pass AssetStateStoreAccessors into response_check_path
Callable in HttpEventTrigger (#72287)
add 6cf8ed6c63a UI: Translate the Spanish strings added since the last
pass (#76466)
add b5ab0a15174 UI: Defer React plugin compatibility runtime (#75083)
add b0581660e45 Support fail_on_reject on every LLM approval operator
(#74493)
add 24464f6d728 Keep Dag and deadline list serialization off the API
server event loop (#76525)
add 020259387b9 Support multimodal prompts with enable_hitl_review in
AgentOperator (#74389)
add c4eaf4b8399 Prepare providers release 2026-11-03 (#76490)
add 3eacdb97dfd Sanitize error message in DatabricksExecutionTrigger
(#70385)
add 8529c41db15 Add environment_variables to MWAA Serverless create/update
workflow operators (#76496)
add c8d8df3353d Add `@task.modal` to run Python functions on Modal without
Airflow in the image (#76502)
add bca1e144da1 Add raphaelauv to fork-ci-gate (#76538)
add 71a19df58c5 Write container logs to the task log in deferrable
AzureContainerInstancesOperator (#76330)
add 6bacb63888f Complete Dutch translations (2026-10-05) (#74286)
add 77762c256df Add `partition_key` to the `DagRun Finished` log line
(#76557)
add 1f4bc05aa0a Allow Human-in-the-loop tasks to be answered while still
running (#75413)
add c7fcba0106a Stop holding openai below 3 in Airflow's CI image and
constraints (#76503)
add 322c178e05b Fix duplicated asset events when name_prefix_pattern
matches all (#74816)
add 1fe65f5f13a Keep parallel tool results replayable across retries in
OpenAI Agents durable runs (#76015)
add 3204b6ebebb Fix enum names and non-ISO dates in airflowctl dags output
(#76354)
add cc1dfb94296 Remove deprecated project_id from BigQueryGetDataOperator
(#76115)
add 2e9ae2a1999 Split mixed OpenLineage tests into unit and integration
(#75642)
add 1e0e003cea8 Template conn_id and config_kwargs in @task.pyspark
(#75764)
add a04fda49d1a Mark MSGraphAsyncOperator as durable capable (#76576)
add 92fa9b36b09 Fix skill call counts and source links in the AI Model tab
(#76541)
add e10575d5479 Release the Java SDK 1.0.0 and pin its schema URL to the
published docs site (#75944)
add 48a35ccd2d8 Fix S3ToAzureBlobStorageOperator failing on S3 folder
markers (#76408)
add e0b7126d573 Let a final release override the
pending-provider-candidate guard (#76592)
add 1f764a2e118 Add Russian (ru) translation agent skill guideline (#76579)
add f90d2607dd4 Return 404 when a DagRun disappears during task API writes
(#72907)
add f5234c744a1 Harden OpenLineage task outcomes system test (#76595)
add 82b33126d3a Chart: Default airflow version to 3.4.0 (#76601)
add c2ff56eff6b UI: Complete the Portuguese translation (#76412)
add a0924b53f86 Mark Airflow 3.4.0 as the latest released version (#76602)
add f396a3b2271 Add Cloud SQL Auth Proxy v2 support to CloudSqlProxyRunner
(#73646)
add a7b8dc96928 Give the SMTP emailer its own defaults for the [smtp]
options (#76346)
add 498c1cd470c Fix CeleryExecutor failing to load with Celery 5.7 (#76591)
add c8e01650d56 Add a regression test for WITH in the asset orphanage
DELETE (#75127)
add 887f6d2b559 Keep Dag parse results tied to their source snapshot
(#74789)
add dac96bcf61c Publish Dag results and inventories through the Execution
API (#74790)
add f2edf564af4 Recover Dag processor work and expire inactive processors
(#74791)
add 2c69a21eb65 Add HTTP publication to the Dag processor manager (#74793)
add f01f7ef65d6 Make the Variable value non-nullable in the Execution API
(#76007)
add 335fd71f58f Stop AWS Glue job run when a deferred task is cleared
(#73702)
add abc3a20f080 Escape server and user text in airflowctl command messages
(#76265)
add c7762927381 Bump happy-dom
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 (aae43e3a968)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/auth-ui-security-updates-0f025de440
(c7762927381)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.agents/skills/airflow-translations/SKILL.md | 8 +
.agents/skills/airflow-translations/locales/es.md | 34 +-
.agents/skills/airflow-translations/locales/it.md | 65 +-
.agents/skills/airflow-translations/locales/pt.md | 26 +
.agents/skills/airflow-translations/locales/ru.md | 242 +
.apache-magpie.lock | 6 +-
.asf.yaml | 10 +-
.github/CODEOWNERS | 2 +-
.github/actions/install-prek/action.yml | 26 +-
.github/actions/load_image/action.yml | 116 +
.../actions/prepare_breeze_and_image/action.yml | 25 +-
.github/actions/prepare_single_ci_image/action.yml | 19 +-
.github/actions/stash-restore/action.yml | 14 +
.github/fork-ci-gate.toml | 2 +
.github/workflows/additional-prod-image-tests.yml | 2 +-
.github/workflows/agent-framework-tests.yml | 2 +-
.github/workflows/airflow-distributions-tests.yml | 4 +-
.github/workflows/auto-approve-workflow-runs.yml | 8 +-
.github/workflows/ci-amd.yml | 43 +-
.github/workflows/ci-arm.yml | 39 +-
.github/workflows/ci-duration-monitor.yml | 1 +
.github/workflows/ci-image-build.yml | 67 +
.github/workflows/ci-notification.yml | 1 +
.github/workflows/codeql-analysis.yml | 1 +
.github/workflows/dependency-upgrade-report.yml | 254 +
.github/workflows/dependency-upgrade-summary.yml | 104 +
.github/workflows/e2e-flaky-tests-report.yml | 1 +
.github/workflows/finalize-tests.yml | 39 -
.github/workflows/generate-constraints.yml | 2 +
.github/workflows/helm-tests.yml | 4 +-
.github/workflows/integration-system-tests.yml | 8 +-
.github/workflows/java-sdk-dependency-security.yml | 1 +
.github/workflows/k8s-tests.yml | 4 +-
.github/workflows/mirror-hardened-base-images.yml | 173 +-
.github/workflows/prod-image-build.yml | 102 +-
.github/workflows/prod-packages-build.yml | 129 +
.github/workflows/publish-docs-to-s3.yml | 66 +-
.github/workflows/recheck-old-bug-report.yml | 1 +
.github/workflows/registry-backfill.yml | 42 +-
.github/workflows/registry-build.yml | 49 +-
.github/workflows/release-constraints.yml | 16 +-
.github/workflows/run-unit-tests.yml | 4 +-
.github/workflows/scheduled-upgrade-check-main.yml | 1 +
.../scheduled-upgrade-check-v3-4-test.yml | 1 +
.../scheduled-verify-release-calendar.yml | 1 +
.github/workflows/stale.yml | 1 +
.github/workflows/test-providers.yml | 4 +
.github/workflows/ts-sdk-release.yml | 15 +-
.github/workflows/upgrade-check.yml | 5 +-
.pre-commit-config.yaml | 6 +-
Dockerfile | 279 +-
Dockerfile.ci | 268 +-
README.md | 12 +-
RELEASE_NOTES.rst | 1099 +++-
.../administration-and-deployment/dag-bundles.rst | 70 +-
.../administration-and-deployment/listeners.rst | 13 +
.../logging-monitoring/callbacks.rst | 2 +
.../logging-monitoring/index.rst | 1 +
.../logging-monitoring/triggers.rst | 122 +
.../task-and-asset-state-store.rst | 2 +
.../docs/authoring-and-scheduling/assets.rst | 2 +
.../authoring-and-scheduling/event-scheduling.rst | 13 +
.../language-sdks/index.rst | 8 +-
.../language-sdks/java.rst | 50 +
.../language-sdks/typescript.rst | 64 +-
.../docs/authoring-and-scheduling/loops.rst | 155 +-
.../docs/authoring-and-scheduling/yaml-dags.rst | 23 +-
airflow-core/docs/best-practices.rst | 6 +-
airflow-core/docs/core-concepts/tasks.rst | 33 +-
airflow-core/docs/faq.rst | 3 +-
.../docs/howto/docker-compose/docker-compose.yaml | 2 +-
airflow-core/docs/howto/docker-compose/index.rst | 6 +-
.../docs/img/ui-dark/dag_overview_versions.png | Bin 0 -> 115759 bytes
airflow-core/docs/img/ui-dark/loops_clear.png | Bin 0 -> 271661 bytes
airflow-core/docs/img/ui-dark/loops_decision.png | Bin 0 -> 73779 bytes
airflow-core/docs/img/ui-dark/loops_graph.png | Bin 0 -> 77163 bytes
airflow-core/docs/img/ui-dark/loops_iterations.png | Bin 0 -> 191319 bytes
.../docs/img/ui-dark/loops_iterations_tab.png | Bin 0 -> 156522 bytes
airflow-core/docs/img/ui-dark/loops_mapped.png | Bin 0 -> 179885 bytes
airflow-core/docs/img/ui-dark/loops_review.png | Bin 0 -> 244676 bytes
.../docs/img/ui-light/dag_overview_versions.png | Bin 0 -> 112317 bytes
airflow-core/docs/img/ui-light/loops_clear.png | Bin 0 -> 268407 bytes
airflow-core/docs/img/ui-light/loops_decision.png | Bin 0 -> 72201 bytes
airflow-core/docs/img/ui-light/loops_graph.png | Bin 0 -> 78174 bytes
.../docs/img/ui-light/loops_iterations.png | Bin 0 -> 189121 bytes
.../docs/img/ui-light/loops_iterations_tab.png | Bin 0 -> 155523 bytes
airflow-core/docs/img/ui-light/loops_mapped.png | Bin 0 -> 177810 bytes
airflow-core/docs/img/ui-light/loops_review.png | Bin 0 -> 243231 bytes
.../docs/installation/supported-versions.rst | 2 +-
airflow-core/docs/migrations-ref.rst | 12 +-
airflow-core/docs/security/api_permissions_ref.rst | 20 +-
airflow-core/docs/troubleshooting.rst | 129 +
airflow-core/docs/ui.rst | 36 +-
airflow-core/newsfragments/74789.significant.rst | 12 +
airflow-core/newsfragments/76007.significant.rst | 22 +
airflow-core/newsfragments/76234.bugfix.rst | 1 +
airflow-core/newsfragments/76430.significant.rst | 11 +
airflow-core/newsfragments/76474.significant.rst | 15 +
airflow-core/pyproject.toml | 10 +-
airflow-core/src/airflow/__init__.py | 2 +-
.../auth/managers/models/resource_details.py | 3 +
.../auth/managers/simple/simple_auth_manager.py | 16 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 38 +-
.../src/airflow/api_fastapi/common/db/assets.py | 5 +-
.../airflow/api_fastapi/common/parameters/misc.py | 10 +-
.../api_fastapi/common/parameters/trigger.py | 133 +
.../src/airflow/api_fastapi/core_api/base.py | 5 +-
.../api_fastapi/core_api/datamodels/assets.py | 5 +-
.../api_fastapi/core_api/datamodels/dag_bundles.py | 32 +-
.../api_fastapi/core_api/datamodels/dags.py | 4 +-
.../api_fastapi/core_api/datamodels/trigger.py | 74 +
.../core_api/datamodels/ui/dag_bundles.py | 9 +-
.../api_fastapi/core_api/datamodels/ui/deadline.py | 2 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 60 +
.../core_api/openapi/v2-rest-api-generated.yaml | 565 +-
.../api_fastapi/core_api/routes/public/__init__.py | 2 +
.../api_fastapi/core_api/routes/public/assets.py | 218 +-
.../core_api/routes/public/dag_bundles.py | 272 +-
.../core_api/routes/public/dag_parsing.py | 18 +
.../api_fastapi/core_api/routes/public/dag_run.py | 4 +-
.../api_fastapi/core_api/routes/public/dags.py | 7 +-
.../api_fastapi/core_api/routes/public/hitl.py | 6 +-
.../core_api/routes/public/task_state_store.py | 5 +-
.../api_fastapi/core_api/routes/public/triggers.py | 285 +
.../api_fastapi/core_api/routes/ui/__init__.py | 2 +
.../api_fastapi/core_api/routes/ui/dag_bundles.py | 81 +
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 9 +-
.../api_fastapi/core_api/routes/ui/deadlines.py | 2 +-
.../src/airflow/api_fastapi/core_api/security.py | 211 +-
.../api_fastapi/core_api/services/public/assets.py | 17 +-
.../core_api/services/public/dag_run.py | 4 +-
.../core_api/services/public/import_errors.py | 76 +
.../core_api/services/public/variables.py | 20 +
.../airflow/api_fastapi/execution_api/AGENTS.md | 1 +
.../execution_api/datamodels/dag_parsing.py | 201 +
.../api_fastapi/execution_api/datamodels/job.py | 4 +-
.../execution_api/datamodels/taskinstance.py | 16 +-
.../execution_api/datamodels/variable.py | 4 +-
.../api_fastapi/execution_api/datamodels/xcom.py | 19 +
.../api_fastapi/execution_api/in_process.py | 3 +-
.../api_fastapi/execution_api/routes/__init__.py | 2 +
.../execution_api/routes/asset_state_store.py | 28 +-
.../execution_api/routes/dag_parsing.py | 630 ++
.../api_fastapi/execution_api/routes/hitl.py | 16 +-
.../api_fastapi/execution_api/routes/jobs.py | 22 +-
.../execution_api/routes/task_instances.py | 62 +-
.../execution_api/routes/task_state_store.py | 22 +-
.../api_fastapi/execution_api/routes/variables.py | 3 +
.../api_fastapi/execution_api/routes/xcoms.py | 22 +-
.../airflow/api_fastapi/execution_api/security.py | 37 +
.../execution_api/services/task_instances.py | 16 +-
.../api_fastapi/execution_api/versions/__init__.py | 19 +-
.../execution_api/versions/v2025_08_10.py | 2 +-
.../execution_api/versions/v2026_10_30.py | 42 +-
.../versions/v2026_10_30_xcom_params.py | 35 -
.../execution_api/versions/v2027_02_28.py | 56 +-
.../src/airflow/api_fastapi/logging/decorators.py | 36 +-
airflow-core/src/airflow/cli/cli_config.py | 21 +-
.../src/airflow/cli/commands/config_command.py | 13 +
.../src/airflow/cli/commands/scheduler_command.py | 17 +-
.../src/airflow/cli/commands/task_command.py | 5 +-
.../src/airflow/config_templates/config.yml | 22 +-
airflow-core/src/airflow/configuration.py | 18 +-
.../src/airflow/dag_processing/api_client.py | 115 +-
.../src/airflow/dag_processing/bundles/base.py | 21 +-
.../src/airflow/dag_processing/bundles/local.py | 1 +
.../src/airflow/dag_processing/bundles/manager.py | 30 +-
.../v2027_02_28.py => dag_processing/claims.py} | 21 +-
.../src/airflow/dag_processing/collection.py | 282 +-
.../src/airflow/dag_processing/maintenance.py | 155 +
airflow-core/src/airflow/dag_processing/manager.py | 1310 +++-
.../src/airflow/dag_processing/processor.py | 83 +-
.../src/airflow/dag_processing/requested_work.py | 139 +
.../importerrors.py => dag_processing/timeouts.py} | 22 +-
.../airflow/example_dags/example_retry_policy.py | 13 +-
.../src/airflow/example_dags/example_task_loops.py | 4 +-
.../src/airflow/executors/local_executor.py | 66 +-
.../src/airflow/jobs/scheduler_job_runner.py | 6 +
.../src/airflow/jobs/triggerer_job_runner.py | 211 +-
.../src/airflow/listeners/spec/importerrors.py | 20 +-
.../0152_3_5_0_add_state_and_owner_to_trigger.py | 134 +
.../0153_3_5_0_add_index_on_callback_trigger_id.py | 71 +
...154_3_5_0_add_idempotency_key_to_hitl_detail.py | 53 +
...55_3_5_0_add_dag_processor_publication_state.py | 78 +
.../0156_3_5_0_add_processor_work_claims.py | 74 +
airflow-core/src/airflow/models/__init__.py | 2 +
airflow-core/src/airflow/models/callback.py | 21 +-
airflow-core/src/airflow/models/dag.py | 1 +
.../models/dag_processor_publication_receipt.py | 46 +
.../xcom.py => models/dag_processor_work_claim.py} | 29 +-
airflow-core/src/airflow/models/dagbag.py | 16 +-
airflow-core/src/airflow/models/dagbundle.py | 3 +
airflow-core/src/airflow/models/dagcode.py | 2 +-
airflow-core/src/airflow/models/dagrun.py | 27 +-
airflow-core/src/airflow/models/dagwarning.py | 30 +-
airflow-core/src/airflow/models/errors.py | 4 +-
airflow-core/src/airflow/models/hitl.py | 43 +
airflow-core/src/airflow/models/taskinstance.py | 2 +
airflow-core/src/airflow/models/trigger.py | 230 +-
airflow-core/src/airflow/sensors/__init__.py | 1 -
.../src/airflow/serialization/definitions/dag.py | 2 +
.../airflow/serialization/serialized_objects.py | 18 +-
airflow-core/src/airflow/settings.py | 1 +
airflow-core/src/airflow/state/metastore.py | 5 +-
airflow-core/src/airflow/triggers/base.py | 31 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 28 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 75 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 75 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 90 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 75 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 374 +-
.../ui/openapi-gen/requests/services.gen.ts | 120 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 257 +-
airflow-core/src/airflow/ui/package.json | 58 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 957 +--
airflow-core/src/airflow/ui/public/i18n/README.md | 7 +
.../airflow/ui/public/i18n/locales/ar/browse.json | 13 +-
.../airflow/ui/public/i18n/locales/ca/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/de/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/de/common.json | 10 +-
.../ui/public/i18n/locales/de/components.json | 4 +
.../src/airflow/ui/public/i18n/locales/de/dag.json | 4 +-
.../airflow/ui/public/i18n/locales/de/dags.json | 1 +
.../ui/public/i18n/locales/de/dashboard.json | 1 +
.../airflow/ui/public/i18n/locales/el/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/en/browse.json | 6 +-
.../airflow/ui/public/i18n/locales/en/common.json | 5 +-
.../ui/public/i18n/locales/en/components.json | 3 +-
.../airflow/ui/public/i18n/locales/es/admin.json | 15 +
.../airflow/ui/public/i18n/locales/es/assets.json | 5 +
.../airflow/ui/public/i18n/locales/es/browse.json | 36 +
.../airflow/ui/public/i18n/locales/es/common.json | 90 +-
.../ui/public/i18n/locales/es/components.json | 45 +-
.../src/airflow/ui/public/i18n/locales/es/dag.json | 138 +-
.../airflow/ui/public/i18n/locales/es/dags.json | 39 +-
.../ui/public/i18n/locales/es/dashboard.json | 22 +-
.../airflow/ui/public/i18n/locales/es/hitl.json | 3 +
.../airflow/ui/public/i18n/locales/fr/admin.json | 3 +
.../airflow/ui/public/i18n/locales/fr/browse.json | 9 +-
.../airflow/ui/public/i18n/locales/fr/common.json | 34 +-
.../ui/public/i18n/locales/fr/components.json | 13 +
.../src/airflow/ui/public/i18n/locales/fr/dag.json | 68 +-
.../airflow/ui/public/i18n/locales/fr/dags.json | 14 +-
.../ui/public/i18n/locales/fr/dashboard.json | 1 +
.../airflow/ui/public/i18n/locales/fr/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/he/browse.json | 7 +-
.../airflow/ui/public/i18n/locales/hi/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/it/admin.json | 55 +-
.../airflow/ui/public/i18n/locales/it/assets.json | 46 +-
.../airflow/ui/public/i18n/locales/it/browse.json | 86 +-
.../airflow/ui/public/i18n/locales/it/common.json | 352 +-
.../ui/public/i18n/locales/it/components.json | 115 +-
.../src/airflow/ui/public/i18n/locales/it/dag.json | 267 +-
.../airflow/ui/public/i18n/locales/it/dags.json | 69 +-
.../ui/public/i18n/locales/it/dashboard.json | 47 +-
.../airflow/ui/public/i18n/locales/it/hitl.json | 18 +-
.../airflow/ui/public/i18n/locales/ko/browse.json | 5 +-
.../airflow/ui/public/i18n/locales/nl/admin.json | 26 +-
.../airflow/ui/public/i18n/locales/nl/assets.json | 18 +-
.../airflow/ui/public/i18n/locales/nl/browse.json | 34 +
.../airflow/ui/public/i18n/locales/nl/common.json | 227 +-
.../ui/public/i18n/locales/nl/components.json | 57 +-
.../src/airflow/ui/public/i18n/locales/nl/dag.json | 139 +-
.../airflow/ui/public/i18n/locales/nl/dags.json | 60 +-
.../ui/public/i18n/locales/nl/dashboard.json | 24 +-
.../airflow/ui/public/i18n/locales/nl/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/pl/browse.json | 9 +-
.../airflow/ui/public/i18n/locales/pt/admin.json | 33 +-
.../airflow/ui/public/i18n/locales/pt/assets.json | 39 +-
.../airflow/ui/public/i18n/locales/pt/browse.json | 60 +
.../airflow/ui/public/i18n/locales/pt/common.json | 314 +-
.../ui/public/i18n/locales/pt/components.json | 92 +-
.../src/airflow/ui/public/i18n/locales/pt/dag.json | 236 +-
.../airflow/ui/public/i18n/locales/pt/dags.json | 65 +-
.../ui/public/i18n/locales/pt/dashboard.json | 44 +-
.../airflow/ui/public/i18n/locales/pt/hitl.json | 15 +
.../ui/public/i18n/locales/zh-CN/browse.json | 5 +-
.../ui/public/i18n/locales/zh-TW/browse.json | 7 +-
.../ui/public/i18n/locales/zh-TW/common.json | 11 +-
.../ui/public/i18n/locales/zh-TW/components.json | 5 +
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 4 +-
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 1 +
.../ui/public/i18n/locales/zh-TW/dashboard.json | 1 +
.../ui/src/components/DagImportErrorModal.test.tsx | 6 +-
.../components/FlexibleForm/FieldArray.test.tsx | 182 +
.../ui/src/components/FlexibleForm/FieldArray.tsx | 141 +
.../components/FlexibleForm/FieldMultiSelect.tsx | 4 +
.../components/FlexibleForm/FieldSelector.test.tsx | 87 +
.../src/components/FlexibleForm/FieldSelector.tsx | 17 +-
.../components/FlexibleForm/FieldStringArray.tsx | 70 -
.../components/FlexibleForm/parseArrayElement.ts | 62 +
.../ui/src/components/Graph/elkGraphUtils.test.ts | 14 +
.../ui/src/components/Graph/elkGraphUtils.ts | 3 -
.../airflow/ui/src/components/ImportErrorCount.tsx | 13 +-
.../ui/src/components/NeedsReviewButton.tsx | 3 +-
.../ui/src/context/groups/GroupsProvider.test.tsx | 34 +-
.../ui/src/context/groups/GroupsProvider.tsx | 45 +-
.../airflow/ui/src/hooks/useRequiredActionTabs.ts | 6 +-
.../src/airflow/ui/src/layouts/BaseLayout.test.tsx | 23 +-
.../src/airflow/ui/src/layouts/BaseLayout.tsx | 18 +-
.../airflow/ui/src/layouts/Details/Grid/Grid.tsx | 1 -
.../Details/Grid/GridSelectionActionBar.test.tsx | 23 +-
.../Details/Grid/GridSelectionActionBar.tsx | 22 +-
.../layouts/Details/Grid/useGridSelection.test.tsx | 30 +-
.../src/layouts/Details/Grid/useGridSelection.ts | 52 +-
airflow-core/src/airflow/ui/src/main.tsx | 19 +-
.../src/airflow/ui/src/mocks/handlers/admin.ts | 1 +
.../src/airflow/ui/src/mocks/handlers/assets.ts | 2 +-
.../ui/src/pages/Asset/AssetEventsFilters.test.tsx | 6 +-
.../src/airflow/ui/src/pages/Asset/Header.test.tsx | 6 +-
.../ui/src/pages/AssetsList/AssetsList.test.tsx | 6 +-
.../Dag/Backfills/BackfillsDateFilter.test.tsx | 6 +-
.../ui/src/pages/Dag/RequiredActionsRoute.test.tsx | 6 +-
.../ui/src/pages/DagBundle/BundleFiles.test.tsx | 62 +
.../airflow/ui/src/pages/DagBundle/BundleFiles.tsx | 29 +-
.../src/pages/DagBundle/FileImportError.test.tsx | 147 +
.../ui/src/pages/DagBundle/FileImportError.tsx | 62 +-
.../ui/src/pages/DagBundles/DagBundles.test.tsx | 6 +-
.../airflow/ui/src/pages/DagRuns/DagRuns.test.tsx | 6 +-
.../src/airflow/ui/src/pages/DagsList/DagCard.tsx | 14 +-
.../src/pages/DagsList/DagRunStateCounts.test.tsx | 5 +
.../ui/src/pages/DagsList/DagRunStateCounts.tsx | 2 +-
.../DagsList/DagsFilters/DagsFilters.test.tsx | 26 +-
.../ui/src/pages/DagsList/DagsList.test.tsx | 6 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 3 +-
.../airflow/ui/src/pages/DagsList/RecentRuns.tsx | 6 +-
.../DagsList/recentRunsLayout.ts} | 12 +-
.../src/airflow/ui/src/pages/Error.test.tsx | 100 +
airflow-core/src/airflow/ui/src/pages/Error.tsx | 13 +
.../HITLTaskInstances/HITLTaskInstances.test.tsx | 11 +-
.../pages/HITLTaskInstances/HITLTaskInstances.tsx | 4 +-
.../src/airflow/ui/src/pages/ReactPlugin.test.tsx | 25 +-
.../src/airflow/ui/src/pages/ReactPlugin.tsx | 14 +-
.../airflow/ui/src/pages/Run/CallbackLogs.test.tsx | 1 +
.../airflow/ui/src/pages/Run/Callbacks.test.tsx | 1 +
.../ui/src/pages/TaskInstance/Logs/Logs.test.tsx | 6 +
.../pages/TaskInstance/Logs/LogsSelection.test.tsx | 6 +
.../TaskInstances/TaskInstancesFilter.test.tsx | 6 +-
.../src/airflow/ui/src/pages/XCom/XCom.test.tsx | 6 +-
.../airflow/ui/src/pages/documentTitle.test.tsx | 62 +-
.../ui/src/queries/dagListQueryKeys.test.tsx | 134 +
.../airflow/ui/src/queries/gridViewQueryKeys.ts | 10 +
.../airflow/ui/src/queries/useBulkClearDagRuns.ts | 3 +-
.../airflow/ui/src/queries/useBulkDeleteDagRuns.ts | 9 +-
.../airflow/ui/src/queries/useBulkPatchDagRun.ts | 5 +-
.../src/airflow/ui/src/queries/useClearRun.ts | 3 +-
.../ui/src/queries/useClearTaskInstances.ts | 3 +-
.../ui/src/queries/useCreateBackfill.test.tsx | 9 +-
.../airflow/ui/src/queries/useCreateBackfill.ts | 6 +-
.../src/airflow/ui/src/queries/useDeleteDagRun.ts | 9 +-
.../ui/src/queries/useHasMultipleDagBundles.ts | 6 +-
.../src/airflow/ui/src/queries/usePatchDagRun.ts | 3 +-
.../src/airflow/ui/src/queries/useTrigger.ts | 15 +-
airflow-core/src/airflow/ui/src/router.test.tsx | 71 +-
airflow-core/src/airflow/ui/src/router.tsx | 316 +-
.../src/airflow/ui/src/utils/AppWrapper.tsx | 16 +-
airflow-core/src/airflow/ui/src/utils/hitl.test.ts | 48 +-
airflow-core/src/airflow/ui/src/utils/hitl.ts | 12 +-
.../src/utils/registerPluginDependencies.test.ts | 59 +
...ppWrapper.tsx => registerPluginDependencies.ts} | 39 +-
.../src/airflow/ui/src/utils/routeModule.ts | 45 +
.../airflow/ui/tests/e2e/specs/dag-bundles.spec.ts | 4 +-
airflow-core/src/airflow/utils/db.py | 2 +-
airflow-core/src/airflow/utils/db_cleanup.py | 25 +-
.../tests/unit/always/test_project_structure.py | 5 -
.../managers/simple/test_simple_auth_manager.py | 17 +
.../tests/unit/api_fastapi/core_api/conftest.py | 27 +-
.../core_api/routes/public/test_assets.py | 503 +-
.../core_api/routes/public/test_dag_bundles.py | 757 +--
.../core_api/routes/public/test_dag_parsing.py | 118 +
.../core_api/routes/public/test_dag_run.py | 129 +
.../core_api/routes/public/test_dags.py | 18 +
.../core_api/routes/public/test_execution.py | 1 +
.../core_api/routes/public/test_hitl.py | 46 +
.../routes/public/test_task_state_store.py | 51 +-
.../core_api/routes/public/test_triggers.py | 688 ++
.../core_api/routes/public/test_variables.py | 104 +
.../core_api/routes/ui/test_dag_bundles.py | 103 +
.../api_fastapi/core_api/routes/ui/test_dags.py | 30 +
.../core_api/routes/ui/test_deadlines.py | 12 +
.../execution_api/test_dag_processor_client.py | 2 +
.../api_fastapi/execution_api/test_security.py | 102 +-
.../execution_api/test_token_scope_boundaries.py | 10 +
.../versions/head/test_asset_events.py | 49 +-
.../versions/head/test_asset_state_store.py | 99 +-
.../versions/head/test_dag_parsing.py | 2137 +++++++
.../execution_api/versions/head/test_hitl.py | 45 +
.../execution_api/versions/head/test_jobs.py | 56 +
.../versions/head/test_task_instances.py | 6 +-
.../versions/head/test_task_state_store.py | 60 +-
.../versions/v2026_10_30/test_task_instances.py | 34 -
.../versions/v2026_10_30/test_task_state_store.py | 51 +
.../versions/v2027_02_28/test_jobs.py | 10 +
.../versions/v2027_02_28/test_task_instances.py | 84 +
.../versions/v2027_02_28/test_variables.py | 65 +
.../unit/api_fastapi/logging/test_decorators.py | 45 +-
.../tests/unit/cli/commands/test_config_command.py | 59 +
.../tests/unit/cli/commands/test_dag_command.py | 8 +-
.../unit/cli/commands/test_scheduler_command.py | 38 +
.../tests/unit/cli/commands/test_task_command.py | 18 +
airflow-core/tests/unit/cli/test_cli_parser.py | 21 +
airflow-core/tests/unit/core/test_settings.py | 44 +-
.../tests/unit/dag_processing/bundles/test_base.py | 6 +-
.../bundles/test_dag_bundle_manager.py | 48 +-
.../unit/dag_processing/bundles/test_local.py | 3 +
airflow-core/tests/unit/dag_processing/conftest.py | 67 +
.../tests/unit/dag_processing/test_api_client.py | 422 +-
.../tests/unit/dag_processing/test_claims.py | 39 +
.../tests/unit/dag_processing/test_collection.py | 59 +-
.../tests/unit/dag_processing/test_maintenance.py | 408 ++
.../tests/unit/dag_processing/test_manager.py | 3462 ++++++++++-
.../dag_processing/test_manager_api_failures.py | 351 ++
.../dag_processing/test_manager_api_inventory.py | 453 ++
.../dag_processing/test_manager_api_isolation.py | 206 +
.../dag_processing/test_manager_api_results.py | 72 +
.../tests/unit/dag_processing/test_processor.py | 165 +-
.../unit/dag_processing/test_requested_work.py | 141 +
.../tests/unit/executors/test_executor_loader.py | 6 +-
.../tests/unit/executors/test_local_executor.py | 232 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 250 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 645 +-
.../tests/unit/listeners/test_importerrors.py | 85 +
.../test_0152_add_state_and_owner_to_trigger.py | 207 +
.../test_0153_add_index_on_callback_trigger_id.py | 249 +
.../test_0156_add_processor_work_claims.py | 165 +
airflow-core/tests/unit/models/test_callback.py | 17 +
airflow-core/tests/unit/models/test_cleartasks.py | 77 +
airflow-core/tests/unit/models/test_dagrun.py | 103 +-
airflow-core/tests/unit/models/test_dagwarning.py | 54 -
.../tests/unit/models/test_taskinstance.py | 1 +
airflow-core/tests/unit/models/test_trigger.py | 281 +-
.../unit/serialization/test_dag_serialization.py | 39 +
airflow-core/tests/unit/state/test_metastore.py | 12 +-
.../tests/unit/timetables/test_cron_mixin.py | 40 +-
.../tests/unit/triggers/test_base_trigger.py | 15 +-
airflow-core/tests/unit/utils/test_db_cleanup.py | 95 +-
airflow-ctl-tests/pyproject.toml | 6 +-
.../tests/airflowctl_tests/conftest.py | 9 +
.../airflowctl_tests/test_airflowctl_commands.py | 24 +-
.../tests/airflowctl_tests/test_dag_run_wait.py | 15 +
airflow-ctl/docs/cli-and-env-variables-ref.rst | 23 +-
airflow-ctl/docs/howto/index.rst | 1 +
airflow-ctl/docs/images/command_hashes.txt | 4 +-
airflow-ctl/docs/images/output_taskinstances.svg | 86 +-
airflow-ctl/docs/images/output_tasks.svg | 94 +-
airflow-ctl/pyproject.toml | 6 +-
airflow-ctl/src/airflowctl/__main__.py | 5 +
airflow-ctl/src/airflowctl/api/client.py | 166 +-
.../airflowctl/api/datamodels/auth_generated.py | 2 +-
.../src/airflowctl/api/datamodels/generated.py | 240 +-
airflow-ctl/src/airflowctl/api/operations.py | 226 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 157 +-
.../src/airflowctl/ctl/commands/auth_command.py | 72 +-
.../src/airflowctl/ctl/commands/config_command.py | 3 +-
.../airflowctl/ctl/commands/connection_command.py | 46 +-
.../src/airflowctl/ctl/commands/dag_command.py | 20 +-
.../src/airflowctl/ctl/commands/pool_command.py | 34 +-
.../src/airflowctl/ctl/commands/task_command.py | 35 +-
.../airflowctl/ctl/commands/variable_command.py | 26 +-
.../src/airflowctl/ctl/console_formatting.py | 7 +-
airflow-ctl/src/airflowctl/ctl/help_texts.yaml | 3 +
airflow-ctl/src/airflowctl/ctl/utils/dag_run.py | 9 +-
airflow-ctl/src/airflowctl/ctl/utils/validation.py | 48 +
airflow-ctl/src/airflowctl/exceptions.py | 4 +
airflow-ctl/tests/airflow_ctl/api/test_client.py | 228 +-
.../tests/airflow_ctl/api/test_operations.py | 217 +-
.../airflow_ctl/ctl/commands/test_auth_command.py | 238 +-
.../ctl/commands/test_config_command.py | 14 +-
.../ctl/commands/test_connections_command.py | 58 +
.../airflow_ctl/ctl/commands/test_dag_command.py | 138 +-
.../airflow_ctl/ctl/commands/test_pool_command.py | 89 +
.../airflow_ctl/ctl/commands/test_task_command.py | 169 +
.../ctl/commands/test_variable_command.py | 85 +
.../tests/airflow_ctl/ctl/test_cli_config.py | 358 +-
.../airflow_ctl/ctl/test_console_formatting.py | 29 +
.../tests/airflow_ctl/ctl/utils}/__init__.py | 0
.../tests/airflow_ctl/ctl/utils/test_dag_run.py | 236 +
.../tests/airflow_ctl/test_main.py | 30 +-
.../tests/airflow_ctl/utils}/__init__.py | 0
.../tests/airflow_ctl/utils/test_helpers.py | 29 +-
.../tests/airflow_ctl/utils/test_module_loading.py | 30 +-
airflow-e2e-tests/docker/openlineage.yml | 69 +-
.../java-native-bundle/gradle.properties | 2 +-
.../java-test-bundle/gradle.properties | 2 +-
.../org/apache/airflow/e2e/TestBundleBuilder.java | 6 +-
airflow-e2e-tests/pyproject.toml | 8 +-
.../tests/airflow_e2e_tests/conftest.py | 5 +
.../java_sdk_tests/test_java_sdk_dag.py | 10 +-
.../dags_extra/openlineage_inlet_assets_dag.py | 64 +
.../airflow_e2e_tests/openlineage_tests/harness.py | 256 +-
.../openlineage_tests/prepare_dags.py | 2 +-
.../openlineage_tests/remove_unused_providers.py | 89 +
.../openlineage_tests/test_openlineage_e2e.py | 13 +-
chart/Chart.yaml | 20 +-
chart/NOTICE | 2 +-
chart/docs/index.rst | 1 +
chart/docs/migrate-to-git-dag-bundle.rst | 226 +
chart/files/pod-template-file.kubernetes-helm-yaml | 87 +-
chart/kustomize-overlays/kerberos/README.rst | 3 +-
chart/newsfragments/72555.significant.rst | 10 +
chart/newsfragments/76601.significant.rst | 3 +
chart/pyproject.toml | 6 +-
chart/templates/workers/worker-deployment.yaml | 84 +-
.../airflow_aux/test_container_lifecycle.py | 8 +-
.../airflow_aux/test_pod_template_file.py | 221 +-
chart/tests/helm_tests/airflow_core/test_worker.py | 92 +-
.../helm_tests/airflow_core/test_worker_sets.py | 211 +-
chart/tests/helm_tests/security/test_kerberos.py | 100 +-
.../helm_tests/security/test_security_context.py | 25 +-
chart/values.schema.json | 174 +-
chart/values.yaml | 58 +-
clients/python/pyproject.toml | 6 +-
contributing-docs/05_pull_requests.rst | 23 +-
contributing-docs/12_provider_distributions.rst | 6 +-
.../13_airflow_dependencies_and_extras.rst | 5 +
contributing-docs/18_contribution_workflow.rst | 20 +-
contributing-docs/25_maintainer_pr_triage.md | 18 +-
dev/AGENTS.md | 8 +-
dev/README_RELEASE_AIRFLOW.md | 16 +
dev/breeze/doc/08_ci_tasks.rst | 10 +-
dev/breeze/doc/09_release_management_tasks.rst | 72 +
dev/breeze/doc/10_ui_tasks.rst | 3 +
dev/breeze/doc/11_registry_tasks.rst | 8 +-
...0-run-ci-for-external-contributions-in-forks.md | 5 +-
.../doc/adr/0021-pin-os-dependencies-images.md | 123 +
dev/breeze/doc/ci/02_images.md | 52 +-
dev/breeze/doc/ci/04_selective_checks.md | 12 +-
dev/breeze/doc/ci/05_workflows.md | 75 +-
.../doc/ci/08_fork_ci_for_external_contributors.md | 263 +-
dev/breeze/doc/images/output_ci-image_build.svg | 178 +-
dev/breeze/doc/images/output_ci-image_build.txt | 2 +-
dev/breeze/doc/images/output_ci-image_load.svg | 32 +-
dev/breeze/doc/images/output_ci-image_load.txt | 2 +-
dev/breeze/doc/images/output_ci-image_save.svg | 26 +-
dev/breeze/doc/images/output_ci-image_save.txt | 2 +-
dev/breeze/doc/images/output_prod-image_build.svg | 238 +-
dev/breeze/doc/images/output_prod-image_build.txt | 2 +-
.../doc/images/output_release-management.svg | 48 +-
.../doc/images/output_release-management.txt | 2 +-
...put_release-management_build-os-deps-images.svg | 146 +
...put_release-management_build-os-deps-images.txt | 1 +
...elease-management_constraints-version-check.svg | 60 +-
...elease-management_constraints-version-check.txt | 2 +-
...t_release-management_publish-os-deps-images.svg | 136 +
...t_release-management_publish-os-deps-images.txt | 1 +
.../output_setup_check-all-params-in-groups.svg | 66 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 76 +-
.../output_setup_regenerate-command-images.txt | 2 +-
.../output_ui_check-translation-completeness.svg | 22 +-
.../output_ui_check-translation-completeness.txt | 2 +-
.../output_workflow-run_mirror-base-images.svg | 30 +-
.../output_workflow-run_mirror-base-images.txt | 2 +-
.../output_workflow-run_release-constraints.svg | 52 +-
.../output_workflow-run_release-constraints.txt | 2 +-
dev/breeze/pyproject.toml | 10 +-
.../src/airflow_breeze/commands/ci_commands.py | 8 +-
.../airflow_breeze/commands/ci_image_commands.py | 57 +-
.../commands/ci_image_commands_config.py | 3 +
.../commands/common_image_options.py | 20 +
.../airflow_breeze/commands/kubernetes_commands.py | 2 +-
.../commands/production_image_commands.py | 4 +
.../commands/production_image_commands_config.py | 1 +
.../airflow_breeze/commands/registry_commands.py | 26 +-
.../src/airflow_breeze/commands/release_command.py | 37 +-
.../commands/release_management_commands.py | 376 +-
.../commands/release_management_commands_config.py | 25 +
.../src/airflow_breeze/commands/ui_commands.py | 329 +-
.../airflow_breeze/commands/ui_commands_config.py | 1 +
.../airflow_breeze/commands/workflow_commands.py | 29 +-
.../commands/workflow_commands_config.py | 2 +
.../files/hardened_os_deps_image_digests.json | 1 +
.../files/hardened_python_image_digests.json | 10 +-
dev/breeze/src/airflow_breeze/global_constants.py | 95 +-
.../src/airflow_breeze/params/build_ci_params.py | 2 +
.../src/airflow_breeze/params/build_prod_params.py | 26 +
.../airflow_breeze/params/common_build_params.py | 37 +
.../templates/pyproject_TEMPLATE.toml.jinja2 | 2 +-
dev/breeze/src/airflow_breeze/utils/ci_audit.py | 177 +-
.../utils/constraints_version_check.py | 67 +-
.../src/airflow_breeze/utils/fork_ci_gate.py | 53 +-
.../src/airflow_breeze/utils/fork_ci_github.py | 62 +-
.../src/airflow_breeze/utils/fork_ci_messages.py | 51 +-
.../src/airflow_breeze/utils/fork_ci_reconcile.py | 545 +-
.../src/airflow_breeze/utils/gh_workflow_utils.py | 8 +-
dev/breeze/src/airflow_breeze/utils/github.py | 58 +-
.../airflow_breeze/utils/provider_dependencies.py | 6 +-
.../src/airflow_breeze/utils/publish_docs_to_s3.py | 32 +-
.../airflow_breeze/utils/release_constraints.py | 67 +-
.../src/airflow_breeze/utils/selective_checks.py | 18 +
.../src/airflow_breeze/utils/verification_plan.py | 5 +
.../airflow_breeze/utils/workflow_run_approval.py | 127 +-
dev/breeze/tests/test_ci_audit.py | 236 +-
dev/breeze/tests/test_ci_image_commands.py | 105 +-
dev/breeze/tests/test_ci_upgrade.py | 1 +
dev/breeze/tests/test_constraints_version_check.py | 140 +
dev/breeze/tests/test_dependency_upgrade_report.py | 398 ++
dev/breeze/tests/test_fork_ci_gate.py | 110 +
dev/breeze/tests/test_fork_ci_github.py | 75 +-
dev/breeze/tests/test_fork_ci_messages.py | 29 +-
dev/breeze/tests/test_fork_ci_reconcile.py | 802 ++-
dev/breeze/tests/test_gh_workflow_utils.py | 6 +-
dev/breeze/tests/test_github_utils.py | 81 +
dev/breeze/tests/test_mirror_base_images.py | 36 +-
dev/breeze/tests/test_os_deps_images.py | 732 +++
dev/breeze/tests/test_provider_dependencies.py | 11 +
dev/breeze/tests/test_publish_docs_to_s3.py | 64 +-
dev/breeze/tests/test_registry_extract_data.py | 90 +
dev/breeze/tests/test_release_command.py | 77 +-
dev/breeze/tests/test_release_constraints.py | 65 +
.../tests/test_release_management_commands.py | 2 +-
dev/breeze/tests/test_selective_checks.py | 63 +-
dev/breeze/tests/test_ui_commands.py | 269 +
dev/breeze/tests/test_workflow_commands.py | 40 +-
dev/breeze/tests/test_workflow_run_approval.py | 205 +-
dev/breeze/uv.lock | 206 +-
dev/mypy/pyproject.toml | 6 +-
dev/pyproject.toml | 6 +-
dev/registry/extract_metadata.py | 22 +-
dev/registry/pyproject.toml | 6 +-
dev/registry/tests/test_extract_metadata.py | 72 +-
dev/remove_unsupported_python_constraints.py | 300 +
devel-common/pyproject.toml | 9 +-
devel-common/src/sphinx_exts/exampleinclude.py | 47 +-
.../src/tests_common/test_utils/asserts.py | 12 +-
.../src/tests_common/test_utils/markers.py | 19 +
docker-stack-docs/README.md | 10 +-
docker-stack-docs/build-arg-ref.rst | 14 +
docker-stack-docs/build.rst | 12 +
.../extending/add-airflow-configuration/Dockerfile | 2 +-
.../extending/add-apt-packages/Dockerfile | 2 +-
.../add-build-essential-extend/Dockerfile | 2 +-
.../extending/add-providers/Dockerfile | 2 +-
.../add-pypi-packages-constraints/Dockerfile | 2 +-
.../extending/add-pypi-packages-uv/Dockerfile | 2 +-
.../extending/add-pypi-packages/Dockerfile | 2 +-
.../extending/add-python-venv/Dockerfile | 2 +-
.../extending/add-requirement-packages/Dockerfile | 2 +-
.../extending/custom-providers/Dockerfile | 2 +-
.../extending/embedding-dags/Dockerfile | 2 +-
.../extending/writable-directory/Dockerfile | 2 +-
docker-stack-docs/entrypoint.rst | 14 +-
docker-stack-docs/pyproject.toml | 6 +-
docker-tests/pyproject.toml | 6 +-
docs/spelling_wordlist.txt | 29 +
generated/PYPI_README.md | 10 +-
generated/known_sdk_imports_in_core.txt | 4 +-
generated/provider_metadata.json | 12 +
go-sdk/DEVELOPMENT.md | 29 +-
go-sdk/README.md | 2 +-
go-sdk/airflow/trigger_dag_run_test.go | 22 +-
go-sdk/capabilities.yaml | 4 +-
go-sdk/pkg/execution/client.go | 96 +-
go-sdk/pkg/execution/client_test.go | 76 +
.../pkg/execution/genmodels/discriminators.gen.go | 12 +-
go-sdk/pkg/execution/genmodels/models.gen.go | 79 +-
go-sdk/pkg/execution/messages.go | 2 +-
go-sdk/schema/supervisor-schema.json | 142 +-
go-sdk/sdk/sdk.go | 4 +
java-sdk/example/README.md | 16 +-
.../apache/airflow/example/AnnotationExample.java | 10 +-
.../airflow/example/ExampleBundleBuilder.java | 11 +-
.../airflow/example/InterfaceExampleBuilder.java | 7 -
.../apache/airflow/example/XComCastingExample.java | 16 +-
.../example/src/resources/dags/java_examples.py | 18 +-
java-sdk/gradle.properties | 2 +-
java-sdk/sdk/build.gradle.kts | 2 +-
.../main/kotlin/org/apache/airflow/sdk/Client.kt | 2 +-
.../main/kotlin/org/apache/airflow/sdk/Context.kt | 66 +-
.../org/apache/airflow/sdk/execution/Client.kt | 8 +-
.../org/apache/airflow/sdk/internal/ConfBinding.kt | 184 +
.../kotlin/org/apache/airflow/sdk/ContextTest.kt | 311 +
.../org/apache/airflow/sdk/execution/CommTest.kt | 91 +-
.../lang_sdk/java_example/gradle.properties | 2 +-
kubernetes-tests/lang_sdk/ts_example/package.json | 4 +-
.../lang_sdk/ts_example/pnpm-lock.yaml | 34 +-
kubernetes-tests/lang_sdk/ts_example/src/main.ts | 2 +-
kubernetes-tests/pyproject.toml | 6 +-
.../test_kubernetes_pod_operator.py | 2 +-
performance/pyproject.toml | 2 +-
providers-summary-docs/pyproject.toml | 6 +-
providers/.last_release_date.txt | 2 +-
providers/.pre-commit-config.yaml | 2 +-
providers/airbyte/pyproject.toml | 2 +-
providers/akeyless/pyproject.toml | 2 +-
providers/alibaba/README.rst | 6 +-
providers/alibaba/docs/changelog.rst | 15 +
providers/alibaba/docs/index.rst | 6 +-
providers/alibaba/provider.yaml | 3 +-
providers/alibaba/pyproject.toml | 8 +-
.../src/airflow/providers/alibaba/__init__.py | 2 +-
.../providers/alibaba/cloud/sensors/oss_key.py | 9 -
providers/amazon/README.rst | 14 +-
providers/amazon/docs/changelog.rst | 55 +
providers/amazon/docs/executors/ecs-executor.rst | 4 +-
.../amazon/docs/executors/lambda-executor.rst | 2 +-
providers/amazon/docs/index.rst | 14 +-
providers/amazon/docs/operators/duckdb.rst | 11 +-
providers/amazon/provider.yaml | 3 +-
providers/amazon/pyproject.toml | 18 +-
.../src/airflow/providers/amazon/__init__.py | 2 +-
.../src/airflow/providers/amazon/aws/exceptions.py | 4 +
.../airflow/providers/amazon/aws/hooks/base_aws.py | 6 +-
.../airflow/providers/amazon/aws/hooks/duckdb.py | 48 +-
.../providers/amazon/aws/hooks/sagemaker.py | 19 +
.../airflow/providers/amazon/aws/operators/glue.py | 51 +-
.../amazon/aws/operators/mwaa_serverless.py | 21 +
.../providers/amazon/aws/operators/sagemaker.py | 19 +-
.../airflow/providers/amazon/aws/triggers/glue.py | 30 +-
.../providers/amazon/aws/triggers/sagemaker.py | 26 +-
.../amazon/tests/system/amazon/aws/example_dms.py | 31 +
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 43 +
.../tests/unit/amazon/aws/hooks/test_duckdb.py | 60 +
.../tests/unit/amazon/aws/hooks/test_sagemaker.py | 59 +
.../tests/unit/amazon/aws/operators/test_glue.py | 141 +-
.../amazon/aws/operators/test_mwaa_serverless.py | 52 +
.../aws/operators/test_sagemaker_training.py | 87 +
.../tests/unit/amazon/aws/triggers/test_glue.py | 41 +
.../unit/amazon/aws/triggers/test_sagemaker.py | 55 +
providers/anthropic/pyproject.toml | 2 +-
providers/apache/arrow/README.rst | 6 +-
providers/apache/arrow/docs/changelog.rst | 19 +
providers/apache/arrow/docs/connections/adbc.rst | 26 +-
providers/apache/arrow/docs/index.rst | 6 +-
providers/apache/arrow/provider.yaml | 15 +-
providers/apache/arrow/pyproject.toml | 8 +-
.../src/airflow/providers/apache/arrow/__init__.py | 2 +-
.../providers/apache/arrow/get_provider_info.py | 10 +-
.../airflow/providers/apache/arrow/hooks/adbc.py | 152 +-
.../tests/unit/apache/arrow/hooks/test_adbc.py | 255 +-
providers/apache/beam/pyproject.toml | 2 +-
providers/apache/cassandra/pyproject.toml | 2 +-
providers/apache/drill/pyproject.toml | 2 +-
providers/apache/druid/pyproject.toml | 2 +-
providers/apache/flink/pyproject.toml | 2 +-
providers/apache/hdfs/pyproject.toml | 2 +-
providers/apache/hive/README.rst | 6 +-
providers/apache/hive/docs/changelog.rst | 16 +
providers/apache/hive/docs/index.rst | 6 +-
providers/apache/hive/provider.yaml | 3 +-
providers/apache/hive/pyproject.toml | 8 +-
.../src/airflow/providers/apache/hive/__init__.py | 2 +-
.../airflow/providers/apache/hive/hooks/hive.py | 18 +-
providers/apache/iceberg/pyproject.toml | 2 +-
providers/apache/impala/pyproject.toml | 2 +-
providers/apache/kafka/README.rst | 6 +-
providers/apache/kafka/docs/changelog.rst | 20 +
providers/apache/kafka/docs/index.rst | 6 +-
providers/apache/kafka/provider.yaml | 3 +-
providers/apache/kafka/pyproject.toml | 8 +-
.../src/airflow/providers/apache/kafka/__init__.py | 2 +-
.../apache/kafka/plugins/event_producer.py | 13 +-
.../apache/kafka/plugins/test_event_producer.py | 26 +-
providers/apache/kylin/pyproject.toml | 2 +-
providers/apache/livy/pyproject.toml | 2 +-
providers/apache/pig/pyproject.toml | 2 +-
providers/apache/pinot/pyproject.toml | 2 +-
providers/apache/spark/docs/decorators/pyspark.rst | 4 +
providers/apache/spark/pyproject.toml | 2 +-
.../providers/apache/spark/decorators/pyspark.py | 2 +
.../unit/apache/spark/decorators/test_pyspark.py | 22 +
providers/apache/tinkerpop/pyproject.toml | 2 +-
providers/apprise/pyproject.toml | 2 +-
providers/arangodb/pyproject.toml | 2 +-
providers/asana/pyproject.toml | 2 +-
providers/atlassian/jira/pyproject.toml | 2 +-
providers/celery/README.rst | 6 +-
providers/celery/docs/celery_executor.rst | 29 +-
providers/celery/docs/changelog.rst | 20 +
providers/celery/docs/index.rst | 6 +-
providers/celery/provider.yaml | 16 +-
providers/celery/pyproject.toml | 8 +-
.../src/airflow/providers/celery/__init__.py | 2 +-
.../providers/celery/executors/celery_executor.py | 19 -
.../celery/executors/celery_executor_utils.py | 12 +-
.../celery/executors/celery_kubernetes_executor.py | 19 +-
.../providers/celery/executors/default_celery.py | 4 +-
.../airflow/providers/celery/get_provider_info.py | 2 +-
.../integration/celery/test_celery_executor.py | 7 +-
.../unit/celery/executors/test_celery_executor.py | 38 -
providers/clickhousedb/pyproject.toml | 2 +-
providers/cloudant/pyproject.toml | 2 +-
providers/cncf/kubernetes/README.rst | 6 +-
providers/cncf/kubernetes/docs/changelog.rst | 42 +
providers/cncf/kubernetes/docs/index.rst | 6 +-
providers/cncf/kubernetes/docs/operators.rst | 7 +-
providers/cncf/kubernetes/provider.yaml | 3 +-
providers/cncf/kubernetes/pyproject.toml | 8 +-
.../airflow/providers/cncf/kubernetes/__init__.py | 2 +-
.../airflow/providers/cncf/kubernetes/callbacks.py | 7 +-
.../cncf/kubernetes/decorators/kubernetes_cmd.py | 7 +-
.../kubernetes/executors/kubernetes_executor.py | 25 +-
.../executors/local_kubernetes_executor.py | 14 -
.../providers/cncf/kubernetes/hooks/kubernetes.py | 23 +-
.../providers/cncf/kubernetes/operators/pod.py | 13 +
.../cncf/kubernetes/utils/xcom_sidecar.py | 2 +-
.../system/cncf/kubernetes/example_kubernetes.py | 2 +-
.../cncf/kubernetes/example_kubernetes_async.py | 2 +-
.../kubernetes/decorators/test_kubernetes_cmd.py | 23 +
.../decorators/test_kubernetes_commons.py | 5 +-
.../executors/test_kubernetes_executor.py | 62 +-
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 57 +
.../unit/cncf/kubernetes/operators/test_pod.py | 90 +-
.../kubernetes/operators/test_spark_kubernetes.py | 44 -
providers/cohere/pyproject.toml | 2 +-
providers/common/ai/docs/approval_gates.rst | 12 +-
providers/common/ai/docs/changelog.rst | 11 +
.../common/ai/docs/connections/pydantic_ai.rst | 4 +
providers/common/ai/docs/durable_execution.rst | 2 +-
providers/common/ai/docs/frameworks/anthropic.rst | 4 +-
.../common/ai/docs/frameworks/claude_agent_sdk.rst | 4 +-
providers/common/ai/docs/frameworks/index.rst | 28 +-
.../common/ai/docs/frameworks/openai_agents.rst | 630 +-
providers/common/ai/docs/frameworks/strands.rst | 7 +-
providers/common/ai/docs/hooks/llamaindex.rst | 6 +
providers/common/ai/docs/observability.rst | 10 +-
providers/common/ai/docs/operators/agent.rst | 7 +-
providers/common/ai/docs/operators/llm.rst | 23 +-
providers/common/ai/docs/operators/llm_batch.rst | 5 +-
providers/common/ai/docs/operators/llm_branch.rst | 4 +-
providers/common/ai/docs/stability.rst | 6 +-
providers/common/ai/docs/toolsets/skills.rst | 31 +
providers/common/ai/docs/troubleshooting.rst | 2 +-
providers/common/ai/provider.yaml | 27 +-
providers/common/ai/pyproject.toml | 16 +-
.../src/airflow/providers/common/ai/batch/state.py | 43 +-
.../providers/common/ai/decorators/agent.py | 16 +-
.../airflow/providers/common/ai/decorators/llm.py | 11 +-
.../providers/common/ai/decorators/llm_branch.py | 11 +-
.../common/ai/decorators/llm_file_analysis.py | 7 +-
.../common/ai/decorators/llm_schema_compare.py | 7 +-
.../providers/common/ai/decorators/llm_sql.py | 7 +-
.../providers/common/ai/durable/capability.py | 9 +-
.../airflow/providers/common/ai/durable/journal.py | 70 +-
.../providers/common/ai/durable/openai_agents.py | 64 +-
.../airflow/providers/common/ai/durable/storage.py | 3 +-
.../airflow/providers/common/ai/durable/strands.py | 20 +-
.../common/ai/example_dags/example_llm.py | 4 +-
.../example_dags/example_llm_analysis_pipeline.py | 7 +-
.../ai/example_dags/example_llm_review_loop.py | 81 +
.../example_openai_agents_data_access.py | 101 +
.../src/airflow/providers/common/ai/exceptions.py | 10 +
.../providers/common/ai/get_provider_info.py | 21 +-
.../providers/common/ai/mixins/hitl_review.py | 15 +-
.../airflow/providers/common/ai/operators/agent.py | 11 +-
.../airflow/providers/common/ai/operators/llm.py | 46 +-
.../providers/common/ai/operators/llm_batch.py | 8 +-
.../providers/common/ai/operators/llm_branch.py | 29 +-
.../common/ai/operators/llm_file_analysis.py | 3 +-
.../common/ai/operators/llm_schema_compare.py | 3 +-
.../providers/common/ai/operators/llm_sql.py | 7 +-
.../ai/plugins/www/src/components/ModelPanel.tsx | 7 +-
.../plugins/www/src/components/SkillsSection.tsx | 103 +
.../ai/plugins/www/src/hooks/useModelInfo.ts | 27 +-
.../common/ai/plugins/www/src/model-api.ts | 9 +-
.../common/ai/plugins/www/src/skill-source.ts | 83 +
.../common/ai/plugins/www/src/types/model.ts | 17 +
.../common/ai/plugins/www/tests/model.test.mjs | 80 +-
.../ai/plugins/www/tests/skill-source.test.ts | 84 +
.../providers/common/ai/sandbox/opensandbox.py | 2 +-
.../ai/src/airflow/providers/common/ai/skills.py | 35 +-
.../airflow/providers/common/ai/tools/__init__.py | 28 +-
.../src/airflow/providers/common/ai/tools/adk.py | 8 +-
.../airflow/providers/common/ai/tools/anthropic.py | 14 +-
.../providers/common/ai/tools/claude_agent_sdk.py | 9 +-
.../providers/common/ai/tools/openai_agents.py | 9 +-
.../airflow/providers/common/ai/tools/strands.py | 6 +-
.../airflow/providers/common/ai/toolsets/mcp.py | 14 +-
.../airflow/providers/common/ai/toolsets/skills.py | 124 +-
.../airflow/providers/common/ai/utils/logging.py | 4 +
.../airflow/providers/common/ai/utils/prompt.py | 20 +-
.../providers/common/ai/utils/validation.py | 24 -
.../ai/tests/unit/common/ai/batch/test_state.py | 52 +
.../tests/unit/common/ai/decorators/test_agent.py | 36 +-
.../ai/tests/unit/common/ai/decorators/test_llm.py | 72 +
.../unit/common/ai/decorators/test_llm_branch.py | 17 +
.../common/ai/decorators/test_llm_file_analysis.py | 21 +
.../ai/decorators/test_llm_schema_compare.py | 22 +
.../unit/common/ai/decorators/test_llm_sql.py | 17 +
.../unit/common/ai/durable/test_capability.py | 7 +-
.../tests/unit/common/ai/durable/test_journal.py | 76 +
.../unit/common/ai/durable/test_openai_agents.py | 486 +-
.../tests/unit/common/ai/durable/test_storage.py | 9 +-
.../tests/unit/common/ai/durable/test_strands.py | 18 +
.../tests/unit/common/ai/hooks/test_llamaindex.py | 11 +
.../tests/unit/common/ai/hooks/test_pydantic_ai.py | 14 +-
.../unit/common/ai/mixins/test_hitl_review.py | 39 +-
.../tests/unit/common/ai/operators/test_agent.py | 35 +-
.../ai/operators/test_agent_tool_approval.py | 5 +-
.../ai/operators/test_llamaindex_embedding.py | 8 +-
.../ai/operators/test_llamaindex_retrieval.py | 11 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 87 +
.../unit/common/ai/operators/test_llm_batch.py | 28 +-
.../unit/common/ai/operators/test_llm_branch.py | 9 +-
.../unit/common/ai/sandbox/test_opensandbox.py | 15 +
.../tests/unit/common/ai/test_provider_metadata.py | 125 +-
.../common/ai/tests/unit/common/ai/test_skills.py | 26 +-
.../common/ai/tests/unit/common/ai/tool_parts.py | 25 +-
.../ai/tests/unit/common/ai/tools/test_adk.py | 6 +
.../tests/unit/common/ai/tools/test_anthropic.py | 13 +-
.../unit/common/ai/tools/test_claude_agent_sdk.py | 10 +
.../unit/common/ai/tools/test_openai_agents.py | 6 +
.../ai/tests/unit/common/ai/tools/test_strands.py | 6 +
.../ai/tests/unit/common/ai/tools/test_tools.py | 43 +-
.../ai/tests/unit/common/ai/toolsets/test_hook.py | 12 +-
.../unit/common/ai/toolsets/test_managed_agent.py | 12 +-
.../ai/tests/unit/common/ai/toolsets/test_mcp.py | 8 +-
.../unit/common/ai/toolsets/test_retry_budget.py | 5 +-
.../tests/unit/common/ai/toolsets/test_skills.py | 359 +-
.../tests/unit/common/ai/utils/test_validation.py | 32 +-
providers/common/compat/README.rst | 6 +-
providers/common/compat/docs/changelog.rst | 17 +
providers/common/compat/docs/index.rst | 6 +-
providers/common/compat/provider.yaml | 3 +-
providers/common/compat/pyproject.toml | 8 +-
.../airflow/providers/common/compat/__init__.py | 2 +-
providers/common/dataquality/pyproject.toml | 2 +-
providers/common/io/README.rst | 6 +-
providers/common/io/docs/changelog.rst | 12 +
providers/common/io/docs/index.rst | 6 +-
providers/common/io/provider.yaml | 3 +-
providers/common/io/pyproject.toml | 8 +-
.../io/src/airflow/providers/common/io/__init__.py | 2 +-
.../providers/common/io/state_store/backend.py | 13 +-
.../unit/common/io/state_store/test_backend.py | 104 +-
providers/common/messaging/pyproject.toml | 2 +-
providers/common/sql/README.rst | 6 +-
providers/common/sql/docs/changelog.rst | 32 +
providers/common/sql/docs/index.rst | 6 +-
providers/common/sql/docs/operators.rst | 47 +
providers/common/sql/provider.yaml | 3 +-
providers/common/sql/pyproject.toml | 8 +-
.../src/airflow/providers/common/sql/__init__.py | 2 +-
.../providers/common/sql/decorators/analytics.py | 4 +-
.../airflow/providers/common/sql/decorators/sql.py | 4 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 37 -
.../src/airflow/providers/common/sql/hooks/sql.pyi | 6 -
.../airflow/providers/common/sql/sensors/sql.py | 86 +-
.../airflow/providers/common/sql/sensors/sql.pyi | 10 +-
.../airflow/providers/common/sql/triggers/sql.py | 85 +-
.../airflow/providers/common/sql/triggers/sql.pyi | 26 +-
.../airflow/providers/common/sql/version_compat.py | 2 +
.../tests/system/common/sql/example_sql_sensor.py | 50 +
.../unit/common/sql/decorators/test_analytics.py | 20 +
.../tests/unit/common/sql/decorators/test_sql.py | 19 +
.../sql/tests/unit/common/sql/sensors/test_sql.py | 200 +-
.../sql/tests/unit/common/sql/triggers/test_sql.py | 94 +-
providers/databricks/README.rst | 8 +-
providers/databricks/docs/changelog.rst | 15 +
providers/databricks/docs/index.rst | 8 +-
providers/databricks/provider.yaml | 3 +-
providers/databricks/pyproject.toml | 10 +-
.../src/airflow/providers/databricks/__init__.py | 2 +-
.../providers/databricks/utils/databricks.py | 20 +-
.../tests/unit/databricks/utils/test_databricks.py | 76 +
providers/datadog/pyproject.toml | 2 +-
providers/dbt/cloud/README.rst | 6 +-
providers/dbt/cloud/docs/changelog.rst | 13 +
providers/dbt/cloud/docs/index.rst | 6 +-
providers/dbt/cloud/provider.yaml | 3 +-
providers/dbt/cloud/pyproject.toml | 8 +-
.../src/airflow/providers/dbt/cloud/__init__.py | 2 +-
.../src/airflow/providers/dbt/cloud/hooks/dbt.py | 8 +-
.../cloud/tests/unit/dbt/cloud/hooks/test_dbt.py | 13 +
providers/dingding/pyproject.toml | 2 +-
providers/discord/pyproject.toml | 2 +-
providers/docker/pyproject.toml | 2 +-
.../tests/unit/docker/decorators/test_docker.py | 63 +-
providers/duckdb/pyproject.toml | 2 +-
providers/edge3/README.rst | 6 +-
providers/edge3/docs/changelog.rst | 19 +
providers/edge3/docs/index.rst | 6 +-
providers/edge3/provider.yaml | 3 +-
providers/edge3/pyproject.toml | 12 +-
.../edge3/src/airflow/providers/edge3/__init__.py | 2 +-
providers/elasticsearch/pyproject.toml | 2 +-
providers/exasol/README.rst | 6 +-
providers/exasol/docs/changelog.rst | 15 +
providers/exasol/docs/index.rst | 6 +-
providers/exasol/provider.yaml | 3 +-
providers/exasol/pyproject.toml | 8 +-
.../src/airflow/providers/exasol/__init__.py | 2 +-
.../src/airflow/providers/exasol/hooks/exasol.py | 22 -
providers/fab/README.rst | 6 +-
providers/fab/docs/auth-manager/access-control.rst | 20 +-
providers/fab/docs/changelog.rst | 47 +
providers/fab/docs/index.rst | 6 +-
providers/fab/provider.yaml | 3 +-
providers/fab/pyproject.toml | 12 +-
.../fab/src/airflow/providers/fab/__init__.py | 2 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 50 +-
.../fab/auth_manager/security_manager/override.py | 2 +
.../providers/fab/www/security/permissions.py | 1 +
.../unit/fab/auth_manager/test_fab_auth_manager.py | 60 +-
providers/facebook/pyproject.toml | 2 +-
providers/ftp/README.rst | 6 +-
providers/ftp/docs/changelog.rst | 12 +
providers/ftp/docs/index.rst | 6 +-
providers/ftp/provider.yaml | 3 +-
providers/ftp/pyproject.toml | 8 +-
.../ftp/src/airflow/providers/ftp/__init__.py | 2 +-
.../ftp/src/airflow/providers/ftp/hooks/ftp.py | 17 +-
providers/ftp/tests/unit/ftp/hooks/test_ftp.py | 27 +
providers/git/pyproject.toml | 2 +-
.../git/src/airflow/providers/git/bundles/git.py | 51 +-
providers/git/tests/unit/git/bundles/test_git.py | 147 +-
providers/github/pyproject.toml | 2 +-
providers/google/README.rst | 20 +-
providers/google/docs/changelog.rst | 68 +
providers/google/docs/connections/gcp.rst | 30 +
providers/google/docs/connections/gcp_sql.rst | 55 +-
providers/google/docs/index.rst | 20 +-
providers/google/docs/operators/cloud/bigquery.rst | 4 -
providers/google/provider.yaml | 3 +-
providers/google/pyproject.toml | 34 +-
.../src/airflow/providers/google/__init__.py | 2 +-
.../providers/google/cloud/hooks/bigquery.py | 46 +-
.../providers/google/cloud/hooks/cloud_sql.py | 116 +-
.../providers/google/cloud/operators/bigquery.py | 20 -
.../providers/google/cloud/operators/dataproc.py | 24 +-
.../providers/google/cloud/sensors/bigquery.py | 73 +-
.../providers/google/cloud/triggers/bigquery.py | 45 +-
.../providers/google/cloud/triggers/dataproc.py | 39 +-
.../google/cloud/utils/credentials_provider.py | 7 +-
.../google/cloud/utils/external_token_supplier.py | 10 +-
.../providers/google/common/hooks/base_google.py | 6 +-
.../example_bigquery_streaming_buffer_sensor.py | 19 +-
.../tests/unit/google/cloud/hooks/test_bigquery.py | 89 +-
.../unit/google/cloud/hooks/test_cloud_sql.py | 234 +
.../tests/unit/google/cloud/links/test_dataproc.py | 199 +
.../google/cloud/links/test_kubernetes_engine.py | 152 +
.../unit/google/cloud/links/test_translate.py | 212 +
.../unit/google/cloud/operators/test_dataproc.py | 45 +
.../unit/google/cloud/sensors/test_bigquery.py | 140 +-
.../unit/google/cloud/transfers/test_gcs_to_gcs.py | 110 +-
.../google/cloud/transfers/test_presto_to_gcs.py | 314 +
.../unit/google/cloud/triggers/test_bigquery.py | 106 +-
.../unit/google/cloud/triggers/test_dataproc.py | 95 +
.../cloud/utils/test_credentials_provider.py | 27 +
.../cloud/utils/test_external_token_supplier.py | 50 +
.../unit/google/common/hooks/test_base_google.py | 23 +
providers/grpc/pyproject.toml | 2 +-
providers/hashicorp/docs/index.rst | 2 +-
providers/hashicorp/pyproject.toml | 4 +-
providers/http/README.rst | 6 +-
providers/http/docs/changelog.rst | 13 +
providers/http/docs/index.rst | 6 +-
providers/http/docs/triggers.rst | 65 +-
providers/http/provider.yaml | 3 +-
providers/http/pyproject.toml | 8 +-
.../http/src/airflow/providers/http/__init__.py | 2 +-
.../src/airflow/providers/http/triggers/http.py | 14 +-
.../http/tests/unit/http/triggers/test_http.py | 79 +
providers/ibm/db2/pyproject.toml | 2 +-
providers/ibm/mq/pyproject.toml | 2 +-
providers/imap/pyproject.toml | 2 +-
providers/influxdb/pyproject.toml | 2 +-
providers/informatica/pyproject.toml | 2 +-
providers/jdbc/pyproject.toml | 2 +-
providers/jenkins/pyproject.toml | 2 +-
providers/keycloak/README.rst | 6 +-
.../docs/auth-manager/manage/permissions.rst | 4 +-
providers/keycloak/docs/changelog.rst | 29 +
providers/keycloak/docs/index.rst | 6 +-
providers/keycloak/provider.yaml | 3 +-
providers/keycloak/pyproject.toml | 8 +-
.../src/airflow/providers/keycloak/__init__.py | 2 +-
.../keycloak/auth_manager/cli/commands.py | 9 +-
.../keycloak/auth_manager/keycloak_auth_manager.py | 7 +-
.../keycloak/auth_manager/cli/test_commands.py | 11 +-
.../auth_manager/test_keycloak_auth_manager.py | 2 +
providers/microsoft/azure/README.rst | 10 +-
providers/microsoft/azure/docs/changelog.rst | 24 +
providers/microsoft/azure/docs/index.rst | 10 +-
providers/microsoft/azure/provider.yaml | 3 +-
providers/microsoft/azure/pyproject.toml | 12 +-
.../airflow/providers/microsoft/azure/__init__.py | 2 +-
.../azure/operators/container_instances.py | 26 +-
.../providers/microsoft/azure/operators/msgraph.py | 4 +
.../microsoft/azure/transfers/s3_to_wasb.py | 40 +-
.../azure/operators/test_container_instances.py | 143 +
.../microsoft/azure/transfers/test_s3_to_wasb.py | 63 +-
providers/microsoft/mssql/README.rst | 6 +-
providers/microsoft/mssql/docs/changelog.rst | 12 +
providers/microsoft/mssql/docs/index.rst | 6 +-
providers/microsoft/mssql/provider.yaml | 3 +-
providers/microsoft/mssql/pyproject.toml | 8 +-
.../airflow/providers/microsoft/mssql/__init__.py | 2 +-
.../providers/microsoft/mssql/hooks/mssql.py | 3 +-
.../tests/unit/microsoft/mssql/hooks/test_mssql.py | 22 +
providers/microsoft/psrp/pyproject.toml | 2 +-
providers/microsoft/winrm/pyproject.toml | 2 +-
providers/modal/docs/index.rst | 13 +-
providers/modal/docs/task_decorator.rst | 179 +
providers/modal/docs/usage.rst | 13 +-
providers/modal/provider.yaml | 12 +-
providers/modal/pyproject.toml | 4 +-
.../providers/modal/decorators}/__init__.py | 0
.../airflow/providers/modal/decorators/modal.py | 308 +
.../src/airflow/providers/modal/exceptions.py | 9 +
.../airflow/providers/modal/get_provider_info.py | 8 +-
.../src/airflow/providers/modal/hooks/modal.py | 80 +-
.../airflow/providers/modal/triggers}/__init__.py | 0
.../src/airflow/providers/modal/triggers/modal.py | 100 +
.../src/airflow/providers/modal/utils}/__init__.py | 0
.../providers/modal/utils/python_sandbox.py | 156 +
.../modal/tests/system}/__init__.py | 0
.../modal/tests/system/modal}/__init__.py | 0
.../modal/tests/system/modal/example_modal_task.py | 80 +
.../modal/tests/unit/modal/decorators}/__init__.py | 0
.../tests/unit/modal/decorators/test_modal.py | 428 ++
.../modal/tests/unit/modal/hooks/test_modal.py | 152 +
providers/modal/tests/unit/modal/local_sandbox.py | 132 +
.../modal/tests/unit/modal/test_exceptions.py | 4 +-
.../modal/tests/unit/modal/triggers}/__init__.py | 0
.../modal/tests/unit/modal/triggers/test_modal.py | 171 +
.../modal/tests/unit/modal/utils}/__init__.py | 0
.../tests/unit/modal/utils/test_python_sandbox.py | 163 +
providers/mongo/pyproject.toml | 2 +-
providers/mysql/README.rst | 6 +-
providers/mysql/docs/changelog.rst | 12 +
providers/mysql/docs/index.rst | 6 +-
providers/mysql/provider.yaml | 3 +-
providers/mysql/pyproject.toml | 8 +-
.../mysql/src/airflow/providers/mysql/__init__.py | 2 +-
providers/neo4j/pyproject.toml | 2 +-
providers/odbc/pyproject.toml | 2 +-
providers/openai/docs/.latest-doc-only-change.txt | 2 +-
providers/openai/pyproject.toml | 2 +-
.../airflow/providers/openai/operators/openai.py | 4 +-
.../tests/unit/openai/operators/test_openai.py | 29 +-
providers/openfaas/pyproject.toml | 2 +-
providers/openlineage/pyproject.toml | 3 +-
.../tests/system/openlineage/constants.py | 6 +
.../openlineage/example_openlineage_clear_dag.py | 169 +
.../example_openlineage_edge_labels_dag.py | 16 +-
.../example_openlineage_manual_lineage_dag.py | 17 +-
.../example_openlineage_manual_state_dag.py | 274 +
.../example_openlineage_mapped_simple_dag.py | 7 +-
.../example_openlineage_policy_conf_locked_dag.py | 59 -
...le_openlineage_policy_dag_events_trigger_dag.py | 6 +-
...xample_openlineage_policy_full_task_info_dag.py | 57 -
...ample_openlineage_schedule_asset_or_time_dag.py | 2 +-
.../example_openlineage_schedule_cron_dag.py | 2 +-
...openlineage_schedule_list_complex_assets_dag.py | 2 +-
...penlineage_schedule_list_multiple_assets_dag.py | 2 +-
...e_openlineage_schedule_list_single_asset_dag.py | 2 +-
...ple_openlineage_schedule_multiple_assets_dag.py | 2 +-
...xample_openlineage_schedule_single_asset_dag.py | 2 +-
.../example_openlineage_schedule_timetable_dag.py | 2 +-
.../example_openlineage_short_circuit_dag.py | 4 +-
.../example_openlineage_task_groups_dag.py | 4 +-
.../example_openlineage_task_loop_dag.py | 4 +-
.../example_openlineage_task_loop_groups_dag.py | 4 +-
.../example_openlineage_task_loop_state_dag.py | 240 +
.../example_openlineage_task_outcomes_dag.py | 287 +
.../example_openlineage_task_states_dag.py | 8 +-
.../openlineage/example_openlineage_trigger_dag.py | 74 +-
.../example_openlineage_trigger_dag_deferrable.py | 65 +-
.../example_openlineage_trigger_failed_dag.py | 11 +-
.../openlineage_all_facets_dag.json | 1 +
.../openlineage_base_complex_dag__af3.json | 114 +-
.../openlineage_base_simple_dag__af3.json | 12 +-
.../expected_events/openlineage_clear_dag.json | 1268 ++++
.../openlineage_custom_operator_failure_dag.json | 16 +-
...openlineage_custom_operator_ol_methods_dag.json | 1 +
.../openlineage_defer_simple_dag__af2.json | 13 +-
.../openlineage_defer_simple_dag__af3.json | 1 +
...openlineage_defer_simple_dag__af3_2_2_plus.json | 1 +
.../expected_events/openlineage_docs_file_dag.json | 26 +
.../expected_events/openlineage_hitl_dag.json | 83 +
.../openlineage_manual_lineage_dag.json | 171 +-
.../openlineage_manual_state_dag.json | 1195 ++++
.../openlineage_mapped_simple_dag.json | 13 +-
.../openlineage_policy_conf_locked_dag.json | 26 -
.../openlineage_policy_full_task_info_dag.json | 38 -
.../openlineage_sensor_reschedule_dag.json | 8 +-
.../openlineage_sensor_reschedule_dag__af3_0.json | 8 +-
.../openlineage_setup_teardown_dag__af3.json | 104 +
.../openlineage_short_circuit_dag.json | 50 +-
.../openlineage_task_groups_dag.json | 29 +
.../openlineage_task_loop_state_dag.json | 3062 +++++++++
.../openlineage_task_outcomes_dag.json | 1164 ++++
.../openlineage_task_states_dag.json | 30 +
.../openlineage_task_states_dag__af3_0.json | 30 +
.../openlineage_taskflow_simple_dag.json | 12 +-
.../expected_events/openlineage_trigger_dag.json | 309 +
.../openlineage_trigger_dag__af3_3_plus.json | 309 +
.../openlineage_trigger_dag_deferrable.json | 61 +-
...lineage_trigger_dag_deferrable__af3_3_plus.json | 61 +-
.../openlineage_trigger_failed_dag.json | 87 +-
...openlineage_trigger_failed_dag__af3_3_plus.json | 87 +-
.../openlineage_versioned_dag__af3.json | 14 +-
.../tests/system/openlineage/manual_state.py | 452 ++
.../tests/system/openlineage/operator.py | 79 +-
.../tests/system/openlineage/triggers.py | 21 +-
.../unit/openlineage/extractors/test_manager.py | 49 +-
providers/opensearch/pyproject.toml | 2 +-
providers/opsgenie/pyproject.toml | 2 +-
providers/oracle/pyproject.toml | 2 +-
providers/pagerduty/pyproject.toml | 2 +-
providers/papermill/pyproject.toml | 2 +-
providers/pgvector/pyproject.toml | 2 +-
providers/pinecone/pyproject.toml | 2 +-
providers/postgres/README.rst | 6 +-
providers/postgres/docs/changelog.rst | 17 +
providers/postgres/docs/index.rst | 6 +-
providers/postgres/provider.yaml | 3 +-
providers/postgres/pyproject.toml | 8 +-
.../src/airflow/providers/postgres/__init__.py | 2 +-
.../airflow/providers/postgres/hooks/postgres.py | 3 +-
.../tests/unit/postgres/hooks/test_postgres.py | 16 +
providers/presto/README.rst | 6 +-
providers/presto/docs/changelog.rst | 15 +
providers/presto/docs/index.rst | 6 +-
providers/presto/provider.yaml | 3 +-
providers/presto/pyproject.toml | 8 +-
.../src/airflow/providers/presto/__init__.py | 2 +-
.../src/airflow/providers/presto/hooks/presto.py | 10 -
providers/qdrant/pyproject.toml | 2 +-
providers/redis/pyproject.toml | 2 +-
providers/salesforce/pyproject.toml | 2 +-
providers/samba/pyproject.toml | 2 +-
providers/segment/pyproject.toml | 2 +-
providers/sendgrid/README.rst | 6 +-
providers/sendgrid/docs/changelog.rst | 12 +
providers/sendgrid/docs/index.rst | 6 +-
providers/sendgrid/provider.yaml | 3 +-
providers/sendgrid/pyproject.toml | 8 +-
.../src/airflow/providers/sendgrid/__init__.py | 2 +-
providers/sftp/pyproject.toml | 2 +-
providers/singularity/pyproject.toml | 2 +-
providers/slack/pyproject.toml | 2 +-
providers/smtp/README.rst | 6 +-
providers/smtp/docs/changelog.rst | 12 +
providers/smtp/docs/connections/smtp.rst | 9 +-
providers/smtp/docs/index.rst | 6 +-
providers/smtp/provider.yaml | 3 +-
providers/smtp/pyproject.toml | 8 +-
.../smtp/src/airflow/providers/smtp/__init__.py | 2 +-
.../src/airflow/providers/smtp/utils/emailer.py | 24 +-
.../smtp/tests/unit/smtp/utils/test_emailer.py | 108 +-
providers/snowflake/README.rst | 14 +-
providers/snowflake/docs/changelog.rst | 23 +
.../docs/connections/pydantic_ai_snowflake.rst | 7 +-
providers/snowflake/docs/connections/snowflake.rst | 27 +
providers/snowflake/docs/index.rst | 14 +-
.../snowflake/docs/operators/cortex_agent.rst | 7 +-
providers/snowflake/provider.yaml | 3 +-
providers/snowflake/pyproject.toml | 10 +-
.../src/airflow/providers/snowflake/__init__.py | 2 +-
.../providers/snowflake/hooks/cortex_agent.py | 193 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 1 +
.../airflow/providers/snowflake/hooks/sql_api.py | 5 +-
.../providers/snowflake/utils/_rest_auth.py | 213 +-
.../unit/snowflake/hooks/test_cortex_agent.py | 498 +-
.../tests/unit/snowflake/hooks/test_snowflake.py | 45 +-
.../tests/unit/snowflake/hooks/test_sql_api.py | 24 +-
...test_snowflake.py => test_snowflake_trigger.py} | 43 +
.../tests/unit/snowflake/utils/test__rest_auth.py | 422 +-
providers/sqlite/pyproject.toml | 2 +-
providers/ssh/README.rst | 6 +-
providers/ssh/docs/changelog.rst | 12 +
providers/ssh/docs/index.rst | 6 +-
providers/ssh/docs/operators/ssh_remote_job.rst | 23 +-
providers/ssh/provider.yaml | 3 +-
providers/ssh/pyproject.toml | 8 +-
.../ssh/src/airflow/providers/ssh/__init__.py | 2 +-
.../providers/ssh/operators/ssh_remote_job.py | 6 +-
.../src/airflow/providers/ssh/utils/remote_job.py | 174 +-
.../ssh/tests/unit/ssh/utils/test_remote_job.py | 227 +-
providers/standard/README.rst | 6 +-
providers/standard/docs/changelog.rst | 36 +
providers/standard/docs/index.rst | 6 +-
providers/standard/docs/sensors/asset.rst | 304 +
providers/standard/provider.yaml | 5 +-
providers/standard/pyproject.toml | 8 +-
.../src/airflow/providers/standard/__init__.py | 2 +-
.../airflow/providers/standard/decorators/bash.py | 4 +-
.../standard/example_dags/example_asset_sensor.py | 85 +
.../providers/standard/get_provider_info.py | 2 +
.../airflow/providers/standard/sensors/asset.py | 330 +
.../providers/standard/sensors/time_delta.py | 23 -
.../tests/unit/standard/decorators/test_bash.py | 21 +
.../tests/unit/standard/sensors/test_asset.py | 806 +++
.../tests/unit/standard/sensors/test_time_delta.py | 47 +-
providers/tableau/pyproject.toml | 2 +-
providers/telegram/pyproject.toml | 2 +-
providers/teradata/README.rst | 6 +-
providers/teradata/docs/changelog.rst | 13 +
providers/teradata/docs/index.rst | 6 +-
providers/teradata/provider.yaml | 3 +-
providers/teradata/pyproject.toml | 8 +-
.../src/airflow/providers/teradata/__init__.py | 2 +-
providers/trino/README.rst | 6 +-
providers/trino/docs/changelog.rst | 15 +
providers/trino/docs/index.rst | 6 +-
providers/trino/provider.yaml | 3 +-
providers/trino/pyproject.toml | 8 +-
.../trino/src/airflow/providers/trino/__init__.py | 2 +-
.../src/airflow/providers/trino/hooks/trino.py | 10 -
providers/vertica/pyproject.toml | 2 +-
providers/vespa/pyproject.toml | 2 +-
providers/weaviate/pyproject.toml | 2 +-
providers/yandex/README.rst | 6 +-
providers/yandex/docs/changelog.rst | 16 +
providers/yandex/docs/index.rst | 6 +-
providers/yandex/provider.yaml | 3 +-
providers/yandex/pyproject.toml | 8 +-
.../src/airflow/providers/yandex/__init__.py | 2 +-
.../src/airflow/providers/yandex/hooks/dataproc.py | 15 -
providers/ydb/pyproject.toml | 2 +-
providers/zendesk/pyproject.toml | 2 +-
pyproject.toml | 59 +-
registry/.eleventy.js | 5 +
registry/README.md | 4 +
registry/src/css/main.css | 37 +-
registry/src/provider-version.njk | 54 +-
reproducible_build.yaml | 4 +-
scripts/ci/docker_data_root_snapshot.sh | 207 +
.../ci/prek/check_airflowctl_command_coverage.py | 1 -
scripts/ci/prek/check_ci_workflows_in_sync.py | 4 +
scripts/ci/prek/check_extra_packages_ref.py | 2 +-
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/check_license.py | 2 +-
.../check_template_context_variable_in_sync.py | 4 +-
scripts/ci/prek/extract_permissions.py | 6 +-
scripts/ci/prek/fab_permissions_doc.py | 41 +-
scripts/ci/prek/lint_dockerfile.py | 2 +-
scripts/ci/prek/ruff_format.py | 2 +-
scripts/ci/prek/supported_versions.py | 2 +-
scripts/ci/prek/upgrade_important_versions.py | 103 +-
scripts/ci/spot_interruptions.py | 16 +
scripts/docker/entrypoint_ci.sh | 20 +-
.../docker/install_airflow_when_building_images.sh | 48 +-
scripts/docker/install_os_dependencies.sh | 123 +-
scripts/in_container/check_junitxml_result.py | 2 +-
scripts/in_container/run_agent_framework_tests.sh | 65 +-
scripts/in_container/run_ci_tests.sh | 12 +
scripts/pyproject.toml | 6 +-
.../tests/ci/prek/test_compile_provider_assets.py | 1 -
scripts/tests/ci/prek/test_compile_ui_assets.py | 1 -
scripts/tests/ci/prek/test_extract_permissions.py | 50 +
.../tests/ci/prek/test_fab_permissions_doc.py | 28 +-
.../ci/prek/test_upgrade_important_versions.py | 114 +-
scripts/tests/ci/test_docker_data_root_snapshot.py | 459 ++
scripts/tests/ci/test_prek_cache_optimizations.py | 84 +-
scripts/tests/ci/test_spot_interruptions.py | 44 +-
scripts/tools/setup_breeze | 2 +-
shared/configuration/pyproject.toml | 6 +-
shared/dagnode/pyproject.toml | 6 +-
shared/listeners/pyproject.toml | 6 +-
shared/logging/pyproject.toml | 6 +-
shared/module_loading/pyproject.toml | 6 +-
.../src/airflow_shared/module_loading/__init__.py | 23 +-
.../module_loading/file_discovery.py | 3 +
.../tests/module_loading/test_entry_points.py | 83 +-
.../tests/module_loading/test_file_discovery.py | 17 +
shared/observability/pyproject.toml | 6 +-
.../observability/metrics/metrics_template.yaml | 37 +-
shared/plugins_manager/pyproject.toml | 6 +-
shared/providers_discovery/pyproject.toml | 6 +-
shared/secrets_backend/pyproject.toml | 6 +-
shared/secrets_masker/pyproject.toml | 6 +-
.../secrets_masker/secrets_masker.py | 32 +-
.../tests/secrets_masker/test_secrets_masker.py | 103 +-
shared/serialization/pyproject.toml | 6 +-
shared/state/pyproject.toml | 6 +-
shared/state/src/airflow_shared/state/__init__.py | 30 +-
shared/state/tests/state/test_state.py | 45 +
shared/template_rendering/pyproject.toml | 6 +-
shared/timezones/pyproject.toml | 6 +-
task-sdk-integration-tests/pyproject.toml | 6 +-
task-sdk/docs/api.rst | 6 +
task-sdk/docs/index.rst | 1 +
task-sdk/docs/task-handler.rst | 127 +
task-sdk/docs/ts-bundle-spec.rst | 2 +-
task-sdk/pyproject.toml | 9 +-
task-sdk/src/airflow/sdk/__init__.py | 17 +-
task-sdk/src/airflow/sdk/__init__.pyi | 4 +
task-sdk/src/airflow/sdk/api/client.py | 9 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 320 +-
.../src/airflow/sdk/coordinators/_subprocess.py | 38 +-
.../airflow/sdk/coordinators/java/coordinator.py | 95 +-
task-sdk/src/airflow/sdk/coordinators/python.py | 212 +
task-sdk/src/airflow/sdk/definitions/context.py | 26 +
.../sdk/definitions/task_handlers/__init__.py | 32 +-
.../sdk/definitions/task_handlers/binding.py | 79 +
.../sdk/definitions/task_handlers/declaration.py | 79 +
.../sdk/definitions/task_handlers/loader.py | 115 +
.../sdk/definitions/task_handlers/registry.py | 65 +
task-sdk/src/airflow/sdk/exceptions.py | 11 +
task-sdk/src/airflow/sdk/execution_time/bundles.py | 29 +-
task-sdk/src/airflow/sdk/execution_time/cache.py | 2 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 24 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 66 +-
.../src/airflow/sdk/execution_time/coordinator.py | 127 +-
.../airflow/sdk/execution_time/request_handlers.py | 10 +
.../airflow/sdk/execution_time/schema/schema.json | 142 +-
.../sdk/execution_time/schema/versions/__init__.py | 11 +-
.../execution_time/schema/versions/v2026_10_30.py | 15 -
.../execution_time/schema/versions/v2027_02_28.py | 71 +
.../sdk/execution_time/secrets/execution_api.py | 4 +-
.../src/airflow/sdk/execution_time/supervisor.py | 31 +-
.../src/airflow/sdk/execution_time/task_runner.py | 131 +-
.../airflow/sdk/importers/yaml_importer/builder.py | 220 +-
.../airflow/sdk/importers/yaml_importer/models.py | 159 +-
task-sdk/tests/task_sdk/api/test_client.py | 71 +
task-sdk/tests/task_sdk/conftest.py | 53 +
.../coordinators/executable/test_coordinator.py | 2 +-
.../task_sdk/coordinators/java/test_coordinator.py | 242 +-
.../coordinators/node/test_bundle_reader.py | 2 +-
.../task_sdk/coordinators/node/test_coordinator.py | 2 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 30 +-
.../definitions/task_handlers/test_loader.py | 164 +
.../task_handlers/test_task_handlers.py | 143 +
.../tests/task_sdk/definitions/test_variables.py | 39 +-
.../execution_time/schema/test_migrator.py | 73 +-
.../tests/task_sdk/execution_time/test_context.py | 68 +-
.../task_sdk/execution_time/test_coordinator.py | 7 +-
.../execution_time/test_python_coordinator.py | 156 +
.../execution_time/test_run_task_handler.py | 149 +
.../task_sdk/execution_time/test_supervisor.py | 69 +-
.../task_sdk/execution_time/test_task_runner.py | 42 +-
.../yaml_importer/test_builder_validation.py | 182 +
.../importers/yaml_importer/test_parser.py | 13 +
ts-sdk/DEVELOPMENT.md | 22 +-
ts-sdk/README.md | 8 +-
ts-sdk/adr/0001-mixed-lang-dag-interface.md | 2 +-
ts-sdk/adr/0002-native-dag-interface.md | 2 +-
ts-sdk/capabilities.yaml | 4 +-
ts-sdk/docs/index.md | 6 +-
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/package.json | 4 +-
ts-sdk/example/src/ai-approval.ts | 6 +-
ts-sdk/example/src/dynamic.ts | 2 +-
ts-sdk/example/src/hitl.ts | 6 +-
ts-sdk/example/src/main.ts | 2 +-
ts-sdk/example/src/native.ts | 2 +-
ts-sdk/example/src/taskflow.ts | 2 +-
ts-sdk/package.json | 5 +-
ts-sdk/pnpm-lock.yaml | 34 +-
ts-sdk/schema/supervisor-schema.json | 142 +-
ts-sdk/scripts/ci/prek/check_dag_schema.py | 1 -
ts-sdk/scripts/validate-release-inputs.mjs | 7 +-
ts-sdk/scripts/validate-release-inputs.test.mjs | 6 +-
ts-sdk/scripts/verify-package.test.mjs | 10 +-
ts-sdk/src/coordinator/arg-binding.ts | 2 +-
ts-sdk/src/coordinator/client.ts | 8 +-
ts-sdk/src/coordinator/serde.ts | 2 +-
ts-sdk/src/generated/supervisor.ts | 206 +-
ts-sdk/src/sdk/brand.ts | 2 +-
ts-sdk/src/sdk/client-types.ts | 2 +-
ts-sdk/src/sdk/client.ts | 2 +-
ts-sdk/tests/cli/fixtures/bundle-v1.min.mjs | 4 +-
ts-sdk/tests/cli/pack.test.ts | 2 +-
ts-sdk/tests/coordinator/arg-binding.test.ts | 2 +-
ts-sdk/tests/coordinator/client.test.ts | 16 +-
ts-sdk/tests/coordinator/serde.test.ts | 8 +
ts-sdk/tests/hitl/operator.test.ts | 2 +-
ts-sdk/tests/public-api.test.ts | 2 +-
ts-sdk/tests/sdk/bundle.test.ts | 2 +-
ts-sdk/tsconfig.json | 6 +-
ts-sdk/vitest.config.ts | 6 +-
uv.lock | 6549 ++++++++++----------
1467 files changed, 75802 insertions(+), 13394 deletions(-)
create mode 100644 .agents/skills/airflow-translations/locales/ru.md
create mode 100644 .github/actions/load_image/action.yml
create mode 100644 .github/workflows/dependency-upgrade-report.yml
create mode 100644 .github/workflows/dependency-upgrade-summary.yml
create mode 100644 .github/workflows/prod-packages-build.yml
create mode 100644
airflow-core/docs/administration-and-deployment/logging-monitoring/triggers.rst
create mode 100644 airflow-core/docs/img/ui-dark/dag_overview_versions.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_clear.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_decision.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_graph.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_iterations.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_iterations_tab.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_mapped.png
create mode 100644 airflow-core/docs/img/ui-dark/loops_review.png
create mode 100644 airflow-core/docs/img/ui-light/dag_overview_versions.png
create mode 100644 airflow-core/docs/img/ui-light/loops_clear.png
create mode 100644 airflow-core/docs/img/ui-light/loops_decision.png
create mode 100644 airflow-core/docs/img/ui-light/loops_graph.png
create mode 100644 airflow-core/docs/img/ui-light/loops_iterations.png
create mode 100644 airflow-core/docs/img/ui-light/loops_iterations_tab.png
create mode 100644 airflow-core/docs/img/ui-light/loops_mapped.png
create mode 100644 airflow-core/docs/img/ui-light/loops_review.png
create mode 100644 airflow-core/newsfragments/74789.significant.rst
create mode 100644 airflow-core/newsfragments/76007.significant.rst
create mode 100644 airflow-core/newsfragments/76234.bugfix.rst
create mode 100644 airflow-core/newsfragments/76430.significant.rst
create mode 100644 airflow-core/newsfragments/76474.significant.rst
create mode 100644
airflow-core/src/airflow/api_fastapi/common/parameters/trigger.py
copy java-sdk/gradle.properties =>
airflow-core/src/airflow/api_fastapi/core_api/datamodels/ui/dag_bundles.py (76%)
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/routes/public/triggers.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dag_bundles.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/services/public/import_errors.py
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/datamodels/dag_parsing.py
create mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/routes/dag_parsing.py
delete mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2026_10_30_xcom_params.py
copy
airflow-core/src/airflow/{api_fastapi/execution_api/versions/v2027_02_28.py =>
dag_processing/claims.py} (58%)
create mode 100644 airflow-core/src/airflow/dag_processing/maintenance.py
create mode 100644 airflow-core/src/airflow/dag_processing/requested_work.py
copy airflow-core/src/airflow/{listeners/spec/importerrors.py =>
dag_processing/timeouts.py} (62%)
create mode 100644
airflow-core/src/airflow/migrations/versions/0152_3_5_0_add_state_and_owner_to_trigger.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0153_3_5_0_add_index_on_callback_trigger_id.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0154_3_5_0_add_idempotency_key_to_hitl_detail.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0155_3_5_0_add_dag_processor_publication_state.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0156_3_5_0_add_processor_work_claims.py
create mode 100644
airflow-core/src/airflow/models/dag_processor_publication_receipt.py
copy airflow-core/src/airflow/{api_fastapi/execution_api/datamodels/xcom.py =>
models/dag_processor_work_claim.py} (53%)
create mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/FieldArray.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/FieldArray.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/FieldSelector.test.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/FieldStringArray.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/parseArrayElement.ts
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagBundle/BundleFiles.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagBundle/FileImportError.test.tsx
copy airflow-core/src/airflow/ui/src/{queries/useHasMultipleDagBundles.ts =>
pages/DagsList/recentRunsLayout.ts} (66%)
create mode 100644 airflow-core/src/airflow/ui/src/pages/Error.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/queries/dagListQueryKeys.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/utils/registerPluginDependencies.test.ts
copy airflow-core/src/airflow/ui/src/utils/{AppWrapper.tsx =>
registerPluginDependencies.ts} (51%)
create mode 100644 airflow-core/src/airflow/ui/src/utils/routeModule.ts
copy providers/modal/src/airflow/providers/modal/exceptions.py =>
airflow-core/tests/unit/api_fastapi/core_api/conftest.py (56%)
create mode 100644
airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_triggers.py
create mode 100644
airflow-core/tests/unit/api_fastapi/core_api/routes/ui/test_dag_bundles.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_dag_parsing.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2026_10_30/test_task_state_store.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2027_02_28/test_task_instances.py
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2027_02_28/test_variables.py
create mode 100644 airflow-core/tests/unit/dag_processing/conftest.py
create mode 100644 airflow-core/tests/unit/dag_processing/test_claims.py
create mode 100644 airflow-core/tests/unit/dag_processing/test_maintenance.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_failures.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_inventory.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_isolation.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_manager_api_results.py
create mode 100644
airflow-core/tests/unit/dag_processing/test_requested_work.py
create mode 100644 airflow-core/tests/unit/listeners/test_importerrors.py
create mode 100644
airflow-core/tests/unit/migrations/test_0152_add_state_and_owner_to_trigger.py
create mode 100644
airflow-core/tests/unit/migrations/test_0153_add_index_on_callback_trigger_id.py
create mode 100644
airflow-core/tests/unit/migrations/test_0156_add_processor_work_claims.py
create mode 100644 airflow-ctl/src/airflowctl/ctl/utils/validation.py
copy {airflow-core/src/airflow/_shared =>
airflow-ctl/tests/airflow_ctl/ctl/utils}/__init__.py (100%)
create mode 100644 airflow-ctl/tests/airflow_ctl/ctl/utils/test_dag_run.py
copy devel-common/src/tests_common/test_utils/markers.py =>
airflow-ctl/tests/airflow_ctl/test_main.py (55%)
copy {airflow-core/src/airflow/_shared =>
airflow-ctl/tests/airflow_ctl/utils}/__init__.py (100%)
copy airflow-core/src/airflow/api_fastapi/execution_api/datamodels/xcom.py =>
airflow-ctl/tests/airflow_ctl/utils/test_helpers.py (51%)
copy devel-common/src/tests_common/test_utils/markers.py =>
airflow-ctl/tests/airflow_ctl/utils/test_module_loading.py (52%)
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/openlineage_tests/dags_extra/openlineage_inlet_assets_dag.py
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/openlineage_tests/remove_unused_providers.py
create mode 100644 chart/docs/migrate-to-git-dag-bundle.rst
create mode 100644 chart/newsfragments/72555.significant.rst
create mode 100644 chart/newsfragments/76601.significant.rst
create mode 100644 dev/breeze/doc/adr/0021-pin-os-dependencies-images.md
create mode 100644
dev/breeze/doc/images/output_release-management_build-os-deps-images.svg
create mode 100644
dev/breeze/doc/images/output_release-management_build-os-deps-images.txt
create mode 100644
dev/breeze/doc/images/output_release-management_publish-os-deps-images.svg
create mode 100644
dev/breeze/doc/images/output_release-management_publish-os-deps-images.txt
create mode 100644
dev/breeze/src/airflow_breeze/files/hardened_os_deps_image_digests.json
create mode 100644 dev/breeze/tests/test_dependency_upgrade_report.py
create mode 100644 dev/breeze/tests/test_os_deps_images.py
create mode 100644 dev/breeze/tests/test_registry_extract_data.py
create mode 100755 dev/remove_unsupported_python_constraints.py
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/ConfBinding.kt
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_review_loop.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_openai_agents_data_access.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/src/components/SkillsSection.tsx
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/src/skill-source.ts
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/tests/skill-source.test.ts
copy
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2027_02_28.py =>
providers/common/ai/tests/unit/common/ai/tool_parts.py (53%)
create mode 100644
providers/common/sql/tests/system/common/sql/example_sql_sensor.py
create mode 100644
providers/google/tests/unit/google/cloud/links/test_dataproc.py
create mode 100644
providers/google/tests/unit/google/cloud/links/test_kubernetes_engine.py
create mode 100644
providers/google/tests/unit/google/cloud/links/test_translate.py
create mode 100644
providers/google/tests/unit/google/cloud/transfers/test_presto_to_gcs.py
create mode 100644 providers/modal/docs/task_decorator.rst
copy {airflow-core/src/airflow/_shared =>
providers/modal/src/airflow/providers/modal/decorators}/__init__.py (100%)
create mode 100644
providers/modal/src/airflow/providers/modal/decorators/modal.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/src/airflow/providers/modal/triggers}/__init__.py (100%)
create mode 100644
providers/modal/src/airflow/providers/modal/triggers/modal.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/src/airflow/providers/modal/utils}/__init__.py (100%)
create mode 100644
providers/modal/src/airflow/providers/modal/utils/python_sandbox.py
copy {airflow-core/tests/integration =>
providers/modal/tests/system}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/system/modal}/__init__.py (100%)
create mode 100644 providers/modal/tests/system/modal/example_modal_task.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal/decorators}/__init__.py (100%)
create mode 100644 providers/modal/tests/unit/modal/decorators/test_modal.py
create mode 100644 providers/modal/tests/unit/modal/local_sandbox.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal/triggers}/__init__.py (100%)
create mode 100644 providers/modal/tests/unit/modal/triggers/test_modal.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal/utils}/__init__.py (100%)
create mode 100644
providers/modal/tests/unit/modal/utils/test_python_sandbox.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_clear_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_manual_state_dag.py
delete mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_conf_locked_dag.py
delete mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_full_task_info_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_task_loop_state_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_task_outcomes_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_clear_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_manual_state_dag.json
delete mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_conf_locked_dag.json
delete mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_full_task_info_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_loop_state_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_outcomes_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/manual_state.py
copy
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2027_02_28.py =>
providers/openlineage/tests/system/openlineage/triggers.py (59%)
rename providers/snowflake/tests/unit/snowflake/triggers/{test_snowflake.py =>
test_snowflake_trigger.py} (80%)
create mode 100644 providers/standard/docs/sensors/asset.rst
create mode 100644
providers/standard/src/airflow/providers/standard/example_dags/example_asset_sensor.py
create mode 100644
providers/standard/src/airflow/providers/standard/sensors/asset.py
create mode 100644 providers/standard/tests/unit/standard/sensors/test_asset.py
create mode 100755 scripts/ci/docker_data_root_snapshot.sh
copy
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2027_02_28.py =>
scripts/tests/ci/prek/test_fab_permissions_doc.py (53%)
create mode 100644 scripts/tests/ci/test_docker_data_root_snapshot.py
create mode 100644 task-sdk/docs/task-handler.rst
create mode 100644 task-sdk/src/airflow/sdk/coordinators/python.py
copy devel-common/src/tests_common/test_utils/markers.py =>
task-sdk/src/airflow/sdk/definitions/task_handlers/__init__.py (53%)
create mode 100644
task-sdk/src/airflow/sdk/definitions/task_handlers/binding.py
create mode 100644
task-sdk/src/airflow/sdk/definitions/task_handlers/declaration.py
create mode 100644 task-sdk/src/airflow/sdk/definitions/task_handlers/loader.py
create mode 100644
task-sdk/src/airflow/sdk/definitions/task_handlers/registry.py
create mode 100644
task-sdk/src/airflow/sdk/execution_time/schema/versions/v2027_02_28.py
create mode 100644 task-sdk/tests/task_sdk/conftest.py
create mode 100644
task-sdk/tests/task_sdk/definitions/task_handlers/test_loader.py
create mode 100644
task-sdk/tests/task_sdk/definitions/task_handlers/test_task_handlers.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/test_python_coordinator.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/test_run_task_handler.py
create mode 100644
task-sdk/tests/task_sdk/importers/yaml_importer/test_builder_validation.py
