This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/ui/chakra-ui-7685d36c64
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 5b1f30d03d2 Bump @chakra-ui/react
add 298756f22c3 Cap open pull requests from non-committers at 5 (#73469)
add dd2c7fd26e7 Keep the table sort in the URL when it matches the saved
sort (#73622)
add c4a0a88a8b3 Fix boolean value of start date used in url start_date_gte
filter. (#73676)
add 1a51ed1b1f5 Account for the open pull request limit in the PR triage
process (#73742)
add a11da87a119 Speed up zip Dag discovery and keep member file names
(#73727)
add 7e5c580cd68 Temporarily remove the open pull request creation cap
(#73754)
add 77a1953cd41 Java SDK: Draw a Java-authored Dag's edges with before and
after (#73594)
add f863982c07c Restore the open pull request creation cap (#73758)
add 1219b1a8541 Eager-load DagCode in the Dag source API (#73752)
add 005fd649bdf Add dedicated tests for cncf.kubernetes secret and
k8s_model modules (#73751)
add 909ca179bcc Update Magpie floor to 0.9.0 and adopt contributor-growth
skills (#73755)
add 05519cd774c Keep task attempt UUIDs and try numbers aligned (#73554)
add 18fe1c60986 UI: Add bulk pause, drain and unpause actions to the Dags
list (#73055)
add 38ea385ce71 i18n(ko): Add missing translations (Sep25) (#73757)
add 3e47fc39968 Catch stale entries in the Java SDK dependency trust list
(#71869)
add 7c597e2830b Speed up the event logs API by loading only display names
(#73021)
add 1d916545b2b Update Magpie floor to 0.9.0.dev202609262258 (#73765)
add e1cd364286c Update README quickstart and stable version table to
Airflow 3.3.2 (#73770)
add a72b73576fb Drop stale entries from the Java SDK dependency trust list
(#73792)
add a3abc237355 Check admin-only views against a dedicated Keycloak
resource in multi-team mode (#73696)
add 22f6bb06664 Stop Keycloak middleware from reissuing a JWT revoked
during the request (#73695)
add 22ebb0943f7 [main] Upgrade important CI environment (#73629)
add 3107af07cd1 Use POSIX-compliant tail to extract token line in EKS
command (#73690)
add 23c6e77067f Fix provider.yaml doc URL check with several suspended
providers (#73782)
add f2fae8c737a Fix flaky test_trigger_log in triggerer job tests (#72919)
add a55f0a1af04 Add GitSync sidecar upgrade warning to Helm chart docs
(#73814)
add 5bc738efafe Add tests for the Google Cloud Tasks links (#72846)
add ebe3bddae79 Keep README stable Airflow version pins in sync with
releases (#73786)
add 46823e47aee Correct the meaning of _arg_bindings in the serialization
schema (#73644)
add f49bce025a8 Optimize UI and Playwright dependency caching (#73183)
add acaa1cba930 Republish repaired prek caches and keep unrelated host
caches (#73182)
add dff97f0908a Added Louisa AI to the list of companies using Apache
Airflow (#73665)
add 28e7c89c363 fix k8s download_schemas_for_version for hpa (#73821)
add 23bcbe6c99a Regenerate provider requirement tables in breeze ci
upgrade (#73802)
add 2827a13dc4f Check ui-field-behaviour drift between hooks and
provider.yaml (#73801)
add 30d0d7bac4a Adjust warnings, import errors, and Dag source models for
sdk/importers (#72474)
add f242c8e0513 Skip CI duration alerts when the newest run is stale
(#73831)
add 3634bc89d04 Discover a bundle's Dag definitions through the importer
registry (#73728)
add 7eac9ac7c1b Add connections and agent-security entries to the
common.ai sidebar (#73837)
add 58af2f521bb Close the ssh askpass helper in GitHook before ssh
executes it (#73427)
add b86fa49a15d Optimize CI disk cleanup (#73184)
add 5fbe8dbb433 Clarify DateTimeSensorAsync changelog entry (#73833)
add 873bd644b51 Let a person approve an agent's tool calls before they run
(#73586)
add 66607ac5483 AIP-82: Add KinesisMessageQueueProvider (#73509)
add b357ae24709 Bump the auth-ui-package-updates group across 1 directory
with 8 updates (#73740)
add 455d9581367 UI: Complete Polish translations and unify slot/deferred
wording (#72623)
add 5428b3b995b Secrets backends order updated (#70681)
add 232255e7fa7 Go SDK: add airflow.Dag and dag.Task, the native Dag
constructors (#73767)
add 0566d6cd5ef Add OpenSandbox backend for sandbox tools (#71676)
add 93978958ae1 Fix example_neptune_analytics by pinning an explicit
region (#73851)
add d6c4c71979e Bump prettier (#73857)
add c8ca02e4158 Update changelog to clarify new LLMBranchOperator
"branches" feature (#73850)
add ad3e67fccd2 Add Modal provider with `ModalHook` and connection type
(#73418)
add ce614baf9b0 Add Strands Agents support for `common.ai` toolsets
(#73587)
add dbac03d87dd Fix KubernetesExecutor not queuing tasks on Airflow 3.0.x
(#73764)
add b3bcb388742 Recognize grouped PR references in provider changelog
tooling (#73855)
add ae1e8385060 Let the sandbox toolset attach to a sandbox another task
provisioned (#73559)
add c1b878ad22c Exclude SQLAlchemy 2.1.0 (#73865)
add 10221c300eb Read the AWS task logs once more after the fetcher is
stopped (#73211)
add 84f75158120 Require `common.sql` 2.2.0 for common.ai's SQL extras
(#73867)
add 3f60fa9e2c7 Fix Firefox and WebKit UI e2e runs failing at login
(#73872)
add ac88accf4ed Add bundle_name tag to missing dag processor metrics
(#73717)
add 7afece8efb0 Update providers metadata 2026-09-29 (#73884)
add 4b6606543fd Distinguish OpenAI batch timeout and cancellation in
deferrable tasks (#72149)
add 8b3d4d315fa Surface the retry policy decision on task instances page
(#73030)
add bc28bb0804c Go SDK: Fix the mixed language task handler binding
semantic (#73648)
add 9ebc2644741 Revert "Secrets backends order updated (#70681)" (#73891)
add 4e23910701b Go SDK: check Go naming conventions with staticcheck
(#73874)
add 0768924a0cd Automatically isolate `breeze testing` for each git
worktree in a totally isolated project. (#73836)
add 3e8318969e1 Add ADR for Lang SDK Dag and mixed-language Task
processing flow (#71929)
add e8d43932077 Add ADR for supporting Dynamic Dag Generation across
Language SDKs (#73518)
add 8d815efdbc3 Own the BaseAsyncOperator event loop through
asyncio.Runner (#73560)
add 647add72afe Mark experimental `common.ai` features ahead of 1.0
(#73896)
add 5eba7439d76 Make cron timetables hashable (#73859)
add d776f003b71 UI: Add team column and filter to the jobs list (#73295)
add d0b8476825d Set `SameSite` on the fab auth manager session cookie
(#73894)
add 6b90003fe27 Document override semantics for EcsRunTaskOperator (#73860)
add a3555c74cfc TS SDK: default a task id to the handler's name (#73437)
add a65a3ddf8be Fix Postgres data volume path in Breeze (#73862)
add 85321901f10 Add EmrServerlessStartSessionOperator to Amazon provider
(#70763)
add 9198acb15e8 UI: Add team filter to Human-in-the-loop task instances
listing (#73726)
add 836a5565c58 Scope plugin scheduling classes to their team in
multi-team mode (#73569)
add cc19675d24f Add DuckDB support to the Amazon provider (#73301)
add 029cdf8f6cc Return an approved agent answer as `output_type` after
human review (#73904)
add 3c76a47f65c Remove accidentally adopted Magpie contributor-growth
plugin (#73927)
add 73b07c5aedb Name the tools a durable agent retry will run again
(#73873)
add 5799660c4d4 TS SDK: draw order-only edges with before and after
(#73438)
add a8a62573f54 TS SDK: embed one source region per native Dag file
(#73723)
add bfa2fe02fc1 Account for AgentOperator spend on failed runs and across
retries (#73706)
add 023f859e5a6 Mask secrets in tool results before they reach the model
(#73897)
add 2b806f949b0 Rework common.ai Strands support into a plugin and add
Google ADK (#73898)
add e46d1938619 Add `ObjectStorageToolset` for reading files on object
storage (#73899)
add 35507e99a6e Let HookToolset pin arguments the model must not choose
(#73900)
add 40ed903b6d6 Count and trace tool calls made by native agent frameworks
(#73901)
add 2eb11c14b85 Document running your own Pydantic AI agent, and sandboxes
in other frameworks (#73902)
add d4ba567a390 Tell the model how many rows a Parquet or Avro file holds
(#73925)
add 21bbf2f40a2 Java SDK: Generate Dag and task configuration from the
serialization schema (#73595)
add 76bf88a4877 API: Translate domain ValueError in Task State Store route
(#73753)
add 1a67bf46b55 Support DagBundle based deployment for Coordinator (#70805)
add 53ca2a427ba TS SDK: add task groups to the native Dag surface (#73439)
add 5e785acfb3b Discard the task state values for a task instance when it
is cleared (#72100)
add 7938c0dbb65 Make `execute_tool` the public method `AirflowToolset`
subclasses implement (#73938)
add 6cd2f6f36d9 Remove migration tests for migrations that have already
landed. (#73953)
add 5136c6c41bf Use plain ifs to normalize configured artifact roots
(#73944)
add e15b3a66137 Retry S3Hook.delete_bucket when a late write leaves bucket
non-empty (#73930)
add acd42922f3d Filter jobs API is_alive in SQL so pagination stays
correct (#73684)
add 508301ab263 Add ADR for per-Dag source in the Lang-SDK bundle artifact
(#73948)
add 91423baf366 Fix breeze down crashing when a start-airflow container is
running (#73955)
add 8e36d6d6efd Show whether a calendar day's run was a backfill (#72782)
add 6317c63ae16 Go SDK: generate DagSpec and TaskSpec from the
serialization schema (#73936)
add f306f1848f6 Refresh HITL review details on task clear (#73235)
add 4fd2c9aabf2 Mark lineage hashes as non-security (#70999)
add f7a27633741 Fix typo in apache-airflow-providers-fab error message
(#73956)
add 8d4ab8a94db Keep OpenAPI error responses in sync with the statuses
routes raise (#71647)
add 0b6c38502ab Add runtime DagRun note updates (#69403)
add ba89738639c Fix short-circuit not skipping already expanded mapped
tasks (#73960)
add 16f974f6a35 Run the `common.ai` agent framework adapter tests in CI
(#73912)
add e364ee76483 Keep agent framework spans when worker tracing is off
(#73903)
add 2e803e58997 Add key-pair JWT authentication to Snowflake Cortex Agent
hook (#73815)
add e92147c12aa UI: Add a time-window scope to the Dags list run state
filter (#70470)
add 63a5966473b Check PyPI history before a new provider's first release
(#73887)
add ede78e095b6 Add embedding kwargs to common AI hooks and operators
(#72002)
add 64943ba6dbb Fix `run_duration` calculation in airflow dags test by
decoupling start_date (#68837)
add 9e67831f2bb Allow filtering the Dag runs list by Dag tags (#70861)
add e22c9d02b2e Add Has Events filter to Assets search (#72460)
add f31b572df18 Fix airflowctl commands crashing instead of printing their
result (#72675)
add 1559dae90ab UI: Use TeamName component for all team name displays
(#73910)
add 489316fbc72 Migrate execution API reads to async sessions (#73403)
add a8e95debbc6 Fix flaky AgentOperator durable usage budget tests (#73996)
add e33e45fe67a Add `AssetAndTimeSchedule` timetable (#58543)
add a91216d5ea9 TS SDK: serialize a native Dag to Dag JSON (#73441)
add 884e687ea77 Fix short-circuit inside a mapped task group not skipping
downstream (#73959)
add 3f19c146545 Go SDK: declare data edges with airflow.Inputs (#73895)
add 13adb691464 Close German Translation Gaps 2026-09-30 (#73980)
add d886882ac14 Let Common AI toolsets use the agent's tool retry budget
(#73957)
add 35633455ed7 Add first-class `capabilities` to Common AI
`AgentOperator` (#73984)
add adaa16f88af Parse Dag files through the Task SDK importers (#73853)
add 12127b07978 Fix check-conn-id-templated crashing on a vanishing
__pycache__ (#74016)
add 4d304d0876c Export files an agent built in a sandbox to object storage
(#73990)
add e9c552cc827 Add a vendor-neutral managed-agent hook contract to Common
AI (#73532)
add a33fe27cace Add async client to `AnthropicHook` (#73967)
add e6a9de5d832 Go SDK: bring the coordinator-protocol models back to the
supervisor schema (#73963)
add 27cd88ca74c Cache repeated agent prompts by default in AgentOperator
(#73994)
add 529f429400a Go SDK: reject a task handler and a Dag that share a
dag_id (#73876)
add bc9ca5b1227 Correctly shutdown async sessions on exit. (#73838)
add f1b36db6093 Back off between GitDagBundle bare clone attempts so a
fresh GitHub App token can propagate (#73878)
add 6b847411de1 Stop rebuilding the FAB app on every users and roles API
call (#73104)
add 56817294cdd Go SDK: add airflow.TriggerDagRun, a task that triggers a
Dag run (#74003)
add b8475094703 Fix go-sdk generated drift (#74028)
add 8f3e8466c67 Support Airflow 2.11 in the Common AI provider (#73991)
add f0cde671827 Use "Airflow versions" in user-facing docs, not "cores"
(#74045)
add 0bb09cb6ba5 Close the providers testing issue right after announcing
the release (#73890)
add 43377466a06 Release the DuckDB provider as 0.2.0 (#73888)
add 53e43f29130 Speed up CI image restores with zstd-compressed stashes
(#73997)
add e4d397f021e Bound get_schema results for very wide tables in the SQL
toolsets (#74017)
add 7d6244bf191 Clarify `max_db_retries` doc wording to avoid off-by-one
confusion (#73722)
add bb463bf9230 Correlate executor task events by attempt UUID (#73916)
add c19faf0c5ae Render the HITL review workflow as a Mermaid diagram
(#74024)
add 2aa31ae7bff Use airflow.sdk imports in Airflow 3 upgrade guide example
(#74015)
add f3532c60eda Use Task SDK TaskInstanceState in OpenSearch log handler
(#72444)
add 0ec26723858 Add GKEPodExecOperator for existing Pods (#72577)
add 740986adfce Add missing cycle assertion to test_semi_complex (#71973)
add fca1c01c73e Fix Windows UnicodeDecodeError during pytest collection
(#73536)
add 1787ef7cbba Run the deferred AWS hook configuration check as a prek
hook (#73681)
add 413ae46a045 Align timetable docs with Airflow 3 data interval and
catchup behaviour (#70658)
add 64f9f3ac784 Update issue templates now that Airflow 2 has reached end
of life (#74056)
add 6330b4de9c5 Go SDK: reject a second TaskSpec or Inputs when dag.Task
applies it (#74057)
add 383a9a87a98 Stop wiping the uv cache before every CI image build
(#74052)
add 58e987defec Fix Non-DB test collection failure in Google Stackdriver
hook test (#74066)
add 498724fc13a Go SDK: enumerate every user-facing enum in the airflow
package (#74064)
add 5e476d7cf89 TS SDK: answer the Dag-parsing request from bundle.serve
(#73442)
add dd271599939 Go SDK: vendor the schemas it generates from (#74047)
add 77927390c17 Move Dag cycle detection from the Task SDK to shared
(#74034)
add a3e07159a0b Add Dag ID filtering to Assets search (#70971)
add d3b9a0dd2b3 Add KafkaSharedStreamProducer and KafkaSharedStreamTrigger
(#68625)
add ae6139d58a8 Fix DecreasingPriorityStrategy example by initializing
try_number before weight evaluation (#62148)
add 402d7885194 Java SDK: Resolve a task's arguments from the Dag's own
wiring (#73596)
add e14854221ad Group and filter Dags by folder on the Dags page (#68544)
add 18af65032e3 Render the Language SDK Spec diagrams as Mermaid (#74065)
add be53013349e Support azure-datalake-store 1.x in AzureDataLakeHook
(#73819)
add bc15e1093b5 Close German Translation Gaps 2026-10-02 (#74088)
add 3045451b8b0 Treat an empty Dag run config as no config in the UI
(#74083)
add c31888641b1 Persist the match-anywhere search toggle in the URL
(#74019)
add 4803c0b3f79 Discover Dag definitions through the Task SDK importers
(#74020)
add f5283f3da9b Move the Dag file processor's shared plumbing into a base
class (#74040)
add e3dd28607b9 Document team-scoped plugins in multi-team mode (#73995)
add b62299ced8a Cap microsoft-kiota-http below 1.13 in the Microsoft Azure
provider (#74090)
add d7b672f44e0 Update docs and diagrams for the Airflow 3 Dag processor
(#74073)
add 7ada977b7be Bump @chakra-ui/react
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 (5b1f30d03d2)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/chakra-ui-7685d36c64
(7ada977b7be)
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:
.apache-magpie-overrides/issue-tracker-config.md | 166 +
.apache-magpie-overrides/pmc-roster.md | 129 +
.../pr-management-code-review-criteria.md | 82 +
.apache-magpie-overrides/pr-management-config.md | 25 +
.../pr-management-quick-merge-config.md | 166 +
.apache-magpie-overrides/reassess-pool-defaults.md | 201 +
.apache-magpie-overrides/release-trains.md | 273 ++
.apache-magpie-overrides/reproducer-conventions.md | 166 +
.apache-magpie-overrides/runtime-invocation.md | 183 +
.apache-magpie.lock | 2 +-
.asf.yaml | 5 +
.github/ISSUE_TEMPLATE/1-airflow_bug_report.yml | 8 +-
.github/ISSUE_TEMPLATE/2-feature_request.yml | 3 +-
.github/actions/install-prek/action.yml | 159 +-
.github/boring-cyborg.yml | 3 +
.github/workflows/agent-framework-tests.yml | 89 +
.github/workflows/basic-tests.yml | 41 +-
.github/workflows/ci-amd.yml | 19 +
.github/workflows/ci-arm.yml | 19 +
.github/workflows/ci-image-build.yml | 8 +
.github/workflows/ui-e2e-tests.yml | 21 +-
.pre-commit-config.yaml | 89 +-
Dockerfile | 2 +-
Dockerfile.ci | 4 +-
INTHEWILD.md | 1 +
README.md | 10 +-
airflow-core/.pre-commit-config.yaml | 6 +
.../0007-taskflow-across-language-boundary.md | 42 +
.../adr/lang-sdk/0008-control-flow-constructs.md | 2 +-
.../0009-provider-operators-as-generated-dsl.md | 4 +-
.../adr/lang-sdk/0010-native-dag-processing.md | 212 +
.../lang-sdk/0011-mixed-language-dag-processing.md | 245 +
.../adr/lang-sdk/0012-lang-sdk-parse-protocol.md | 233 +
.../0013-persisted-task-handler-bindings.md | 593 +++
.../0014-bundle-metadata-and-cache-digest.md | 122 +
.../0015-per-dag-source-in-bundle-artifact.md | 127 +
airflow-core/adr/lang-sdk/README.md | 6 +
.../modules_management.rst | 2 +-
.../docs/administration-and-deployment/plugins.rst | 172 +-
.../task-and-asset-state-store.rst | 4 +
.../authoring-and-scheduling/asset-scheduling.rst | 31 +-
.../authoring-and-scheduling/language-sdks/go.rst | 22 +-
.../language-sdks/java.rst | 89 +-
.../language-sdks/typescript.rst | 144 +-
.../docs/authoring-and-scheduling/timetable.rst | 179 +-
airflow-core/docs/best-practices.rst | 12 +-
airflow-core/docs/core-concepts/dag-run.rst | 11 +-
airflow-core/docs/core-concepts/dags.rst | 6 +-
airflow-core/docs/core-concepts/executor/index.rst | 23 +-
airflow-core/docs/core-concepts/multi-team.rst | 16 +-
airflow-core/docs/core-concepts/overview.rst | 4 +-
.../docs/core-concepts/resumable-tasks.rst | 75 +-
.../docs/core-concepts/task-state-store.rst | 6 +-
airflow-core/docs/extra-packages-ref.rst | 2 +
.../img/diagram_basic_airflow_architecture.md5sum | 2 +-
.../img/diagram_basic_airflow_architecture.png | Bin 116194 -> 127853
bytes
.../docs/img/diagram_basic_airflow_architecture.py | 9 +-
...agram_dag_processor_airflow_architecture.md5sum | 2 +-
.../diagram_dag_processor_airflow_architecture.png | Bin 237657 -> 237572
bytes
.../diagram_dag_processor_airflow_architecture.py | 23 +-
...diagram_distributed_airflow_architecture.md5sum | 2 +-
.../diagram_distributed_airflow_architecture.png | Bin 192497 -> 215541
bytes
.../diagram_distributed_airflow_architecture.py | 20 +-
.../docs/installation/upgrading_to_airflow3.rst | 2 +-
airflow-core/docs/migrations-ref.rst | 11 +-
airflow-core/docs/public-airflow-interface.rst | 5 +-
airflow-core/docs/security/api_permissions_ref.rst | 4 +
airflow-core/newsfragments/58543.feature.rst | 1 +
airflow-core/newsfragments/68496.significant.rst | 4 +-
airflow-core/newsfragments/72100.significant.rst | 59 +
airflow-core/newsfragments/72407.significant.rst | 5 +-
airflow-core/newsfragments/73554.significant.rst | 24 +
airflow-core/pyproject.toml | 6 +-
airflow-core/src/airflow/api/common/delete_dag.py | 7 +-
airflow-core/src/airflow/api_fastapi/app.py | 2 +
.../auth/managers/simple/ui/package.json | 16 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 356 +-
.../api_fastapi/common/parameters/__init__.py | 8 +
.../airflow/api_fastapi/common/parameters/asset.py | 23 +
.../airflow/api_fastapi/common/parameters/dag.py | 87 +
.../api_fastapi/common/parameters/dag_run.py | 35 +-
.../airflow/api_fastapi/common/parameters/job.py | 50 +
.../airflow/api_fastapi/common/parameters/misc.py | 43 +
.../api_fastapi/core_api/datamodels/dag_sources.py | 1 +
.../api_fastapi/core_api/datamodels/dag_warning.py | 4 +-
.../api_fastapi/core_api/datamodels/dags.py | 6 +
.../core_api/datamodels/import_error.py | 1 +
.../core_api/datamodels/task_instance_history.py | 19 +-
.../core_api/datamodels/task_instances.py | 23 +-
.../api_fastapi/core_api/datamodels/ui/calendar.py | 1 +
.../api_fastapi/core_api/datamodels/ui/dags.py | 14 +
.../api_fastapi/core_api/openapi/_private_ui.yaml | 145 +
.../core_api/openapi/v2-rest-api-generated.yaml | 273 +-
.../core_api/routes/public/connections.py | 6 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 6 +-
.../core_api/routes/public/dag_sources.py | 3 +-
.../core_api/routes/public/dag_warning.py | 6 +-
.../api_fastapi/core_api/routes/public/dags.py | 26 +-
.../core_api/routes/public/event_logs.py | 31 +-
.../api_fastapi/core_api/routes/public/hitl.py | 21 +-
.../core_api/routes/public/import_error.py | 2 +
.../api_fastapi/core_api/routes/public/job.py | 10 +-
.../api_fastapi/core_api/routes/public/log.py | 2 +-
.../core_api/routes/public/task_instances.py | 15 +-
.../core_api/routes/public/task_state_store.py | 7 +-
.../core_api/routes/public/variables.py | 2 +-
.../api_fastapi/core_api/routes/ui/assets.py | 5 +
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 51 +
.../core_api/routes/ui/partitioned_dag_runs.py | 1 +
.../api_fastapi/core_api/routes/ui/teams.py | 2 +
.../src/airflow/api_fastapi/core_api/security.py | 34 +
.../core_api/services/public/dag_run.py | 17 +-
.../api_fastapi/core_api/services/public/dags.py | 96 +
.../core_api/services/public/task_instances.py | 41 +
.../api_fastapi/core_api/services/ui/calendar.py | 10 +-
.../src/airflow/api_fastapi/execution_api/app.py | 2 +
.../execution_api/datamodels/taskinstance.py | 13 +-
.../execution_api/routes/asset_events.py | 8 +-
.../api_fastapi/execution_api/routes/assets.py | 14 +-
.../api_fastapi/execution_api/routes/dag_runs.py | 18 +-
.../api_fastapi/execution_api/routes/hitl.py | 74 +-
.../execution_api/routes/task_instances.py | 159 +-
.../execution_api/routes/task_reschedules.py | 6 +-
.../api_fastapi/execution_api/routes/xcoms.py | 12 +
.../api_fastapi/execution_api/versions/__init__.py | 6 +
.../execution_api/versions/v2026_10_30.py | 35 +-
.../airflow/cli/commands/dag_processor_command.py | 26 +-
.../src/airflow/config_templates/config.yml | 43 +-
.../src/airflow/dag_processing/bundles/manager.py | 40 +-
.../src/airflow/dag_processing/collection.py | 127 +-
airflow-core/src/airflow/dag_processing/dagbag.py | 240 +-
.../airflow/dag_processing/importers/__init__.py | 39 -
.../src/airflow/dag_processing/importers/base.py | 266 --
.../dag_processing/importers/python_importer.py | 360 --
airflow-core/src/airflow/dag_processing/manager.py | 152 +-
.../src/airflow/dag_processing/processor.py | 160 +-
.../src/airflow/executors/base_executor.py | 123 +-
.../src/airflow/executors/local_executor.py | 13 +-
.../src/airflow/executors/workloads/task.py | 3 +-
.../src/airflow/executors/workloads/types.py | 17 +-
.../src/airflow/jobs/scheduler_job_runner.py | 408 +-
..._3_4_0_allocate_pending_task_attempt_numbers.py | 200 +
...9_3_4_0_add_source_reference_to_import_error.py | 34 +-
.../0140_3_4_0_add_language_to_dag_code.py | 36 +-
..._3_4_0_add_timetable_asset_gated_to_dagmodel.py | 55 +
airflow-core/src/airflow/models/dag.py | 32 +-
airflow-core/src/airflow/models/dag_version.py | 5 +
airflow-core/src/airflow/models/dagcode.py | 48 +-
airflow-core/src/airflow/models/dagrun.py | 67 +-
airflow-core/src/airflow/models/dagwarning.py | 31 +-
airflow-core/src/airflow/models/errors.py | 12 +-
airflow-core/src/airflow/models/serialized_dag.py | 19 +-
airflow-core/src/airflow/models/taskinstance.py | 70 +-
airflow-core/src/airflow/plugins_manager.py | 42 +
airflow-core/src/airflow/serialization/encoders.py | 9 +
airflow-core/src/airflow/serialization/schema.json | 2 +-
airflow-core/src/airflow/settings.py | 14 +-
.../ti_deps/deps/not_previously_skipped_dep.py | 6 +-
airflow-core/src/airflow/timetables/_cron.py | 2 +-
airflow-core/src/airflow/timetables/assets.py | 112 +-
airflow-core/src/airflow/timetables/base.py | 16 +
airflow-core/src/airflow/timetables/simple.py | 1 +
.../src/airflow/ui/openapi-gen/queries/common.ts | 36 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 61 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 61 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 74 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 61 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 272 +-
.../ui/openapi-gen/requests/services.gen.ts | 77 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 171 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 8 +-
.../airflow/ui/public/i18n/locales/ar/dags.json | 2 -
.../airflow/ui/public/i18n/locales/ca/dags.json | 4 -
.../airflow/ui/public/i18n/locales/de/assets.json | 1 +
.../airflow/ui/public/i18n/locales/de/browse.json | 30 +
.../airflow/ui/public/i18n/locales/de/common.json | 35 +-
.../ui/public/i18n/locales/de/components.json | 5 +
.../src/airflow/ui/public/i18n/locales/de/dag.json | 5 +
.../airflow/ui/public/i18n/locales/de/dags.json | 26 +-
.../ui/public/i18n/locales/de/dashboard.json | 17 +-
.../airflow/ui/public/i18n/locales/el/dags.json | 2 -
.../airflow/ui/public/i18n/locales/en/assets.json | 1 +
.../airflow/ui/public/i18n/locales/en/common.json | 18 +-
.../src/airflow/ui/public/i18n/locales/en/dag.json | 5 +
.../airflow/ui/public/i18n/locales/en/dags.json | 17 +-
.../airflow/ui/public/i18n/locales/es/dags.json | 4 -
.../airflow/ui/public/i18n/locales/fr/dags.json | 2 -
.../airflow/ui/public/i18n/locales/he/dags.json | 2 -
.../airflow/ui/public/i18n/locales/hi/dags.json | 2 -
.../airflow/ui/public/i18n/locales/ko/browse.json | 18 +-
.../airflow/ui/public/i18n/locales/ko/common.json | 12 +
.../ui/public/i18n/locales/ko/components.json | 1 +
.../airflow/ui/public/i18n/locales/ko/dags.json | 4 -
.../ui/public/i18n/locales/ko/dashboard.json | 17 +-
.../airflow/ui/public/i18n/locales/pl/admin.json | 30 +-
.../airflow/ui/public/i18n/locales/pl/assets.json | 21 +-
.../airflow/ui/public/i18n/locales/pl/browse.json | 38 +
.../airflow/ui/public/i18n/locales/pl/common.json | 103 +-
.../ui/public/i18n/locales/pl/components.json | 29 +-
.../src/airflow/ui/public/i18n/locales/pl/dag.json | 13 +-
.../airflow/ui/public/i18n/locales/pl/dags.json | 30 +-
.../ui/public/i18n/locales/pl/dashboard.json | 6 +-
.../airflow/ui/public/i18n/locales/pl/hitl.json | 2 +-
.../airflow/ui/public/i18n/locales/ru/dags.json | 2 -
.../airflow/ui/public/i18n/locales/zh-CN/dags.json | 4 -
.../airflow/ui/public/i18n/locales/zh-TW/dags.json | 4 -
.../TaskInstance/ClearGroupTaskInstanceDialog.tsx | 40 +-
.../TaskInstance/ClearTaskInstanceDialog.test.tsx | 127 +
.../Clear/TaskInstance/ClearTaskInstanceDialog.tsx | 23 +-
.../src/components/DataTable/searchParams.test.ts | 21 +-
.../ui/src/components/DataTable/searchParams.ts | 16 +-
.../ui/src/components/FilterBar/FilterBar.test.tsx | 21 +
.../ui/src/components/FilterBar/FilterBar.tsx | 31 +-
.../FilterBar/filters/RunStateFilter.tsx | 234 +
.../FilterBar/filters/runStateParams.test.ts | 95 +
.../components/FilterBar/filters/runStateParams.ts | 76 +
.../airflow/ui/src/components/FilterBar/types.ts | 14 +-
.../ui/src/components/PauseOrDrainChoiceModal.tsx | 66 +
.../ui/src/components/TaskTrySelect.test.tsx | 6 +-
.../airflow/ui/src/components/TaskTrySelect.tsx | 5 +-
.../src/airflow/ui/src/components/TogglePause.tsx | 44 +-
.../TriggerDag/TriggerDAGButton.test.tsx | 112 +
.../src/components/TriggerDag/TriggerDAGButton.tsx | 7 +-
.../src/airflow/ui/src/constants/filterConfigs.tsx | 38 +-
.../src/airflow/ui/src/constants/localStorage.ts | 2 +
.../src/airflow/ui/src/constants/searchParams.ts | 6 +
.../ui/src/hooks/useAdvancedSearch.test.tsx | 148 +
.../src/airflow/ui/src/hooks/useAdvancedSearch.ts | 36 +-
.../airflow/ui/src/hooks/useUserSettings.test.tsx | 21 +
.../src/airflow/ui/src/hooks/useUserSettings.ts | 4 +
.../src/airflow/ui/src/layouts/Details/NavTabs.tsx | 4 +-
.../src/airflow/ui/src/mocks/handlers/dag_runs.ts | 49 +-
.../src/airflow/ui/src/mocks/handlers/dags.ts | 16 +-
.../ui/src/pages/AssetsList/AssetsList.test.tsx | 113 +-
.../airflow/ui/src/pages/AssetsList/AssetsList.tsx | 21 +-
.../ui/src/pages/Connections/Connections.tsx | 4 +
.../ui/src/pages/Dag/Calendar/CalendarCell.tsx | 36 +-
.../ui/src/pages/Dag/Calendar/CalendarLegend.tsx | 11 +
.../ui/src/pages/Dag/Calendar/CalendarTooltip.tsx | 14 +-
.../src/pages/Dag/Calendar/HourlyCalendarView.tsx | 10 +-
.../src/pages/Dag/Calendar/calendarUtils.test.ts | 22 +
.../ui/src/pages/Dag/Calendar/calendarUtils.ts | 4 +
.../src/airflow/ui/src/pages/Dag/Calendar/types.ts | 1 +
.../src/airflow/ui/src/pages/Dag/Code/Code.tsx | 10 +-
.../airflow/ui/src/pages/DagRuns/DagRuns.test.tsx | 27 +
.../src/airflow/ui/src/pages/DagRuns/DagRuns.tsx | 10 +-
.../ui/src/pages/DagRuns/DagRunsFilters.tsx | 1 +
.../pages/DagsList/BulkPauseDrainDagsButton.tsx | 105 +
.../src/pages/DagsList/BulkUnpauseDagsButton.tsx | 85 +
.../DagsList/DagFolderTree/DagFolderTree.test.tsx | 323 ++
.../pages/DagsList/DagFolderTree/DagFolderTree.tsx | 216 +
.../DagsList/DagFolderTree/buildFolderTree.test.ts | 119 +
.../DagsList/DagFolderTree/buildFolderTree.ts | 152 +
.../ui/src/pages/DagsList/DagFolderTree/index.ts | 20 +-
.../src/pages/DagsList/DagsFilters/DagsFilters.tsx | 3 +-
.../ui/src/pages/DagsList/DagsList.test.tsx | 184 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 210 +-
.../src/airflow/ui/src/pages/Events/Events.tsx | 4 +
.../ui/src/pages/HITLTaskInstances/HITLFilters.tsx | 6 +
.../HITLTaskInstances/HITLTaskInstances.test.tsx | 62 +-
.../pages/HITLTaskInstances/HITLTaskInstances.tsx | 21 +
airflow-core/src/airflow/ui/src/pages/Jobs.tsx | 31 +-
.../src/airflow/ui/src/pages/Pools/PoolBarCard.tsx | 12 +-
.../src/airflow/ui/src/pages/Run/Details.tsx | 4 +-
.../ui/src/pages/Settings/Settings.test.tsx | 8 +
.../src/airflow/ui/src/pages/Settings/Settings.tsx | 13 +
.../ui/src/pages/TaskInstance/Details.test.tsx | 137 +
.../airflow/ui/src/pages/TaskInstance/Details.tsx | 16 +
.../ui/src/pages/TaskInstance/Header.test.tsx | 54 +
.../airflow/ui/src/pages/TaskInstance/Header.tsx | 20 +
.../ui/src/pages/TaskInstance/Logs/Logs.tsx | 80 +-
.../pages/TaskInstance/Logs/LogsTryNumber.test.tsx | 174 +
.../src/pages/TaskInstance/TaskInstance.test.tsx | 102 +-
.../ui/src/pages/TaskInstance/TaskInstance.tsx | 26 +-
.../index.ts => pages/TaskInstance/stateReason.ts} | 24 +-
.../TaskInstances/BulkClearTaskInstancesButton.tsx | 34 +-
.../airflow/ui/src/pages/Variables/Variables.tsx | 4 +
.../ui/src/queries/useBulkClearTaskInstances.ts | 2 +
.../ui/src/queries/useBulkSetDagSchedulingState.ts | 89 +
.../src/airflow/ui/src/queries/useDagFolders.ts | 32 +-
.../src/airflow/ui/src/queries/useDags.tsx | 9 +
.../utils/{index.ts => hasDagRunConfig.test.ts} | 25 +-
.../src/airflow/ui/src/utils/hasDagRunConfig.ts | 23 +-
airflow-core/src/airflow/ui/src/utils/index.ts | 1 +
.../ui/src/utils/useFiltersHandler.test.tsx | 63 +
.../src/airflow/ui/src/utils/useFiltersHandler.ts | 22 +-
.../ui/tests/e2e/fixtures/task-tries-data.ts | 46 +
.../src/airflow/ui/tests/e2e/global-setup.ts | 14 +-
.../src/airflow/ui/tests/e2e/global-teardown.ts | 2 +
.../src/airflow/ui/tests/e2e/pages/DagsPage.ts | 18 +-
.../airflow/ui/tests/e2e/specs/task-tries.spec.ts | 111 +
airflow-core/src/airflow/utils/db.py | 4 +-
airflow-core/src/airflow/utils/file.py | 50 +-
airflow-core/tests/integration/otel/test_otel.py | 2 +-
.../tests/unit/always/test_project_structure.py | 3 -
.../tests/unit/api/common/test_delete_dag.py | 49 +
.../api_fastapi/auth/managers/simple/conftest.py | 3 +-
airflow-core/tests/unit/api_fastapi/conftest.py | 27 +-
.../core_api/routes/public/test_auth.py | 28 +-
.../core_api/routes/public/test_backfills.py | 20 +-
.../core_api/routes/public/test_connections.py | 9 +-
.../core_api/routes/public/test_dag_bundles.py | 43 +-
.../core_api/routes/public/test_dag_parsing.py | 18 +-
.../core_api/routes/public/test_dag_run.py | 134 +-
.../core_api/routes/public/test_dag_sources.py | 4 +
.../core_api/routes/public/test_dag_warning.py | 19 +
.../core_api/routes/public/test_dags.py | 210 +
.../core_api/routes/public/test_event_logs.py | 29 +-
.../core_api/routes/public/test_extra_links.py | 33 +-
.../core_api/routes/public/test_hitl.py | 77 +-
.../core_api/routes/public/test_import_error.py | 76 +-
.../api_fastapi/core_api/routes/public/test_job.py | 51 +
.../api_fastapi/core_api/routes/public/test_log.py | 14 +-
.../core_api/routes/public/test_task_instances.py | 437 +-
.../routes/public/test_task_state_store.py | 14 +
.../api_fastapi/core_api/routes/ui/test_assets.py | 23 +
.../core_api/routes/ui/test_calendar.py | 239 +-
.../api_fastapi/core_api/routes/ui/test_dags.py | 226 +
.../unit/api_fastapi/execution_api/conftest.py | 18 +-
.../unit/api_fastapi/execution_api/test_app.py | 84 +-
.../execution_api/versions/head/test_hitl.py | 36 +-
.../versions/head/test_task_instances.py | 449 +-
.../versions/v2026_10_30/test_dag_run_notes.py | 43 +
.../versions/v2026_10_30/test_task_instances.py | 166 +
airflow-core/tests/unit/api_fastapi/test_app.py | 108 +-
.../cli/commands/test_dag_processor_command.py | 58 +
airflow-core/tests/unit/core/test_settings.py | 120 +
.../bundles/test_dag_bundle_manager.py | 86 +-
.../unit/dag_processing/importers/test_registry.py | 99 -
.../tests/unit/dag_processing/test_collection.py | 433 +-
.../tests/unit/dag_processing/test_dagbag.py | 283 +-
.../tests/unit/dag_processing/test_manager.py | 416 +-
.../tests/unit/dag_processing/test_processor.py | 32 +-
.../tests/unit/executors/test_base_executor.py | 278 +-
.../tests/unit/executors/test_local_executor.py | 10 +-
.../tests/unit/executors/test_workloads.py | 16 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 1059 ++++-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 23 +-
...est_0049_remove_pickled_data_from_xcom_table.py | 237 -
...t_0055_remove_pickled_data_from_dagrun_table.py | 143 -
.../test_0080_deadline_callback_migration.py | 268 --
.../test_0094_deadline_callback_migration.py | 178 -
.../test_0117_deadline_interval_json_migration.py | 91 -
...9_add_indexes_on_serialized_dag_and_dag_code.py | 55 -
.../migrations/test_0131_lower_case_team_names.py | 138 -
.../test_0136_fold_task_map_into_xcom.py | 184 -
airflow-core/tests/unit/models/test_cleartasks.py | 190 +-
airflow-core/tests/unit/models/test_dag.py | 69 +-
airflow-core/tests/unit/models/test_dag_version.py | 24 +
airflow-core/tests/unit/models/test_dagcode.py | 47 +
airflow-core/tests/unit/models/test_dagrun.py | 97 +-
airflow-core/tests/unit/models/test_dagwarning.py | 38 +-
airflow-core/tests/unit/models/test_errors.py | 86 +
.../tests/unit/models/test_taskinstance.py | 174 +-
airflow-core/tests/unit/models/test_trigger.py | 3 +
.../tests/unit/plugins/test_plugins_manager.py | 61 +
airflow-core/tests/unit/state/test_metastore.py | 9 +
.../deps/test_not_previously_skipped_dep.py | 44 +
.../tests/unit/timetables/test_assets_timetable.py | 227 +-
.../unit/timetables/test_trigger_timetable.py | 7 +
airflow-core/tests/unit/utils/test_file.py | 37 +-
airflow-core/tests/unit/utils/test_session.py | 18 +-
airflow-ctl-tests/pyproject.toml | 4 +-
airflow-ctl/pyproject.toml | 4 +-
.../airflowctl/api/datamodels/auth_generated.py | 2 +-
.../src/airflowctl/api/datamodels/generated.py | 103 +-
airflow-ctl/src/airflowctl/api/operations.py | 2 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 12 +-
.../tests/airflow_ctl/api/test_operations.py | 20 +-
.../tests/airflow_ctl/ctl/test_cli_config.py | 34 +-
airflow-e2e-tests/pyproject.toml | 6 +-
.../go_sdk_tests/test_go_sdk_taskflow_binding.py | 72 +-
.../airflow_e2e_tests/openlineage_tests/README.md | 2 +-
.../dags_extra/e2e_versioned_bundle.py | 4 +-
chart/docs/manage-dag-files.rst | 4 +
chart/pyproject.toml | 4 +-
clients/python/pyproject.toml | 4 +-
contributing-docs/05_pull_requests.rst | 11 +
contributing-docs/25_maintainer_pr_triage.md | 4 +
contributing-docs/30_new_language_sdk.rst | 6 +
contributing-docs/32_open_pull_request_limit.rst | 169 +
contributing-docs/README.rst | 3 +
dev/README_RELEASE_AIRFLOW.md | 6 +-
dev/README_RELEASE_PROVIDERS.md | 87 +-
dev/breeze/doc/03_developer_tasks.rst | 44 +-
dev/breeze/doc/04_troubleshooting.rst | 11 +
dev/breeze/doc/05_test_commands.rst | 14 +
dev/breeze/doc/08_ci_tasks.rst | 4 +-
dev/breeze/doc/ci/02_images.md | 4 +-
dev/breeze/doc/ci/04_selective_checks.md | 9 +-
dev/breeze/doc/ci/05_workflows.md | 26 +
dev/breeze/doc/images/output-commands.svg | 165 +-
dev/breeze/doc/images/output_build-docs.svg | 4 +-
dev/breeze/doc/images/output_build-docs.txt | 2 +-
dev/breeze/doc/images/output_cleanup.svg | 2 +-
dev/breeze/doc/images/output_cleanup.txt | 2 +-
dev/breeze/doc/images/output_down.svg | 48 +-
dev/breeze/doc/images/output_down.txt | 2 +-
...tput_release-management_add-back-references.svg | 4 +-
...tput_release-management_add-back-references.txt | 2 +-
...elease-management_classify-provider-changes.svg | 4 +-
...elease-management_classify-provider-changes.txt | 2 +-
...management_generate-issue-content-providers.svg | 4 +-
...management_generate-issue-content-providers.txt | 2 +-
...ease-management_generate-providers-metadata.svg | 10 +-
...ease-management_generate-providers-metadata.txt | 2 +-
...e-management_prepare-provider-distributions.svg | 4 +-
...e-management_prepare-provider-distributions.txt | 2 +-
...e-management_prepare-provider-documentation.svg | 4 +-
...e-management_prepare-provider-documentation.txt | 2 +-
.../output_release-management_publish-docs.svg | 4 +-
.../output_release-management_publish-docs.txt | 2 +-
dev/breeze/doc/images/output_run.svg | 45 +-
dev/breeze/doc/images/output_run.txt | 2 +-
...output_sbom_generate-providers-requirements.svg | 2 +-
...output_sbom_generate-providers-requirements.txt | 2 +-
dev/breeze/doc/images/output_shell.svg | 285 +-
dev/breeze/doc/images/output_shell.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 237 +-
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
.../doc/images/output_testing_core-tests.svg | 145 +-
.../doc/images/output_testing_core-tests.txt | 2 +-
.../doc/images/output_testing_providers-tests.svg | 161 +-
.../doc/images/output_testing_providers-tests.txt | 2 +-
.../images/output_workflow-run_publish-docs.svg | 4 +-
.../images/output_workflow-run_publish-docs.txt | 2 +-
dev/breeze/pyproject.toml | 10 +-
.../src/airflow_breeze/commands/ci_commands.py | 9 +
.../airflow_breeze/commands/ci_image_commands.py | 4 +-
.../src/airflow_breeze/commands/common_options.py | 10 +-
.../airflow_breeze/commands/developer_commands.py | 52 +-
.../commands/developer_commands_config.py | 2 +-
.../airflow_breeze/commands/kubernetes_commands.py | 2 +-
.../src/airflow_breeze/commands/main_command.py | 23 +-
.../commands/release_management_commands.py | 6 +-
.../airflow_breeze/commands/testing_commands.py | 14 +-
.../commands/testing_commands_config.py | 5 +-
dev/breeze/src/airflow_breeze/global_constants.py | 19 +-
.../src/airflow_breeze/params/shell_params.py | 17 +-
.../prepare_providers/provider_documentation.py | 11 +-
.../templates/pyproject_TEMPLATE.toml.jinja2 | 2 +-
.../airflow_breeze/utils/docker_command_utils.py | 248 +-
dev/breeze/src/airflow_breeze/utils/path_utils.py | 10 +-
.../src/airflow_breeze/utils/selective_checks.py | 22 +
dev/breeze/tests/test_ci_image_commands.py | 20 +
dev/breeze/tests/test_ci_upgrade.py | 16 +-
dev/breeze/tests/test_developer_commands.py | 38 +-
dev/breeze/tests/test_docker_command_utils.py | 487 +-
dev/breeze/tests/test_provider_documentation.py | 48 +
dev/breeze/tests/test_selective_checks.py | 122 +-
dev/breeze/tests/test_shell_params.py | 82 +
dev/breeze/uv.lock | 160 +-
dev/close_prs_over_open_pr_limit.py | 353 ++
dev/mypy/pyproject.toml | 4 +-
dev/pyproject.toml | 4 +-
dev/registry/pyproject.toml | 4 +-
devel-common/pyproject.toml | 6 +-
devel-common/src/tests_common/pytest_plugin.py | 56 +-
devel-common/src/tests_common/test_utils/config.py | 24 +-
.../src/tests_common/test_utils/mock_executor.py | 5 +-
.../src/tests_common/test_utils/mock_plugins.py | 42 +-
.../src/tests_common/test_utils/providers.py | 2 +-
.../__init__.py => devel-common/tests/conftest.py | 3 +
.../tests/unit/tests_common/test_dag_maker.py | 103 +
docker-stack-docs/pyproject.toml | 4 +-
docker-tests/pyproject.toml | 4 +-
docs/spelling_wordlist.txt | 8 +
generated/PYPI_README.md | 10 +-
generated/known_airflow_exceptions.txt | 2 +-
generated/known_sdk_imports_in_core.txt | 8 +-
generated/provider_metadata.json | 496 +-
go-sdk/.pre-commit-config.yaml | 7 +
go-sdk/Justfile | 4 +
go-sdk/README.md | 88 +-
go-sdk/adr/0006-cross-language-argument-binding.md | 15 +-
.../adr/0007-mixed-lang-task-handler-interface.md | 6 +-
go-sdk/adr/0008-native-dag-interface.md | 25 +-
go-sdk/airflow/bundle.go | 99 +-
go-sdk/airflow/bundle_test.go | 155 +-
go-sdk/airflow/dag.go | 323 ++
go-sdk/airflow/dag_test.go | 545 +++
go-sdk/airflow/enums.go | 156 +
go-sdk/airflow/enums_test.go | 221 +
go-sdk/airflow/inputs.go | 145 +
go-sdk/airflow/inputs_test.go | 437 ++
go-sdk/airflow/serve.go | 2 +-
go-sdk/airflow/spec.gen.go | 170 +
go-sdk/airflow/spec.go | 96 +
go-sdk/airflow/task_handler.go | 29 +-
go-sdk/airflow/task_handler_test.go | 6 +-
go-sdk/airflow/task_option.go | 49 +
go-sdk/airflow/testdata/foreigntaskoption/main.go | 34 +
go-sdk/airflow/trigger_dag_run.go | 165 +
go-sdk/airflow/trigger_dag_run_test.go | 276 ++
.../cmd/airflow-go-pack/pack_integration_test.go | 4 +-
go-sdk/dags/go_examples.py | 28 +-
.../bundle/concurrentxcom/concurrentxcom_test.go | 2 +-
go-sdk/example/bundle/main.go | 14 +-
.../bundle/taskflowbinding/taskflowbinding.go | 61 +-
.../bundle/taskflowbinding/taskflowbinding_test.go | 44 +-
go-sdk/internal/bundle/task.go | 30 +-
go-sdk/internal/genlicense/genlicense.go | 71 +
go-sdk/internal/genlicense/genlicense_test.go | 83 +
go-sdk/internal/genspec/authoring.go | 470 ++
go-sdk/internal/genspec/authoring_test.go | 329 ++
go-sdk/internal/genspec/main.go | 109 +
go-sdk/internal/genspec/main_test.go | 37 +
go-sdk/internal/genspec/normalize.go | 176 +
go-sdk/internal/genspec/normalize_test.go | 257 +
go-sdk/pkg/binding/binding.go | 112 +-
go-sdk/pkg/binding/binding_test.go | 133 +-
go-sdk/pkg/execution/client.go | 22 +-
go-sdk/pkg/execution/client_test.go | 6 +-
go-sdk/pkg/execution/comms.go | 13 +-
go-sdk/pkg/execution/comms_test.go | 10 +-
.../pkg/execution/genmodels/discriminators.gen.go | 4 +
go-sdk/pkg/execution/genmodels/gen.go | 13 +-
go-sdk/pkg/execution/genmodels/gen/main.go | 49 +-
go-sdk/pkg/execution/genmodels/models.gen.go | 171 +-
go-sdk/pkg/execution/integration_test.go | 14 +-
go-sdk/pkg/execution/messages.go | 6 +-
go-sdk/pkg/execution/messages_test.go | 27 +-
{ts-sdk => go-sdk}/schema/dag-schema.json | 2 +-
.../schema/supervisor-schema.json | 65 +
go-sdk/sdk/sdk.go | 4 +-
java-sdk/README.md | 35 +-
.../airflow/example/ExampleBundleBuilder.java | 3 +-
.../example/nativedag/InterfaceExample.java | 76 +
java-sdk/gradle/verification-metadata.xml | 68 -
.../org/apache/airflow/sdk/BuilderProcessor.kt | 120 +-
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 174 +-
java-sdk/sdk/build.gradle.kts | 443 +-
{ts-sdk => java-sdk/sdk}/schema/dag-schema.json | 2 +-
.../src/main/kotlin/org/apache/airflow/sdk/Arg.kt | 78 +
.../main/kotlin/org/apache/airflow/sdk/Builder.kt | 109 -
.../main/kotlin/org/apache/airflow/sdk/Bundle.kt | 47 +-
.../main/kotlin/org/apache/airflow/sdk/Context.kt | 10 +-
.../main/kotlin/org/apache/airflow/sdk/DagDef.kt | 104 +-
.../src/main/kotlin/org/apache/airflow/sdk/Deps.kt | 91 +
.../kotlin/org/apache/airflow/sdk/InputTask.kt | 2 +-
.../org/apache/airflow/sdk/execution/Task.kt | 7 +-
.../org/apache/airflow/sdk/internal/ArgValues.kt | 124 +
.../org/apache/airflow/sdk/internal/Fields.kt | 107 +
.../org/apache/airflow/sdk/internal/TaskArgs.kt | 42 +-
.../org/apache/airflow/sdk/ArgTestSupport.kt | 15 +
.../kotlin/org/apache/airflow/sdk/ArgValuesTest.kt | 2 +-
.../kotlin/org/apache/airflow/sdk/BundleTest.kt | 79 +
.../kotlin/org/apache/airflow/sdk/DagDefTest.kt | 254 +
.../kotlin/org/apache/airflow/sdk/InputTaskTest.kt | 90 +
.../org/apache/airflow/sdk/execution/TaskTest.kt | 24 +
.../apache/airflow/sdk/internal/ArgValuesTest.kt | 266 ++
kubernetes-tests/pyproject.toml | 4 +-
.../test_kubernetes_pod_operator.py | 2 +-
performance/pyproject.toml | 2 +-
providers-summary-docs/pyproject.toml | 4 +-
providers/.pre-commit-config.yaml | 7 +
providers/airbyte/pyproject.toml | 2 +-
providers/akeyless/pyproject.toml | 2 +-
providers/alibaba/pyproject.toml | 2 +-
providers/amazon/README.rst | 4 +-
providers/amazon/docs/index.rst | 10 +-
providers/amazon/docs/message-queues/index.rst | 55 +
providers/amazon/docs/operators/bedrock.rst | 40 +
providers/amazon/docs/operators/duckdb.rst | 180 +
providers/amazon/docs/operators/ecs.rst | 35 +
.../amazon/docs/operators/emr/emr_serverless.rst | 23 +
providers/amazon/provider.yaml | 32 +
providers/amazon/pyproject.toml | 21 +-
.../airflow/providers/amazon/aws/hooks/bedrock.py | 229 +-
.../airflow/providers/amazon/aws/hooks/duckdb.py | 277 ++
.../src/airflow/providers/amazon/aws/hooks/eks.py | 6 +-
.../src/airflow/providers/amazon/aws/hooks/emr.py | 51 +
.../src/airflow/providers/amazon/aws/hooks/s3.py | 8 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 3 +
.../airflow/providers/amazon/aws/operators/emr.py | 112 +
.../airflow/providers/amazon/aws/queues/kinesis.py | 48 +
.../airflow/providers/amazon/aws/triggers/emr.py | 48 +
.../providers/amazon/aws/utils/task_log_fetcher.py | 38 +-
.../amazon/aws/waiters/emr-serverless.json | 37 +
.../airflow/providers/amazon/get_provider_info.py | 28 +-
.../tests/system/amazon/aws/example_duckdb.py | 158 +
.../amazon/aws/example_emr_serverless_session.py | 103 +
.../amazon/aws/example_kinesis_message_queue.py | 98 +
.../system/amazon/aws/example_neptune_analytics.py | 20 +-
.../tests/unit/amazon/aws/hooks/test_bedrock.py | 280 ++
.../tests/unit/amazon/aws/hooks/test_duckdb.py | 307 ++
.../amazon/tests/unit/amazon/aws/hooks/test_eks.py | 40 +-
.../unit/amazon/aws/hooks/test_emr_serverless.py | 57 +
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 19 +
.../aws/operators/test_emr_serverless_session.py | 137 +
.../tests/unit/amazon/aws/queues/test_kinesis.py | 185 +
.../amazon/aws/test_deferred_hook_configuration.py | 242 +-
.../tests/unit/amazon/aws/triggers/test_emr.py | 60 +
.../unit/amazon/aws/utils/test_task_log_fetcher.py | 36 +-
providers/anthropic/pyproject.toml | 4 +-
.../airflow/providers/anthropic/hooks/anthropic.py | 99 +-
.../tests/unit/anthropic/hooks/test_anthropic.py | 141 +-
providers/apache/arrow/pyproject.toml | 2 +-
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/docs/index.rst | 2 +-
providers/apache/hive/pyproject.toml | 4 +-
providers/apache/iceberg/pyproject.toml | 2 +-
providers/apache/impala/docs/index.rst | 8 +-
providers/apache/impala/pyproject.toml | 4 +-
providers/apache/kafka/docs/triggers.rst | 33 +
providers/apache/kafka/provider.yaml | 1 +
providers/apache/kafka/pyproject.toml | 2 +-
.../providers/apache/kafka/get_provider_info.py | 1 +
.../apache/kafka/triggers/shared_stream.py | 407 ++
.../providers/apache/kafka/version_compat.py | 2 +
.../apache/kafka/triggers/test_shared_stream.py | 259 ++
.../apache/kafka/triggers/test_shared_stream.py | 481 ++
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/pyproject.toml | 2 +-
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/pyproject.toml | 2 +-
.../unit/celery/executors/test_celery_executor.py | 4 +
providers/clickhousedb/pyproject.toml | 2 +-
providers/cloudant/pyproject.toml | 2 +-
providers/cncf/kubernetes/pyproject.toml | 2 +-
.../kubernetes/executors/kubernetes_executor.py | 12 +-
.../cncf/kubernetes/utils/xcom_sidecar.py | 2 +-
.../system/cncf/kubernetes/example_kubernetes.py | 2 +-
.../cncf/kubernetes/example_kubernetes_async.py | 2 +-
.../executors/test_kubernetes_executor.py | 34 +
.../unit/cncf/kubernetes/operators/test_pod.py | 6 +-
.../tests/unit/cncf/kubernetes/test_k8s_model.py | 47 +
.../cncf/kubernetes/{models => }/test_secret.py | 45 +
providers/cohere/pyproject.toml | 2 +-
providers/common/ai/README.rst | 50 +-
providers/common/ai/docs/agent_security.rst | 54 +-
providers/common/ai/docs/approval_gates.rst | 7 +-
providers/common/ai/docs/capabilities.rst | 137 +
providers/common/ai/docs/changelog.rst | 28 +-
providers/common/ai/docs/classifier_models.rst | 5 +
providers/common/ai/docs/code_mode.rst | 12 +-
providers/common/ai/docs/connections/index.rst | 62 +
providers/common/ai/docs/connections/langchain.rst | 5 +
.../common/ai/docs/connections/llamaindex.rst | 5 +
providers/common/ai/docs/durable_execution.rst | 19 +-
providers/common/ai/docs/examples.rst | 3 +
providers/common/ai/docs/features.rst | 15 +-
providers/common/ai/docs/frameworks/adk.rst | 109 +
providers/common/ai/docs/frameworks/index.rst | 174 +
.../common/ai/docs/frameworks/pydantic_ai.rst | 78 +
providers/common/ai/docs/frameworks/strands.rst | 186 +
providers/common/ai/docs/guardrails.rst | 60 -
providers/common/ai/docs/hitl_review.rst | 63 +-
providers/common/ai/docs/hooks/langchain.rst | 25 +-
providers/common/ai/docs/hooks/llamaindex.rst | 17 +
providers/common/ai/docs/index.rst | 58 +-
providers/common/ai/docs/installation.rst | 40 +-
providers/common/ai/docs/observability.rst | 120 +-
providers/common/ai/docs/operations.rst | 1 -
providers/common/ai/docs/operators/agent.rst | 170 +-
.../common/ai/docs/operators/document_loader.rst | 5 +
providers/common/ai/docs/operators/index.rst | 4 +-
.../ai/docs/operators/llamaindex_embedding.rst | 31 +-
.../ai/docs/operators/llamaindex_retrieval.rst | 23 +-
providers/common/ai/docs/operators/llm.rst | 35 +-
providers/common/ai/docs/operators/llm_batch.rst | 9 +-
providers/common/ai/docs/operators/llm_branch.rst | 7 +-
.../common/ai/docs/operators/llm_file_analysis.rst | 5 +
.../ai/docs/operators/llm_schema_compare.rst | 5 +
providers/common/ai/docs/operators/llm_sql.rst | 5 +
providers/common/ai/docs/quickstart.rst | 3 +-
providers/common/ai/docs/rag_pipelines.rst | 5 +
providers/common/ai/docs/redirects.txt | 1 +
providers/common/ai/docs/retry_policies.rst | 60 +-
providers/common/ai/docs/sandbox/backends.rst | 142 +-
providers/common/ai/docs/sandbox/configuration.rst | 251 +-
providers/common/ai/docs/sandbox/index.rst | 124 +-
providers/common/ai/docs/self_hosted_models.rst | 3 +-
providers/common/ai/docs/stability.rst | 188 +
providers/common/ai/docs/tool_approval.rst | 153 +
providers/common/ai/docs/toolsets/datafusion.rst | 18 +-
providers/common/ai/docs/toolsets/hook.rst | 63 +-
providers/common/ai/docs/toolsets/index.rst | 86 +-
providers/common/ai/docs/toolsets/langchain.rst | 39 +-
providers/common/ai/docs/toolsets/logging.rst | 5 +
.../common/ai/docs/toolsets/managed_agent.rst | 342 +-
.../common/ai/docs/toolsets/object_storage.rst | 127 +
providers/common/ai/docs/toolsets/skills.rst | 5 +
providers/common/ai/docs/toolsets/sql.rst | 45 +-
providers/common/ai/docs/troubleshooting.rst | 8 +-
providers/common/ai/provider.yaml | 6 +-
providers/common/ai/pyproject.toml | 19 +-
.../ai/src/airflow/providers/common/ai/__init__.py | 4 +-
.../airflow/providers/common/ai/batch/__init__.py | 2 +-
.../airflow/providers/common/ai/batch/anthropic.py | 10 +-
.../src/airflow/providers/common/ai/batch/base.py | 10 +
.../airflow/providers/common/ai/batch/dispatch.py | 5 +
.../airflow/providers/common/ai/batch/openai.py | 10 +-
.../airflow/providers/common/ai/batch/results.py | 5 +-
.../providers/common/ai/decorators/agent.py | 2 +-
.../airflow/providers/common/ai/decorators/llm.py | 2 +-
.../providers/common/ai/decorators/llm_batch.py | 7 +-
.../providers/common/ai/decorators/llm_branch.py | 2 +-
.../common/ai/decorators/llm_file_analysis.py | 7 +-
.../common/ai/decorators/llm_schema_compare.py | 7 +-
.../providers/common/ai/decorators/llm_sql.py | 7 +-
.../airflow/providers/common/ai/durable/base.py | 19 +-
.../providers/common/ai/durable/caching_model.py | 126 +-
.../providers/common/ai/durable/caching_toolset.py | 64 +-
.../providers/common/ai/durable/fingerprint.py | 12 +-
.../providers/common/ai/durable/replay_usage.py | 240 +
.../providers/common/ai/durable/step_counter.py | 4 +
.../airflow/providers/common/ai/durable/storage.py | 23 +-
.../common/ai/durable/task_state_store.py | 20 +-
.../common/ai/example_dags/example_adk_agent.py | 105 +
.../ai/example_dags/example_agent_capabilities.py | 27 +-
.../ai/example_dags/example_agent_tool_approval.py | 58 +
.../ai/example_dags/example_classifier_model.py | 8 +-
.../example_dags/example_object_storage_toolset.py | 48 +
.../ai/example_dags/example_pydantic_ai_agent.py | 72 +
.../ai/example_dags/example_sandbox_toolset.py | 170 +-
.../ai/example_dags/example_strands_agent.py | 91 +
.../src/airflow/providers/common/ai/exceptions.py | 47 +-
.../providers/common/ai/get_provider_info.py | 7 +-
.../airflow/providers/common/ai/hooks/langchain.py | 35 +-
.../providers/common/ai/hooks/llamaindex.py | 30 +-
.../providers/common/ai/hooks/pydantic_ai.py | 10 +
.../providers/common/ai/managed_agents/__init__.py | 49 +
.../providers/common/ai/managed_agents/base.py | 251 +
.../providers/common/ai/managed_agents/failover.py | 145 +
.../airflow/providers/common/ai/mixins/approval.py | 36 +-
.../airflow/providers/common/ai/observability.py | 19 +-
.../airflow/providers/common/ai/operators/agent.py | 964 +++-
.../common/ai/operators/document_loader.py | 5 +
.../common/ai/operators/llamaindex_embedding.py | 20 +-
.../common/ai/operators/llamaindex_retrieval.py | 21 +-
.../airflow/providers/common/ai/operators/llm.py | 44 +-
.../providers/common/ai/operators/llm_batch.py | 5 +
.../providers/common/ai/operators/llm_branch.py | 6 +-
.../common/ai/operators/llm_file_analysis.py | 5 +
.../common/ai/operators/llm_schema_compare.py | 5 +
.../providers/common/ai/operators/llm_sql.py | 5 +
.../providers/common/ai/policies/decision.py | 11 +
.../airflow/providers/common/ai/policies/retry.py | 17 +-
.../providers/common/ai/sandbox/__init__.py | 6 +
.../airflow/providers/common/ai/sandbox/base.py | 425 +-
.../airflow/providers/common/ai/sandbox/modal.py | 251 +-
.../providers/common/ai/sandbox/opensandbox.py | 599 +++
.../airflow/providers/common/ai/sandbox/output.py | 6 +-
.../src/airflow/providers/common/ai/sandbox/sbx.py | 112 +-
.../ai/src/airflow/providers/common/ai/skills.py | 5 +
.../airflow/providers/common/ai/tools/__init__.py | 172 +
.../providers/common/ai/tools/_from_toolset.py | 255 +
.../src/airflow/providers/common/ai/tools/adk.py | 112 +
.../airflow/providers/common/ai/tools/strands.py | 155 +
.../airflow/providers/common/ai/tools/tracing.py | 192 +
.../providers/common/ai/toolsets/__init__.py | 6 +-
.../providers/common/ai/toolsets/datafusion.py | 70 +-
.../airflow/providers/common/ai/toolsets/hook.py | 76 +-
.../common/ai/toolsets/langchain_bridge.py | 190 +-
.../providers/common/ai/toolsets/logging.py | 15 +-
.../providers/common/ai/toolsets/managed_agent.py | 393 +-
.../airflow/providers/common/ai/toolsets/mcp.py | 35 +-
.../providers/common/ai/toolsets/object_storage.py | 391 ++
.../providers/common/ai/toolsets/sandbox.py | 597 ++-
.../airflow/providers/common/ai/toolsets/skills.py | 5 +
.../airflow/providers/common/ai/toolsets/sql.py | 80 +-
.../providers/common/ai/triggers/llm_batch.py | 5 +
.../providers/common/ai/utils/coroutines.py} | 35 +-
.../providers/common/ai/utils/file_analysis.py | 123 +-
.../airflow/providers/common/ai/utils/logging.py | 60 +-
.../airflow/providers/common/ai/utils/masking.py | 120 +
.../providers/common/ai/utils/prompt_cache.py | 140 +
.../providers/common/ai/utils/query_results.py | 209 +-
.../providers/common/ai/utils/task_logger.py | 67 +
.../providers/common/ai/utils/tool_definition.py | 13 +-
.../providers/common/ai/utils/tool_metrics.py | 63 +
.../providers/common/ai/utils/toolset_base.py | 269 ++
.../providers/common/ai/utils/usage_budget.py | 215 +
.../common/ai/tests/system/common/ai/README.md | 37 +-
.../common/ai/example_sandbox_toolset_modal.py | 138 +-
.../ai/example_sandbox_toolset_opensandbox.py | 142 +
.../ai/tests/unit/common/ai/batch/test_dispatch.py | 2 +-
.../ai/tests/unit/common/ai/batch/test_results.py | 2 +-
.../ai/tests/unit/common/ai/batch/test_state.py | 2 +-
.../common/ai/tests/unit/common/ai/conftest.py | 45 +-
.../tests/unit/common/ai/decorators/test_agent.py | 31 +-
.../unit/common/ai/decorators/test_llm_batch.py | 3 +-
.../common/ai/decorators/test_llm_file_analysis.py | 5 +-
.../ai/tests/unit/common/ai/durable/test_base.py | 2 +-
.../unit/common/ai/durable/test_caching_model.py | 252 +-
.../unit/common/ai/durable/test_caching_toolset.py | 91 +-
.../unit/common/ai/durable/test_fingerprint.py | 20 +
.../unit/common/ai/durable/test_replay_cost.py | 173 +-
.../unit/common/ai/durable/test_replay_usage.py | 114 +
.../common/ai/durable/test_replay_verification.py | 2 +-
.../tests/unit/common/ai/durable/test_storage.py | 11 +-
.../common/ai/durable/test_task_state_store.py | 24 +-
.../tests/unit/common/ai/hooks/test_langchain.py | 66 +
.../tests/unit/common/ai/hooks/test_llamaindex.py | 72 +
.../tests/unit/common/ai/hooks/test_pydantic_ai.py | 15 +
.../unit/common/ai/managed_agents}/__init__.py | 0
.../unit/common/ai/managed_agents/test_base.py | 137 +
.../unit/common/ai/managed_agents/test_failover.py | 205 +
.../tests/unit/common/ai/mixins/test_approval.py | 6 +-
.../tests/unit/common/ai/operators/test_agent.py | 1866 +++++++-
.../ai/operators/test_agent_tool_approval.py | 599 +++
.../common/ai/operators/test_document_loader.py | 12 +-
.../ai/operators/test_llamaindex_embedding.py | 17 +-
.../ai/operators/test_llamaindex_retrieval.py | 19 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 24 +-
.../unit/common/ai/operators/test_llm_batch.py | 3 +-
.../unit/common/ai/operators/test_llm_branch.py | 4 +-
.../common/ai/operators/test_llm_file_analysis.py | 11 +-
.../tests/unit/common/ai/operators/test_llm_sql.py | 4 +-
.../ai/tests/unit/common/ai/sandbox/fake_modal.py | 17 +
.../ai/tests/unit/common/ai/sandbox/fake_tags.py | 63 +
.../ai/tests/unit/common/ai/sandbox/test_base.py | 336 +-
.../ai/tests/unit/common/ai/sandbox/test_modal.py | 207 +-
.../unit/common/ai/sandbox/test_opensandbox.py | 871 ++++
.../ai/tests/unit/common/ai/sandbox/test_sbx.py | 112 +
.../ai/tests/unit/common/ai/test_observability.py | 19 +
.../ai/tests/unit/common/ai/tools}/__init__.py | 0
.../unit/common/ai/tools/test__from_toolset.py | 375 ++
.../ai/tests/unit/common/ai/tools/test_adk.py | 157 +
.../ai/tests/unit/common/ai/tools/test_strands.py | 207 +
.../ai/tests/unit/common/ai/tools/test_tools.py | 145 +
.../ai/tests/unit/common/ai/tools/test_tracing.py | 230 +
.../unit/common/ai/toolsets/test_datafusion.py | 71 +-
.../ai/tests/unit/common/ai/toolsets/test_hook.py | 167 +-
.../common/ai/toolsets/test_langchain_bridge.py | 58 +-
.../tests/unit/common/ai/toolsets/test_logging.py | 18 +
.../unit/common/ai/toolsets/test_managed_agent.py | 403 +-
.../ai/tests/unit/common/ai/toolsets/test_mcp.py | 8 +
.../unit/common/ai/toolsets/test_object_storage.py | 422 ++
.../unit/common/ai/toolsets/test_retry_budget.py | 98 +
.../tests/unit/common/ai/toolsets/test_sandbox.py | 889 +++-
.../ai/tests/unit/common/ai/toolsets/test_sql.py | 116 +-
.../tests/unit/common/ai/utils/test_coroutines.py} | 23 +-
.../unit/common/ai/utils/test_file_analysis.py | 27 +-
.../ai/tests/unit/common/ai/utils/test_logging.py | 132 +-
.../ai/tests/unit/common/ai/utils/test_masking.py | 117 +
.../unit/common/ai/utils/test_prompt_cache.py | 209 +
.../unit/common/ai/utils/test_query_results.py | 176 +-
.../tests/unit/common/ai/utils/test_task_logger.py | 82 +
.../unit/common/ai/utils/test_tool_definition.py | 21 +-
.../unit/common/ai/utils/test_tool_metrics.py | 179 +
.../unit/common/ai/utils/test_toolset_base.py | 281 ++
.../unit/common/ai/utils/test_usage_budget.py | 242 +
providers/common/compat/pyproject.toml | 2 +-
.../common/compat/_set_during_execution.py | 40 +
.../src/airflow/providers/common/compat/sdk.py | 14 +-
.../common/compat/security/test_access_view.py | 8 +-
.../common/compat/test__set_during_execution.py | 43 +
.../compat/tests/unit/common/compat/test_sdk.py | 18 +-
providers/common/dataquality/pyproject.toml | 2 +-
providers/common/io/pyproject.toml | 2 +-
providers/common/messaging/pyproject.toml | 2 +-
providers/common/sql/docs/index.rst | 2 +-
providers/common/sql/pyproject.toml | 4 +-
providers/databricks/docs/index.rst | 2 +-
providers/databricks/pyproject.toml | 4 +-
providers/datadog/pyproject.toml | 2 +-
providers/dbt/cloud/pyproject.toml | 2 +-
providers/dingding/pyproject.toml | 2 +-
providers/discord/pyproject.toml | 2 +-
providers/docker/pyproject.toml | 2 +-
providers/duckdb/README.rst | 6 +-
providers/duckdb/docs/changelog.rst | 9 +-
providers/duckdb/docs/index.rst | 6 +-
providers/duckdb/docs/operators.rst | 6 +
providers/duckdb/provider.yaml | 2 +-
providers/duckdb/pyproject.toml | 8 +-
.../src/airflow/providers/duckdb/__init__.py | 2 +-
.../src/airflow/providers/duckdb/hooks/duckdb.py | 6 +-
.../airflow/providers/duckdb/operators/duckdb.py | 48 +-
.../tests/unit/duckdb/operators/test_duckdb.py | 33 +-
providers/edge3/pyproject.toml | 4 +-
providers/elasticsearch/pyproject.toml | 2 +-
providers/exasol/docs/index.rst | 8 +-
providers/exasol/pyproject.toml | 4 +-
providers/fab/docs/auth-manager/access-control.rst | 4 +
providers/fab/pyproject.toml | 6 +-
.../fab/auth_manager/api_fastapi/routes/roles.py | 14 +-
.../fab/auth_manager/api_fastapi/routes/users.py | 12 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 4 +-
.../fab/src/airflow/providers/fab/www/package.json | 2 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 10 +-
.../fab/src/airflow/providers/fab/www/views.py | 6 +-
.../unit/fab/auth_manager/api_fastapi/conftest.py | 21 +
.../auth_manager/api_fastapi/routes/test_roles.py | 161 +-
.../auth_manager/api_fastapi/routes/test_users.py | 128 +-
providers/fab/tests/unit/fab/www/test_views.py | 21 +-
providers/facebook/pyproject.toml | 2 +-
providers/ftp/pyproject.toml | 2 +-
providers/git/pyproject.toml | 2 +-
.../git/src/airflow/providers/git/bundles/git.py | 31 +-
.../git/src/airflow/providers/git/hooks/git.py | 38 +-
providers/git/tests/unit/git/bundles/test_git.py | 44 +
providers/git/tests/unit/git/hooks/test_git.py | 29 +
providers/github/pyproject.toml | 2 +-
providers/google/README.rst | 80 +-
providers/google/docs/index.rst | 90 +-
.../docs/operators/cloud/kubernetes_engine.rst | 20 +
.../google/docs/operators/cloud/vertex_ai.rst | 24 +
providers/google/pyproject.toml | 88 +-
.../google/cloud/hooks/vertex_ai/agent_engine.py | 159 +-
.../google/cloud/operators/kubernetes_engine.py | 114 +
.../kubernetes_engine/example_kubernetes_engine.py | 105 +-
.../unit/google/cloud/hooks/test_stackdriver.py | 2 +-
.../cloud/hooks/vertex_ai/test_agent_engine.py | 145 +
.../unit/google/cloud/links/test_cloud_tasks.py | 155 +
.../cloud/operators/test_kubernetes_engine.py | 146 +-
providers/grpc/pyproject.toml | 2 +-
providers/hashicorp/docs/index.rst | 2 +-
providers/hashicorp/pyproject.toml | 4 +-
providers/http/pyproject.toml | 2 +-
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/docs/index.rst | 2 +-
providers/jdbc/pyproject.toml | 4 +-
providers/jenkins/pyproject.toml | 2 +-
.../docs/auth-manager/manage/permissions.rst | 4 +
providers/keycloak/docs/changelog.rst | 10 +
providers/keycloak/pyproject.toml | 2 +-
.../keycloak/auth_manager/cli/commands.py | 21 +
.../keycloak/auth_manager/keycloak_auth_manager.py | 18 +-
.../providers/keycloak/auth_manager/middleware.py | 35 +-
.../providers/keycloak/auth_manager/resources.py | 5 +
.../keycloak/auth_manager/cli/test_commands.py | 35 +-
.../auth_manager/test_keycloak_auth_manager.py | 48 +
.../unit/keycloak/auth_manager/test_middleware.py | 97 +-
providers/microsoft/azure/README.rst | 34 +-
providers/microsoft/azure/docs/index.rst | 34 +-
providers/microsoft/azure/pyproject.toml | 41 +-
.../providers/microsoft/azure/hooks/data_lake.py | 13 +-
.../unit/microsoft/azure/hooks/test_data_lake.py | 61 +-
providers/microsoft/mssql/pyproject.toml | 2 +-
providers/microsoft/psrp/pyproject.toml | 2 +-
providers/microsoft/winrm/pyproject.toml | 2 +-
{airflow-core => providers/modal}/.gitignore | 0
{chart => providers/modal}/LICENSE | 0
NOTICE => providers/modal/NOTICE | 0
providers/{duckdb => modal}/README.rst | 33 +-
providers/modal/docs/.latest-doc-only-change.txt | 1 +
providers/{duckdb => modal}/docs/changelog.rst | 6 +-
.../docs/changelog.rst => modal/docs/commits.rst} | 17 +-
.../models/__init__.py => modal/docs/conf.py} | 10 +
providers/modal/docs/connections.rst | 85 +
providers/modal/docs/index.rst | 131 +
.../docs/installing-providers-from-sources.rst | 0
providers/modal/docs/integration-logos/Modal.png | Bin 0 -> 10357 bytes
providers/{anthropic => modal}/docs/security.rst | 0
providers/modal/docs/usage.rst | 158 +
providers/modal/provider.yaml | 74 +
providers/{vespa => modal}/pyproject.toml | 22 +-
.../modal/src/airflow}/__init__.py | 0
.../modal/src/airflow/providers}/__init__.py | 0
.../src/airflow/providers/modal}/__init__.py | 4 +-
.../src/airflow/providers/modal/exceptions.py | 19 +-
.../airflow/providers/modal/get_provider_info.py | 61 +
.../src/airflow/providers/modal/hooks}/__init__.py | 0
.../src/airflow/providers/modal/hooks/modal.py | 279 ++
providers/{airbyte => modal}/tests/conftest.py | 0
.../modal/tests/unit}/__init__.py | 0
.../modal/tests/unit/modal}/__init__.py | 0
.../modal/tests/unit/modal/hooks}/__init__.py | 0
.../modal/tests/unit/modal/hooks/test_modal.py | 372 ++
.../tests/unit/modal/test_exceptions.py} | 23 +-
providers/mongo/pyproject.toml | 2 +-
providers/mysql/pyproject.toml | 2 +-
providers/neo4j/pyproject.toml | 2 +-
providers/odbc/pyproject.toml | 2 +-
providers/openai/docs/changelog.rst | 19 +
providers/openai/pyproject.toml | 2 +-
.../src/airflow/providers/openai/exceptions.py | 11 +
.../src/airflow/providers/openai/hooks/openai.py | 50 +-
.../airflow/providers/openai/operators/openai.py | 63 +-
.../airflow/providers/openai/triggers/openai.py | 19 +-
.../openai/tests/unit/openai/hooks/test_openai.py | 36 +
.../tests/unit/openai/operators/test_openai.py | 114 +-
.../openai/tests/unit/openai/test_exceptions.py | 15 +-
.../tests/unit/openai/triggers/test_openai.py | 47 +-
providers/openfaas/pyproject.toml | 2 +-
providers/openlineage/docs/index.rst | 8 +-
providers/openlineage/pyproject.toml | 4 +-
providers/opensearch/pyproject.toml | 2 +-
.../providers/opensearch/log/os_task_handler.py | 3 +-
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/docs/index.rst | 2 +-
providers/postgres/pyproject.toml | 4 +-
providers/presto/docs/index.rst | 2 +-
providers/presto/pyproject.toml | 4 +-
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/pyproject.toml | 2 +-
providers/sftp/pyproject.toml | 2 +-
providers/singularity/pyproject.toml | 2 +-
providers/slack/pyproject.toml | 2 +-
providers/smtp/pyproject.toml | 2 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 2 +-
providers/snowflake/pyproject.toml | 2 +-
.../snowflake/hooks/snowflake_cortex_agent.py | 42 +-
.../snowflake/hooks/test_snowflake_cortex_agent.py | 106 +-
providers/sqlite/pyproject.toml | 2 +-
providers/ssh/pyproject.toml | 2 +-
providers/standard/docs/changelog.rst | 2 +-
providers/standard/pyproject.toml | 2 +-
.../airflow/providers/standard/operators/hitl.py | 6 +-
.../tests/unit/standard/operators/test_hitl.py | 4 +-
providers/tableau/pyproject.toml | 2 +-
providers/telegram/pyproject.toml | 2 +-
providers/teradata/docs/index.rst | 2 +-
providers/teradata/pyproject.toml | 4 +-
providers/trino/pyproject.toml | 2 +-
providers/vertica/docs/index.rst | 8 +-
providers/vertica/pyproject.toml | 4 +-
providers/vespa/pyproject.toml | 2 +-
providers/weaviate/pyproject.toml | 2 +-
providers/yandex/pyproject.toml | 2 +-
providers/ydb/docs/index.rst | 8 +-
providers/ydb/pyproject.toml | 4 +-
providers/zendesk/pyproject.toml | 2 +-
pyproject.toml | 20 +-
scripts/ci/analyze_ci_job_durations.py | 24 +-
scripts/ci/docker-compose/backend-mysql.yml | 6 +
scripts/ci/docker-compose/backend-postgres.yml | 10 +-
scripts/ci/docker-compose/base.yml | 9 +
.../ci/docker-compose/integration-cassandra.yml | 5 +
scripts/ci/docker-compose/integration-celery.yml | 8 +
scripts/ci/docker-compose/integration-drill.yml | 5 +
.../docker-compose/integration-elasticsearch.yml | 5 +
scripts/ci/docker-compose/integration-kafka.yml | 2 +
scripts/ci/docker-compose/integration-kerberos.yml | 7 +
scripts/ci/docker-compose/integration-keycloak.yml | 2 +
.../ci/docker-compose/integration-localstack.yml | 2 +
scripts/ci/docker-compose/integration-mongo.yml | 5 +
scripts/ci/docker-compose/integration-mssql.yml | 5 +
.../ci/docker-compose/integration-openlineage.yml | 5 +
.../ci/docker-compose/integration-opensearch.yml | 5 +
scripts/ci/docker-compose/integration-otel.yml | 11 +
scripts/ci/docker-compose/integration-pinot.yml | 2 +
scripts/ci/docker-compose/integration-qdrant.yml | 2 +
scripts/ci/docker-compose/integration-redis.yml | 7 +
scripts/ci/docker-compose/integration-statsd.yml | 8 +
.../ci/docker-compose/integration-tinkerpop.yml | 5 +
scripts/ci/docker-compose/integration-trino.yml | 5 +
scripts/ci/docker-compose/integration-ydb.yml | 2 +
scripts/ci/docker-compose/local-all-sources.yml | 6 +
scripts/ci/docker-compose/local.yml | 6 +
scripts/ci/docker-compose/remove-sources.yml | 1 +
scripts/ci/docker-compose/tests-sources.yml | 1 +
.../ci/lang_sdk_serialization}/__init__.py | 0
scripts/ci/lang_sdk_serialization/compare.py | 233 +
.../ci/lang_sdk_serialization/serialize_python.py | 140 +
scripts/ci/lang_sdk_serialization/test_dags.yaml | 166 +
scripts/ci/prek/changelog_duplicates.py | 11 +-
scripts/ci/prek/check_conn_id_templated.py | 18 +-
.../ci/prek/check_deferred_hook_configuration.py | 294 ++
scripts/ci/prek/check_extra_packages_ref.py | 2 +-
scripts/ci/prek/check_go_sdk_generated_drift.py | 190 +
scripts/ci/prek/check_imports_in_providers.py | 2 +-
.../ci/prek/check_openapi_exception_doc_in_sync.py | 239 +
scripts/ci/prek/check_provider_conn_fields.py | 123 +-
scripts/ci/prek/common_prek_utils.py | 26 +-
scripts/ci/prek/download_k8s_schemas.py | 7 +-
scripts/ci/prek/extract_permissions.py | 1 +
scripts/ci/prek/fab_permissions_doc.py | 8 +
.../regenerate_java_sdk_verification_metadata.py | 165 +
scripts/ci/prek/ruff_format.py | 2 +-
scripts/ci/prek/supported_versions.py | 34 +
scripts/ci/prek/sync_go_sdk_schemas.py | 142 +
scripts/ci/prek/update_providers_dependencies.py | 14 +-
scripts/ci/prek_cache_markers.py | 60 +
scripts/in_container/provider_suspension.py | 38 +
scripts/in_container/run_agent_framework_tests.sh | 90 +
.../in_container/run_provider_yaml_files_check.py | 91 +-
scripts/pyproject.toml | 4 +-
.../tests/ci/lang_sdk_serialization}/__init__.py | 0
.../ci/lang_sdk_serialization/test_compare.py | 245 +
scripts/tests/ci/prek/test_changelog_duplicates.py | 36 +-
.../tests/ci/prek/test_check_conn_id_templated.py | 26 +-
.../prek/test_check_deferred_hook_configuration.py | 373 ++
.../ci/prek/test_check_go_sdk_generated_drift.py | 179 +
.../test_check_openapi_exception_doc_in_sync.py | 335 ++
.../test_check_ui_field_behaviour_matches_hook.py | 130 +
scripts/tests/ci/prek/test_extract_permissions.py | 3 +
...st_regenerate_java_sdk_verification_metadata.py | 175 +
scripts/tests/ci/prek/test_supported_versions.py | 71 +
scripts/tests/ci/prek/test_sync_go_sdk_schemas.py | 127 +
scripts/tests/ci/test_analyze_ci_job_durations.py | 46 +
scripts/tests/ci/test_prek_cache_optimizations.py | 439 ++
.../tests/in_container/test_provider_suspension.py | 64 +
.../_shared => scripts/tests/tools}/__init__.py | 0
scripts/tests/tools/test_free_up_disk_space.py | 98 +
scripts/tools/free_up_disk_space.sh | 25 +-
scripts/tools/setup_breeze | 2 +-
shared/configuration/pyproject.toml | 4 +-
shared/dagnode/pyproject.toml | 4 +-
shared/dagnode/src/airflow_shared/dagnode/cycle.py | 73 +
shared/dagnode/tests/dagnode/test_cycle.py | 79 +
shared/listeners/pyproject.toml | 4 +-
shared/logging/pyproject.toml | 4 +-
shared/module_loading/pyproject.toml | 4 +-
shared/observability/pyproject.toml | 4 +-
.../observability/metrics/metrics_template.yaml | 33 +-
shared/plugins_manager/pyproject.toml | 4 +-
shared/providers_discovery/pyproject.toml | 4 +-
shared/secrets_backend/pyproject.toml | 4 +-
shared/secrets_masker/pyproject.toml | 4 +-
shared/serialization/pyproject.toml | 4 +-
shared/state/pyproject.toml | 4 +-
shared/template_rendering/pyproject.toml | 4 +-
shared/timezones/pyproject.toml | 4 +-
task-sdk-integration-tests/pyproject.toml | 4 +-
task-sdk/docs/api.rst | 2 +
task-sdk/docs/conf.py | 1 +
task-sdk/docs/lang-sdk-spec.rst | 83 +-
task-sdk/pyproject.toml | 4 +-
task-sdk/src/airflow/sdk/__init__.py | 3 +
task-sdk/src/airflow/sdk/__init__.pyi | 2 +
task-sdk/src/airflow/sdk/api/client.py | 29 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 22 +-
task-sdk/src/airflow/sdk/bases/operator.py | 69 +-
task-sdk/src/airflow/sdk/bases/timetable.py | 7 +
.../airflow/sdk/coordinators/_bundle_metadata.py | 33 +-
.../src/airflow/sdk/coordinators/_subprocess.py | 211 +-
.../sdk/coordinators/executable/coordinator.py | 17 +-
.../airflow/sdk/coordinators/java/coordinator.py | 24 +-
.../sdk/coordinators/node/_bundle_reader.py | 210 +-
.../airflow/sdk/coordinators/node/coordinator.py | 21 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 49 +-
.../airflow/sdk/definitions/timetables/assets.py | 25 +
task-sdk/src/airflow/sdk/execution_time/bundles.py | 90 +
task-sdk/src/airflow/sdk/execution_time/comms.py | 7 +
.../airflow/sdk/execution_time/request_handlers.py | 9 +
.../airflow/sdk/execution_time/schema/schema.json | 65 +
.../sdk/execution_time/schema/versions/__init__.py | 8 +-
.../execution_time/schema/versions/v2026_10_30.py | 21 +
.../src/airflow/sdk/execution_time/supervisor.py | 123 +-
.../src/airflow/sdk/execution_time/task_runner.py | 115 +-
task-sdk/src/airflow/sdk/execution_time/tracing.py | 60 +
task-sdk/src/airflow/sdk/importers/base.py | 137 +-
.../src/airflow/sdk/importers/python_importer.py | 26 +-
task-sdk/src/airflow/sdk/importers/zip_importer.py | 49 +-
task-sdk/src/airflow/sdk/lineage.py | 2 +-
task-sdk/src/airflow/sdk/serde/__init__.py | 7 +-
task-sdk/src/airflow/sdk/types.py | 2 +
task-sdk/tests/task_sdk/api/test_client.py | 25 +-
task-sdk/tests/task_sdk/bases/test_operator.py | 171 +
.../coordinators/executable/test_coordinator.py | 60 +-
.../task_sdk/coordinators/java/test_coordinator.py | 39 +
.../coordinators/node/_bundle_test_utils.py | 55 +-
.../coordinators/node/test_bundle_reader.py | 125 +-
.../task_sdk/coordinators/node/test_coordinator.py | 51 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 264 +-
task-sdk/tests/task_sdk/definitions/test_dag.py | 18 +-
.../tests/task_sdk/execution_time/test_bundles.py | 86 +
.../task_sdk/execution_time/test_supervisor.py | 281 +-
.../task_sdk/execution_time/test_task_runner.py | 279 +-
.../tests/task_sdk/execution_time/test_tracing.py | 144 +
.../task_sdk/importers/test_python_importer.py | 20 +
task-sdk/tests/task_sdk/importers/test_registry.py | 153 +
.../tests/task_sdk/importers/test_zip_importer.py | 27 +
ts-sdk/.pre-commit-config.yaml | 14 +
ts-sdk/adr/0002-native-dag-interface.md | 58 +-
ts-sdk/package.json | 3 +-
ts-sdk/pnpm-lock.yaml | 27 +-
ts-sdk/schema/dag-schema.json | 2 +-
.../ci/prek/check_serialization_conformance.py | 44 +
ts-sdk/src/cli/bundle-encoder.ts | 181 +-
ts-sdk/src/cli/pack.ts | 144 +-
ts-sdk/src/coordinator/manifest.ts | 24 +-
ts-sdk/src/coordinator/runtime.ts | 69 +-
ts-sdk/src/coordinator/serde.ts | 751 +++
ts-sdk/src/generated/supervisor.ts | 68 +-
ts-sdk/src/index.ts | 4 +-
ts-sdk/src/sdk/bundle.ts | 7 +
ts-sdk/src/sdk/dag.ts | 708 ++-
ts-sdk/src/sdk/module-source.ts | 74 +
ts-sdk/tests/cli/fixtures/bundle-v1.min.mjs | 6 +-
ts-sdk/tests/cli/pack.test.ts | 391 +-
ts-sdk/tests/conformance/serialize_typescript.ts | 163 +
ts-sdk/tests/coordinator/arg-binding.test.ts | 19 +
ts-sdk/tests/coordinator/integration.test.ts | 108 +-
ts-sdk/tests/coordinator/runtime-manifest.test.ts | 26 +
ts-sdk/tests/coordinator/serde.test.ts | 846 ++++
ts-sdk/tests/public-api.test.ts | 120 +-
ts-sdk/tests/sdk/dag.test.ts | 723 ++-
uv.lock | 4885 +++++++++++---------
1208 files changed, 71344 insertions(+), 12800 deletions(-)
create mode 100644 .apache-magpie-overrides/issue-tracker-config.md
create mode 100644 .apache-magpie-overrides/pmc-roster.md
create mode 100644
.apache-magpie-overrides/pr-management-code-review-criteria.md
create mode 100644 .apache-magpie-overrides/pr-management-quick-merge-config.md
create mode 100644 .apache-magpie-overrides/reassess-pool-defaults.md
create mode 100644 .apache-magpie-overrides/release-trains.md
create mode 100644 .apache-magpie-overrides/reproducer-conventions.md
create mode 100644 .apache-magpie-overrides/runtime-invocation.md
create mode 100644 .github/workflows/agent-framework-tests.yml
create mode 100644 airflow-core/adr/lang-sdk/0010-native-dag-processing.md
create mode 100644
airflow-core/adr/lang-sdk/0011-mixed-language-dag-processing.md
create mode 100644 airflow-core/adr/lang-sdk/0012-lang-sdk-parse-protocol.md
create mode 100644
airflow-core/adr/lang-sdk/0013-persisted-task-handler-bindings.md
create mode 100644
airflow-core/adr/lang-sdk/0014-bundle-metadata-and-cache-digest.md
create mode 100644
airflow-core/adr/lang-sdk/0015-per-dag-source-in-bundle-artifact.md
create mode 100644 airflow-core/newsfragments/58543.feature.rst
create mode 100644 airflow-core/newsfragments/72100.significant.rst
create mode 100644 airflow-core/newsfragments/73554.significant.rst
create mode 100644
airflow-core/src/airflow/api_fastapi/common/parameters/job.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/services/public/dags.py
delete mode 100644
airflow-core/src/airflow/dag_processing/importers/__init__.py
delete mode 100644 airflow-core/src/airflow/dag_processing/importers/base.py
delete mode 100644
airflow-core/src/airflow/dag_processing/importers/python_importer.py
create mode 100644
airflow-core/src/airflow/migrations/versions/0138_3_4_0_allocate_pending_task_attempt_numbers.py
copy providers/common/ai/src/airflow/providers/common/ai/batch/__init__.py =>
airflow-core/src/airflow/migrations/versions/0139_3_4_0_add_source_reference_to_import_error.py
(51%)
copy providers/common/ai/src/airflow/providers/common/ai/batch/__init__.py =>
airflow-core/src/airflow/migrations/versions/0140_3_4_0_add_language_to_dag_code.py
(51%)
create mode 100644
airflow-core/src/airflow/migrations/versions/0141_3_4_0_add_timetable_asset_gated_to_dagmodel.py
create mode 100644
airflow-core/src/airflow/ui/src/components/Clear/TaskInstance/ClearTaskInstanceDialog.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FilterBar/filters/RunStateFilter.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FilterBar/filters/runStateParams.test.ts
create mode 100644
airflow-core/src/airflow/ui/src/components/FilterBar/filters/runStateParams.ts
create mode 100644
airflow-core/src/airflow/ui/src/components/PauseOrDrainChoiceModal.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/TriggerDag/TriggerDAGButton.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/hooks/useAdvancedSearch.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/BulkPauseDrainDagsButton.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/BulkUnpauseDagsButton.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/DagFolderTree/DagFolderTree.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/DagFolderTree/DagFolderTree.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/DagFolderTree/buildFolderTree.test.ts
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/DagFolderTree/buildFolderTree.ts
copy
java-sdk/example/src/java/org/apache/airflow/example/ExampleBundleBuilder.java
=> airflow-core/src/airflow/ui/src/pages/DagsList/DagFolderTree/index.ts (66%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskInstance/Details.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskInstance/Logs/LogsTryNumber.test.tsx
copy airflow-core/src/airflow/ui/src/{utils/index.ts =>
pages/TaskInstance/stateReason.ts} (50%)
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkSetDagSchedulingState.ts
copy
java-sdk/example/src/java/org/apache/airflow/example/ExampleBundleBuilder.java
=> airflow-core/src/airflow/ui/src/queries/useDagFolders.ts (61%)
copy airflow-core/src/airflow/ui/src/utils/{index.ts =>
hasDagRunConfig.test.ts} (55%)
copy
java-sdk/example/src/java/org/apache/airflow/example/ExampleBundleBuilder.java
=> airflow-core/src/airflow/ui/src/utils/hasDagRunConfig.ts (66%)
create mode 100644
airflow-core/src/airflow/ui/tests/e2e/fixtures/task-tries-data.ts
create mode 100644
airflow-core/src/airflow/ui/tests/e2e/specs/task-tries.spec.ts
create mode 100644
airflow-core/tests/unit/api_fastapi/execution_api/versions/v2026_10_30/test_dag_run_notes.py
delete mode 100644
airflow-core/tests/unit/dag_processing/importers/test_registry.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0049_remove_pickled_data_from_xcom_table.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0055_remove_pickled_data_from_dagrun_table.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0080_deadline_callback_migration.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0094_deadline_callback_migration.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0117_deadline_interval_json_migration.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0129_add_indexes_on_serialized_dag_and_dag_code.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0131_lower_case_team_names.py
delete mode 100644
airflow-core/tests/unit/migrations/test_0136_fold_task_map_into_xcom.py
create mode 100644 airflow-core/tests/unit/models/test_errors.py
create mode 100644 contributing-docs/32_open_pull_request_limit.rst
create mode 100644 dev/close_prs_over_open_pr_limit.py
copy providers/cncf/kubernetes/tests/unit/cncf/kubernetes/models/__init__.py
=> devel-common/tests/conftest.py (90%)
create mode 100644 devel-common/tests/unit/tests_common/test_dag_maker.py
create mode 100644 go-sdk/airflow/dag.go
create mode 100644 go-sdk/airflow/dag_test.go
create mode 100644 go-sdk/airflow/enums.go
create mode 100644 go-sdk/airflow/enums_test.go
create mode 100644 go-sdk/airflow/inputs.go
create mode 100644 go-sdk/airflow/inputs_test.go
create mode 100644 go-sdk/airflow/spec.gen.go
create mode 100644 go-sdk/airflow/spec.go
create mode 100644 go-sdk/airflow/task_option.go
create mode 100644 go-sdk/airflow/testdata/foreigntaskoption/main.go
create mode 100644 go-sdk/airflow/trigger_dag_run.go
create mode 100644 go-sdk/airflow/trigger_dag_run_test.go
create mode 100644 go-sdk/internal/genlicense/genlicense.go
create mode 100644 go-sdk/internal/genlicense/genlicense_test.go
create mode 100644 go-sdk/internal/genspec/authoring.go
create mode 100644 go-sdk/internal/genspec/authoring_test.go
create mode 100644 go-sdk/internal/genspec/main.go
create mode 100644 go-sdk/internal/genspec/main_test.go
create mode 100644 go-sdk/internal/genspec/normalize.go
create mode 100644 go-sdk/internal/genspec/normalize_test.go
copy {ts-sdk => go-sdk}/schema/dag-schema.json (99%)
copy task-sdk/src/airflow/sdk/execution_time/schema/schema.json =>
go-sdk/schema/supervisor-schema.json (98%)
create mode 100644
java-sdk/example/src/java/org/apache/airflow/example/nativedag/InterfaceExample.java
copy {ts-sdk => java-sdk/sdk}/schema/dag-schema.json (99%)
create mode 100644 java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Arg.kt
delete mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Builder.kt
create mode 100644 java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/Deps.kt
create mode 100644
java-sdk/sdk/src/main/kotlin/org/apache/airflow/sdk/internal/Fields.kt
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/internal/ArgValuesTest.kt
create mode 100644 providers/amazon/docs/operators/duckdb.rst
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/hooks/duckdb.py
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/queues/kinesis.py
create mode 100644 providers/amazon/tests/system/amazon/aws/example_duckdb.py
create mode 100644
providers/amazon/tests/system/amazon/aws/example_emr_serverless_session.py
create mode 100644
providers/amazon/tests/system/amazon/aws/example_kinesis_message_queue.py
create mode 100644 providers/amazon/tests/unit/amazon/aws/hooks/test_duckdb.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/operators/test_emr_serverless_session.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/queues/test_kinesis.py
create mode 100644
providers/apache/kafka/src/airflow/providers/apache/kafka/triggers/shared_stream.py
create mode 100644
providers/apache/kafka/tests/integration/apache/kafka/triggers/test_shared_stream.py
create mode 100644
providers/apache/kafka/tests/unit/apache/kafka/triggers/test_shared_stream.py
create mode 100644
providers/cncf/kubernetes/tests/unit/cncf/kubernetes/test_k8s_model.py
rename providers/cncf/kubernetes/tests/unit/cncf/kubernetes/{models =>
}/test_secret.py (74%)
create mode 100644 providers/common/ai/docs/capabilities.rst
create mode 100644 providers/common/ai/docs/connections/index.rst
create mode 100644 providers/common/ai/docs/frameworks/adk.rst
create mode 100644 providers/common/ai/docs/frameworks/index.rst
create mode 100644 providers/common/ai/docs/frameworks/pydantic_ai.rst
create mode 100644 providers/common/ai/docs/frameworks/strands.rst
delete mode 100644 providers/common/ai/docs/guardrails.rst
create mode 100644 providers/common/ai/docs/stability.rst
create mode 100644 providers/common/ai/docs/tool_approval.rst
create mode 100644 providers/common/ai/docs/toolsets/object_storage.rst
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/replay_usage.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_adk_agent.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_agent_tool_approval.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_object_storage_toolset.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_pydantic_ai_agent.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_strands_agent.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/managed_agents/__init__.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/managed_agents/base.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/managed_agents/failover.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/sandbox/opensandbox.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/tools/__init__.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/tools/_from_toolset.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/tools/adk.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/tools/strands.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/tools/tracing.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/toolsets/object_storage.py
copy providers/{google/tests/unit/google/cloud/hooks/test_stackdriver.py =>
common/ai/src/airflow/providers/common/ai/utils/coroutines.py} (50%)
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/masking.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/prompt_cache.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/task_logger.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/tool_metrics.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/toolset_base.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/usage_budget.py
create mode 100644
providers/common/ai/tests/system/common/ai/example_sandbox_toolset_opensandbox.py
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_replay_usage.py
rename {airflow-core/tests/unit/dag_processing/importers =>
providers/common/ai/tests/unit/common/ai/managed_agents}/__init__.py (100%)
create mode 100644
providers/common/ai/tests/unit/common/ai/managed_agents/test_base.py
create mode 100644
providers/common/ai/tests/unit/common/ai/managed_agents/test_failover.py
create mode 100644
providers/common/ai/tests/unit/common/ai/operators/test_agent_tool_approval.py
create mode 100644
providers/common/ai/tests/unit/common/ai/sandbox/fake_tags.py
create mode 100644
providers/common/ai/tests/unit/common/ai/sandbox/test_opensandbox.py
copy {airflow-core/src/airflow/_shared =>
providers/common/ai/tests/unit/common/ai/tools}/__init__.py (100%)
create mode 100644
providers/common/ai/tests/unit/common/ai/tools/test__from_toolset.py
create mode 100644 providers/common/ai/tests/unit/common/ai/tools/test_adk.py
create mode 100644
providers/common/ai/tests/unit/common/ai/tools/test_strands.py
create mode 100644 providers/common/ai/tests/unit/common/ai/tools/test_tools.py
create mode 100644
providers/common/ai/tests/unit/common/ai/tools/test_tracing.py
create mode 100644
providers/common/ai/tests/unit/common/ai/toolsets/test_object_storage.py
create mode 100644
providers/common/ai/tests/unit/common/ai/toolsets/test_retry_budget.py
copy providers/{openai/src/airflow/providers/openai/exceptions.py =>
common/ai/tests/unit/common/ai/utils/test_coroutines.py} (57%)
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_masking.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_prompt_cache.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_task_logger.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_tool_metrics.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_toolset_base.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_usage_budget.py
create mode 100644
providers/common/compat/src/airflow/providers/common/compat/_set_during_execution.py
create mode 100644
providers/common/compat/tests/unit/common/compat/test__set_during_execution.py
create mode 100644
providers/google/tests/unit/google/cloud/links/test_cloud_tasks.py
copy {airflow-core => providers/modal}/.gitignore (100%)
copy {chart => providers/modal}/LICENSE (100%)
copy NOTICE => providers/modal/NOTICE (100%)
copy providers/{duckdb => modal}/README.rst (63%)
create mode 100644 providers/modal/docs/.latest-doc-only-change.txt
copy providers/{duckdb => modal}/docs/changelog.rst (88%)
copy providers/{duckdb/docs/changelog.rst => modal/docs/commits.rst} (65%)
rename
providers/{cncf/kubernetes/tests/unit/cncf/kubernetes/models/__init__.py =>
modal/docs/conf.py} (74%)
create mode 100644 providers/modal/docs/connections.rst
create mode 100644 providers/modal/docs/index.rst
copy providers/{airbyte => modal}/docs/installing-providers-from-sources.rst
(100%)
create mode 100644 providers/modal/docs/integration-logos/Modal.png
copy providers/{anthropic => modal}/docs/security.rst (100%)
create mode 100644 providers/modal/docs/usage.rst
create mode 100644 providers/modal/provider.yaml
copy providers/{vespa => modal}/pyproject.toml (90%)
copy {airflow-core/tests/integration =>
providers/modal/src/airflow}/__init__.py (100%)
copy {airflow-core/tests/integration =>
providers/modal/src/airflow/providers}/__init__.py (100%)
copy providers/{duckdb/src/airflow/providers/duckdb =>
modal/src/airflow/providers/modal}/__init__.py (92%)
copy airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_sources.py
=> providers/modal/src/airflow/providers/modal/exceptions.py (62%)
create mode 100644
providers/modal/src/airflow/providers/modal/get_provider_info.py
copy {airflow-core/src/airflow/_shared =>
providers/modal/src/airflow/providers/modal/hooks}/__init__.py (100%)
create mode 100644 providers/modal/src/airflow/providers/modal/hooks/modal.py
copy providers/{airbyte => modal}/tests/conftest.py (100%)
copy {airflow-core/tests/integration =>
providers/modal/tests/unit}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
providers/modal/tests/unit/modal/hooks}/__init__.py (100%)
create mode 100644 providers/modal/tests/unit/modal/hooks/test_modal.py
copy
providers/{keycloak/src/airflow/providers/keycloak/auth_manager/resources.py =>
modal/tests/unit/modal/test_exceptions.py} (61%)
copy {airflow-core/src/airflow/_shared =>
scripts/ci/lang_sdk_serialization}/__init__.py (100%)
create mode 100644 scripts/ci/lang_sdk_serialization/compare.py
create mode 100644 scripts/ci/lang_sdk_serialization/serialize_python.py
create mode 100644 scripts/ci/lang_sdk_serialization/test_dags.yaml
create mode 100755 scripts/ci/prek/check_deferred_hook_configuration.py
create mode 100755 scripts/ci/prek/check_go_sdk_generated_drift.py
create mode 100755 scripts/ci/prek/check_openapi_exception_doc_in_sync.py
create mode 100755 scripts/ci/prek/regenerate_java_sdk_verification_metadata.py
create mode 100755 scripts/ci/prek/sync_go_sdk_schemas.py
create mode 100644 scripts/ci/prek_cache_markers.py
create mode 100644 scripts/in_container/provider_suspension.py
create mode 100755 scripts/in_container/run_agent_framework_tests.sh
copy {airflow-core/src/airflow/_shared =>
scripts/tests/ci/lang_sdk_serialization}/__init__.py (100%)
create mode 100644 scripts/tests/ci/lang_sdk_serialization/test_compare.py
create mode 100644
scripts/tests/ci/prek/test_check_deferred_hook_configuration.py
create mode 100644 scripts/tests/ci/prek/test_check_go_sdk_generated_drift.py
create mode 100644
scripts/tests/ci/prek/test_check_openapi_exception_doc_in_sync.py
create mode 100644
scripts/tests/ci/prek/test_check_ui_field_behaviour_matches_hook.py
create mode 100644
scripts/tests/ci/prek/test_regenerate_java_sdk_verification_metadata.py
create mode 100644 scripts/tests/ci/prek/test_supported_versions.py
create mode 100644 scripts/tests/ci/prek/test_sync_go_sdk_schemas.py
create mode 100644 scripts/tests/ci/test_prek_cache_optimizations.py
create mode 100644 scripts/tests/in_container/test_provider_suspension.py
copy {airflow-core/src/airflow/_shared => scripts/tests/tools}/__init__.py
(100%)
create mode 100644 scripts/tests/tools/test_free_up_disk_space.py
create mode 100644 shared/dagnode/src/airflow_shared/dagnode/cycle.py
create mode 100644 shared/dagnode/tests/dagnode/test_cycle.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/bundles.py
create mode 100644 task-sdk/src/airflow/sdk/execution_time/tracing.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_bundles.py
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_tracing.py
create mode 100755 ts-sdk/scripts/ci/prek/check_serialization_conformance.py
create mode 100644 ts-sdk/src/coordinator/serde.ts
create mode 100644 ts-sdk/src/sdk/module-source.ts
create mode 100644 ts-sdk/tests/conformance/serialize_typescript.ts
create mode 100644 ts-sdk/tests/coordinator/serde.test.ts
