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-788431b67f
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit c56079dd896 Bump @chakra-ui/react
add e9a41115aea Implements Support for Format="Duration" in Params (#65469)
add c2dbd7a75ad Fix IDC domain S3 path resolution (#67987)
add a5d91ed2838 Bump the edge-ui-package-updates group across 1 directory
with 7 updates (#68087)
add 7e55559406e fix: guard the to.finish stats emission (#67955)
add db6ce848baf Improve AIP progress tracker example for accuracy (#68037)
add 5dde3cdf1d5 Improve SnowflakeSqlApiOperator error message on query
status check failure (#66642)
add 9326f169f48 CI: drive milestone auto-tag skip from live labels + issue
events (#67518)
add d4a5294dcef Add token_provider for short-lived MCP auth in common.ai
(#68104)
add a218626923b Remove large-PR heuristic from selective checks (#68109)
add d88504564c5 Support multi-schema introspection in common.ai SQLToolset
(#68103)
add a77dcb6cc96 Allow DESCRIBE/SHOW in common.ai SQLToolset read-only
queries (#68102)
add 007ce9d11eb Add Snowflake Workload Identity Federation (WIF) support
(#68107)
add e371845a222 Verify TCP connection ownership before accepting Java
coordinator supervisor channel (#67781)
add 294467ab1f9 Exclude auto-generated REST API reference from docs
spell-check (#68114)
add b64a0e636d9 Add `awaiting_input` task state for Human-in-the-loop, off
the triggerer (#68028)
add 97e90643dbf Document selective-checks algorithm and heuristics (#68116)
add 31fcbf65cc2 UI: Add checkboxes to clear task instances (#68029)
add 0c5da3d3d37 Revert "Fix CI/CD running full matrix on push to release
branches (v3-X-test) (#68057)" (#68120)
add 0effe0af7ce Add Zomato to INTHEWILD.md (#68123)
add d2161ae04cb Hide Dashboard metric percentages when a state count is
capped (#67664)
add a4ea3ffc405 Fix LatestBoto CI test stuck at boto3 1.38.2 (below
provider minimum) (#68122)
add cbd21a2d47d Fix language key for dag bundle filter (#68131)
add d9d7a568796 Updated verbiage for backfill runs being deprioritized
(#67338)
add 2f3865240de Update Magpie in .gitignore (#68132)
add 1a67db3f9b4 Fix team name authorization bypass in edgeworker (#64556)
add 85843a30d5c AIP-103: Documentation for Task and Asset Store (#67299)
add 33c95639297 Add indexes on dag_run.created_dag_version_id and
task_instance.dag_version_id (#64818)
add 1250b88557b Only run testable integrations relevant to the change in
selective checks (#68112)
add fc4c3837181 Fix `airflow dags clear` clearing the wrong day for
non-UTC partitioned timetables (#67717)
add e4b34471e46 Rename resumablemixin file to match class name (#68137)
add 0c2079585e4 Fix DagFileProcessorManager silent hang on DB lock
contention (#68118)
add 942de38a350 Make .agents/skills the canonical agent-skills home
(#68143)
add 84270cbc234 Fix Java SDK tasks rejected by coordinator
connection-ownership check (#68147)
add 89efec77305 Add ipFamilyPolicy and ipFamilies support to all Helm
service templates (#66616)
add db9c9cc94de Bump pydantic-ai-slim to resolve dependabot (#68105)
add 4677e1e0c41 Fix K8s executor pod_override stringified without cncf
provider (#67895)
add c0b5a6f078d Fix AirflowSDKConfigParser missing mask_secrets method
(#66077)
add 2f7e50f0b1d [main] CI: Upgrade important CI environment (#68062)
add 94fa4d2b4f6 fixed sort order for mapped task instances (#67551)
add ef0b326c24c Mark Java SDK E2E test XFail until #68160 resolved (#68161)
add 4d3f52bb2b0 Fix task_defer method with non-JSON next_kwargs in
TaskInstance (#64714)
add 48029203f7d fix: sanitize Dag processor metric file names (#67029)
add d299b68e97e fix: task run exception never catch by Sentry (#65161)
add 7212829ee59 Fix Java SDK tasks rejected by coordinator on IPv4-mapped
IPv6 connections (#68169)
add ba6c8ee9856 Write newline after provider dependency changes to shasum
file (#68170)
add 2ba6b334648 Complete missing Hebrew (he) translations (#67918)
add 581a8506fda Extend CodeQL language gating to push events (main +
release branches) (#68085)
add 4b407142e59 Fix CronMixin in task-sdk not resolving cron presets
before validation (#66102)
add 09d40ae1e73 Remove overhead (and instability) to use Docker to cleanup
repo (#68179)
add f636d83bd95 [main] Upgrade important CI environment (#68163)
add 853571c1970 fix: allow deadline callbacks within the same dag module
(#66702)
add 6769feb82e1 Return common.ai SQLToolset errors to the agent so it
self-corrects (#68117)
add adf903571bb Add spec_file support to PydanticAIHook.create_agent
(#67788)
add da57d5ecf81 Add regression tests for task_instance_mutation_hook under
scheduler commit guard (#67980)
add c24aabe31b0 Update providers metadata 2026-06-07 (#68191)
add 03d26f86c5b Go SDK: airflow-go-pack tool for self-contained bundle
binaries (#67156)
add 1aa5fa3fab8 Add Go-SDK e2e test (#67956)
add 2e16d6542ef Fix cred configs in publish workflow (#68073)
add 15dcef5cbf3 Complete Taiwanese Mandarin translations (#68167)
add 285978e2d7b Breeze: shim fallback outside worktrees + publish-docs
workflow ref (#68192)
add 4830882c6e1 Remove uneccessary json.dumps from example task store dag
(#68202)
add 42aeb4b398c Documentation for ResumableJobMixin and resumable tasks
(#68136)
add e75718992c1 Prepare providers release 2026-06-08 (#68203)
add 1e110172033 Change state for version 2.11.2 to EOL (#68212)
add 2b1ada2369f Run spotless against Java files in static checks (#68211)
add 82d157698b0 Bump to snapshot for release (#68205)
add ccf34ff384f Mark Triggerer supervisor as a server context so it can
read metastore connections (#64022)
add 953aa794504 Add FanOutMapper for one-to-many partition fan-out (#66030)
add 9c5843e7a2d Harden Java process exit (#68216)
add fe994e6f297 Remove automated backporting to v3-2-test (#68220)
add cc13ca22b02 Wait for Bedrock AgentCore Runtime deletion (#68140)
add 0a2aefa0709 Docs: fix removed webserver command in FAB SSO guide for
Airflow 3 (#68166)
add a053537e5bd docs: update FAB auth manager Flask config wording for
Airflow 3 (#68162)
add e9d54fcc998 Fix mapped task instance links without start date (#68194)
add fe30279b379 Fix scheduler crash with InvalidStatsNameException for
non-ASCII DAG names when OTel metrics enabled (#68023)
add 675439d1590 Refresh apache-magpie setup bootstrap skill from framework
upgrade (#68235)
add 8e91fa7cd35 fix: remove redundant columns in XCom panel on task
instance page (#68188)
add 2d0b1e77f58 Skip ktlint prek hook unless java-sdk files changed
(#68210)
add 30b92c5daf2 Docs: Add CLI examples for team-scoped pools (#68111)
add 60ff4669c9b Consumer team asset filtering: add API endpoint support
(#68034)
add 8f36246f458 Fix import errors total_entries count with multiple DAGs
per file (#67550)
add bb510f2b799 Bump the auth-ui-package-updates group across 1 directory
with 18 updates (#68231)
add 21d37d3ff29 Import ldap.filter in security_manager override (#68226)
add 7651e4b9859 UI: Use bulk clearDagRuns endpoint for bulk Dag run clear
(#67846)
add f90ebd0835b Add --team-name support to pool CLI commands (#68110)
add 16d95dd8879 Fix `none_failed_min_one_success` trigger rule checks
(#67873)
add 837bfdee031 Fix CLI variables import with structured falsy values
(#67060)
add fe92cfd4e01 API: Add bulk update to mark Dag runs as success/failed
(#67948)
add c0c12273f61 UI: align backend state aggregation with
active-over-pending priority (#67543)
add 77920c5794e Close German Translation Gaps 2026-06-06 (#68130)
add 2a924677557 Retry TriggerDagRunOperator when the triggered DagRun
fails (#65390)
add 6e44476ab0b [main] CI: Upgrade important CI environment (#68209)
add 744ff2e6443 Add asset and task store UI (#67292)
add 2e5af2a0517 fix(ui): prevent duplicate TI summary stream refreshes
after mutations (#67892)
add bbb043cde9f Fix team consumer asset filtering (#68242)
add cd5509fc701 Reduce SSH connection churn in `SSHRemoteJobOperator`
under high fan-out (#68115)
add 43048cec906 Go-SDK: Make go-sdk docs up to date with Coordinator
change (#68221)
add 1e8be208e3f Honor retry_policy on non-deferrable TriggerDagRunOperator
wait failures (#68254)
add 1e406495ec5 Fix spurious "Failed to detach context" error on Execution
API disconnects (#68039)
add 035be6d3621 Go-SDK: Add Go Task SDK authoring guide to airflow-core
docs (#68223)
add 65a82aa10ad Rename config for state_backend on workers to
state_store_backend (#68270)
add 12a9985bd5f Add better logging to ResumableJobMixin for crash recovery
observability (#68206)
add f00b2853282 fix(ci): Add retry logic to download commands in CI image
build (#68255)
add 17325b9082c UI: Fix laggy multi-selection checkboxes in tables (#68229)
add 96122a4e9d0 Remove v3-2-test scheduled CI upgrade check (#68275)
add 75cba2925f7 Add Redis client self-identification for Apache Airflow
(#61866)
add 76bed661465 Add GCSToAzureBlobStorageOperator for GCS to Azure Blob
transfer (#64966)
add d8961101b03 Add MongoToGCSOperator to copy MongoDB collections to GCS
(#66013)
add b2a840d68c8 Load example DAGs from providers via ProvidersManager
(continuation of #57320) (#66161)
add f94b48937f5 Add remote log upload support for callback subprocesses
(#66379)
add 6132261fb49 Rename task-failure handlers so naming matches the call
hierarchy (#68264)
add fc6c9844d28 fix(tests): Add retries to EMR on EKS system test job
submission (#68257)
add a11fa2fa5df fix(tests): Use unique S3 bucket name in bedrock
evaluation system test (#68256)
add b183a4cb7b7 Use execute_values instead of execute_batch for better
bulk insert performance with PostgresHook (#68207)
add 2b306ca05a8 Fix secrets backend connection errors silently swallowed
at DEBUG level (#68301)
add db04a4ef8c2 Fix older and custom secrets backends breaking on Airflow
3.2 (#68302)
add 05117d0855f Fix remote-log providers not satisfying RemoteLogIO upload
contract (#68300)
add 3e480942fb0 Go-SDK: Expose task runtime context to coordinator-mode
tasks (#68271)
add b311e6fb453 Pass task/asset scopes to serialize methods instead of
ti_id/asset_ref (#68274)
add f3ca1c27abd Crash recovery for YARN cluster mode in
SparkSubmitOperator built on AIP-103 (#67473)
add f392484cc58 i18n(zh-CN): add missing translations (#68289)
add 04f19d19b07 Fix scheduler crashloop when last task instance predates
Dag versioning (#68253)
add a8c99107c9f feat(AIP-76): support forward fan-out via forward kwarg on
Window (#67475)
add f690474a26a Add FixedKeyMapper and SegmentWindow for categorical
asset-partition rollup (#67716)
add e8b2098d616 CI: Fix generated/provider_dependencies.json (#68324)
add 764c516b01f Fix DagProcessor crash: add missing name_is_otel_safe()
guard to gauge() and timer() (#68284)
add 5f1c969ccc3 UI: Fix wrong language auto-detected from browser
preferences (#68258)
add 21123cecdad Reuse a session-scoped FastAPI app across api_fastapi
tests (#68261)
add d93a93849db Add missing template_fields to
BedrockCreateEvaluationJobOperator (#68310)
add 6a5cbdbc131 ci: sync AGENTS.md commands from contributing docs via
prek hook (#68204)
add 44f03af0a2f PR template: request before/after screenshots for UI
changes (#68201)
add e6fc8734077 fix(scheduler): populate partition_date for temporal asset
partitions (#68266)
add 8d199cf59d7 feat: close Taiwanese Mandarin Translation Gap (#68335)
add ac82cecf144 Fix 500 error for event logs with NULL dttm (#68338)
add a48c549d031 Speed up Dags list and dashboard queries on large DagRun
tables (#67721)
add 40b6796fac5 Avoid N+1 team-name queries in bulk Dag run authorization
(#68286)
add 31f3ad90157 Fix apache-airflow-mypy release docs to match ASF dist
conventions (#68332)
add eeb0c9d1b5b Fix role bindings for workers.celery.serviceAccount
(#68306)
add cc20a79b3ca Bump stylelint (#68347)
add 85ceb631177 Fill TR Translation Gaps Main (#68182)
add e51289d6892 Add import error to deactivated dag (#65687)
add 71f334aef14 Close Catalan gap on main (#68272)
add 18704832a39 Remove deprecated SecurityContext from chart (#68036)
add e5a89f13ba1 Remove deprecated ingress options from chart (#68043)
add 67e935988ae Modify values in pod launcher role tests (#68357)
add 71827ec13fb Align apache-airflow-mypy RC verification steps with other
release docs (#68350)
add cdbeb481670 Kubernetes Pod Operator - handle pod preemption before
container creation (#68328)
add 471e9a17faf Pass DagRun to task_instance_mutation_hook for run-aware
task mutation (#68198)
add 27754b93fea Add team_name to Multi-Team metrics (#68108)
add ae2fe0ce713 fix: Fix Triggered DAG button not visible during
queued/running state (#67327)
add 57b427449b1 docs: update architecture overview to Airflow 3
architecture (#67994)
add 227506a9783 [main] Upgrade important CI environment (#68322)
add 6e6edfd5cdc Add prek hook to auto-update copyright year in NOTICE
files (#67146)
add b7247b13219 feat(core): add per-mapper max_fan_out override for
partition fan-out cap (#67184)
add 439105f33b3 Add `task_store` table to `airflow db clean` mechanism
(#68218)
add 34901b68ae8 Fix cursor encoding for column-form SortParam to_replace
(#67973)
add d31f66509df Fix Vault GCP auth for metadata credentials (#68069)
add d411f55c7e3 Go-SDK: Inject task runtime context as sdk.TIRunContext
parameter (#68349)
add a6380161db6 Docs: Add sdk.TIRunContext for Go-SDK (#68319)
add e1dadc77c03 Docs: Remove stale reload_on_plugin_change from API config
reference (#68364)
add d4c7791a704 Fix MySQL downgrade from 3.3.0 on deadline_alert.interval
JSON conversion (#68337)
add 023ae241c47 Fix setup/teardown auto-inclusion when clearing or marking
tasks (#68193)
add 5319f6da8f1 Revert "Surface remote-log upload failures via structured
warnings (#66571)" (#68371)
add 402683f9361 Improve providers release docs: carry over testing-issue
checkmarks + tag-providers --release-date (#68228)
add 87640330536 Mask all connection extra and variable values in API audit
log (#68049)
add e609f032f40 UI: Bulk mark Dag runs as success/failed from multi-select
(#68278)
add 7ccec1dcdcb UI: Add Details tab to the mapped task instance view
(#68340)
add dd048b35f0a Fix Gantt tooltip showing wrong start date on
queued/scheduled segments (#68176)
add a0be5d8c5f8 [AIP-94] Create a CLI airflowctl client and adopt it in
existing commands (#68175)
add a5ffa6c7949 Fix upstream map index resolution after placeholder
expansion (#59691)
add 872427c2534 Version the worker-bound TaskInstance fields in the
execution API schema (#68390)
add 0ec51a96621 Conditional deprecated table generation in doc (#68363)
add 742f9a7909d Add HTTPRoute (Gateway API) support to API server in Helm
Chart (#67675)
add dab70fbcf20 Require edit rights for async connection test updates
(#68127)
add cf904d7852f refactor: Explicitly added pydantic dependency to http
provider as raised by @NBardelot (#68321)
add 1f938e55823 Add language SDK contributing doc (#68330)
add a57fcc1c19d UI: Add custom expiration datetime picker for task store
modal (#68394)
add 40aac72bef2 UI: Add a column in asset store display table linking to
the TI that wrote it (#68395)
add 6c10f4c1161 Add metrics and traces to `ResumableJobMixin` for crash
recovery (#68213)
add d2f42e62cfc Optimize TaskGroup.topological_sort for reverse-declared
Dags (#67688)
add 1691f6c4678 Update providers metadata 2026-06-12 (#68419)
add 390db26ec04 Fix Typo in EdgeExecutor Architecture diagram (#68401)
add 4a7775a7974 Fix empty labels in Stackdriver log IO for Airflow 3
Supervisor (#68292)
add 41ebdf3e3b0 Revert #59691 due to broken trigger rules in mapped task
groups (#68418)
add 460cf26088a feat: Add fullscreen toggle to code viewer (#68044)
add e35f720baf1 Rename resumablejobmixin test file to match its src file
(#68427)
add 48b17e8f809 docs: clarify when to use custom `handler` (#68345)
add 15173321dea Let partitioned Dag runs fire on a partial upstream window
with wait_policy (#66848)
add 30827b1a9e5 Fix typo and restore SVG diagram headers (#68435)
add 36c439c39cf Fix Java-SDK connection port casting (#68433)
add 9126a64abab Fix BackfillDagRun.partition_key type annotation (str, not
datetime) (#68432)
add 36dd823770b Fix backward compatibility for DagRunInfo partition fields
(#68342)
add 390fc454bb2 Java gradle plugin and project split (#68380)
add 29a8fe3e208 i18n(ko): add missing translations (#68234)
add def50a90211 feat(dag_command.py): change to use bulk clear (#68280)
add 5f8d7400a86 [main] CI: Upgrade important CI environment (#68436)
add cfdad662f2c 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 (c56079dd896)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/chakra-ui-788431b67f
(cfdad662f2c)
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:
.../skills/aip-user-stories/SKILL.md | 0
.../references/playbook-template.md | 0
.../skills/airflow-translations/SKILL.md | 0
.../skills/airflow-translations/locales/ar.md | 0
.../skills/airflow-translations/locales/ca.md | 0
.../skills/airflow-translations/locales/de.md | 0
.../skills/airflow-translations/locales/el.md | 0
.../skills/airflow-translations/locales/es.md | 0
.../skills/airflow-translations/locales/fr.md | 0
.../skills/airflow-translations/locales/he.md | 10 +-
.../skills/airflow-translations/locales/hi.md | 0
.../skills/airflow-translations/locales/hu.md | 0
.../skills/airflow-translations/locales/it.md | 0
.../skills/airflow-translations/locales/ja.md | 0
.../skills/airflow-translations/locales/ko.md | 0
.../skills/airflow-translations/locales/nl.md | 0
.../skills/airflow-translations/locales/pl.md | 0
.../skills/airflow-translations/locales/pt.md | 0
.../skills/airflow-translations/locales/th.md | 0
.../skills/airflow-translations/locales/tr.md | 0
.../skills/airflow-translations/locales/zh-CN.md | 0
.../skills/airflow-translations/locales/zh-TW.md | 0
{.github => .agents}/skills/magpie-setup/SKILL.md | 107 +-
{.github => .agents}/skills/magpie-setup/adopt.md | 286 +-
.agents/skills/magpie-setup/agents.md | 198 +
.../skills/magpie-setup/overrides.md | 0
.../skills/magpie-setup/unadopt.md | 119 +-
.../skills/magpie-setup/upgrade.md | 195 +-
{.github => .agents}/skills/magpie-setup/verify.md | 113 +-
.../skills/magpie-setup/worktree-init.md | 90 +-
.../prepare-providers-documentation/SKILL.md | 0
.claude/skills/aip-user-stories | 2 +-
.claude/skills/airflow-translations | 1 +
.claude/skills/magpie-setup | 2 +-
.claude/skills/prepare-providers-documentation | 1 +
.github/PULL_REQUEST_TEMPLATE.md | 3 +
.github/boring-cyborg.yml | 18 -
.github/skills/aip-user-stories | 1 +
.github/skills/airflow-translations | 1 +
.github/skills/magpie-setup | 1 +
.github/skills/magpie-setup/conventions.md | 278 -
.github/skills/prepare-providers-documentation | 1 +
.github/workflows/additional-ci-image-checks.yml | 2 +-
.github/workflows/additional-prod-image-tests.yml | 23 +-
.github/workflows/airflow-distributions-tests.yml | 2 +-
.github/workflows/airflow-e2e-tests.yml | 6 +-
.github/workflows/basic-tests.yml | 10 +-
.github/workflows/ci-amd.yml | 12 +-
.github/workflows/ci-arm.yml | 12 +-
.github/workflows/ci-image-build.yml | 2 +-
.github/workflows/ci-image-checks.yml | 8 +-
.github/workflows/codeql-analysis.yml | 32 +-
.github/workflows/finalize-tests.yml | 4 +-
.github/workflows/generate-constraints.yml | 2 +-
.github/workflows/helm-tests.yml | 4 +-
.github/workflows/integration-system-tests.yml | 6 +-
.github/workflows/k8s-tests.yml | 2 +-
.github/workflows/prod-image-build.yml | 4 +-
.github/workflows/publish-docs-to-s3.yml | 4 +-
.github/workflows/push-image-cache.yml | 4 +-
.github/workflows/release_dockerhub_image.yml | 2 +-
.../workflows/release_single_dockerhub_image.yml | 4 +-
.github/workflows/run-unit-tests.yml | 2 +-
.../scheduled-upgrade-check-v3-2-test.yml | 35 -
.github/workflows/test-providers.yml | 4 +-
.github/workflows/ui-e2e-tests.yml | 2 +-
.../update-constraints-on-push-stable.yml | 4 +-
.github/workflows/update-constraints-on-push.yml | 4 +-
.github/workflows/upgrade-check.yml | 2 +-
.gitignore | 8 +-
.pre-commit-config.yaml | 76 +-
AGENTS.md | 3 +
Dockerfile | 20 +-
Dockerfile.ci | 38 +-
INTHEWILD.md | 1 +
README.md | 16 +-
.../cluster-policies.rst | 19 +-
.../docs/administration-and-deployment/index.rst | 2 +
.../task-and-asset-store-cleanup.rst | 73 +
.../task-and-asset-store.rst | 211 +
.../administration-and-deployment/web-stack.rst | 1 -
.../docs/authoring-and-scheduling/assets.rst | 83 +
.../docs/authoring-and-scheduling/deferring.rst | 9 +
.../authoring-and-scheduling/language-sdks/go.rst | 462 ++
.../language-sdks/index.rst | 27 +
.../language-sdks/java.rst | 205 +-
airflow-core/docs/best-practices.rst | 2 +-
airflow-core/docs/conf.py | 6 +-
airflow-core/docs/core-concepts/asset-store.rst | 177 +
airflow-core/docs/core-concepts/executor/index.rst | 6 +-
airflow-core/docs/core-concepts/index.rst | 10 +
airflow-core/docs/core-concepts/multi-team.rst | 53 +
airflow-core/docs/core-concepts/overview.rst | 68 +-
airflow-core/docs/core-concepts/params.rst | 3 +
.../docs/core-concepts/resumable-tasks.rst | 187 +
.../docs/core-concepts/task-and-asset-store.rst | 80 +
airflow-core/docs/core-concepts/task-store.rst | 278 +
airflow-core/docs/core-concepts/tasks.rst | 1 +
.../docs/img/diagram_task_lifecycle.md5sum | 2 +-
airflow-core/docs/img/diagram_task_lifecycle.png | Bin 601178 -> 671852
bytes
airflow-core/docs/img/diagram_task_lifecycle.py | 23 +-
.../docs/installation/supported-versions.rst | 20 +-
airflow-core/docs/migrations-ref.rst | 5 +-
airflow-core/docs/security/audit_logs.rst | 1 +
airflow-core/docs/tutorial/hitl.rst | 11 +
airflow-core/newsfragments/66030.feature.rst | 1 +
airflow-core/newsfragments/66161.significant.rst | 12 +
airflow-core/newsfragments/66848.feature.rst | 1 +
airflow-core/newsfragments/67184.feature.rst | 1 +
airflow-core/newsfragments/67475.feature.rst | 1 +
airflow-core/newsfragments/67688.improvement.rst | 1 +
airflow-core/newsfragments/67716.feature.rst | 1 +
airflow-core/newsfragments/67873.bugfix.rst | 1 +
airflow-core/newsfragments/68028.feature.rst | 1 +
airflow-core/newsfragments/68175.significant.rst | 24 +
airflow-core/newsfragments/68266.bugfix.rst | 1 +
airflow-core/pyproject.toml | 5 +-
.../src/airflow/api/client/local_client.py | 103 -
airflow-core/src/airflow/api/common/mark_tasks.py | 3 +
.../api_fastapi/auth/managers/base_auth_manager.py | 16 +
.../auth/managers/simple/simple_auth_manager.py | 3 +
.../auth/managers/simple/ui/package.json | 36 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 898 ++--
.../src/airflow/api_fastapi/common/cursors.py | 23 +-
.../src/airflow/api_fastapi/common/parameters.py | 86 +-
.../api_fastapi/core_api/datamodels/assets.py | 8 +
.../api_fastapi/core_api/datamodels/dag_run.py | 4 +-
.../core_api/datamodels/ui/dashboard.py | 1 +
.../api_fastapi/core_api/openapi/_private_ui.yaml | 5 +
.../core_api/openapi/v2-rest-api-generated.yaml | 72 +-
.../api_fastapi/core_api/routes/public/assets.py | 7 +
.../core_api/routes/public/connections.py | 8 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 48 +-
.../core_api/routes/public/event_logs.py | 22 +-
.../api_fastapi/core_api/routes/public/hitl.py | 52 +
.../core_api/routes/public/import_error.py | 42 +-
.../core_api/routes/public/task_instances.py | 9 +
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 70 +-
.../api_fastapi/core_api/routes/ui/dashboard.py | 48 +-
.../src/airflow/api_fastapi/core_api/security.py | 9 +-
.../core_api/services/public/dag_run.py | 244 +-
.../src/airflow/api_fastapi/execution_api/app.py | 5 +-
.../execution_api/datamodels/taskinstance.py | 34 +
.../execution_api/routes/task_instances.py | 47 +-
.../api_fastapi/execution_api/versions/__init__.py | 10 +-
.../execution_api/versions/v2026_06_30.py | 29 +-
.../src/airflow/api_fastapi/logging/decorators.py | 23 +-
airflow-core/src/airflow/assets/manager.py | 60 +-
airflow-core/src/airflow/cli/api_client.py | 129 +
airflow-core/src/airflow/cli/cli_config.py | 15 +-
.../src/airflow/cli/commands/asset_command.py | 66 +-
.../src/airflow/cli/commands/dag_command.py | 132 +-
.../src/airflow/cli/commands/pool_command.py | 101 +-
.../src/airflow/cli/commands/variable_command.py | 2 +-
airflow-core/src/airflow/cli/utils.py | 36 +-
.../src/airflow/config_templates/config.yml | 18 +-
.../src/airflow/dag_processing/bundles/manager.py | 71 +
.../src/airflow/dag_processing/collection.py | 2 +-
airflow-core/src/airflow/dag_processing/dagbag.py | 26 -
airflow-core/src/airflow/dag_processing/manager.py | 95 +-
.../example_dags/example_asset_partition.py | 92 +
.../example_dags/example_params_ui_tutorial.py | 9 +
.../src/airflow/example_dags/example_task_store.py | 3 +-
airflow-core/src/airflow/example_dags/standard | 1 -
.../src/airflow/executors/base_executor.py | 1 +
.../src/airflow/executors/workloads/task.py | 32 +-
.../src/airflow/jobs/scheduler_job_runner.py | 387 +-
.../src/airflow/jobs/triggerer_job_runner.py | 32 +-
.../0117_3_3_0_change_deadline_interval_to_json.py | 46 +-
...22_3_3_0_add_indexes_on_dag_run_created_dag_.py | 77 +
airflow-core/src/airflow/models/backfill.py | 2 +-
airflow-core/src/airflow/models/connection.py | 5 +-
airflow-core/src/airflow/models/dagrun.py | 30 +-
airflow-core/src/airflow/models/hitl.py | 18 +
airflow-core/src/airflow/models/pool.py | 17 +-
airflow-core/src/airflow/models/taskinstance.py | 27 +-
airflow-core/src/airflow/models/taskmap.py | 11 +-
airflow-core/src/airflow/models/variable.py | 5 +-
.../src/airflow/partition_mappers/__init__.py | 4 +
.../src/airflow/partition_mappers/allowed_key.py | 10 +-
airflow-core/src/airflow/partition_mappers/base.py | 81 +-
.../src/airflow/partition_mappers/chain.py | 18 +-
.../src/airflow/partition_mappers/fixed_key.py | 65 +
.../src/airflow/partition_mappers/product.py | 13 +-
.../src/airflow/partition_mappers/temporal.py | 186 +-
.../src/airflow/partition_mappers/wait_policy.py | 174 +
.../src/airflow/partition_mappers/window.py | 136 +-
airflow-core/src/airflow/policies.py | 54 +-
airflow-core/src/airflow/serialization/decoders.py | 21 +
.../src/airflow/serialization/definitions/dag.py | 16 +
.../src/airflow/serialization/definitions/param.py | 8 +-
.../airflow/serialization/definitions/taskgroup.py | 67 +-
airflow-core/src/airflow/serialization/encoders.py | 120 +-
airflow-core/src/airflow/serialization/helpers.py | 21 +-
.../airflow/serialization/serialized_objects.py | 14 +-
airflow-core/src/airflow/settings.py | 8 +-
.../src/airflow/ti_deps/dependencies_states.py | 7 +
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 25 +-
airflow-core/src/airflow/timetables/_cron.py | 10 +
airflow-core/src/airflow/timetables/base.py | 20 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 6 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 12 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 12 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 14 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 12 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 70 +-
.../ui/openapi-gen/requests/services.gen.ts | 12 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 28 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 9 +-
.../airflow/ui/public/i18n/locales/ca/assets.json | 14 +
.../airflow/ui/public/i18n/locales/ca/browse.json | 18 +
.../airflow/ui/public/i18n/locales/ca/common.json | 14 +-
.../ui/public/i18n/locales/ca/components.json | 3 +
.../src/airflow/ui/public/i18n/locales/ca/dag.json | 22 +
.../ui/public/i18n/locales/ca/dashboard.json | 2 +
.../airflow/ui/public/i18n/locales/de/browse.json | 18 +
.../airflow/ui/public/i18n/locales/de/common.json | 9 +
.../ui/public/i18n/locales/de/components.json | 2 +
.../ui/public/i18n/locales/de/dashboard.json | 2 +
.../airflow/ui/public/i18n/locales/en/assets.json | 17 +
.../airflow/ui/public/i18n/locales/en/common.json | 12 +-
.../ui/public/i18n/locales/en/components.json | 3 +
.../src/airflow/ui/public/i18n/locales/en/dag.json | 22 +
.../airflow/ui/public/i18n/locales/he/admin.json | 21 +-
.../airflow/ui/public/i18n/locales/he/assets.json | 6 +-
.../airflow/ui/public/i18n/locales/he/browse.json | 19 +
.../airflow/ui/public/i18n/locales/he/common.json | 76 +-
.../ui/public/i18n/locales/he/components.json | 11 +-
.../src/airflow/ui/public/i18n/locales/he/dag.json | 69 +-
.../airflow/ui/public/i18n/locales/he/dags.json | 5 +
.../ui/public/i18n/locales/he/dashboard.json | 2 +
.../airflow/ui/public/i18n/locales/ko/browse.json | 18 +
.../airflow/ui/public/i18n/locales/ko/common.json | 8 +
.../ui/public/i18n/locales/ko/components.json | 3 +
.../ui/public/i18n/locales/ko/dashboard.json | 2 +
.../airflow/ui/public/i18n/locales/tr/admin.json | 3 +-
.../airflow/ui/public/i18n/locales/tr/assets.json | 1 -
.../airflow/ui/public/i18n/locales/tr/browse.json | 18 +
.../airflow/ui/public/i18n/locales/tr/common.json | 58 +
.../ui/public/i18n/locales/tr/components.json | 9 +-
.../src/airflow/ui/public/i18n/locales/tr/dag.json | 51 +
.../airflow/ui/public/i18n/locales/tr/dags.json | 5 +
.../ui/public/i18n/locales/tr/dashboard.json | 2 +
.../ui/public/i18n/locales/zh-CN/admin.json | 3 +-
.../ui/public/i18n/locales/zh-CN/assets.json | 14 +
.../ui/public/i18n/locales/zh-CN/browse.json | 18 +
.../ui/public/i18n/locales/zh-CN/common.json | 63 +-
.../ui/public/i18n/locales/zh-CN/components.json | 8 +-
.../airflow/ui/public/i18n/locales/zh-CN/dag.json | 73 +
.../airflow/ui/public/i18n/locales/zh-CN/dags.json | 5 +
.../ui/public/i18n/locales/zh-CN/dashboard.json | 2 +
.../ui/public/i18n/locales/zh-TW/assets.json | 14 +
.../ui/public/i18n/locales/zh-TW/browse.json | 18 +
.../ui/public/i18n/locales/zh-TW/common.json | 10 +-
.../ui/public/i18n/locales/zh-TW/components.json | 3 +
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 22 +
.../ui/public/i18n/locales/zh-TW/dashboard.json | 2 +
.../components/ActionAccordion/ActionAccordion.tsx | 11 +-
.../ui/src/components/ActionAccordion/columns.tsx | 61 +-
.../ui/src/components/Banner/BackfillBanner.tsx | 8 +-
.../ClearTaskInstanceConfirmationDialog.tsx | 12 +-
.../Clear/TaskInstance/ClearTaskInstanceDialog.tsx | 162 +-
.../src/components/DagActions/RunBackfillForm.tsx | 1 +
.../src/components/DagDeactivatedBanner.test.tsx | 147 +
.../ui/src/components/DagDeactivatedBanner.tsx | 70 +
.../{useRowSelection.ts => useRowSelection.tsx} | 78 +-
.../src/airflow/ui/src/components/DeleteDialog.tsx | 9 +-
.../components/FlexibleForm/FieldDuration.test.tsx | 105 +
.../src/components/FlexibleForm/FieldDuration.tsx | 76 +
.../src/components/FlexibleForm/FieldSelector.tsx | 6 +
.../src/components/FlexibleForm/FlexibleForm.tsx | 6 +-
.../src/airflow/ui/src/components/HeaderCard.tsx | 49 +-
.../ui/src/components/NeedsReviewButton.tsx | 2 +-
.../src/airflow/ui/src/components/StateIcon.tsx | 11 +-
.../ui/src/components/StoreValueCell.test.tsx | 86 +
.../airflow/ui/src/components/StoreValueCell.tsx | 54 +
.../src/airflow/ui/src/constants/filterConfigs.tsx | 2 +-
.../src/airflow/ui/src/constants/stateOptions.ts | 1 +
.../airflow/ui/src/hooks/useRequiredActionTabs.ts | 4 +-
.../src/airflow/ui/src/i18n/config.test.ts | 91 +
airflow-core/src/airflow/ui/src/i18n/config.ts | 81 +-
.../ui/src/layouts/Details/DagBreadcrumb.tsx | 5 +-
.../ui/src/layouts/Details/DetailsLayout.tsx | 14 +-
.../ui/src/layouts/Details/Gantt/GanttTimeline.tsx | 2 +-
.../airflow/ui/src/layouts/Details/Gantt/utils.ts | 5 +-
.../Details/Graph/useGraphFilteredNodes.test.ts | 49 +
.../layouts/Details/Graph/useGraphFilteredNodes.ts | 30 +-
.../src/airflow/ui/src/layouts/Details/NavTabs.tsx | 77 +-
.../StorageLayout.tsx} | 20 +-
.../src/airflow/ui/src/pages/Asset/AssetEvents.tsx | 79 +
.../src/airflow/ui/src/pages/Asset/AssetLayout.tsx | 63 +-
.../Asset/AssetStore/AddAssetStoreButton.tsx} | 24 +-
.../ui/src/pages/Asset/AssetStore/AssetStore.tsx | 161 +
.../src/pages/Asset/AssetStore/AssetStoreModal.tsx | 138 +
.../Asset/AssetStore/ClearAllAssetStoreButton.tsx | 66 +
.../Asset/AssetStore/DeleteAssetStoreButton.tsx | 67 +
.../Asset/AssetStore/EditAssetStoreButton.tsx} | 27 +-
.../Asset/AssetStore/index.ts} | 8 +-
.../ui/src/pages/Connections/Connections.tsx | 53 +-
.../src/airflow/ui/src/pages/Dag/Code/Code.tsx | 321 +-
.../ui/src/pages/Dag/DagImportErrorModal.tsx | 72 +
.../src/airflow/ui/src/pages/Dag/Header.test.tsx | 1 -
.../src/airflow/ui/src/pages/Dag/Header.tsx | 11 +-
.../src/pages/DagRuns/BulkClearDagRunsButton.tsx | 6 +-
.../src/pages/DagRuns/BulkMarkDagRunsAsButton.tsx | 130 +
.../src/airflow/ui/src/pages/DagRuns/DagRuns.tsx | 51 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 4 +-
.../Dashboard/HistoricalMetrics/DagRunMetrics.tsx | 5 +
.../Dashboard/HistoricalMetrics/MetricSection.tsx | 5 +-
.../HistoricalMetrics/TaskInstanceMetrics.tsx | 6 +
.../{DAGImportErrors.tsx => DagImportErrors.tsx} | 7 +-
...ortErrorsModal.tsx => DagImportErrorsModal.tsx} | 38 +-
.../airflow/ui/src/pages/Dashboard/Stats/Stats.tsx | 4 +-
.../ui/src/pages/GroupTaskInstance/Header.tsx | 4 +-
.../HITLTaskInstances/HITLResponseForm.test.tsx | 34 +
.../pages/HITLTaskInstances/HITLResponseForm.tsx | 4 +-
.../HITLTaskInstances/HITLTaskInstances.test.tsx | 49 +
.../pages/HITLTaskInstances/HITLTaskInstances.tsx | 12 +-
.../ui/src/pages/MappedTaskInstance/Details.tsx | 140 +
.../ui/src/pages/MappedTaskInstance/Header.tsx | 23 +-
.../MappedTaskInstance/MappedTaskInstance.tsx | 17 +-
.../airflow/ui/src/pages/TaskInstance/Header.tsx | 14 +-
.../ui/src/pages/TaskInstance/TaskInstance.tsx | 9 +-
.../src/pages/TaskInstances/TaskInstances.test.tsx | 168 +
.../ui/src/pages/TaskInstances/TaskInstances.tsx | 51 +-
.../TaskStore/AddTaskStoreButton.tsx} | 33 +-
.../pages/TaskStore/ClearAllTaskStoreButton.tsx | 69 +
.../src/pages/TaskStore/DeleteTaskStoreButton.tsx | 70 +
.../TaskStore/EditTaskStoreButton.tsx} | 37 +-
.../airflow/ui/src/pages/TaskStore/TaskStore.tsx | 165 +
.../ui/src/pages/TaskStore/TaskStoreModal.tsx | 237 +
.../TaskStore/index.ts} | 9 +-
.../airflow/ui/src/pages/Variables/Variables.tsx | 50 +-
.../src/airflow/ui/src/pages/XCom/XCom.tsx | 112 +-
.../airflow/ui/src/queries/useBulkClearDagRuns.ts | 130 +-
.../ui/src/queries/useBulkClearDagRunsDryRun.ts | 67 +-
.../airflow/ui/src/queries/useBulkMarkAsDryRun.ts | 2 +-
.../airflow/ui/src/queries/useBulkPatchDagRun.ts | 115 +
.../ui/src/queries/useGridTISummaries.test.tsx | 260 +
.../airflow/ui/src/queries/useGridTISummaries.ts | 50 +-
.../src/airflow/ui/src/queries/useStoreMutation.ts | 67 +
airflow-core/src/airflow/ui/src/router.tsx | 22 +-
airflow-core/src/airflow/ui/src/theme.ts | 1 +
airflow-core/src/airflow/ui/src/utils/hitl.test.ts | 52 +-
airflow-core/src/airflow/ui/src/utils/hitl.ts | 12 +-
airflow-core/src/airflow/ui/src/utils/links.ts | 15 +-
airflow-core/src/airflow/ui/src/utils/query.ts | 1 +
.../src/airflow/ui/src/utils/stateUtils.ts | 1 +
.../src/airflow/ui/tests/e2e/utils/test-helpers.ts | 10 +-
airflow-core/src/airflow/utils/dates.py | 2 +
airflow-core/src/airflow/utils/db.py | 2 +-
airflow-core/src/airflow/utils/db_cleanup.py | 7 +-
airflow-core/src/airflow/utils/file.py | 3 +-
airflow-core/src/airflow/utils/sqlalchemy.py | 49 +-
airflow-core/src/airflow/utils/state.py | 5 +
airflow-core/tests/integration/otel/test_otel.py | 2 +-
.../tests/unit/always/test_example_dags.py | 3 -
airflow-core/tests/unit/always/test_secrets.py | 50 +
.../tests/unit/api/common/test_mark_tasks.py | 36 +-
.../tests/unit/api_fastapi/common/test_cursors.py | 56 +
.../tests/unit/api_fastapi/common/test_dagbag.py | 6 +-
.../unit/api_fastapi/common/test_parameters.py | 24 +-
airflow-core/tests/unit/api_fastapi/conftest.py | 142 +-
.../core_api/routes/public/test_assets.py | 93 +-
.../core_api/routes/public/test_backfills.py | 2 +-
.../core_api/routes/public/test_connections.py | 22 +
.../core_api/routes/public/test_dag_parsing.py | 4 +-
.../core_api/routes/public/test_dag_run.py | 133 +-
.../core_api/routes/public/test_dag_sources.py | 2 +-
.../core_api/routes/public/test_event_logs.py | 35 +
.../core_api/routes/public/test_hitl.py | 55 +
.../core_api/routes/public/test_import_error.py | 184 +
.../core_api/routes/public/test_task_instances.py | 231 +-
.../core_api/routes/ui/test_dashboard.py | 13 +-
.../unit/api_fastapi/core_api/test_security.py | 41 +
.../unit/api_fastapi/execution_api/test_app.py | 80 +-
.../unit/api_fastapi/logging/test_decorators.py | 81 +-
airflow-core/tests/unit/assets/test_manager.py | 277 +-
.../tests/unit/cli/commands/test_asset_command.py | 148 +-
.../unit/cli/commands/test_backfill_command.py | 4 +-
.../unit/cli/commands/test_command_deprecations.py | 72 +
.../tests/unit/cli/commands/test_dag_command.py | 985 +++-
.../tests/unit/cli/commands/test_pool_command.py | 238 +-
.../tests/unit/cli/commands/test_task_command.py | 18 +-
.../tests/unit/cli/commands/test_team_command.py | 2 +-
.../unit/cli/commands/test_variable_command.py | 33 +-
airflow-core/tests/unit/cli/conftest.py | 22 +-
airflow-core/tests/unit/cli/test_api_client.py | 140 +
airflow-core/tests/unit/cli/test_utils.py | 48 +
.../tests/unit/cluster_policies/__init__.py | 8 +-
.../tests/unit/core/test_impersonation_tests.py | 2 +-
airflow-core/tests/unit/core/test_policies.py | 77 +
.../bundles/test_dag_bundle_manager.py | 11 +-
.../tests/unit/dag_processing/test_collection.py | 4 +-
.../tests/unit/dag_processing/test_dagbag.py | 148 +-
.../tests/unit/dag_processing/test_manager.py | 134 +-
.../tests/unit/dag_processing/test_processor.py | 1 +
.../tests/unit/executors/test_base_executor.py | 114 +-
.../tests/unit/executors/test_local_executor.py | 6 +-
.../tests/unit/executors/test_workloads.py | 37 +
airflow-core/tests/unit/jobs/test_scheduler_job.py | 540 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 50 +
.../test_0117_deadline_interval_json_migration.py | 91 +
airflow-core/tests/unit/models/test_cleartasks.py | 63 +
airflow-core/tests/unit/models/test_dag.py | 10 +-
airflow-core/tests/unit/models/test_dagcode.py | 18 +-
airflow-core/tests/unit/models/test_dagrun.py | 377 +-
.../tests/unit/models/test_serialized_dag.py | 22 +-
.../tests/unit/models/test_taskinstance.py | 62 +-
.../unit/partition_mappers/test_allowed_key.py | 17 +
.../tests/unit/partition_mappers/test_base.py | 57 +-
.../tests/unit/partition_mappers/test_chain.py | 37 +-
.../tests/unit/partition_mappers/test_fan_out.py | 339 ++
.../tests/unit/partition_mappers/test_fixed_key.py | 120 +
.../tests/unit/partition_mappers/test_identity.py | 15 +
.../tests/unit/partition_mappers/test_product.py | 21 +-
.../partition_mappers/test_rollup_wait_policy.py | 541 ++
.../tests/unit/partition_mappers/test_temporal.py | 115 +-
.../tests/unit/partition_mappers/test_window.py | 213 +-
.../unit/serialization/definitions/test_param.py | 60 +
.../unit/serialization/test_dag_serialization.py | 6 +-
.../unit/serialization/test_serialized_objects.py | 104 +-
.../unit/ti_deps/deps/test_trigger_rule_dep.py | 58 +-
.../tests/unit/timetables/test_base_timetable.py | 22 +
.../tests/unit/timetables/test_cron_mixin.py | 30 +
.../unit/timetables/test_partitioned_timetable.py | 18 +
.../unit/timetables/test_trigger_timetable.py | 16 +
airflow-core/tests/unit/utils/test_db_cleanup.py | 108 +-
airflow-core/tests/unit/utils/test_task_group.py | 42 +
airflow-ctl-tests/pyproject.toml | 4 +-
airflow-ctl/pyproject.toml | 4 +-
.../src/airflowctl/api/datamodels/generated.py | 208 +-
.../airflowctl/ctl/commands/variable_command.py | 13 +-
.../ctl/commands/test_variable_command.py | 38 +-
airflow-e2e-tests/docker/go.yml | 37 +
airflow-e2e-tests/pyproject.toml | 4 +-
.../tests/airflow_e2e_tests/conftest.py | 183 +-
.../tests/airflow_e2e_tests/constants.py | 22 +-
.../airflow_e2e_tests/go_sdk_tests}/__init__.py | 0
.../go_sdk_tests/test_go_sdk_dag.py | 239 +
chart/docs/conf.py | 8 +-
chart/docs/parameters-ref.rst | 4 +
chart/docs/production-guide.rst | 24 +
chart/newsfragments/68036.significant.rst | 3 +
chart/newsfragments/68043.significant.rst | 12 +
chart/pyproject.toml | 4 +-
chart/templates/NOTES.txt | 127 +-
chart/templates/_helpers.yaml | 36 +-
.../templates/api-server/api-server-httproute.yaml | 61 +
chart/templates/api-server/api-server-ingress.yaml | 11 +-
chart/templates/api-server/api-server-service.yaml | 6 +
chart/templates/flower/flower-ingress.yaml | 11 +-
chart/templates/flower/flower-service.yaml | 6 +
.../otel-collector/otel-collector-service.yaml | 6 +
chart/templates/pgbouncer/pgbouncer-ingress.yaml | 2 +-
chart/templates/pgbouncer/pgbouncer-service.yaml | 6 +
chart/templates/rbac/job-launcher-rolebinding.yaml | 15 +-
chart/templates/rbac/pod-launcher-rolebinding.yaml | 15 +-
.../security-context-constraint-rolebinding.yaml | 5 +-
chart/templates/redis/redis-service.yaml | 6 +
chart/templates/scheduler/scheduler-service.yaml | 6 +
chart/templates/statsd/statsd-ingress.yaml | 2 +-
chart/templates/statsd/statsd-service.yaml | 6 +
chart/templates/triggerer/triggerer-service.yaml | 6 +
chart/templates/workers/worker-service.yaml | 6 +
.../gateway.networking.k8s.io_httproutes.yaml | 5546 ++++++++++++++++++++
chart/tests/chart_utils/helm_template_generator.py | 4 +-
.../airflow_aux/test_basic_helm_chart.py | 2 +-
.../airflow_aux/test_job_launcher_role.py | 100 +-
.../airflow_aux/test_pod_launcher_role.py | 86 +-
.../airflow_aux/test_pod_template_file.py | 16 -
.../helm_tests/airflow_core/test_api_server.py | 20 +
.../helm_tests/airflow_core/test_scheduler.py | 44 +-
.../helm_tests/airflow_core/test_triggerer.py | 24 +
chart/tests/helm_tests/airflow_core/test_worker.py | 22 +
.../apiserver/test_httproute_apiserver.py | 207 +
.../helm_tests/apiserver/test_ingress_apiserver.py | 95 +-
.../otel_collector/test_otel_collector.py | 19 +
chart/tests/helm_tests/other/test_flower.py | 22 +
chart/tests/helm_tests/other/test_pgbouncer.py | 22 +
chart/tests/helm_tests/other/test_redis.py | 20 +
chart/tests/helm_tests/other/test_statsd.py | 48 +-
.../helm_tests/security/test_scc_rolebinding.py | 83 +-
.../helm_tests/security/test_security_context.py | 193 -
chart/values.schema.json | 623 +--
chart/values.yaml | 174 +-
clients/python/pyproject.toml | 4 +-
contributing-docs/08_static_code_checks.rst | 14 +
contributing-docs/30_new_language_sdk.rst | 260 +
contributing-docs/testing/unit_tests.rst | 27 +
dev/README_RELEASE_MYPY.md | 243 +-
dev/README_RELEASE_PROVIDERS.md | 33 +-
dev/breeze/README.md | 41 +-
...017-use-uvx-to-run-breeze-from-local-sources.md | 56 +-
dev/breeze/doc/ci/02_images.md | 6 +-
dev/breeze/doc/ci/04_selective_checks.md | 309 +-
.../images/output_testing_airflow-e2e-tests.svg | 2 +-
.../images/output_testing_airflow-e2e-tests.txt | 2 +-
.../images/output_workflow-run_publish-docs.svg | 58 +-
.../images/output_workflow-run_publish-docs.txt | 2 +-
dev/breeze/pyproject.toml | 4 +-
.../src/airflow_breeze/commands/ci_commands.py | 217 +-
.../airflow_breeze/commands/developer_commands.py | 2 +-
.../airflow_breeze/commands/kubernetes_commands.py | 2 +-
.../commands/release_management_commands.py | 10 +-
.../airflow_breeze/commands/testing_commands.py | 1 +
.../airflow_breeze/commands/workflow_commands.py | 14 +-
dev/breeze/src/airflow_breeze/global_constants.py | 25 +-
dev/breeze/src/airflow_breeze/utils/path_utils.py | 152 +-
.../airflow_breeze/utils/provider_dependencies.py | 2 +-
.../src/airflow_breeze/utils/selective_checks.py | 188 +-
dev/breeze/tests/test_selective_checks.py | 475 +-
dev/breeze/tests/test_set_milestone.py | 326 +-
dev/breeze/tests/test_shim_version_check.py | 212 +
dev/breeze/uv.lock | 199 +-
dev/mypy/pyproject.toml | 4 +-
dev/pyproject.toml | 4 +-
dev/registry/pyproject.toml | 4 +-
devel-common/pyproject.toml | 2 +-
.../task_lifecycle/awaiting_input_state.png | Bin 0 -> 2467 bytes
devel-common/src/tests_common/pytest_plugin.py | 39 +-
devel-common/src/tests_common/test_utils/db.py | 43 +-
docker-stack-docs/build-arg-ref.rst | 2 +-
.../customizing/add-build-essential-custom.sh | 2 +-
.../docker-examples/customizing/custom-sources.sh | 2 +-
.../customizing/pypi-dev-runtime-deps.sh | 2 +-
.../customizing/pypi-extras-and-deps.sh | 2 +-
.../customizing/pypi-selected-version.sh | 2 +-
.../restricted/restricted_environments.sh | 2 +-
docker-stack-docs/pyproject.toml | 4 +-
docker-tests/pyproject.toml | 4 +-
docs/spelling_wordlist.txt | 3 +
generated/provider_dependencies.json | 8 +-
generated/provider_dependencies.json.sha256sum | 2 +-
generated/provider_metadata.json | 476 +-
go-sdk/Justfile | 5 +
go-sdk/README.md | 326 +-
...0002-use-go-tool-directive-for-bundle-packer.md | 110 +-
go-sdk/bundle/bundlev1/bundlev1server/server.go | 66 +-
go-sdk/bundle/bundlev1/registry.go | 94 +-
go-sdk/bundle/bundlev1/registry_test.go | 35 +
go-sdk/bundle/bundlev1/schemas.go | 30 +-
go-sdk/bundle/bundlev1/task.go | 30 +-
go-sdk/bundle/bundlev1/task_test.go | 77 +
go-sdk/cmd/airflow-go-pack/inspect.go | 57 +
go-sdk/cmd/airflow-go-pack/inspect_test.go | 74 +
go-sdk/cmd/airflow-go-pack/main.go | 146 +
go-sdk/cmd/airflow-go-pack/pack.go | 672 +++
.../cmd/airflow-go-pack/pack_integration_test.go | 357 ++
go-sdk/cmd/airflow-go-pack/pack_test.go | 506 ++
go-sdk/dags/go_examples.py | 87 +
go-sdk/example/bundle/Justfile | 25 +-
go-sdk/example/bundle/main.go | 33 +-
go-sdk/example/bundle/main_test.go | 4 +-
go-sdk/go.mod | 4 +-
go-sdk/internal/airflowmetadata/airflowmetadata.go | 51 +
go-sdk/internal/bundlefooter/footer.go | 280 +
go-sdk/internal/bundlefooter/footer_test.go | 158 +
go-sdk/pkg/execution/integration_test.go | 91 +
go-sdk/pkg/execution/messages.go | 19 +-
go-sdk/pkg/execution/messages_test.go | 31 +-
go-sdk/pkg/execution/metadata.go | 157 +
go-sdk/pkg/execution/metadata_test.go | 119 +
go-sdk/pkg/execution/task_runner.go | 32 +
go-sdk/pkg/sdkcontext/keys.go | 11 +
go-sdk/sdk/client.go | 4 +
go-sdk/sdk/connection.go | 8 +
go-sdk/sdk/context.go | 110 +
go-sdk/sdk/context_test.go | 54 +
go-sdk/sdk/doc.go | 26 +-
go-sdk/sdk/errors.go | 8 +-
go-sdk/sdk/sdk.go | 29 +-
java-sdk/README.md | 96 +-
java-sdk/{example => bom}/build.gradle.kts | 37 +-
java-sdk/build.gradle.kts | 61 -
.../buildSrc/build.gradle.kts | 21 +-
.../main/kotlin/airflow-jvm-conventions.gradle.kts | 58 +
.../src/main/kotlin/airflow-publish.gradle.kts | 112 +
.../example/{build.gradle.kts => build.gradle} | 28 +-
java-sdk/example/gradle.properties | 1 +
.../example/settings.gradle | 21 +-
.../apache/airflow/example/AnnotationExample.java | 3 +-
.../airflow/example/ExampleBundleBuilder.java | 2 +-
.../src/resources}/dags/java_examples.py | 0
java-sdk/gradle.properties | 2 +-
java-sdk/plugin/build.gradle.kts | 57 +
.../apache/airflow/sdk/plugin/AirflowSdkPlugin.kt | 221 +
java-sdk/{example => processor}/build.gradle.kts | 38 +-
.../org/apache/airflow/sdk/BuilderProcessor.kt} | 70 -
.../services/javax.annotation.processing.Processor | 0
.../kotlin/org/apache/airflow/sdk/BuilderTest.kt | 0
java-sdk/sdk/build.gradle.kts | 80 +-
.../main/kotlin/org/apache/airflow/sdk/Builder.kt | 192 +-
.../main/kotlin/org/apache/airflow/sdk/Client.kt | 4 +-
.../org/apache/airflow/sdk/execution/Comm.kt | 8 +-
.../kotlin/org/apache/airflow/sdk/ClientTest.kt | 92 +
.../org/apache/airflow/sdk/execution/TaskTest.kt | 4 +-
java-sdk/settings.gradle.kts | 20 +-
kubernetes-tests/pyproject.toml | 4 +-
.../test_kubernetes_pod_operator.py | 2 +-
providers-summary-docs/pyproject.toml | 4 +-
providers/.last_release_date.txt | 2 +-
.../alibaba/cloud/log/oss_task_handler.py | 2 +-
providers/amazon/docs/changelog.rst | 4 +
providers/amazon/docs/operators/bedrock.rst | 2 +
.../aws/hooks/sagemaker_unified_studio_notebook.py | 39 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 2 +-
.../providers/amazon/aws/log/s3_task_handler.py | 2 +-
.../providers/amazon/aws/operators/bedrock.py | 59 +-
.../providers/amazon/aws/triggers/bedrock.py | 36 +
.../aws/waiters/bedrock-agentcore-control.json | 37 +
.../amazon/aws/example_bedrock_evaluation.py | 2 +-
.../tests/system/amazon/aws/example_emr_eks.py | 7 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 1 +
.../test_sagemaker_unified_studio_notebook.py | 36 +-
.../unit/amazon/aws/operators/test_bedrock.py | 66 +-
.../tests/unit/amazon/aws/triggers/test_bedrock.py | 29 +
.../aws/waiters/test_bedrock_agentcore_control.py | 37 +
.../providers/apache/hdfs/log/hdfs_task_handler.py | 2 +-
providers/apache/spark/docs/changelog.rst | 8 +
.../providers/apache/spark/hooks/spark_submit.py | 65 +-
.../apache/spark/operators/spark_submit.py | 66 +-
.../unit/apache/spark/hooks/test_spark_submit.py | 132 +-
.../apache/spark/operators/test_spark_submit.py | 163 +-
providers/clickhousedb/README.rst | 24 +-
.../clickhousedb/docs/connections/clickhouse.rst | 2 +-
providers/clickhousedb/docs/index.rst | 2 +-
.../clickhousedb/docs/operators/clickhouse.rst | 4 +-
providers/cncf/kubernetes/docs/changelog.rst | 1 +
.../providers/cncf/kubernetes/utils/pod_manager.py | 7 +
.../cncf/kubernetes/utils/xcom_sidecar.py | 2 +-
.../system/cncf/kubernetes/example_kubernetes.py | 2 +-
.../cncf/kubernetes/example_kubernetes_async.py | 2 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 6 +-
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 22 +
providers/common/ai/README.rst | 2 +-
providers/common/ai/docs/connections/mcp.rst | 40 +-
providers/common/ai/docs/hooks/pydantic_ai.rst | 30 +
providers/common/ai/docs/index.rst | 2 +-
providers/common/ai/docs/toolsets.rst | 56 +-
providers/common/ai/pyproject.toml | 6 +-
.../common/ai/example_dags/example_agent_spec.yaml | 15 +-
.../example_dags/example_aip_progress_tracker.py | 1057 +++-
.../ai/example_dags/example_pydantic_ai_hook.py | 43 +
.../ai/example_dags/skills/aip-tracker/SKILL.md | 143 +
.../src/airflow/providers/common/ai/hooks/mcp.py | 62 +-
.../providers/common/ai/hooks/pydantic_ai.py | 76 +-
.../providers/common/ai/operators/llm_sql.py | 11 +-
.../common/ai/toolsets/langchain_bridge.py | 38 +-
.../airflow/providers/common/ai/toolsets/mcp.py | 19 +-
.../airflow/providers/common/ai/toolsets/sql.py | 200 +-
.../providers/common/ai/utils/sql_validation.py | 75 +-
.../ai/tests/unit/common/ai/hooks/test_mcp.py | 102 +-
.../tests/unit/common/ai/hooks/test_pydantic_ai.py | 128 +
.../common/ai/toolsets/test_langchain_bridge.py | 34 +
.../ai/tests/unit/common/ai/toolsets/test_mcp.py | 20 +-
.../ai/tests/unit/common/ai/toolsets/test_sql.py | 381 +-
.../unit/common/ai/utils/test_sql_validation.py | 101 +-
providers/edge3/docs/changelog.rst | 6 +
.../edge3/docs/img/distributed_architecture.svg | 5 +-
providers/edge3/docs/img/edge_package.svg | 5 +-
providers/edge3/pyproject.toml | 4 +-
.../providers/edge3/plugins/www/package.json | 14 +-
.../providers/edge3/plugins/www/pnpm-lock.yaml | 539 +-
.../providers/edge3/worker_api/routes/jobs.py | 11 +-
.../edge3/worker_api/v2-edge-generated.yaml | 55 +-
.../unit/edge3/worker_api/routes/test_jobs.py | 28 +-
.../providers/elasticsearch/log/es_task_handler.py | 5 +-
.../unit/elasticsearch/log/test_es_task_handler.py | 3 +
.../docs/auth-manager/configuring-flask-app.rst | 14 +-
providers/fab/docs/auth-manager/sso.rst | 4 +-
providers/fab/pyproject.toml | 4 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 24 +
.../fab/auth_manager/security_manager/override.py | 1 +
.../fab/src/airflow/providers/fab/www/package.json | 2 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 106 +-
.../unit/fab/auth_manager/test_fab_auth_manager.py | 26 +
providers/fab/tests/unit/fab/www/views/conftest.py | 3 +-
providers/google/docs/index.rst | 1 +
.../docs/operators/transfer/mongo_to_gcs.rst | 68 +
providers/google/provider.yaml | 4 +
providers/google/pyproject.toml | 4 +
.../providers/google/cloud/log/gcs_task_handler.py | 2 +-
.../google/cloud/log/stackdriver_task_handler.py | 14 +-
.../google/cloud/transfers/mongo_to_gcs.py | 225 +
.../airflow/providers/google/get_provider_info.py | 6 +
.../google/cloud/transfers/example_mongo_to_gcs.py | 111 +
.../cloud/log/test_stackdriver_task_handler.py | 45 +
.../unit/google/cloud/operators/test_dataproc.py | 2 +-
.../unit/google/cloud/operators/test_looker.py | 2 +-
.../google/cloud/transfers/test_mongo_to_gcs.py | 273 +
.../hashicorp/_internal_client/vault_client.py | 8 +-
.../_internal_client/test_vault_client.py | 55 +
providers/http/README.rst | 1 +
providers/http/docs/index.rst | 1 +
providers/http/pyproject.toml | 1 +
.../keycloak/auth_manager/keycloak_auth_manager.py | 30 +-
.../auth_manager/test_keycloak_auth_manager.py | 21 +-
providers/microsoft/azure/docs/index.rst | 2 +
.../microsoft/azure/docs/transfer/gcs_to_wasb.rst | 69 +
providers/microsoft/azure/provider.yaml | 4 +
providers/microsoft/azure/pyproject.toml | 8 +
.../providers/microsoft/azure/get_provider_info.py | 6 +
.../microsoft/azure/log/wasb_task_handler.py | 2 +-
.../microsoft/azure/transfers/gcs_to_wasb.py | 261 +
.../microsoft/azure/transfers/test_gcs_to_wasb.py | 259 +
.../unit/openlineage/plugins/test_execution.py | 2 -
.../providers/opensearch/log/os_task_handler.py | 5 +-
.../unit/opensearch/log/test_os_task_handler.py | 5 +
.../airflow/providers/papermill/hooks/kernel.py | 4 +-
.../airflow/providers/postgres/hooks/postgres.py | 37 +-
.../tests/unit/postgres/hooks/test_postgres.py | 48 +-
.../src/airflow/providers/redis/hooks/redis.py | 25 +
.../redis/tests/unit/redis/hooks/test_redis.py | 73 +-
providers/snowflake/README.rst | 2 +-
providers/snowflake/docs/connections/snowflake.rst | 42 +-
providers/snowflake/docs/index.rst | 2 +-
providers/snowflake/pyproject.toml | 3 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 23 +-
.../providers/snowflake/operators/snowflake.py | 2 +-
.../tests/unit/snowflake/hooks/test_snowflake.py | 95 +
.../unit/snowflake/operators/test_snowflake.py | 17 +
providers/ssh/docs/operators/ssh_remote_job.rst | 42 +-
.../ssh/src/airflow/providers/ssh/hooks/ssh.py | 25 +-
.../providers/ssh/operators/ssh_remote_job.py | 242 +-
.../providers/ssh/triggers/ssh_remote_job.py | 252 +-
providers/ssh/tests/unit/ssh/hooks/test_ssh.py | 20 +
.../unit/ssh/operators/test_ssh_remote_job.py | 131 +
.../tests/unit/ssh/triggers/test_ssh_remote_job.py | 273 +-
.../airflow/providers/standard/operators/hitl.py | 37 +-
.../providers/standard/operators/trigger_dagrun.py | 19 +-
.../tests/unit/standard/operators/test_hitl.py | 83 +-
.../unit/standard/operators/test_trigger_dagrun.py | 31 +-
.../standard/sensors/test_external_task_sensor.py | 32 +-
.../tests/unit/standard/sensors/test_time_delta.py | 17 +-
.../tests/unit/standard/sensors/test_weekday.py | 12 +-
pyproject.toml | 13 +-
scripts/ci/install_breeze.sh | 2 +-
scripts/ci/prek/check_extra_packages_ref.py | 2 +-
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/check_notice_files.py | 8 +-
.../check_partition_mapper_defaults_in_sync.py | 386 ++
scripts/ci/prek/check_task_instance_dto_sync.py | 125 -
scripts/ci/prek/check_window_in_sync.py | 216 +
scripts/ci/prek/generate_agent_skills.py | 110 +
scripts/ci/prek/known_airflow_exceptions.txt | 2 +-
scripts/ci/prek/ruff_format.py | 2 +-
scripts/ci/prek/supported_versions.py | 2 +-
scripts/ci/prek/sync_translation_namespaces.py | 2 +-
scripts/ci/prek/update_notice_year.py | 74 +
scripts/docker/entrypoint_ci.sh | 6 +-
scripts/docker/install_jdk.sh | 2 +-
scripts/docker/install_os_dependencies.sh | 14 +-
scripts/pyproject.toml | 4 +-
...test_check_partition_mapper_defaults_in_sync.py | 388 ++
.../tests/ci/prek/test_generate_agent_skills.py | 34 +-
scripts/tools/setup_breeze | 47 +-
shared/configuration/pyproject.toml | 4 +-
shared/dagnode/pyproject.toml | 4 +-
shared/listeners/pyproject.toml | 4 +-
shared/logging/pyproject.toml | 4 +-
.../logging/src/airflow_shared/logging/remote.py | 2 +-
shared/logging/tests/logging/test_remote.py | 4 +
shared/module_loading/pyproject.toml | 4 +-
.../src/airflow_shared/module_loading/__init__.py | 4 +
.../src/airflow_shared/module_loading/dag_file.py | 9 +-
.../tests/module_loading/test_dag_file.py | 11 +-
shared/observability/pyproject.toml | 4 +-
.../observability/metrics/metrics_template.yaml | 35 +
.../observability/metrics/otel_logger.py | 32 +-
.../observability/metrics/test_otel_logger.py | 48 +-
shared/plugins_manager/pyproject.toml | 4 +-
shared/providers_discovery/pyproject.toml | 4 +-
shared/secrets_backend/pyproject.toml | 4 +-
.../src/airflow_shared/secrets_backend/base.py | 40 +-
.../tests/secrets_backend/test_base.py | 95 +
shared/secrets_masker/pyproject.toml | 4 +-
shared/serialization/pyproject.toml | 4 +-
shared/state/pyproject.toml | 4 +-
shared/state/src/airflow_shared/state/__init__.py | 11 +-
shared/state/tests/state/test_state.py | 40 +-
shared/template_rendering/pyproject.toml | 4 +-
shared/timezones/pyproject.toml | 4 +-
task-sdk-integration-tests/pyproject.toml | 4 +-
task-sdk/docs/api.rst | 14 +
task-sdk/docs/deferred-vs-async-operators.rst | 9 +
task-sdk/docs/executable-bundle-spec.rst | 59 +-
task-sdk/docs/index.rst | 1 +
task-sdk/docs/resumable-job-mixin.rst | 167 +
task-sdk/pyproject.toml | 5 +-
task-sdk/src/airflow/sdk/__init__.py | 26 +-
task-sdk/src/airflow/sdk/__init__.pyi | 16 +
task-sdk/src/airflow/sdk/api/client.py | 6 +
.../src/airflow/sdk/api/datamodels/_generated.py | 18 +
.../{resumablemixin.py => resumablejobmixin.py} | 98 +-
task-sdk/src/airflow/sdk/configuration.py | 41 +
.../src/airflow/sdk/coordinators/_subprocess.py | 97 +-
.../sdk/coordinators/executable/coordinator.py | 4 +-
.../airflow/sdk/coordinators/java/coordinator.py | 4 +-
.../sdk/definitions/asset/access_control.py | 6 +-
task-sdk/src/airflow/sdk/definitions/param.py | 10 +-
.../definitions/partition_mappers/allowed_key.py | 6 +-
.../sdk/definitions/partition_mappers/base.py | 46 +-
.../sdk/definitions/partition_mappers/chain.py | 8 +-
.../sdk/definitions/partition_mappers/fixed_key.py | 52 +
.../sdk/definitions/partition_mappers/product.py | 14 +-
.../sdk/definitions/partition_mappers/temporal.py | 130 +-
.../definitions/partition_mappers/wait_policy.py | 74 +
.../sdk/definitions/partition_mappers/window.py | 85 +-
task-sdk/src/airflow/sdk/definitions/taskgroup.py | 92 +-
.../airflow/sdk/definitions/timetables/_cron.py | 18 +
task-sdk/src/airflow/sdk/exceptions.py | 42 +
.../sdk/execution_time/callback_supervisor.py | 76 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 17 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 31 +-
.../src/airflow/sdk/execution_time/coordinator.py | 6 +-
.../airflow/sdk/execution_time/schema/schema.json | 313 +-
.../sdk/execution_time/sentry/configured.py | 6 +-
.../src/airflow/sdk/execution_time/supervisor.py | 33 +-
.../src/airflow/sdk/execution_time/task_runner.py | 106 +-
.../airflow/sdk/execution_time/workloads/task.py | 53 -
task-sdk/src/airflow/sdk/log.py | 28 +-
.../tests/task_sdk/bases/test_resumablejobmixin.py | 341 ++
.../tests/task_sdk/bases/test_resumablemixin.py | 199 -
.../coordinators/executable/test_coordinator.py | 8 +-
.../task_sdk/coordinators/java/test_coordinator.py | 8 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 217 +-
.../definitions/test_asset_access_control.py | 2 +-
task-sdk/tests/task_sdk/definitions/test_param.py | 33 +
.../task_sdk/definitions/test_partition_mappers.py | 130 +
.../task_sdk/definitions/test_retry_policy.py | 20 +-
.../tests/task_sdk/definitions/test_taskgroup.py | 45 +
.../tests/task_sdk/definitions/test_wait_policy.py | 56 +
.../task_sdk/definitions/timetables}/__init__.py | 0
.../task_sdk/definitions/timetables/test__cron.py | 64 +
.../execution_time/test_callback_supervisor.py | 241 +-
.../tests/task_sdk/execution_time/test_context.py | 32 +-
.../tests/task_sdk/execution_time/test_sentry.py | 55 +
.../task_sdk/execution_time/test_supervisor.py | 83 +-
.../task_sdk/execution_time/test_task_runner.py | 323 +-
task-sdk/tests/task_sdk/test_configuration.py | 27 +
task-sdk/tests/task_sdk/test_log.py | 120 -
uv.lock | 5044 ++++++++++--------
843 files changed, 45464 insertions(+), 11151 deletions(-)
rename {.github => .agents}/skills/aip-user-stories/SKILL.md (100%)
rename {.github =>
.agents}/skills/aip-user-stories/references/playbook-template.md (100%)
rename {.github => .agents}/skills/airflow-translations/SKILL.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/ar.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/ca.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/de.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/el.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/es.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/fr.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/he.md (97%)
rename {.github => .agents}/skills/airflow-translations/locales/hi.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/hu.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/it.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/ja.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/ko.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/nl.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/pl.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/pt.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/th.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/tr.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/zh-CN.md (100%)
rename {.github => .agents}/skills/airflow-translations/locales/zh-TW.md (100%)
rename {.github => .agents}/skills/magpie-setup/SKILL.md (80%)
rename {.github => .agents}/skills/magpie-setup/adopt.md (86%)
create mode 100644 .agents/skills/magpie-setup/agents.md
rename {.github => .agents}/skills/magpie-setup/overrides.md (100%)
rename {.github => .agents}/skills/magpie-setup/unadopt.md (72%)
rename {.github => .agents}/skills/magpie-setup/upgrade.md (82%)
rename {.github => .agents}/skills/magpie-setup/verify.md (88%)
rename {.github => .agents}/skills/magpie-setup/worktree-init.md (74%)
rename {.github => .agents}/skills/prepare-providers-documentation/SKILL.md
(100%)
create mode 120000 .claude/skills/airflow-translations
create mode 120000 .claude/skills/prepare-providers-documentation
create mode 120000 .github/skills/aip-user-stories
create mode 120000 .github/skills/airflow-translations
create mode 120000 .github/skills/magpie-setup
delete mode 100644 .github/skills/magpie-setup/conventions.md
create mode 120000 .github/skills/prepare-providers-documentation
delete mode 100644 .github/workflows/scheduled-upgrade-check-v3-2-test.yml
create mode 100644
airflow-core/docs/administration-and-deployment/task-and-asset-store-cleanup.rst
create mode 100644
airflow-core/docs/administration-and-deployment/task-and-asset-store.rst
create mode 100644
airflow-core/docs/authoring-and-scheduling/language-sdks/go.rst
create mode 100644 airflow-core/docs/core-concepts/asset-store.rst
create mode 100644 airflow-core/docs/core-concepts/resumable-tasks.rst
create mode 100644 airflow-core/docs/core-concepts/task-and-asset-store.rst
create mode 100644 airflow-core/docs/core-concepts/task-store.rst
create mode 100644 airflow-core/newsfragments/66030.feature.rst
create mode 100644 airflow-core/newsfragments/66161.significant.rst
create mode 100644 airflow-core/newsfragments/66848.feature.rst
create mode 100644 airflow-core/newsfragments/67184.feature.rst
create mode 100644 airflow-core/newsfragments/67475.feature.rst
create mode 100644 airflow-core/newsfragments/67688.improvement.rst
create mode 100644 airflow-core/newsfragments/67716.feature.rst
create mode 100644 airflow-core/newsfragments/67873.bugfix.rst
create mode 100644 airflow-core/newsfragments/68028.feature.rst
create mode 100644 airflow-core/newsfragments/68175.significant.rst
create mode 100644 airflow-core/newsfragments/68266.bugfix.rst
delete mode 100644 airflow-core/src/airflow/api/client/local_client.py
create mode 100644 airflow-core/src/airflow/cli/api_client.py
delete mode 120000 airflow-core/src/airflow/example_dags/standard
create mode 100644
airflow-core/src/airflow/migrations/versions/0122_3_3_0_add_indexes_on_dag_run_created_dag_.py
create mode 100644 airflow-core/src/airflow/partition_mappers/fixed_key.py
create mode 100644 airflow-core/src/airflow/partition_mappers/wait_policy.py
create mode 100644
airflow-core/src/airflow/ui/src/components/DagDeactivatedBanner.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/DagDeactivatedBanner.tsx
rename
airflow-core/src/airflow/ui/src/components/DataTable/{useRowSelection.ts =>
useRowSelection.tsx} (54%)
create mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/FieldDuration.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/FlexibleForm/FieldDuration.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/StoreValueCell.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/StoreValueCell.tsx
create mode 100644 airflow-core/src/airflow/ui/src/i18n/config.test.ts
copy airflow-core/src/airflow/ui/src/{components/DagDeactivatedBadge.tsx =>
layouts/StorageLayout.tsx} (62%)
create mode 100644 airflow-core/src/airflow/ui/src/pages/Asset/AssetEvents.tsx
copy airflow-core/src/airflow/ui/src/{components/DagDeactivatedBadge.tsx =>
pages/Asset/AssetStore/AddAssetStoreButton.tsx} (59%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Asset/AssetStore/AssetStore.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Asset/AssetStore/AssetStoreModal.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Asset/AssetStore/ClearAllAssetStoreButton.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Asset/AssetStore/DeleteAssetStoreButton.tsx
copy airflow-core/src/airflow/ui/src/{components/DagDeactivatedBadge.tsx =>
pages/Asset/AssetStore/EditAssetStoreButton.tsx} (54%)
copy airflow-core/src/airflow/ui/src/{components/DagDeactivatedBadge.tsx =>
pages/Asset/AssetStore/index.ts} (74%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dag/DagImportErrorModal.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagRuns/BulkMarkDagRunsAsButton.tsx
rename
airflow-core/src/airflow/ui/src/pages/Dashboard/Stats/{DAGImportErrors.tsx =>
DagImportErrors.tsx} (89%)
rename
airflow-core/src/airflow/ui/src/pages/Dashboard/Stats/{DAGImportErrorsModal.tsx
=> DagImportErrorsModal.tsx} (76%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/MappedTaskInstance/Details.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskInstances/TaskInstances.test.tsx
copy airflow-core/src/airflow/ui/src/{components/DagDeactivatedBadge.tsx =>
pages/TaskStore/AddTaskStoreButton.tsx} (55%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskStore/ClearAllTaskStoreButton.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskStore/DeleteTaskStoreButton.tsx
copy airflow-core/src/airflow/ui/src/{components/DagDeactivatedBadge.tsx =>
pages/TaskStore/EditTaskStoreButton.tsx} (50%)
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskStore/TaskStore.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskStore/TaskStoreModal.tsx
copy airflow-core/src/airflow/ui/src/{components/DagDeactivatedBadge.tsx =>
pages/TaskStore/index.ts} (74%)
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkPatchDagRun.ts
create mode 100644
airflow-core/src/airflow/ui/src/queries/useGridTISummaries.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/queries/useStoreMutation.ts
create mode 100644
airflow-core/tests/unit/cli/commands/test_command_deprecations.py
create mode 100644 airflow-core/tests/unit/cli/test_api_client.py
create mode 100644 airflow-core/tests/unit/cli/test_utils.py
create mode 100644
airflow-core/tests/unit/migrations/test_0117_deadline_interval_json_migration.py
create mode 100644 airflow-core/tests/unit/partition_mappers/test_fan_out.py
create mode 100644 airflow-core/tests/unit/partition_mappers/test_fixed_key.py
create mode 100644
airflow-core/tests/unit/partition_mappers/test_rollup_wait_policy.py
create mode 100644
airflow-core/tests/unit/serialization/definitions/test_param.py
create mode 100644 airflow-e2e-tests/docker/go.yml
copy {airflow-core/src/airflow/_shared =>
airflow-e2e-tests/tests/airflow_e2e_tests/go_sdk_tests}/__init__.py (100%)
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py
create mode 100644 chart/newsfragments/68036.significant.rst
create mode 100644 chart/newsfragments/68043.significant.rst
create mode 100644 chart/templates/api-server/api-server-httproute.yaml
create mode 100644
chart/tests/chart_utils/gateway.networking.k8s.io_httproutes.yaml
create mode 100644 chart/tests/helm_tests/apiserver/test_httproute_apiserver.py
create mode 100644 contributing-docs/30_new_language_sdk.rst
create mode 100644 dev/breeze/tests/test_shim_version_check.py
create mode 100644
devel-common/src/docs/diagrams/task_lifecycle/awaiting_input_state.png
create mode 100644 go-sdk/cmd/airflow-go-pack/inspect.go
create mode 100644 go-sdk/cmd/airflow-go-pack/inspect_test.go
create mode 100644 go-sdk/cmd/airflow-go-pack/main.go
create mode 100644 go-sdk/cmd/airflow-go-pack/pack.go
create mode 100644 go-sdk/cmd/airflow-go-pack/pack_integration_test.go
create mode 100644 go-sdk/cmd/airflow-go-pack/pack_test.go
create mode 100644 go-sdk/dags/go_examples.py
create mode 100644 go-sdk/internal/airflowmetadata/airflowmetadata.go
create mode 100644 go-sdk/internal/bundlefooter/footer.go
create mode 100644 go-sdk/internal/bundlefooter/footer_test.go
create mode 100644 go-sdk/pkg/execution/metadata.go
create mode 100644 go-sdk/pkg/execution/metadata_test.go
create mode 100644 go-sdk/sdk/context.go
create mode 100644 go-sdk/sdk/context_test.go
copy java-sdk/{example => bom}/build.gradle.kts (53%)
delete mode 100644 java-sdk/build.gradle.kts
copy airflow-core/src/airflow/ui/src/components/DagDeactivatedBadge.tsx =>
java-sdk/buildSrc/build.gradle.kts (71%)
create mode 100644
java-sdk/buildSrc/src/main/kotlin/airflow-jvm-conventions.gradle.kts
create mode 100644 java-sdk/buildSrc/src/main/kotlin/airflow-publish.gradle.kts
copy java-sdk/example/{build.gradle.kts => build.gradle} (69%)
create mode 120000 java-sdk/example/gradle.properties
rename airflow-core/src/airflow/ui/src/components/DagDeactivatedBadge.tsx =>
java-sdk/example/settings.gradle (69%)
rename java-sdk/{ => example/src/resources}/dags/java_examples.py (100%)
create mode 100644 java-sdk/plugin/build.gradle.kts
create mode 100644
java-sdk/plugin/src/main/kotlin/org/apache/airflow/sdk/plugin/AirflowSdkPlugin.kt
rename java-sdk/{example => processor}/build.gradle.kts (50%)
copy java-sdk/{sdk/src/main/kotlin/org/apache/airflow/sdk/Builder.kt =>
processor/src/main/kotlin/org/apache/airflow/sdk/BuilderProcessor.kt} (76%)
rename java-sdk/{sdk =>
processor}/src/main/resources/META-INF/services/javax.annotation.processing.Processor
(100%)
rename java-sdk/{sdk =>
processor}/src/test/kotlin/org/apache/airflow/sdk/BuilderTest.kt (100%)
create mode 100644
java-sdk/sdk/src/test/kotlin/org/apache/airflow/sdk/ClientTest.kt
copy java-sdk/gradle.properties =>
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_agent_spec.yaml
(71%)
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/skills/aip-tracker/SKILL.md
create mode 100644 providers/google/docs/operators/transfer/mongo_to_gcs.rst
create mode 100644
providers/google/src/airflow/providers/google/cloud/transfers/mongo_to_gcs.py
create mode 100644
providers/google/tests/system/google/cloud/transfers/example_mongo_to_gcs.py
create mode 100644
providers/google/tests/unit/google/cloud/transfers/test_mongo_to_gcs.py
create mode 100644 providers/microsoft/azure/docs/transfer/gcs_to_wasb.rst
create mode 100644
providers/microsoft/azure/src/airflow/providers/microsoft/azure/transfers/gcs_to_wasb.py
create mode 100644
providers/microsoft/azure/tests/unit/microsoft/azure/transfers/test_gcs_to_wasb.py
create mode 100755 scripts/ci/prek/check_partition_mapper_defaults_in_sync.py
delete mode 100755 scripts/ci/prek/check_task_instance_dto_sync.py
create mode 100755 scripts/ci/prek/check_window_in_sync.py
create mode 100644 scripts/ci/prek/generate_agent_skills.py
create mode 100644 scripts/ci/prek/update_notice_year.py
create mode 100644
scripts/tests/ci/prek/test_check_partition_mapper_defaults_in_sync.py
copy
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2026_06_30.py =>
scripts/tests/ci/prek/test_generate_agent_skills.py (50%)
rename airflow-core/src/airflow/api/client/__init__.py =>
shared/module_loading/src/airflow_shared/module_loading/dag_file.py (81%)
rename task-sdk/src/airflow/sdk/execution_time/workloads/__init__.py =>
shared/module_loading/tests/module_loading/test_dag_file.py (72%)
create mode 100644 task-sdk/docs/resumable-job-mixin.rst
rename task-sdk/src/airflow/sdk/bases/{resumablemixin.py =>
resumablejobmixin.py} (64%)
create mode 100644
task-sdk/src/airflow/sdk/definitions/partition_mappers/fixed_key.py
create mode 100644
task-sdk/src/airflow/sdk/definitions/partition_mappers/wait_policy.py
delete mode 100644 task-sdk/src/airflow/sdk/execution_time/workloads/task.py
create mode 100644 task-sdk/tests/task_sdk/bases/test_resumablejobmixin.py
delete mode 100644 task-sdk/tests/task_sdk/bases/test_resumablemixin.py
create mode 100644 task-sdk/tests/task_sdk/definitions/test_wait_policy.py
copy {airflow-core/src/airflow/_shared =>
task-sdk/tests/task_sdk/definitions/timetables}/__init__.py (100%)
create mode 100644 task-sdk/tests/task_sdk/definitions/timetables/test__cron.py
delete mode 100644 task-sdk/tests/task_sdk/test_log.py
