This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/ui/eslint-3515529389
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit e4f5025a7d6 chore(deps-dev): bump the eslint group across 1 directory
with 6 updates
add 35e087691b9 Fix flaky test_run_no_log in DbApiHook by verifying caplog
text instead of length. (#63860)
add e29d13e366e update Amazon's provider.yaml with some missing modules
(#64009)
add 79c5ca3807b chore(deps): bump the github-actions-updates group with 4
updates (#64007)
add 99e3f958620 Suppress Python build output in Docker builds unless build
fails (#63984)
add 59882ae5ea6 CI: Skip newsfragment check when label is set (#63983)
add df1e397adae Mention Python 3.14 support in docs (#63950)
add 5ddd2840e37 Add INFO-level logging to asset scheduling path (#63958)
add 5371552a75f Update mocking connections docs to use task SDK
Connection.get (#63996) (#64014)
add 3e02720e0b3 Improve 0102_3_2_0_make_external_executor_id_text
downgrade migration (#63625)
add 39e01a2d3a7 Bump Node.js to 24 and upgrade actions to Node.js 24
runtimes (#64021)
add b1a69eaeaa1 Fix `uv export` missing `--no-emit-workspace` causing
parallel install lock issues (#64020)
add c64ebe56e2d Fix Python 3.14 ARM failures by removing side-loaded
packages (#64028)
add fc3b015a217 Fetching dynamic target branches for execution API prek
hook (#63985)
add 6e6ab0bd111 Rectify DetachedInstanceError for airflow tasks render
command (#63916)
add eff66653029 Adds support for go worker in breeze start (#52156)
add 5e64571ca95 Add Bulk operations for edge workers page (#64033)
add 64875d3eb95 Fix helm release process (#64040)
add 741102eccf6 Fix Airflow dist URL in helm chart release docs (#64049)
add 7ed98492b96 Docs: add missing words to spelling wordlist (#64047)
add e04d09c2a61 Ensure gh CLI auth in Slack notification workflows (#64045)
add 3aa2745022d Use archive.apache.org for Apache RAT download in release
docs (#64053)
add bfb8e497a1a remove useless mock db (#63740)
add 5309218ff28 fix: suppress false error logs for partitioned timetables
when next_dagrun fields are None (#63962)
add abb2a979b71 Fix typo in `monitor_databricks_job` (#63651)
add 51e43165a00 remove leftover of `uv.lock` file changes (#64055)
add d603e6cf688 fix: add __call__ to MockOptional for WTForms validator
compatibility (#63823)
add 96eefca6d2f fix: elasticsearch / opensearch logging exception details
are missing in task log tab (#63739)
add 78f8c974a27 Update google change log (#64065)
add b0cc7e10877 Removes hardcoded api_key in run_tmux (#64073)
add 8985247f3ea Update Helm Chart bug template post 1.20.0 release (#64080)
add bf1e5fda206 add application name as env var to driver and executor
pods for SparkKubernetesOperator (#64015)
add bfcb77fb6f3 Post Helm release upgrade chart version (#64081)
add 03ff055ef32 Update link to triage team member list (#64079)
add 26cd35328ee Add Python 3.14 Support (#64061)
add be1fb803329 Fix helm chart release doc: remove outdated Fastly cache
invalidation step (#64088)
add b57ae490002 fix: optimize migration 0094 upgrade to use SQL instead of
Python deserialization (#63628)
add a35ef873d8a Improve 0101_3_2_0_ui_improvements_for_deadlines upgrade
migration (#63920)
add 2f6dbffe81d Make TaskSDK conf respect default config from provider
metadata (#62696)
add 5a7d957fbb7 delete duplicate import in test_hitl.py (#63886)
add d5e5f432d86 feat: Add ChainMapper (#64094)
add 930f733f270 Optimize public get_dag_runs endpoint (#63940)
add 682aaabf5e6 Update google change log for release 21.0 (#64091)
add 0f68191fbbc FAB: fix 403 from roles endpoint despite admin rights
(#64097)
add a00e48c2421 Add Python 3.14 Support (#64096)
add 5c6c34243b9 Order of task arguments in task definition causing error
when parsing DAG (#62174)
add 09ed27a11d6 Add ConnectionResponse serializer safeguard (#63883)
add 497f1c53012 Add Vespa.ai to INTHEWILD.md (#64101)
add 4eabf7964a7 Fix DagRun._emit_dagrun_span crash on None context_carrier
(#64087)
add 23b31280a20 Fix: restore searchable dropdown for DAG params enum
fields (#63895)
add 194cdb6ebb5 Display docker command attempted when reporting docker
failure (#64082)
add 3651eea45bc Persisting filter by tag (#63273)
add ce03fd67288 Remove deprecated classes scheduled for March 2026 (#64098)
add b35c155bf8b Fix dag run accessorkey on clear ti page (#64072)
add 6990f2cfbc3 Upper bound limit starlette < 1.0.0 (#64115)
add 91dcbd9a7da Support elasticsearch 9 (#64070)
add d45ea10189b clean google changelog.rst (#64112)
add 7dca298eb81 Adds a state param into keycloak login (#64114)
add 01f5f66033b set `object_name`, `payload`, `external_id_field` as
templated fields in `SalesforceBulkOperator` (#63109)
add 29ff64795b9 update footer summary table for constraints version check
script (#64117)
add 19ce393c565 Fix conf import to common.compat in
`ElasticsearchTaskHandler` (#64118)
add 9c1f5d894e6 Replace the scan of container groups in a resource group
with a direct in AzureContainerInstanceHook (#63567)
add f6c19194004 Fix shell injection in GitHook SSH passphrase askpass
script (#64126)
add 51e98df6519 fix(providers/standard): add response_timeout to
HITLOperator to prevent race with execution_timeout (#63475)
add 0dc4d33b602 Introduce parent task spans and nest worker and trigger
spans under them (#63839)
add 5d9819fea58 Speed up 'Generate the FastAPI API spec' prek hook (~2min
→ ~25s) (#64131)
add af4f825962c update Dag Runs document under Core Concept to make it
consistent with BashOperator document (#64129)
add 821a4ad583e fix(providers/alibaba): pass relative path to oss_write in
OSSRemoteLogIO.upload (#63246)
add 4f2493d9b44 fix: block path traversal via ".." in dag_id and run_id
(#63296)
add c09f02de555 Update celery provider conf imports to use common compat
SDK (#64134)
add e967fb56538 Update sdk lazy imports for lineage (#64123)
add 13ab3ec0de4 fix typos and spelling (#64139)
add 62cbf63c515 update check_clie_definition_import to allow using common
provider sdk (#64138)
add eb9ff5e3755 Fix typo in debug message for `AirbyteTriggerSyncOperator`
(#64084)
add e686aeebc73 Immediatly refresh TISummaries when gridRuns are
invalidated (#64113)
add a594c9943eb Update edge executor's import conf path to use common
compat SDK (#64137)
add cb2c5e66529 fix(ui/e2e): improve Playwright test patterns in
task-logs.spec.ts (#63990)
add f6621f3015d Fix `TypeError` crashes on `/users/list` and `/roles/list`
in FAB UI caused by concurrent API schema requests (#63986)
add 20bb220423d Fix partitioned asset events incorrectly triggering
non-partition-aware Dags (#63848)
add 52734ea7cc6 docs: asset partition (#63262)
add d12d3daa255 refactor: Limited myself as code owner of the msgraph
modules, not the entire Azure provider (#64158)
add 6c97aede3f0 improve e2e tests for dag audit log (#63463)
add 485ce81fdd8 chore(deps): bump the fab-ui-package-updates group across
1 directory with 4 updates (#64111)
add 2563e07a139 Fix FAB DB manager discovery in migration-only contexts
(#64145)
add e20026b4491 UpdateConfImports (#64165)
add eef9acf63da Remove self parameter from resolve_nested (#64146)
add 6849c3e4bd5 Relax `kubernetes_asyncio<<36.0.0` (#64144)
add 4b510de4e8c Fix zip DAG import errors being cleared during bundle
refresh (#63617)
add c4719098852 Make test_celery_integration runnable (#64153)
add 6f998c7c65d FIX: Allow override of HTTP method in run_method of
LivyAsyncHook (#64150)
add fd648242fcb Add Helm Refurbish approach into dev docs (#64063)
add c8ad7a98515 UI: Show clear permission toast for 403 errors on user
actions (#61588)
add ee2e5d2c6ef Update pools slot input (#63900)
add 539d8cfc9cd Fix Task SDK Connection extras from URI constructor
(#64120)
add 45bdd0d3efc fix toaster (#64142)
add fca550ca5fe Fix unclear error when pyspark is not installed for JDBC
script (#64174)
add 46f344af174 Change hebrew wording for Asset Triggered (#64177)
add 9c46b2176d9 Clarify reattach order of `find_spark_job` in
`SparkKubernetesOperator` (#64186)
add 8d43942b24f Simplify default rows limit return result (#64183)
add 6be5bb52e9e Fix SSRF in Bid Manager report download via URL allowlist
(#64180)
add 84f6ee0cf8e Prepare Providers Release 2026-03-24 (#64122)
add db42774e8d5 binds go-sdk in breeze's docker compose (#64167)
add 8eb89dbad18 Remove gunicorn upper bound now that 25.2.0 is released
with the fix (#64193)
add 1baafd48652 fix(Asset-Partition): sort partitioned DagRun by
partition_date (#62866)
add 95d1a382a13 tests: refactor unit test of elasticsearch (#64200)
add 9f17981cab3 Fix `RayJobBaseOperator` polling to recognize STOPPED as
terminal status (#64206)
add 19ed5080673 Remove outdated TODO comment about permissions (#64169)
add e7ea925f2dc Change default sort to 'id' for list task instances
(#64168)
add 64f22f81b43 Update python client version/changelog for 3.1.8 release
(#64214)
add d87e8c4bc1e chore(deps): bump the auth-ui-package-updates group across
1 directory with 9 updates (#64102)
add 8b90b420ee1 chore(deps-dev): bump eslint (#64171)
add 326680fd977 Refactor bundle refresh persistence into overridable
get/update methods (#63835)
add eca09a04b5a Add newsframent for namespace logger level feature added
last year (#64218)
add 10715fb8a81 Add durable execution for ``AgentOperator`` &
``@task.agent`` (#64199)
add f5ff9671ec8 Raise ``TaskAlreadyRunningError`` when starting an
already-running task instance (#60855)
add 97959da0877 Re-enable start_from_trigger feature with rendering of
template fields (#55068)
add f7c57937a60 Teardown Waiting for All in-scope Tasks to Complete
(#64181)
add 8210f69505c Fix SSHHookAsync defaulting no_host_key_check to False
unlike SSHHook (#64225)
add 90776562809 refactor: Ignore if db test collecting failed due to no
tests available (#64222)
add 221cdd64056 Fix SQLToolset read-only mode bypass via data-modifying
CTEs and SELECT INTO (#64173)
add 42d24243fb3 Add docs for using toolsets directly with PydanticAI in
any task (#64234)
add f8b2649ba7e Update Python Client Release Document to provide easier
check (#64228)
add c2ba5fc8407 Bump pyodps for python>=3.13 (#64210)
add 16f2fc10aa9 Use compat sdk conf import in Informatica provider (#64155)
add a3584d730bf Use compat sdk conf import in Google Gen AI operators
(#64157)
add 89c82681011 Compat sdk conf follow-up for multiple providers (#64161)
add ac9b401c5f3 Add initial Portuguese (pt) translation agent skill
(#62001) (#62083)
add 8d44a84e71b simplify the bug report template (#63851)
add c65c7fd0d45 Ensure presence of conn.login in microsoft azure hook
before usage (#64241)
add a8e130d39e2 Apache RAT 0.18 is released, upgrade references (#64231)
add 526768d7217 [main] Upgrade important CI environment (#64239)
add fbe7cbef234 fix(providers/standard): remove premature param value
validation in HITLOperator (#64108)
add a6e6d04e709 Fixed output encoding in WinRMTrigger for WinRMOperator in
deferred mode (#64154)
add fba15d6f04a fix(mypy): Pass parameters to Kubernetes methods
conditionally (#64242)
add 853028b3bf4 Fix assume_role_with_web_identity not using botocore
config for STS calls (#64216)
add 63be7a6be9b Fix dag_display_name property bypass for DagStats query
(#64256)
add 283ab813cf5 Improve Playwright test patterns in VariablePage (#63965)
(#63979)
add fa20f18ea44 Add suspending providers section to provider governance
(#64252)
add 9ad468cb955 Restore `deactivate_deleted_dags` signature broken by
#63617 (#64245)
add cc9abce01b0 Add explicit type annotations to k8s code to fix mypy
(#64260)
add bd08e77d962 Add locale configuration to Playwright test settings
(#64125)
add 3bec5d61818 AIP-99: Add LLMFileAnalysisOperator and
@task.llm_file_analysis (#64077)
add f8c9c517d69 UI Fix: Date time input 'year' field unmodifiable (#63885)
add 0c2a8d548bd Fix PoolBar links using wrong query params for task
instances filtering (#64182)
add 43945831cef Clear, Mark Success/Fail and delete multiple Task
Instances (#64141)
add efdc08e9869 Fix LLMApprovalMixin to enforce allow_modifications in
execute_complete (#64244)
add 059e9a40ecb misc: specify remove date for deprecations warnings
(#63505)
add 95fc11ed217 Ignore redelivered message for already-running task
(#64052)
add 1680d60934e tests: fix failing integration test after upgrading to
elasticsearch 9 (#64276)
add 3bb2dd5ec41 refactor(partition-mapper): rename ToXXXMapper to
StartOfXXXMapper (#64160)
add e8e22bd4678 Improve Playwright test patterns in providers.spec.ts
(#64078)
add 2eaa200a182 UI: Fix RenderedJsonField flickering when collapsed
(#64261)
add 0ed72b480c5 Refactor xcom API to use shared serialisation constants
(#64148)
add 677e53436ce Fix AwsBaseWaiterTrigger losing error details on deferred
task failure (#64085)
add 536101b12e4 Allow gray, black, and white color tokens in
AIRFLOW__API__THEME (#64232)
add a5fc6385833 Invalidate queries on dag run add/delete (#64269)
add abfda18a461 Add 4-day cooldown for uv dependency resolution (#64249)
add 40da4ae928e Fix NPM security issues in FAB provider (#64308)
add de332af25cc Fix NPM security alerts in simple auth manager (#64309)
add b3ee9286dd7 Bump minimum uv version to 0.9.17 (#64329)
add 6a58dd9bd38 Fix SAM login showing cryptic error on failed
authentication (#64303)
add 205650c7467 Add "# Days Stale" column and distinct status colors to
`constraints-version-check` (#64331)
add b086a22e80d fix(glue): Fix GlueJobOperator verbose logs not showing in
deferrable mode (#63086)
add 36211e53d30 Create airflow_ctl_issue_template.yml (#64327)
add 48685e7715d Revert "fix(glue): Fix GlueJobOperator verbose logs not
showing in deferrable mode (#63086)" (#64340)
add 3f8baeaaf2f chore(deps-dev): bump happy-dom (#64272)
add 33fa95c176a Compat sdk conf follow-up: Celery, Common AI, FAB, Edge3
(#64292)
add 06930d1c64d SQLA: Replace the deprecated `lazy="noload"` with
`lazy="raise"` (#64262)
add b786fd70f49 Align log_id_template with current default in
Elasticsearch provider (#64332)
add cb54ad885d2 Fix documentation link (#64355)
add 6542fe6a289 Improve creation of RuntimeTaskInstance in TriggerRunner
regarding start_for_trigger functionality (#64298)
add 1b2c15c5229 Update providers metadata 2026-03-28 (#64357)
add 5dff61841fb Upgrade important CI Versions (#64270)
add 0496f98e722 Adds retry to go-sdk connection (#64184)
add 6710866c2c9 chore(deps): bump joserfc from 1.5.0 to 1.6.3 (#63850)
add eab43f2db8b Fix Docs menu REST API link visibility when API docs are
disabled (#64359)
add eb8f5a1a357 Fix dependabot alarms for React references in react plugin
template (#64371)
add 484fb38802b Fix dependabot alarms in FAB provider (#64369)
add 65971cb73e2 Fix dependabot alarms in Edge provider (#64368)
add 2f135c87d01 Add missing fields in schema file (#64339)
add fa996944ae4 Fix dependabot alarms for React references in core (#64370)
add 2097a7a145f chore(deps-dev): bump the eslint group across 1 directory
with 6 updates
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e4f5025a7d6)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/eslint-3515529389
(2097a7a145f)
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:
.github/CODEOWNERS | 4 +-
.github/ISSUE_TEMPLATE/1-airflow_bug_report.yml | 57 +-
.../4-airflow_helmchart_bug_report.yml | 3 +-
.../ISSUE_TEMPLATE/airflow_ctl_issue_template.yml | 118 +
.github/actions/breeze/action.yml | 2 +-
.github/actions/install-prek/action.yml | 2 +-
.github/skills/airflow-translations/locales/pt.md | 78 +
.github/workflows/basic-tests.yml | 4 +-
.github/workflows/check-newsfragment-pr-number.yml | 10 +-
.github/workflows/ci-amd-arm.yml | 13 +-
.github/workflows/ci-image-checks.yml | 8 +-
.github/workflows/ci-notification.yml | 11 +-
.github/workflows/finalize-tests.yml | 2 +-
.github/workflows/helm-tests.yml | 6 +-
.github/workflows/prod-image-build.yml | 4 +-
.github/workflows/publish-docs-to-s3.yml | 2 +-
.github/workflows/push-image-cache.yml | 2 +-
.github/workflows/registry-backfill.yml | 6 +-
.github/workflows/registry-build.yml | 4 +-
.github/workflows/registry-tests.yml | 2 +-
.../workflows/release_single_dockerhub_image.yml | 2 +-
.github/workflows/ui-e2e-tests.yml | 4 +-
.github/workflows/update-constraints-on-push.yml | 2 +-
.pre-commit-config.yaml | 3 +-
Dockerfile | 25 +-
Dockerfile.ci | 38 +-
INTHEWILD.md | 1 +
ISSUE_TRIAGE_PROCESS.rst | 2 +-
README.md | 2 +-
airflow-core/.pre-commit-config.yaml | 1 +
.../docs/authoring-and-scheduling/assets.rst | 148 ++
airflow-core/docs/best-practices.rst | 4 +-
airflow-core/docs/core-concepts/dag-run.rst | 3 +-
airflow-core/docs/howto/customize-ui.rst | 45 +-
airflow-core/docs/start.rst | 2 +-
airflow-core/newsfragments/55850.significant.rst | 13 +
airflow-core/newsfragments/63296.significant.rst | 16 +
airflow-core/newsfragments/64232.feature.rst | 1 +
airflow-core/pyproject.toml | 13 +-
airflow-core/src/airflow/_shared/serialization | 1 +
.../simple/ui/openapi-gen/queries/common.ts | 11 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 21 +-
.../simple/ui/openapi-gen/queries/index.ts | 2 +-
.../ui/openapi-gen/queries/infiniteQueries.ts | 2 +-
.../simple/ui/openapi-gen/queries/prefetch.ts | 21 +-
.../simple/ui/openapi-gen/queries/queries.ts | 33 +-
.../simple/ui/openapi-gen/queries/suspense.ts | 27 +-
.../simple/ui/openapi-gen/requests/client.gen.ts | 16 +
.../ui/openapi-gen/requests/client/client.gen.ts | 156 ++
.../simple/ui/openapi-gen/requests/client/index.ts | 23 +
.../ui/openapi-gen/requests/client/types.gen.ts | 160 ++
.../ui/openapi-gen/requests/client/utils.gen.ts | 208 ++
.../ui/openapi-gen/requests/core/ApiError.ts | 21 -
.../openapi-gen/requests/core/ApiRequestOptions.ts | 14 -
.../ui/openapi-gen/requests/core/ApiResult.ts | 7 -
.../openapi-gen/requests/core/CancelablePromise.ts | 126 --
.../simple/ui/openapi-gen/requests/core/OpenAPI.ts | 58 -
.../ui/openapi-gen/requests/core/auth.gen.ts | 41 +
.../requests/core/bodySerializer.gen.ts | 84 +
.../ui/openapi-gen/requests/core/params.gen.ts | 169 ++
.../requests/core/pathSerializer.gen.ts | 171 ++
.../requests/core/queryKeySerializer.gen.ts | 117 +
.../simple/ui/openapi-gen/requests/core/request.ts | 374 ----
.../requests/core/serverSentEvents.gen.ts | 243 +++
.../ui/openapi-gen/requests/core/types.gen.ts | 104 +
.../ui/openapi-gen/requests/core/utils.gen.ts | 140 ++
.../simple/ui/openapi-gen/requests/index.ts | 6 +-
.../simple/ui/openapi-gen/requests/schemas.gen.ts | 177 +-
.../simple/ui/openapi-gen/requests/sdk.gen.ts | 67 +
.../simple/ui/openapi-gen/requests/services.gen.ts | 74 +-
.../simple/ui/openapi-gen/requests/types.gen.ts | 195 +-
.../auth/managers/simple/ui/package.json | 23 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 733 +++----
.../managers/simple/ui/src/alert/ErrorAlert.tsx | 43 +-
.../simple/ui/src/queries/useCreateToken.ts | 4 +-
.../auth/managers/simple/ui/src/queryClient.ts | 10 +-
.../src/airflow/api_fastapi/common/dagbag.py | 2 +-
.../src/airflow/api_fastapi/common/db/common.py | 10 -
.../src/airflow/api_fastapi/common/db/dag_runs.py | 118 +-
.../api_fastapi/common/db/task_instances.py | 5 +-
.../src/airflow/api_fastapi/common/types.py | 38 +-
.../api_fastapi/core_api/datamodels/connections.py | 9 +-
.../core_api/datamodels/task_instances.py | 1 +
.../api_fastapi/core_api/datamodels/xcom.py | 23 +
.../api_fastapi/core_api/openapi/_private_ui.yaml | 28 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 6 +
.../api_fastapi/core_api/routes/public/dag_run.py | 15 +-
.../api_fastapi/core_api/routes/public/hitl.py | 8 +-
.../core_api/routes/public/task_instances.py | 45 +-
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 4 +
.../core_api/services/public/task_instances.py | 13 +-
.../core_api/services/ui/connections.py | 96 +-
.../execution_api/datamodels/taskinstance.py | 38 +-
.../execution_api/routes/task_instances.py | 46 +
airflow-core/src/airflow/assets/manager.py | 2 +-
.../src/airflow/cli/commands/task_command.py | 3 +
.../src/airflow/config_templates/config.yml | 10 +
airflow-core/src/airflow/configuration.py | 143 +-
.../src/airflow/dag_processing/collection.py | 7 +-
airflow-core/src/airflow/dag_processing/manager.py | 198 +-
.../example_dags/example_asset_partition.py | 22 +-
..._workday_timetable.py => example_failed_dag.py} | 24 +-
.../src/airflow/executors/workloads/task.py | 1 -
.../src/airflow/executors/workloads/trigger.py | 8 +-
.../src/airflow/jobs/scheduler_job_runner.py | 91 +-
.../src/airflow/jobs/triggerer_job_runner.py | 302 ++-
...0_replace_deadline_inline_callback_with_fkey.py | 594 ++++--
.../0101_3_2_0_ui_improvements_for_deadlines.py | 311 ++-
.../0102_3_2_0_make_external_executor_id_text.py | 53 +-
airflow-core/src/airflow/models/dag.py | 17 +-
airflow-core/src/airflow/models/dagbag.py | 58 +-
airflow-core/src/airflow/models/dagrun.py | 113 +-
airflow-core/src/airflow/models/log.py | 2 +-
airflow-core/src/airflow/models/taskinstance.py | 89 +-
.../src/airflow/models/taskinstancehistory.py | 2 +-
airflow-core/src/airflow/models/taskmap.py | 16 +
airflow-core/src/airflow/models/xcom.py | 2 +-
.../partition_mappers/{product.py => chain.py} | 52 +-
.../src/airflow/partition_mappers/temporal.py | 12 +-
airflow-core/src/airflow/providers_manager.py | 23 +-
.../src/airflow/serialization/definitions/dag.py | 3 +
airflow-core/src/airflow/serialization/encoders.py | 56 +-
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 57 +-
airflow-core/src/airflow/triggers/base.py | 63 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 37 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 13 +-
airflow-core/src/airflow/ui/package.json | 14 +-
airflow-core/src/airflow/ui/playwright.config.ts | 1 +
airflow-core/src/airflow/ui/pnpm-lock.yaml | 446 ++--
.../airflow/ui/public/i18n/locales/en/common.json | 29 +-
.../airflow/ui/public/i18n/locales/he/common.json | 2 +-
.../components/ActionAccordion/ActionAccordion.tsx | 87 +-
.../ui/src/components/ActionAccordion/columns.tsx | 2 +-
.../TaskInstance/ClearGroupTaskInstanceDialog.tsx | 3 +-
.../airflow/ui/src/components/DateTimeInput.tsx | 47 +-
.../components/FlexibleForm/FieldDropdown.test.tsx | 27 +-
.../src/components/FlexibleForm/FieldDropdown.tsx | 77 +-
.../src/airflow/ui/src/components/PoolBar.tsx | 2 +-
.../ui/src/components/RenderedJsonField.tsx | 25 +-
.../ui/src/components/ui/Toaster/createToaster.ts | 8 +-
.../ui/src/components/ui/createErrorToaster.ts | 40 -
.../airflow/ui/src/layouts/Nav/DocsButton.test.tsx | 56 +
.../src/airflow/ui/src/layouts/Nav/DocsButton.tsx | 2 +-
airflow-core/src/airflow/ui/src/pages/Dag/Dag.tsx | 23 +-
.../src/pages/DagsList/DagsFilters/DagsFilters.tsx | 21 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 6 +-
.../ui/src/pages/DagsList/useTagFilter.test.tsx | 275 +++
.../airflow/ui/src/pages/DagsList/useTagFilter.ts | 63 +
.../src/airflow/ui/src/pages/Pools/PoolForm.tsx | 34 +-
.../TaskInstances/BulkClearTaskInstancesButton.tsx | 157 ++
.../BulkDeleteTaskInstancesButton.tsx | 153 ++
.../BulkMarkTaskInstancesAsButton.tsx | 208 ++
.../ui/src/pages/TaskInstances/TaskInstances.tsx | 87 +-
.../index.ts => queries/gridViewQueryKeys.ts} | 28 +-
.../airflow/ui/src/queries/useBulkClearDryRun.ts | 113 +
.../ui/src/queries/useBulkClearTaskInstances.ts | 118 +
.../ui/src/queries/useBulkDeleteVariables.ts | 4 +-
.../airflow/ui/src/queries/useBulkMarkAsDryRun.ts | 113 +
.../airflow/ui/src/queries/useBulkTaskInstances.ts | 105 +
.../src/airflow/ui/src/queries/useClearRun.ts | 27 +-
.../ui/src/queries/useClearTaskInstances.ts | 17 +-
.../src/airflow/ui/src/queries/useDagParsing.ts | 12 +-
.../airflow/ui/src/queries/useDeleteConnection.ts | 18 +-
.../src/airflow/ui/src/queries/useDeleteDag.ts | 25 +-
.../src/airflow/ui/src/queries/useDeleteDagRun.ts | 22 +-
.../src/airflow/ui/src/queries/useDeletePool.ts | 18 +-
.../ui/src/queries/useDeleteTaskInstance.ts | 16 +-
.../airflow/ui/src/queries/useDeleteVariable.ts | 18 +-
.../airflow/ui/src/queries/useGridTISummaries.ts | 2 +
.../src/airflow/ui/src/queries/usePatchDagRun.ts | 27 +-
.../airflow/ui/src/queries/usePatchTaskInstance.ts | 27 +-
.../ui/src/queries/useRefreshOnNewDagRuns.ts | 65 +-
.../src/airflow/ui/src/queries/useTogglePause.ts | 10 +-
.../src/airflow/ui/src/queries/useTrigger.ts | 32 +-
.../airflow/ui/src/queries/useUpdateHITLDetail.ts | 9 +-
airflow-core/src/airflow/ui/src/queryClient.ts | 30 +-
.../src/airflow/ui/src/utils/errorHandling.ts | 90 +
airflow-core/src/airflow/ui/src/utils/index.ts | 1 +
.../src/airflow/ui/tests/e2e/pages/EventsPage.ts | 116 +-
.../airflow/ui/tests/e2e/pages/ProvidersPage.ts | 58 +-
.../src/airflow/ui/tests/e2e/pages/VariablePage.ts | 27 +-
.../ui/tests/e2e/specs/dag-audit-log.spec.ts | 52 +-
.../airflow/ui/tests/e2e/specs/providers.spec.ts | 44 +-
.../airflow/ui/tests/e2e/specs/task-logs.spec.ts | 12 +-
airflow-core/src/airflow/utils/db_manager.py | 33 +-
airflow-core/src/airflow/utils/helpers.py | 4 +
airflow-core/tests/integration/otel/test_otel.py | 10 +-
.../tests/unit/api_fastapi/common/test_types.py | 135 +-
.../core_api/routes/public/test_task_instances.py | 140 ++
.../core_api/routes/public/test_xcom.py | 19 +
.../api_fastapi/core_api/routes/ui/test_config.py | 80 +-
.../core_api/services/ui/test_connections.py | 19 +-
.../versions/head/test_task_instances.py | 116 +
airflow-core/tests/unit/assets/test_manager.py | 23 +
.../tests/unit/cli/commands/test_task_command.py | 24 +
airflow-core/tests/unit/cli/conftest.py | 2 +-
airflow-core/tests/unit/core/test_configuration.py | 3 +
.../tests/unit/dag_processing/test_collection.py | 31 +
.../tests/unit/dag_processing/test_manager.py | 402 +++-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 62 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 106 +-
airflow-core/tests/unit/models/test_dagbag.py | 79 +
airflow-core/tests/unit/models/test_dagrun.py | 76 +-
airflow-core/tests/unit/models/test_log.py | 22 +
.../tests/unit/models/test_taskinstance.py | 262 +++
airflow-core/tests/unit/models/test_xcom.py | 20 +
.../tests/unit/partition_mappers/test_chain.py | 71 +
.../tests/unit/partition_mappers/test_product.py | 34 +-
.../tests/unit/partition_mappers/test_temporal.py | 45 +-
.../unit/serialization/test_serialized_objects.py | 114 +-
.../unit/ti_deps/deps/test_trigger_rule_dep.py | 111 +
.../tests/unit/triggers/test_base_trigger.py | 69 +
airflow-core/tests/unit/utils/test_db_manager.py | 68 +-
airflow-core/tests/unit/utils/test_helpers.py | 10 +
airflow-ctl/README.md | 2 +-
.../src/airflowctl/api/datamodels/generated.py | 1 +
airflow-e2e-tests/docker/elasticsearch.yml | 2 +-
.../test_remote_logging_elasticsearch.py | 42 +
chart/Chart.yaml | 4 +-
chart/README.md | 2 +-
chart/values.schema.json | 78 +-
chart/values.yaml | 2 +-
clients/python/CHANGELOG.md | 9 +
clients/python/version.txt | 2 +-
contributing-docs/07_local_virtualenv.rst | 2 +-
contributing-docs/18_contribution_workflow.rst | 4 +
dev/README_AIRFLOW3_DEV.md | 9 +-
dev/README_HELM_CHART2_DEV.md | 133 ++
dev/README_RELEASE_AIRFLOW.md | 14 +-
dev/README_RELEASE_AIRFLOWCTL.md | 12 +-
dev/README_RELEASE_HELM_CHART.md | 73 +-
dev/README_RELEASE_PROVIDERS.md | 12 +-
dev/README_RELEASE_PYTHON_CLIENT.md | 91 +-
dev/breeze/doc/ci/02_images.md | 6 +-
...lease-management_prepare-helm-chart-package.svg | 28 +-
...lease-management_prepare-helm-chart-package.txt | 2 +-
dev/breeze/doc/images/output_shell.svg | 190 +-
dev/breeze/doc/images/output_shell.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 150 +-
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
dev/breeze/pyproject.toml | 5 +-
.../src/airflow_breeze/commands/common_options.py | 8 +
.../airflow_breeze/commands/developer_commands.py | 11 +
.../commands/developer_commands_config.py | 12 +
.../commands/release_management_commands.py | 171 +-
.../commands/release_management_commands_config.py | 1 -
dev/breeze/src/airflow_breeze/global_constants.py | 3 +
.../src/airflow_breeze/params/shell_params.py | 3 +
.../utils/constraints_version_check.py | 79 +-
.../airflow_breeze/utils/docker_command_utils.py | 3 +
.../src/airflow_breeze/utils/release_validator.py | 10 +-
dev/breeze/tests/test_selective_checks.py | 2 -
dev/breeze/uv.lock | 74 +-
.../react_plugin_template/package.json | 7 +-
.../react_plugin_template/pnpm-lock.yaml | 119 +-
devel-common/src/tests_common/pytest_plugin.py | 47 +-
.../src/tests_common/test_utils/version_compat.py | 1 +
docker-stack-docs/build.rst | 22 +-
docs/spelling_wordlist.txt | 14 +
generated/PYPI_README.md | 2 +-
generated/provider_metadata.json | 388 ++++
go-sdk/edge/worker.go | 34 +-
go-sdk/pkg/config/config.go | 29 +-
go-sdk/pkg/edgeapi/client.go | 40 +-
providers/.last_release_date.txt | 2 +-
providers/PROVIDER_GOVERNANCE.rst | 20 +
providers/airbyte/README.rst | 8 +-
providers/airbyte/docs/changelog.rst | 19 +
providers/airbyte/docs/index.rst | 6 +-
providers/airbyte/provider.yaml | 3 +-
providers/airbyte/pyproject.toml | 6 +-
.../src/airflow/providers/airbyte/__init__.py | 2 +-
.../airflow/providers/airbyte/operators/airbyte.py | 2 +-
providers/alibaba/README.rst | 8 +-
providers/alibaba/docs/changelog.rst | 19 +
providers/alibaba/docs/index.rst | 15 +-
providers/alibaba/provider.yaml | 3 +-
providers/alibaba/pyproject.toml | 9 +-
.../src/airflow/providers/alibaba/__init__.py | 2 +-
.../alibaba/cloud/log/oss_task_handler.py | 6 +-
.../alibaba/cloud/log/test_oss_task_handler.py | 21 +
providers/amazon/README.rst | 19 +-
providers/amazon/docs/changelog.rst | 46 +-
providers/amazon/docs/index.rst | 6 +-
providers/amazon/docs/logging/s3-task-handler.rst | 4 +-
providers/amazon/provider.yaml | 9 +-
providers/amazon/pyproject.toml | 9 +-
.../src/airflow/providers/amazon/__init__.py | 2 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 11 +-
.../airflow/providers/amazon/aws/operators/dms.py | 36 +-
.../airflow/providers/amazon/aws/operators/emr.py | 35 +-
.../providers/amazon/aws/operators/neptune.py | 27 +-
.../airflow/providers/amazon/aws/sensors/mwaa.py | 11 +-
.../airflow/providers/amazon/aws/triggers/base.py | 25 +-
.../airflow/providers/amazon/aws/triggers/dms.py | 2 +-
.../airflow/providers/amazon/aws/triggers/glue.py | 2 +-
.../airflow/providers/amazon/get_provider_info.py | 7 +-
.../aws/executors/batch/test_batch_executor.py | 3 +-
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 61 +-
.../tests/unit/amazon/aws/operators/test_dms.py | 51 +
.../amazon/aws/operators/test_emr_serverless.py | 20 +
.../tests/unit/amazon/aws/sensors/test_mwaa.py | 22 +
.../tests/unit/amazon/aws/triggers/test_base.py | 19 +
.../tests/unit/amazon/aws/triggers/test_glue.py | 7 +-
.../tests/unit/amazon/aws/triggers/test_neptune.py | 6 +-
providers/apache/cassandra/README.rst | 8 +-
providers/apache/cassandra/docs/changelog.rst | 18 +
providers/apache/cassandra/docs/index.rst | 7 +-
providers/apache/cassandra/provider.yaml | 3 +-
providers/apache/cassandra/pyproject.toml | 7 +-
.../airflow/providers/apache/cassandra/__init__.py | 2 +-
providers/apache/drill/README.rst | 8 +-
providers/apache/drill/docs/changelog.rst | 12 +
providers/apache/drill/docs/index.rst | 6 +-
providers/apache/drill/provider.yaml | 3 +-
providers/apache/drill/pyproject.toml | 6 +-
.../src/airflow/providers/apache/drill/__init__.py | 2 +-
providers/apache/druid/README.rst | 8 +-
providers/apache/druid/docs/changelog.rst | 12 +
providers/apache/druid/docs/index.rst | 6 +-
providers/apache/druid/provider.yaml | 3 +-
providers/apache/druid/pyproject.toml | 6 +-
.../src/airflow/providers/apache/druid/__init__.py | 2 +-
providers/apache/flink/README.rst | 8 +-
providers/apache/flink/docs/changelog.rst | 12 +
providers/apache/flink/docs/index.rst | 6 +-
providers/apache/flink/provider.yaml | 3 +-
providers/apache/flink/pyproject.toml | 6 +-
.../src/airflow/providers/apache/flink/__init__.py | 2 +-
providers/apache/hdfs/README.rst | 20 +-
providers/apache/hdfs/docs/changelog.rst | 17 +
providers/apache/hdfs/docs/index.rst | 6 +-
providers/apache/hdfs/provider.yaml | 3 +-
providers/apache/hdfs/pyproject.toml | 6 +-
.../src/airflow/providers/apache/hdfs/__init__.py | 2 +-
providers/apache/hive/README.rst | 17 +-
providers/apache/hive/docs/changelog.rst | 18 +
providers/apache/hive/docs/index.rst | 6 +-
providers/apache/hive/provider.yaml | 3 +-
providers/apache/hive/pyproject.toml | 6 +-
.../src/airflow/providers/apache/hive/__init__.py | 2 +-
providers/apache/iceberg/README.rst | 8 +-
providers/apache/iceberg/docs/changelog.rst | 13 +
providers/apache/iceberg/docs/index.rst | 6 +-
providers/apache/iceberg/provider.yaml | 3 +-
providers/apache/iceberg/pyproject.toml | 6 +-
.../airflow/providers/apache/iceberg/__init__.py | 2 +-
providers/apache/impala/README.rst | 8 +-
providers/apache/impala/docs/changelog.rst | 14 +
providers/apache/impala/docs/index.rst | 6 +-
providers/apache/impala/provider.yaml | 3 +-
providers/apache/impala/pyproject.toml | 6 +-
.../airflow/providers/apache/impala/__init__.py | 2 +-
providers/apache/kafka/README.rst | 20 +-
providers/apache/kafka/docs/changelog.rst | 21 +
providers/apache/kafka/docs/index.rst | 6 +-
providers/apache/kafka/provider.yaml | 3 +-
providers/apache/kafka/pyproject.toml | 6 +-
.../src/airflow/providers/apache/kafka/__init__.py | 2 +-
providers/apache/kylin/README.rst | 8 +-
providers/apache/kylin/docs/changelog.rst | 17 +
providers/apache/kylin/docs/index.rst | 6 +-
providers/apache/kylin/provider.yaml | 3 +-
providers/apache/kylin/pyproject.toml | 6 +-
.../src/airflow/providers/apache/kylin/__init__.py | 2 +-
providers/apache/livy/README.rst | 11 +-
providers/apache/livy/docs/changelog.rst | 23 +
providers/apache/livy/docs/index.rst | 8 +-
providers/apache/livy/provider.yaml | 3 +-
providers/apache/livy/pyproject.toml | 8 +-
.../src/airflow/providers/apache/livy/__init__.py | 2 +-
.../airflow/providers/apache/livy/hooks/livy.py | 2 +-
.../livy/tests/unit/apache/livy/hooks/test_livy.py | 27 +-
providers/apache/pig/README.rst | 8 +-
providers/apache/pig/docs/changelog.rst | 15 +
providers/apache/pig/docs/index.rst | 6 +-
providers/apache/pig/provider.yaml | 3 +-
providers/apache/pig/pyproject.toml | 6 +-
.../src/airflow/providers/apache/pig/__init__.py | 2 +-
providers/apache/pinot/README.rst | 8 +-
providers/apache/pinot/docs/changelog.rst | 12 +
providers/apache/pinot/docs/index.rst | 6 +-
providers/apache/pinot/provider.yaml | 3 +-
providers/apache/pinot/pyproject.toml | 6 +-
.../src/airflow/providers/apache/pinot/__init__.py | 2 +-
providers/apache/spark/README.rst | 10 +-
providers/apache/spark/docs/changelog.rst | 21 +
providers/apache/spark/docs/index.rst | 6 +-
providers/apache/spark/provider.yaml | 3 +-
providers/apache/spark/pyproject.toml | 6 +-
.../src/airflow/providers/apache/spark/__init__.py | 2 +-
.../apache/spark/hooks/spark_jdbc_script.py | 7 +-
providers/apache/tinkerpop/README.rst | 30 +-
providers/apache/tinkerpop/docs/changelog.rst | 19 +
providers/apache/tinkerpop/docs/index.rst | 6 +-
providers/apache/tinkerpop/provider.yaml | 3 +-
providers/apache/tinkerpop/pyproject.toml | 6 +-
.../airflow/providers/apache/tinkerpop/__init__.py | 2 +-
providers/apprise/README.rst | 8 +-
providers/apprise/docs/changelog.rst | 16 +
providers/apprise/docs/index.rst | 6 +-
providers/apprise/provider.yaml | 3 +-
providers/apprise/pyproject.toml | 6 +-
.../src/airflow/providers/apprise/__init__.py | 2 +-
providers/arangodb/README.rst | 8 +-
providers/arangodb/docs/changelog.rst | 17 +
providers/arangodb/docs/index.rst | 6 +-
providers/arangodb/provider.yaml | 3 +-
providers/arangodb/pyproject.toml | 6 +-
.../src/airflow/providers/arangodb/__init__.py | 2 +-
providers/asana/README.rst | 8 +-
providers/asana/docs/changelog.rst | 22 +
providers/asana/docs/index.rst | 6 +-
providers/asana/provider.yaml | 3 +-
providers/asana/pyproject.toml | 6 +-
.../asana/src/airflow/providers/asana/__init__.py | 2 +-
providers/atlassian/jira/README.rst | 8 +-
providers/atlassian/jira/docs/changelog.rst | 17 +
providers/atlassian/jira/docs/index.rst | 6 +-
providers/atlassian/jira/provider.yaml | 3 +-
providers/atlassian/jira/pyproject.toml | 6 +-
.../airflow/providers/atlassian/jira/__init__.py | 2 +-
providers/celery/README.rst | 10 +-
providers/celery/docs/changelog.rst | 24 +
providers/celery/docs/index.rst | 8 +-
providers/celery/provider.yaml | 3 +-
providers/celery/pyproject.toml | 8 +-
.../src/airflow/providers/celery/__init__.py | 2 +-
.../airflow/providers/celery/cli/celery_command.py | 2 +-
.../src/airflow/providers/celery/cli/definition.py | 2 +-
.../providers/celery/executors/celery_executor.py | 2 +-
.../celery/executors/celery_executor_utils.py | 58 +-
.../celery/executors/celery_kubernetes_executor.py | 2 +-
.../providers/celery/executors/default_celery.py | 3 +-
.../src/airflow/providers/celery/version_compat.py | 3 +-
.../integration/celery/test_celery_executor.py | 86 +-
.../tests/unit/celery/cli/test_celery_command.py | 17 +-
.../unit/celery/executors/test_celery_executor.py | 57 +-
.../executors/test_celery_kubernetes_executor.py | 2 +-
providers/cloudant/README.rst | 8 +-
providers/cloudant/docs/changelog.rst | 16 +
providers/cloudant/docs/index.rst | 6 +-
providers/cloudant/provider.yaml | 3 +-
providers/cloudant/pyproject.toml | 6 +-
.../src/airflow/providers/cloudant/__init__.py | 2 +-
providers/cncf/kubernetes/README.rst | 19 +-
providers/cncf/kubernetes/docs/changelog.rst | 41 +-
providers/cncf/kubernetes/docs/index.rst | 8 +-
providers/cncf/kubernetes/provider.yaml | 3 +-
providers/cncf/kubernetes/pyproject.toml | 8 +-
.../airflow/providers/cncf/kubernetes/__init__.py | 2 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 37 +-
.../kubernetes/operators/custom_object_launcher.py | 3 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 9 +
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 2 -
.../kubernetes/operators/test_spark_kubernetes.py | 78 +-
providers/cohere/README.rst | 17 +-
providers/cohere/docs/changelog.rst | 19 +-
providers/cohere/docs/index.rst | 6 +-
providers/cohere/provider.yaml | 3 +-
providers/cohere/pyproject.toml | 6 +-
.../src/airflow/providers/cohere/__init__.py | 2 +-
providers/common/ai/docs/index.rst | 2 +-
providers/common/ai/docs/operators/agent.rst | 104 +
providers/common/ai/docs/operators/index.rst | 12 +-
.../common/ai/docs/operators/llm_file_analysis.rst | 141 ++
providers/common/ai/docs/toolsets.rst | 25 +
providers/common/ai/provider.yaml | 4 +
providers/common/ai/pyproject.toml | 10 +-
.../decorators/{agent.py => llm_file_analysis.py} | 63 +-
.../providers/common/ai/durable}/__init__.py | 0
.../providers/common/ai/durable/caching_model.py | 81 +
.../providers/common/ai/durable/caching_toolset.py | 75 +
.../providers/common/ai/durable/step_counter.py | 42 +-
.../airflow/providers/common/ai/durable/storage.py | 158 ++
.../ai/example_dags/example_agent_durable.py | 87 +
.../ai/example_dags/example_llm_file_analysis.py | 133 ++
.../ai/example_dags/example_pydantic_ai_hook.py | 37 +-
.../src/airflow/providers/common/ai/exceptions.py | 16 +
.../providers/common/ai/get_provider_info.py | 6 +
.../airflow/providers/common/ai/mixins/approval.py | 6 +-
.../airflow/providers/common/ai/operators/agent.py | 87 +-
.../common/ai/operators/llm_file_analysis.py | 165 ++
.../providers/common/ai/plugins/hitl_review.py | 2 +-
.../providers/common/ai/utils/file_analysis.py | 670 ++++++
.../providers/common/ai/utils/sql_validation.py | 43 +
.../ai/tests/unit/common/ai/assets}/__init__.py | 0
.../unit/common/ai/assets}/airflow-3-task-sdk.png | Bin
.../tests/unit/common/ai/decorators/test_agent.py | 19 +
.../{test_llm.py => test_llm_file_analysis.py} | 65 +-
.../ai/tests/unit/common/ai/durable}/__init__.py | 0
.../unit/common/ai/durable/test_caching_model.py | 109 +
.../unit/common/ai/durable/test_caching_toolset.py | 126 ++
.../unit/common/ai/durable/test_step_counter.py} | 29 +-
.../tests/unit/common/ai/durable/test_storage.py | 139 ++
.../tests/unit/common/ai/mixins/test_approval.py | 12 +
.../tests/unit/common/ai/operators/test_agent.py | 58 +
.../common/ai/operators/test_llm_file_analysis.py | 303 +++
.../unit/common/ai/utils/test_file_analysis.py | 525 +++++
.../unit/common/ai/utils/test_sql_validation.py | 54 +
providers/common/compat/README.rst | 17 +-
providers/common/compat/docs/changelog.rst | 15 +
providers/common/compat/docs/index.rst | 6 +-
providers/common/compat/provider.yaml | 3 +-
providers/common/compat/pyproject.toml | 6 +-
.../airflow/providers/common/compat/__init__.py | 2 +-
providers/common/io/README.rst | 21 +-
providers/common/io/docs/changelog.rst | 15 +
providers/common/io/docs/index.rst | 6 +-
providers/common/io/provider.yaml | 3 +-
providers/common/io/pyproject.toml | 6 +-
.../io/src/airflow/providers/common/io/__init__.py | 2 +-
providers/common/messaging/README.rst | 8 +-
providers/common/messaging/docs/changelog.rst | 15 +
providers/common/messaging/docs/index.rst | 2 +-
providers/common/messaging/provider.yaml | 3 +-
providers/common/messaging/pyproject.toml | 6 +-
.../airflow/providers/common/messaging/__init__.py | 2 +-
providers/common/sql/README.rst | 16 +-
providers/common/sql/docs/changelog.rst | 24 +
providers/common/sql/docs/index.rst | 6 +-
providers/common/sql/docs/operators.rst | 2 +-
providers/common/sql/provider.yaml | 3 +-
providers/common/sql/pyproject.toml | 6 +-
.../src/airflow/providers/common/sql/__init__.py | 2 +-
.../providers/common/sql/datafusion/engine.py | 13 +-
.../providers/common/sql/operators/analytics.py | 42 +-
.../unit/common/sql/datafusion/test_engine.py | 39 +-
.../sql/tests/unit/common/sql/hooks/test_dbapi.py | 2 +-
.../unit/common/sql/operators/test_analytics.py | 11 +-
providers/databricks/README.rst | 28 +-
providers/databricks/docs/changelog.rst | 30 +
providers/databricks/docs/index.rst | 6 +-
providers/databricks/provider.yaml | 3 +-
providers/databricks/pyproject.toml | 6 +-
.../src/airflow/providers/databricks/__init__.py | 2 +-
.../providers/databricks/operators/databricks.py | 2 +-
providers/datadog/README.rst | 8 +-
providers/datadog/docs/changelog.rst | 18 +
providers/datadog/docs/index.rst | 6 +-
providers/datadog/provider.yaml | 3 +-
providers/datadog/pyproject.toml | 6 +-
.../src/airflow/providers/datadog/__init__.py | 2 +-
providers/dbt/cloud/README.rst | 17 +-
providers/dbt/cloud/docs/changelog.rst | 19 +
providers/dbt/cloud/docs/index.rst | 6 +-
providers/dbt/cloud/provider.yaml | 3 +-
providers/dbt/cloud/pyproject.toml | 6 +-
.../src/airflow/providers/dbt/cloud/__init__.py | 2 +-
providers/dingding/README.rst | 8 +-
providers/dingding/docs/changelog.rst | 15 +
providers/dingding/docs/index.rst | 6 +-
providers/dingding/provider.yaml | 3 +-
providers/dingding/pyproject.toml | 6 +-
.../src/airflow/providers/dingding/__init__.py | 2 +-
providers/discord/README.rst | 8 +-
providers/discord/docs/changelog.rst | 18 +
providers/discord/docs/index.rst | 6 +-
providers/discord/provider.yaml | 3 +-
providers/discord/pyproject.toml | 6 +-
.../src/airflow/providers/discord/__init__.py | 2 +-
providers/docker/README.rst | 8 +-
providers/docker/docs/changelog.rst | 12 +
providers/docker/docs/index.rst | 6 +-
providers/docker/provider.yaml | 3 +-
providers/docker/pyproject.toml | 6 +-
.../src/airflow/providers/docker/__init__.py | 2 +-
providers/edge3/README.rst | 8 +-
providers/edge3/docs/changelog.rst | 41 +-
providers/edge3/docs/index.rst | 6 +-
providers/edge3/provider.yaml | 3 +-
providers/edge3/pyproject.toml | 6 +-
.../edge3/src/airflow/providers/edge3/__init__.py | 2 +-
.../src/airflow/providers/edge3/cli/api_client.py | 2 +-
.../src/airflow/providers/edge3/cli/definition.py | 2 +-
.../airflow/providers/edge3/cli/edge_command.py | 2 +-
.../src/airflow/providers/edge3/cli/worker.py | 3 +-
.../providers/edge3/executors/edge_executor.py | 3 +-
.../edge3/src/airflow/providers/edge3/models/db.py | 2 +-
.../edge3/plugins/edge_executor_plugin.py | 3 +-
.../providers/edge3/plugins/www/package.json | 9 +-
.../providers/edge3/plugins/www/pnpm-lock.yaml | 147 +-
.../www/src/components/BulkWorkerOperations.tsx | 181 ++
.../providers/edge3/plugins/www/src/constants.ts | 16 +
.../plugins/www/src/hooks/useBulkWorkerActions.ts | 185 ++
.../edge3/plugins/www/src/pages/WorkerPage.tsx | 120 +-
.../src/airflow/providers/edge3/worker_api/auth.py | 2 +-
.../providers/edge3/worker_api/routes/logs.py | 3 +-
.../unit/edge3/executors/test_edge_executor.py | 3 +-
providers/elasticsearch/README.rst | 10 +-
providers/elasticsearch/docs/changelog.rst | 21 +
providers/elasticsearch/docs/index.rst | 8 +-
providers/elasticsearch/provider.yaml | 3 +-
providers/elasticsearch/pyproject.toml | 8 +-
.../airflow/providers/elasticsearch/__init__.py | 2 +-
.../providers/elasticsearch/hooks/elasticsearch.py | 6 +-
.../providers/elasticsearch/log/es_response.py | 11 +-
.../providers/elasticsearch/log/es_task_handler.py | 59 +-
.../elasticsearch/log/test_es_remote_log_io.py | 33 +-
.../unit/elasticsearch/hooks/test_elasticsearch.py | 8 +-
.../unit/elasticsearch/log/elasticmock/__init__.py | 111 -
.../log/elasticmock/fake_elasticsearch.py | 628 ------
.../log/elasticmock/utilities/__init__.py | 232 --
.../unit/elasticsearch/log/test_es_task_handler.py | 1211 +++++------
providers/exasol/README.rst | 17 +-
providers/exasol/docs/changelog.rst | 12 +
providers/exasol/docs/index.rst | 6 +-
providers/exasol/provider.yaml | 3 +-
providers/exasol/pyproject.toml | 6 +-
.../src/airflow/providers/exasol/__init__.py | 2 +-
providers/fab/README.rst | 30 +-
providers/fab/docs/changelog.rst | 42 +
providers/fab/docs/index.rst | 6 +-
providers/fab/provider.yaml | 3 +-
providers/fab/pyproject.toml | 6 +-
.../providers/3rd-party-licenses/LICENSES-ui.txt | 2 +-
.../fab/src/airflow/providers/fab/__init__.py | 2 +-
.../auth_manager/api/auth/backend/kerberos_auth.py | 2 +-
.../fab/auth_manager/api_fastapi/parameters.py | 2 +-
.../fab/auth_manager/api_fastapi/routes/login.py | 2 +-
.../fab/auth_manager/api_fastapi/services/login.py | 2 +-
.../fab/auth_manager/cli_commands/utils.py | 2 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 16 +-
.../fab/auth_manager/security_manager/override.py | 2 +-
.../providers/fab/auth_manager/views/auth_oauth.py | 2 +-
providers/fab/src/airflow/providers/fab/www/app.py | 2 +-
.../fab/src/airflow/providers/fab/www/auth.py | 2 +-
.../fab/www/extensions/init_appbuilder.py | 2 +-
.../fab/www/extensions/init_jinja_globals.py | 2 +-
.../providers/fab/www/extensions/init_security.py | 3 +-
.../providers/fab/www/extensions/init_session.py | 2 +-
.../fab/www/extensions/init_wsgi_middlewares.py | 2 +-
.../fab/src/airflow/providers/fab/www/package.json | 16 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 278 +--
.../fab/src/airflow/providers/fab/www/utils.py | 16 +-
.../fab/src/airflow/providers/fab/www/views.py | 2 +-
.../fab/auth_manager/cli_commands/test_utils.py | 2 +-
providers/fab/tests/unit/fab/www/test_utils.py | 11 +-
providers/facebook/README.rst | 8 +-
providers/facebook/docs/changelog.rst | 15 +
providers/facebook/docs/index.rst | 6 +-
providers/facebook/provider.yaml | 3 +-
providers/facebook/pyproject.toml | 6 +-
.../src/airflow/providers/facebook/__init__.py | 2 +-
providers/ftp/README.rst | 19 +-
providers/ftp/docs/changelog.rst | 15 +
providers/ftp/docs/index.rst | 6 +-
providers/ftp/provider.yaml | 3 +-
providers/ftp/pyproject.toml | 6 +-
.../ftp/src/airflow/providers/ftp/__init__.py | 2 +-
providers/git/README.rst | 8 +-
providers/git/docs/changelog.rst | 29 +
providers/git/docs/index.rst | 6 +-
providers/git/provider.yaml | 3 +-
providers/git/pyproject.toml | 6 +-
.../git/src/airflow/providers/git/__init__.py | 2 +-
.../git/src/airflow/providers/git/hooks/git.py | 3 +-
providers/github/README.rst | 8 +-
providers/github/docs/changelog.rst | 17 +
providers/github/docs/index.rst | 6 +-
providers/github/provider.yaml | 3 +-
providers/github/pyproject.toml | 6 +-
.../src/airflow/providers/github/__init__.py | 2 +-
providers/google/README.rst | 20 +-
providers/google/docs/changelog.rst | 67 +-
providers/google/docs/index.rst | 8 +-
.../google/docs/operators/cloud/vertex_ai.rst | 22 +-
providers/google/provider.yaml | 3 -
providers/google/pyproject.toml | 5 +-
.../providers/google/cloud/hooks/dataflow.py | 8 +-
.../airflow/providers/google/cloud/hooks/gcs.py | 2 +-
.../airflow/providers/google/cloud/hooks/pubsub.py | 2 +-
.../airflow/providers/google/cloud/hooks/ray.py | 5 +
.../google/cloud/hooks/vertex_ai/auto_ml.py | 181 --
.../providers/google/cloud/links/dataproc.py | 2 +-
.../google/cloud/log/stackdriver_task_handler.py | 2 +-
.../providers/google/cloud/operators/dataproc.py | 2 +-
.../providers/google/cloud/operators/gcs.py | 2 +-
.../providers/google/cloud/operators/gen_ai.py | 2 +-
.../google/cloud/operators/kubernetes_engine.py | 2 +-
.../providers/google/cloud/operators/ray.py | 2 +-
.../google/cloud/operators/vertex_ai/auto_ml.py | 81 -
.../providers/google/cloud/sensors/bigquery.py | 2 +-
.../cloud/transfers/azure_fileshare_to_gcs.py | 2 +-
.../google/cloud/transfers/bigquery_to_mssql.py | 2 +-
.../providers/google/cloud/transfers/gcs_to_gcs.py | 6 +-
.../google/cloud/triggers/kubernetes_engine.py | 4 +-
.../marketing_platform/operators/bid_manager.py | 23 +-
.../cloud/vertex_ai/example_vertex_ai_dataset.py | 24 +-
.../unit/google/cloud/hooks/test_bigquery_dts.py | 8 +-
.../google/cloud/hooks/test_kubernetes_engine.py | 4 +-
.../tests/unit/google/cloud/hooks/test_ray.py | 6 +-
.../unit/google/cloud/hooks/vertex_ai/test_ray.py | 2 +-
.../tests/unit/google/cloud/links/test_ray.py | 4 +
.../tests/unit/google/cloud/operators/test_ray.py | 13 +-
.../unit/google/cloud/operators/test_vertex_ai.py | 89 -
.../unit/google/cloud/triggers/test_dataproc.py | 5 +-
.../operators/test_bid_manager.py | 17 +-
providers/grpc/README.rst | 8 +-
providers/grpc/docs/changelog.rst | 19 +
providers/grpc/docs/index.rst | 6 +-
providers/grpc/provider.yaml | 3 +-
providers/grpc/pyproject.toml | 6 +-
.../grpc/src/airflow/providers/grpc/__init__.py | 2 +-
providers/hashicorp/README.rst | 8 +-
providers/hashicorp/docs/changelog.rst | 24 +
providers/hashicorp/docs/index.rst | 6 +-
providers/hashicorp/provider.yaml | 3 +-
providers/hashicorp/pyproject.toml | 6 +-
.../src/airflow/providers/hashicorp/__init__.py | 2 +-
providers/http/README.rst | 17 +-
providers/http/docs/changelog.rst | 19 +
providers/http/docs/index.rst | 6 +-
providers/http/provider.yaml | 3 +-
providers/http/pyproject.toml | 6 +-
.../http/src/airflow/providers/http/__init__.py | 2 +-
.../http/src/airflow/providers/http/hooks/http.py | 37 +-
providers/http/tests/unit/http/hooks/test_http.py | 16 +
providers/imap/README.rst | 8 +-
providers/imap/docs/changelog.rst | 15 +
providers/imap/docs/index.rst | 6 +-
providers/imap/provider.yaml | 3 +-
providers/imap/pyproject.toml | 6 +-
.../imap/src/airflow/providers/imap/__init__.py | 2 +-
providers/influxdb/README.rst | 8 +-
providers/influxdb/docs/changelog.rst | 17 +
providers/influxdb/docs/index.rst | 6 +-
providers/influxdb/provider.yaml | 3 +-
providers/influxdb/pyproject.toml | 6 +-
.../src/airflow/providers/influxdb/__init__.py | 2 +-
providers/informatica/README.rst | 8 +-
providers/informatica/docs/changelog.rst | 12 +
providers/informatica/docs/index.rst | 6 +-
providers/informatica/provider.yaml | 3 +-
providers/informatica/pyproject.toml | 6 +-
.../src/airflow/providers/informatica/__init__.py | 2 +-
.../src/airflow/providers/informatica/hooks/edc.py | 2 +-
.../providers/informatica/plugins/informatica.py | 2 +-
providers/jdbc/README.rst | 8 +-
providers/jdbc/docs/changelog.rst | 12 +
providers/jdbc/docs/index.rst | 6 +-
providers/jdbc/provider.yaml | 3 +-
providers/jdbc/pyproject.toml | 6 +-
.../jdbc/src/airflow/providers/jdbc/__init__.py | 2 +-
providers/jenkins/README.rst | 8 +-
providers/jenkins/docs/changelog.rst | 14 +
providers/jenkins/docs/index.rst | 6 +-
providers/jenkins/provider.yaml | 3 +-
providers/jenkins/pyproject.toml | 6 +-
.../src/airflow/providers/jenkins/__init__.py | 2 +-
providers/keycloak/README.rst | 8 +-
providers/keycloak/docs/changelog.rst | 22 +
providers/keycloak/docs/index.rst | 6 +-
providers/keycloak/provider.yaml | 3 +-
providers/keycloak/pyproject.toml | 6 +-
.../src/airflow/providers/keycloak/__init__.py | 2 +-
.../keycloak/auth_manager/keycloak_auth_manager.py | 7 +-
.../keycloak/auth_manager/routes/login.py | 17 +-
.../keycloak/auth_manager/routes/test_login.py | 5 +-
providers/microsoft/azure/README.rst | 9 +-
providers/microsoft/azure/docs/changelog.rst | 32 +-
providers/microsoft/azure/docs/index.rst | 6 +-
providers/microsoft/azure/provider.yaml | 3 +-
providers/microsoft/azure/pyproject.toml | 6 +-
.../airflow/providers/microsoft/azure/__init__.py | 2 +-
.../microsoft/azure/hooks/container_instance.py | 10 +-
.../microsoft/azure/hooks/container_registry.py | 7 +
.../providers/microsoft/azure/operators/powerbi.py | 8 +-
.../azure/hooks/test_container_instance.py | 40 +-
providers/microsoft/mssql/README.rst | 17 +-
providers/microsoft/mssql/docs/changelog.rst | 12 +
providers/microsoft/mssql/docs/index.rst | 6 +-
providers/microsoft/mssql/provider.yaml | 3 +-
providers/microsoft/mssql/pyproject.toml | 6 +-
.../airflow/providers/microsoft/mssql/__init__.py | 2 +-
providers/microsoft/psrp/README.rst | 8 +-
providers/microsoft/psrp/docs/changelog.rst | 15 +
providers/microsoft/psrp/docs/index.rst | 6 +-
providers/microsoft/psrp/provider.yaml | 3 +-
providers/microsoft/psrp/pyproject.toml | 6 +-
.../airflow/providers/microsoft/psrp/__init__.py | 2 +-
providers/microsoft/winrm/README.rst | 8 +-
providers/microsoft/winrm/docs/changelog.rst | 12 +
providers/microsoft/winrm/docs/index.rst | 6 +-
providers/microsoft/winrm/provider.yaml | 3 +-
providers/microsoft/winrm/pyproject.toml | 6 +-
.../airflow/providers/microsoft/winrm/__init__.py | 2 +-
.../providers/microsoft/winrm/operators/winrm.py | 28 +-
.../providers/microsoft/winrm/triggers/winrm.py | 13 +-
.../unit/microsoft/winrm/operators/test_winrm.py | 54 +
.../unit/microsoft/winrm/triggers/test_winrm.py | 2 -
providers/mongo/README.rst | 8 +-
providers/mongo/docs/changelog.rst | 12 +
providers/mongo/docs/index.rst | 6 +-
providers/mongo/provider.yaml | 3 +-
providers/mongo/pyproject.toml | 6 +-
.../mongo/src/airflow/providers/mongo/__init__.py | 2 +-
providers/mysql/README.rst | 8 +-
providers/mysql/docs/changelog.rst | 13 +
providers/mysql/docs/index.rst | 6 +-
providers/mysql/provider.yaml | 3 +-
providers/mysql/pyproject.toml | 6 +-
.../mysql/src/airflow/providers/mysql/__init__.py | 2 +-
providers/neo4j/README.rst | 8 +-
providers/neo4j/docs/changelog.rst | 16 +
providers/neo4j/docs/index.rst | 6 +-
providers/neo4j/provider.yaml | 3 +-
providers/neo4j/pyproject.toml | 6 +-
.../neo4j/src/airflow/providers/neo4j/__init__.py | 2 +-
providers/odbc/README.rst | 8 +-
providers/odbc/docs/changelog.rst | 14 +
providers/odbc/docs/index.rst | 6 +-
providers/odbc/provider.yaml | 3 +-
providers/odbc/pyproject.toml | 6 +-
.../odbc/src/airflow/providers/odbc/__init__.py | 2 +-
providers/openai/README.rst | 14 +-
providers/openai/docs/changelog.rst | 24 +
providers/openai/docs/commits.rst | 4 +-
providers/openai/docs/index.rst | 6 +-
providers/openai/provider.yaml | 3 +-
providers/openai/pyproject.toml | 6 +-
.../src/airflow/providers/openai/__init__.py | 2 +-
providers/openfaas/README.rst | 8 +-
providers/openfaas/docs/changelog.rst | 16 +
providers/openfaas/docs/index.rst | 6 +-
providers/openfaas/provider.yaml | 3 +-
providers/openfaas/pyproject.toml | 6 +-
.../src/airflow/providers/openfaas/__init__.py | 2 +-
providers/openlineage/README.rst | 8 +-
providers/openlineage/docs/changelog.rst | 27 +-
providers/openlineage/docs/index.rst | 6 +-
providers/openlineage/provider.yaml | 3 +-
providers/openlineage/pyproject.toml | 6 +-
.../src/airflow/providers/openlineage/__init__.py | 2 +-
providers/opensearch/README.rst | 8 +-
providers/opensearch/docs/changelog.rst | 23 +
providers/opensearch/docs/index.rst | 6 +-
providers/opensearch/provider.yaml | 3 +-
providers/opensearch/pyproject.toml | 6 +-
.../src/airflow/providers/opensearch/__init__.py | 2 +-
.../providers/opensearch/log/os_task_handler.py | 54 +-
.../unit/opensearch/log/test_os_task_handler.py | 217 ++
providers/opsgenie/README.rst | 8 +-
providers/opsgenie/docs/changelog.rst | 18 +
providers/opsgenie/docs/index.rst | 6 +-
providers/opsgenie/provider.yaml | 3 +-
providers/opsgenie/pyproject.toml | 6 +-
.../src/airflow/providers/opsgenie/__init__.py | 2 +-
providers/oracle/README.rst | 16 +-
providers/oracle/docs/changelog.rst | 12 +
providers/oracle/docs/index.rst | 6 +-
providers/oracle/provider.yaml | 3 +-
providers/oracle/pyproject.toml | 6 +-
.../src/airflow/providers/oracle/__init__.py | 2 +-
providers/pagerduty/README.rst | 8 +-
providers/pagerduty/docs/changelog.rst | 22 +
providers/pagerduty/docs/index.rst | 6 +-
providers/pagerduty/provider.yaml | 3 +-
providers/pagerduty/pyproject.toml | 6 +-
.../src/airflow/providers/pagerduty/__init__.py | 2 +-
providers/papermill/README.rst | 26 +-
providers/papermill/docs/changelog.rst | 15 +
providers/papermill/docs/index.rst | 6 +-
providers/papermill/provider.yaml | 3 +-
providers/papermill/pyproject.toml | 6 +-
.../src/airflow/providers/papermill/__init__.py | 2 +-
providers/pgvector/README.rst | 8 +-
providers/pgvector/docs/changelog.rst | 12 +
providers/pgvector/docs/index.rst | 6 +-
providers/pgvector/provider.yaml | 3 +-
providers/pgvector/pyproject.toml | 6 +-
.../src/airflow/providers/pgvector/__init__.py | 2 +-
providers/pinecone/README.rst | 8 +-
providers/pinecone/docs/changelog.rst | 17 +
providers/pinecone/docs/index.rst | 6 +-
providers/pinecone/provider.yaml | 3 +-
providers/pinecone/pyproject.toml | 6 +-
.../src/airflow/providers/pinecone/__init__.py | 2 +-
providers/postgres/README.rst | 18 +-
providers/postgres/docs/changelog.rst | 17 +
providers/postgres/docs/index.rst | 6 +-
providers/postgres/provider.yaml | 3 +-
providers/postgres/pyproject.toml | 6 +-
.../src/airflow/providers/postgres/__init__.py | 2 +-
providers/presto/README.rst | 17 +-
providers/presto/docs/changelog.rst | 14 +
providers/presto/docs/index.rst | 6 +-
providers/presto/provider.yaml | 3 +-
providers/presto/pyproject.toml | 6 +-
.../src/airflow/providers/presto/__init__.py | 2 +-
providers/qdrant/README.rst | 16 +-
providers/qdrant/docs/changelog.rst | 16 +
providers/qdrant/docs/index.rst | 6 +-
providers/qdrant/provider.yaml | 3 +-
providers/qdrant/pyproject.toml | 6 +-
.../src/airflow/providers/qdrant/__init__.py | 2 +-
providers/redis/README.rst | 10 +-
providers/redis/docs/changelog.rst | 22 +
providers/redis/docs/index.rst | 6 +-
providers/redis/provider.yaml | 3 +-
providers/redis/pyproject.toml | 6 +-
.../redis/src/airflow/providers/redis/__init__.py | 2 +-
providers/salesforce/README.rst | 17 +-
providers/salesforce/docs/changelog.rst | 18 +
providers/salesforce/docs/index.rst | 6 +-
providers/salesforce/provider.yaml | 3 +-
providers/salesforce/pyproject.toml | 6 +-
.../src/airflow/providers/salesforce/__init__.py | 2 +-
.../airflow/providers/salesforce/operators/bulk.py | 4 +-
.../tests/unit/salesforce/operators/test_bulk.py | 35 +
providers/samba/README.rst | 8 +-
providers/samba/docs/changelog.rst | 14 +
providers/samba/docs/index.rst | 6 +-
providers/samba/provider.yaml | 3 +-
providers/samba/pyproject.toml | 6 +-
.../samba/src/airflow/providers/samba/__init__.py | 2 +-
providers/segment/README.rst | 8 +-
providers/segment/docs/changelog.rst | 15 +
providers/segment/docs/index.rst | 6 +-
providers/segment/provider.yaml | 3 +-
providers/segment/pyproject.toml | 6 +-
.../src/airflow/providers/segment/__init__.py | 2 +-
providers/sendgrid/README.rst | 17 +-
providers/sendgrid/docs/changelog.rst | 15 +
providers/sendgrid/docs/index.rst | 6 +-
providers/sendgrid/provider.yaml | 3 +-
providers/sendgrid/pyproject.toml | 6 +-
.../src/airflow/providers/sendgrid/__init__.py | 2 +-
providers/sftp/README.rst | 17 +-
providers/sftp/docs/changelog.rst | 18 +
providers/sftp/docs/index.rst | 6 +-
providers/sftp/provider.yaml | 3 +-
providers/sftp/pyproject.toml | 6 +-
.../sftp/src/airflow/providers/sftp/__init__.py | 2 +-
providers/singularity/README.rst | 8 +-
providers/singularity/docs/changelog.rst | 15 +
providers/singularity/docs/index.rst | 6 +-
providers/singularity/provider.yaml | 3 +-
providers/singularity/pyproject.toml | 6 +-
.../src/airflow/providers/singularity/__init__.py | 2 +-
providers/slack/README.rst | 17 +-
providers/slack/docs/changelog.rst | 23 +
providers/slack/docs/index.rst | 6 +-
providers/slack/provider.yaml | 3 +-
providers/slack/pyproject.toml | 6 +-
.../slack/src/airflow/providers/slack/__init__.py | 2 +-
providers/smtp/README.rst | 8 +-
providers/smtp/docs/changelog.rst | 12 +
providers/smtp/docs/index.rst | 6 +-
providers/smtp/provider.yaml | 3 +-
providers/smtp/pyproject.toml | 6 +-
.../smtp/src/airflow/providers/smtp/__init__.py | 2 +-
providers/snowflake/README.rst | 14 +-
providers/snowflake/docs/changelog.rst | 23 +
providers/snowflake/docs/index.rst | 6 +-
providers/snowflake/provider.yaml | 3 +-
providers/snowflake/pyproject.toml | 6 +-
.../src/airflow/providers/snowflake/__init__.py | 2 +-
providers/sqlite/README.rst | 8 +-
providers/sqlite/docs/changelog.rst | 14 +
providers/sqlite/docs/index.rst | 6 +-
providers/sqlite/provider.yaml | 3 +-
providers/sqlite/pyproject.toml | 6 +-
.../src/airflow/providers/sqlite/__init__.py | 2 +-
providers/ssh/README.rst | 8 +-
providers/ssh/docs/changelog.rst | 12 +
providers/ssh/docs/index.rst | 6 +-
providers/ssh/provider.yaml | 3 +-
providers/ssh/pyproject.toml | 6 +-
.../ssh/src/airflow/providers/ssh/__init__.py | 2 +-
.../ssh/src/airflow/providers/ssh/hooks/ssh.py | 2 +-
providers/standard/README.rst | 8 +-
providers/standard/docs/changelog.rst | 24 +
providers/standard/docs/index.rst | 6 +-
providers/standard/provider.yaml | 3 +-
providers/standard/pyproject.toml | 6 +-
.../src/airflow/providers/standard/__init__.py | 2 +-
.../standard/example_dags/example_hitl_operator.py | 4 +-
.../airflow/providers/standard/operators/hitl.py | 36 +-
.../tests/unit/standard/operators/test_hitl.py | 100 +-
providers/tableau/README.rst | 8 +-
providers/tableau/docs/changelog.rst | 22 +-
providers/tableau/docs/index.rst | 6 +-
providers/tableau/provider.yaml | 3 +-
providers/tableau/pyproject.toml | 6 +-
.../src/airflow/providers/tableau/__init__.py | 2 +-
providers/telegram/README.rst | 8 +-
providers/telegram/docs/changelog.rst | 16 +
providers/telegram/docs/index.rst | 6 +-
providers/telegram/provider.yaml | 3 +-
providers/telegram/pyproject.toml | 6 +-
.../src/airflow/providers/telegram/__init__.py | 2 +-
providers/teradata/README.rst | 8 +-
providers/teradata/docs/changelog.rst | 14 +
providers/teradata/docs/index.rst | 6 +-
providers/teradata/provider.yaml | 3 +-
providers/teradata/pyproject.toml | 6 +-
.../src/airflow/providers/teradata/__init__.py | 2 +-
providers/trino/README.rst | 17 +-
providers/trino/docs/changelog.rst | 15 +
providers/trino/docs/index.rst | 6 +-
providers/trino/provider.yaml | 3 +-
providers/trino/pyproject.toml | 6 +-
.../trino/src/airflow/providers/trino/__init__.py | 2 +-
providers/vertica/README.rst | 8 +-
providers/vertica/docs/changelog.rst | 12 +
providers/vertica/docs/index.rst | 6 +-
providers/vertica/provider.yaml | 3 +-
providers/vertica/pyproject.toml | 6 +-
.../src/airflow/providers/vertica/__init__.py | 2 +-
providers/weaviate/README.rst | 17 +-
providers/weaviate/docs/changelog.rst | 17 +
providers/weaviate/docs/index.rst | 6 +-
providers/weaviate/provider.yaml | 3 +-
providers/weaviate/pyproject.toml | 6 +-
.../src/airflow/providers/weaviate/__init__.py | 2 +-
providers/yandex/README.rst | 10 +-
providers/yandex/docs/changelog.rst | 18 +
providers/yandex/docs/index.rst | 6 +-
providers/yandex/provider.yaml | 3 +-
providers/yandex/pyproject.toml | 6 +-
.../src/airflow/providers/yandex/__init__.py | 2 +-
providers/ydb/README.rst | 8 +-
providers/ydb/docs/changelog.rst | 13 +
providers/ydb/docs/index.rst | 6 +-
providers/ydb/provider.yaml | 3 +-
providers/ydb/pyproject.toml | 6 +-
.../ydb/src/airflow/providers/ydb/__init__.py | 2 +-
providers/zendesk/README.rst | 8 +-
providers/zendesk/docs/changelog.rst | 18 +
providers/zendesk/docs/index.rst | 6 +-
providers/zendesk/provider.yaml | 3 +-
providers/zendesk/pyproject.toml | 6 +-
.../src/airflow/providers/zendesk/__init__.py | 2 +-
pyproject.toml | 37 +-
.../docker-compose/integration-elasticsearch.yml | 2 +-
scripts/ci/docker-compose/local.yml | 3 +
.../ci/dockerfiles/apache-rat/build_and_push.sh | 2 +-
scripts/ci/prek/check_airflow_imports_in_shared.py | 23 +
scripts/ci/prek/check_cli_definition_imports.py | 2 +
scripts/ci/prek/check_execution_api_versions.py | 75 +-
scripts/ci/prek/generate_openapi_spec.py | 2 +-
scripts/ci/prek/upgrade_important_versions.py | 33 +-
scripts/ci/testing/run_unit_tests.sh | 7 +-
scripts/docker/entrypoint_ci.sh | 9 +-
scripts/docker/install_os_dependencies.sh | 25 +-
scripts/in_container/bin/generate_mprocs_config.py | 39 +-
scripts/in_container/bin/run_tmux | 16 +-
.../prek/test_check_excluded_provider_markers.py | 24 +-
.../src/airflow_shared/configuration/parser.py | 208 +-
.../tests/configuration/test_parser.py | 122 +-
.../observability/traces/__init__.py | 12 +
{airflow-core => shared/serialization}/.gitignore | 0
.../pyproject.toml | 4 +-
.../src/airflow_shared/serialization}/__init__.py | 29 +-
.../tests/conftest.py | 0
.../serialization/tests/serialization}/__init__.py | 0
.../tests/serialization/test_constants.py | 6 +-
task-sdk/docs/api.rst | 21 +-
task-sdk/pyproject.toml | 2 +
task-sdk/src/airflow/sdk/__init__.py | 41 +-
task-sdk/src/airflow/sdk/__init__.pyi | 26 +-
task-sdk/src/airflow/sdk/_shared/serialization | 1 +
task-sdk/src/airflow/sdk/api/client.py | 20 +-
task-sdk/src/airflow/sdk/bases/decorator.py | 38 +
task-sdk/src/airflow/sdk/bases/operator.py | 22 +
task-sdk/src/airflow/sdk/configuration.py | 19 +-
.../sdk/definitions/_internal/abstractoperator.py | 53 -
.../airflow/sdk/definitions/_internal/templater.py | 94 +-
task-sdk/src/airflow/sdk/definitions/connection.py | 2 +-
.../src/airflow/sdk/definitions/mappedoperator.py | 14 +-
.../partition_mappers/{product.py => chain.py} | 6 +-
.../sdk/definitions/partition_mappers/temporal.py | 12 +-
task-sdk/src/airflow/sdk/exceptions.py | 4 +
.../src/airflow/sdk/execution_time/task_runner.py | 4 +-
.../src/airflow/sdk/providers_manager_runtime.py | 33 +
task-sdk/src/airflow/sdk/serde/__init__.py | 19 +-
task-sdk/tests/task_sdk/api/test_client.py | 59 +-
task-sdk/tests/task_sdk/bases/test_decorator.py | 147 +-
task-sdk/tests/task_sdk/bases/test_operator.py | 20 +
.../definitions/_internal/test_templater.py | 188 ++
.../tests/task_sdk/definitions/test_connection.py | 9 +
.../task_sdk/execution_time/test_supervisor.py | 70 +-
.../task_sdk/execution_time/test_task_runner.py | 87 +-
.../task_sdk/test_providers_manager_runtime.py | 35 +
uv.lock | 2251 ++++++++++----------
1086 files changed, 22466 insertions(+), 9582 deletions(-)
create mode 100644 .github/ISSUE_TEMPLATE/airflow_ctl_issue_template.yml
create mode 100644 .github/skills/airflow-translations/locales/pt.md
create mode 100644 airflow-core/newsfragments/55850.significant.rst
create mode 100644 airflow-core/newsfragments/63296.significant.rst
create mode 100644 airflow-core/newsfragments/64232.feature.rst
create mode 120000 airflow-core/src/airflow/_shared/serialization
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/client.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/client/client.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/client/index.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/client/types.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/client/utils.gen.ts
delete mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/ApiError.ts
delete mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/ApiRequestOptions.ts
delete mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/ApiResult.ts
delete mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/CancelablePromise.ts
delete mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/OpenAPI.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/auth.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/bodySerializer.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/params.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/pathSerializer.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/queryKeySerializer.gen.ts
delete mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/request.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/serverSentEvents.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/types.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/core/utils.gen.ts
create mode 100644
airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui/openapi-gen/requests/sdk.gen.ts
copy airflow-core/src/airflow/example_dags/{example_workday_timetable.py =>
example_failed_dag.py} (69%)
copy airflow-core/src/airflow/partition_mappers/{product.py => chain.py} (50%)
delete mode 100644
airflow-core/src/airflow/ui/src/components/ui/createErrorToaster.ts
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Nav/DocsButton.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/useTagFilter.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/useTagFilter.ts
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskInstances/BulkClearTaskInstancesButton.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskInstances/BulkDeleteTaskInstancesButton.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/TaskInstances/BulkMarkTaskInstancesAsButton.tsx
copy airflow-core/src/airflow/ui/src/{hooks/navigation/index.ts =>
queries/gridViewQueryKeys.ts} (56%)
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkClearDryRun.ts
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkClearTaskInstances.ts
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkMarkAsDryRun.ts
create mode 100644
airflow-core/src/airflow/ui/src/queries/useBulkTaskInstances.ts
create mode 100644 airflow-core/src/airflow/ui/src/utils/errorHandling.ts
copy providers/amazon/src/airflow/providers/amazon/aws/links/athena.py =>
airflow-core/tests/unit/api_fastapi/core_api/services/ui/test_connections.py
(59%)
create mode 100644 airflow-core/tests/unit/partition_mappers/test_chain.py
create mode 100644 airflow-core/tests/unit/triggers/test_base_trigger.py
create mode 100644 dev/README_HELM_CHART2_DEV.md
create mode 100644 providers/common/ai/docs/operators/llm_file_analysis.rst
copy providers/common/ai/src/airflow/providers/common/ai/decorators/{agent.py
=> llm_file_analysis.py} (55%)
copy {airflow-core/src/airflow/_shared =>
providers/common/ai/src/airflow/providers/common/ai/durable}/__init__.py (100%)
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/caching_model.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/caching_toolset.py
copy airflow-core/src/airflow/dag_processing/bundles/local.py =>
providers/common/ai/src/airflow/providers/common/ai/durable/step_counter.py
(52%)
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/storage.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_agent_durable.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_llm_file_analysis.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/operators/llm_file_analysis.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/file_analysis.py
copy {airflow-core/src/airflow/_shared =>
providers/common/ai/tests/unit/common/ai/assets}/__init__.py (100%)
copy {task-sdk/docs/img =>
providers/common/ai/tests/unit/common/ai/assets}/airflow-3-task-sdk.png (100%)
copy providers/common/ai/tests/unit/common/ai/decorators/{test_llm.py =>
test_llm_file_analysis.py} (54%)
copy {airflow-core/src/airflow/_shared =>
providers/common/ai/tests/unit/common/ai/durable}/__init__.py (100%)
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_caching_model.py
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_caching_toolset.py
copy
providers/{cncf/kubernetes/src/airflow/providers/cncf/kubernetes/backcompat/__init__.py
=> common/ai/tests/unit/common/ai/durable/test_step_counter.py} (58%)
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_storage.py
create mode 100644
providers/common/ai/tests/unit/common/ai/operators/test_llm_file_analysis.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_file_analysis.py
create mode 100644
providers/edge3/src/airflow/providers/edge3/plugins/www/src/components/BulkWorkerOperations.tsx
create mode 100644
providers/edge3/src/airflow/providers/edge3/plugins/www/src/hooks/useBulkWorkerActions.ts
delete mode 100644
providers/elasticsearch/tests/unit/elasticsearch/log/elasticmock/__init__.py
delete mode 100644
providers/elasticsearch/tests/unit/elasticsearch/log/elasticmock/fake_elasticsearch.py
delete mode 100644
providers/elasticsearch/tests/unit/elasticsearch/log/elasticmock/utilities/__init__.py
copy {airflow-core => shared/serialization}/.gitignore (100%)
copy shared/{template_rendering => serialization}/pyproject.toml (91%)
copy {airflow-core/src/airflow/lineage =>
shared/serialization/src/airflow_shared/serialization}/__init__.py (62%)
copy shared/{module_loading => serialization}/tests/conftest.py (100%)
copy {airflow-core/src/airflow/_shared =>
shared/serialization/tests/serialization}/__init__.py (100%)
copy airflow-core/src/airflow/listeners/__init__.py =>
shared/serialization/tests/serialization/test_constants.py (87%)
create mode 120000 task-sdk/src/airflow/sdk/_shared/serialization
copy task-sdk/src/airflow/sdk/definitions/partition_mappers/{product.py =>
chain.py} (85%)
