This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/gradle/java-sdk/java-sdk-security-updates-b5969151e9
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 139324e3c99 Bump the java-sdk-security-updates group across 1
directory with 2 updates
add e14449953fd Fix deferral paths in task lifecycle diagram (#75428)
add a7066062a13 Fix pulling `AgentOperator` output for list, marker and
function types (#74729)
add 7e02d460c8a Bump swagger-ui-dist from 5.33.3 to 5.34.0 in /registry
(#75509)
add 89e5d07a07e Bump typescript-eslint in /ts-sdk in the
ts-sdk-package-updates group (#75512)
add 46348732ca3 Bump @tanstack/react-query from 5.104.3 to 5.104.4 in
/airflow-core/src/airflow/api_fastapi/auth/managers/simple/ui (#75505)
add b9c657b3bcd Make Dags sidebar button a link and move Dag Runs and Task
Instances to Browse (#75422)
add 1159db91258 Deprecate deferrable implying wait in no-wait-default AWS
operators (#75361)
add a9ba9b1791f Deprecate deferrable overriding wait_for_completion in AWS
operators (#75360)
add 90efd88e2c1 Fix BedrockBatchInferenceSensor sharing success states
across tasks (#75265)
add 8aa1cf26ea3 Let each team's KubernetesExecutor connect to its own
cluster (#75251)
add 9ef5f3d463f Add XCom read access to deadline callbacks run by
executors (#74779)
add 34c72c5e53a Allow excluding datasets from OpenLineage events by
pattern and hook (#71312)
add e9a89e25eb0 Fix Common AI's AI Model tab for tasks inside a task loop
(#75518)
add 5d1c1d42328 Load Common AI plugin tabs when the browser reaches
Airflow on another origin (#75522)
add 57a4751c967 Add an LLM task loop example that stops on a dollar or
token budget (#75516)
add 4639f244f84 Remove info tooltip from Dag version comparison (#75526)
add 602e150aace Allow building docs with a local sphinx_airflow_theme
checkout (#75001)
add 829759749df Add missing German Dag trigger translations (#75519)
add e025c334a56 Allow jason810496 to publish docs to S3 (#75548)
add a5af91d2c52 Enable auto-merge, gated on a dedicated CI passed check
(#75142)
add 9761167313d Go SDK: stop log attributes from displacing standard log
fields (#73820)
add 55632723532 Fix KubernetesJobOperator dry_run printing a Pod instead
of a Job (#75403)
add f6c19bd1293 Prevent Dag processor crashes with Google Cloud Logging
when its log directory is outside `base_log_folder` (#74926)
add 3ce8be439e8 Add the fork CI gate to ci-amd.yml (#74819)
add 164a812559d Run fork pushes with pull-request selective checks (#74820)
add bad9f9c83b5 Add the fork CI reconciler and its scheduled monitor
(#74822)
add ce044584888 Add breeze ci audit for the fork CI setup (#74823)
add 7b5fc4b7068 Reset Dag autoregistration state when a Python Dag file
fails to load (#74911)
add b9ae12ac432 Add asset ID filtering to database cleanup (#74498)
add 976c1d08f21 Fix scheduler crash when retrying a task that timed out or
was killed externally (#75472)
add 52983d2d5e4 Update providers metadata 2026-10-24 (#75580)
add ad3ecb8c1ab Fix serialization of datetimes with a fixed UTC offset
(#74922)
add bfc288222a3 Document fork CI for contributors and maintainers (#74825)
add 1b9a32b5283 Do not fail CI passed for a cancelled duplicate CI run
(#75578)
add 8e3a9113290 Keep Breeze unit tests independent of the CI repository
(#75587)
add daa2a86fdbd Delete the project CI runs that only gate a pull request
to fork CI (#75588)
add 0c1fa8eeb72 Keep a Breeze test's --dry-run from leaking into later
tests (#75589)
add fd52d8703fb Commit pre-release constraints onto the shared
constraints-X-Y branch (#75329)
add da4fafc5ca2 UI: Fix visual and console-error bugs in Dag list and
details (#75418)
add ea661e93307 Fix Go SDK install command breaking the first bundle build
(#75574)
add f5329a6c804 Cover YAML-generated TypeScript Dags in the ts_sdk e2e
test (#75054)
add a1976c57411 Cancel the BigQuery job when BigQueryToBigQueryOperator is
killed (#75101)
add 8b2ef80dcde Fix "Dynamic require" error for CommonJS packages in
airflow-ts-pack (#75067)
add 054d093651d TS SDK: Reject a blank queue in Dag and task specs (#75573)
add b5bc253fc2d Run maintainer and canary CI on self-hosted RunsOn runners
(#74889)
add 320a469429c Refresh the Magpie reconciliation stamp (#75606)
add 06771a97969 Let the fork CI monitor gate pull requests and stop
repeating Slack alerts (#75611)
add 05f55513e99 Stop the cdxgen server containers when SBOM generation
ends (#75613)
add 757898c95e5 Check newsfragment PR numbers in static checks instead of
a separate workflow (#75612)
add 4386cb1f89e Report EC2 Spot interruptions on pull requests and keep
them out of Slack (#75615)
add 2f7a7ea4be9 Show each fork CI job's status on gated pull requests
(#75616)
add e5f2c87a3ab Cancel the workflow runs of pull requests that have
already merged (#75619)
add 352ca600361 Fix API client errors losing detail behind a reverse proxy
(#75493)
add e9904306f1a Stop airflowctl from failing on fields added by newer API
servers (#75610)
add 47296ef5892 Run only the component's tests on chart and airflow-ctl
release branches (#75621)
add 2a3ee7ffe25 Auto-approve cheap CI runs of external contributors' PRs
(#75455)
add 1d7959a624f Detect when enhanced Power BI refreshes finish or fail
(#74600)
add 365692aac59 Run the database test jobs on RunsOn with docker in RAM
(#75625)
add 77fe4132770 Fetch provider release tags from apache/airflow in fork CI
runs (#75632)
add 9cdb49017ec Run the component branch selection tests against main on
every branch (#75633)
add 8bdb287f7ee Build no images on the airflow-ctl release branches
(#75628)
add 6e990ea1927 Make common.ai hooks report misconfiguration instead of
failing silently (#74451)
add c3e00461d06 Make LoggingToolset private and update Experimental notes
in common.ai (#74694)
add 0d527b72265 Fix Go SDK build on 32-bit targets (#75551)
add 4138878208c Use EXISTS instead of a fan-out join in asset orphanage
(#75404)
add 0df550012b1 Clear retry policy state when a TI is cleared (#73889)
add 6b264738614 Add High Obtainability (HO) mode support to Dataproc
operators (#74753)
add 840d3a41c63 Return 5xx on database deadlock when updating task state
(#75368)
add a15d3527df1 Require a selection before responding to a multiple-choice
HITL request (#75643)
add 77da6dac565 Stop a commented executable_resumable from marking a
module durable (#73607)
add be274194a97 Normalize zh-TW plural forms and wording (#75504)
add eb7a35984ee Propagate OpenLineage parent and root job types to
triggered Dags (#75303)
add a57b1e6e241 Fix task loop information and tests for OpenLineage
provider (#74752)
add 8dde17bf52a Update zh-TW plural form guidance for translators (#75669)
add 437daf6eddc Approve fork CI runs that started before "use fork ci" was
added (#75654)
add bb213a30692 Honor next when an authenticated user reaches the FAB
login page (#75665)
add 54f645dd303 Check for workflow runs to auto-approve every 15 minutes
(#75655)
add 72628b5c4f4 Stop a stale callback stat from forcing constant Dag file
reparsing (#73433)
add d1491b82c90 Refuse Human-in-the-loop responses once the task stopped
waiting (#75645)
add 6d7e0010cd6 Close German Translation Gaps 2026-10-26 (#75676)
add bfb620d271b Cancel the runs of merged pull requests when they merge
(#75683)
add e4efc876f48 Switch the default async MySQL driver to asyncmy (#75218)
add 9f1348c2013 Keep the spot interruption notice green on transient
GitHub errors (#75681)
add 36038d73b5a Pin the real selective-checks auto-approve test to main
(#75682)
add 33486021776 Check out constraints from apache/airflow when diffing
them in CI (#75675)
add ffd9398e4b4 Always approve workflow runs of PRs from trusted
stakeholder repositories (#75677)
add d22f4e4b470 Retry GitHub server errors in the fork CI monitor (#75692)
add 62e50c50030 List Meta among common.ai's external services and
recognise new pydantic-ai 2.59 providers (#75641)
add dac0a7adc44 Keep common.ai on anthropic 1.x until pydantic-ai supports
anthropic 2 (#75640)
add b19bc48f96f Let the EKS executor run per team and next to
KubernetesExecutor (#75449)
add 3f0cea0e8ba Add task instance state store commands to airflowctl
(#72746)
add 562977d11bf Make the Kubernetes, E2E and Helm release jobs pass on
fork CI (#75699)
add 2ae00f1606a Retry GitHub calls that fail to connect in the fork CI
monitor (#75701)
add ad6ec79c73e Deprecate airflow.utils.email in favor of the SMTP
provider (#75414)
add df03024a9a3 Fix BigQuery durable recovery for regional jobs (#75430)
add b70a439a238 Allow FastAPI 0.137+ by requiring cadwyn 8.1 (#75689)
add 04afd601aee Restart crashed Breeze components under mprocs (#75585)
add ec8737c5417 Handle empty or corrupted JSON in airflowctl credentials
loading (#75279)
add e3f5e6ff3af Skip scheduling tasks when their Dag cannot be
deserialized (#75263)
add 3a37fb1c33e Fix BigQuery cancellation and links with inferred job
locations (#75717)
add bec92bcad02 Let listeners see the end date of a skipped task instance
(#75685)
add 34a955c17dd Remove unused type: ignore comments in airflow-ctl (#75203)
add 750f849cc23 Run a language SDK runtime in its own process group
(#75707)
add 5243901c818 Add dag_id and task_id tags to resumable_job metrics
(#75721)
add c79293ea4b9 Wait for a maintainer when a fork PR changes any
CI-defining file (#75718)
add d340be05a4e Add metrics for task and asset state store access (#75729)
add 91fbcbff93b Fix airflowctl config lint filters matching partial config
names (#75690)
add 8eb5357fb13 Keep cancelled CI runs from showing a failed CI passed
check (#75720)
add 968cca0c7e4 Add a dag_run index on (dag_id, run_after) (#74481)
add fa9c935035d airflowctl: fix datetime.datetime CLI parameters rejecting
all input (#70249)
add 21a8a98ba96 Report language SDK runtime launch failures in the task
log (#75561)
add aee26d49b6b Fix airflowctl ignoring --env for non-auth commands
(#73808)
add ead86184fb5 Emit resumable_job metrics from KubernetesPodOperator
(#75734)
add 6cac8fcddc1 Handle None response from airflowctl connections
create-defaults (#68853)
add a22fcb9a67b Stop importing airflow.utils.email in the Amazon SES hook
(#75711)
add 8b5306690ac Fix 'lineage' export in airflow.sdk (#75744)
add c4ab82253de Report AwsEksExecutor as the caller in its AWS user agent
(#75698)
add 4ace0a1deb7 Run automatic backport PRs on RunsOn runners (#75749)
add 7c7157b124e Stop breeze k8s commands from silently rewriting uv.lock
(#75763)
add cb582009a0b Raise the stale bot operation budget so it reaches older
PRs (#75761)
add 7de5ac36770 UI: Remove unused filter count helper (#75760)
add 455f5125c9a UI: Remove unused clipboard wrappers (#75759)
add 36767cb0073 UI: Remove unused quick filter button (#75758)
add aaba5c37195 UI: Don't fire keyboard shortcuts while typing in a Monaco
editor (#75684)
add d92a4805a92 UI: Fix labels that render as raw translation keys (#75326)
add 91ca0ac42c8 UI: Fix slow pending Dag run checks on large databases
(#75674)
add 8f7a8e4ff58 Hide empty log groups in the task log view (#75686)
add df37268410b Fix UI crash by validating unresolvable Windows PT
timezone (#75723)
add ae50f958ea2 Surface errors from OpenLineage database info lookups
without losing lineage (#74805)
add d583ffe5984 Hide the scheduled run icon in the grid legend (#75775)
add de5798196d2 Make Breeze Kubernetes image tests independent of the
branch (#75724)
add a5ff71dffd3 Keep breeze verify working when dry-run is on (#75713)
add be28f7fe9c2 Tell agents to stop when breeze cannot run, not use a host
venv (#75599)
add efd28053bed Stop Google Cloud Logging handler from starting a thread
on close (#75596)
add 70a78162261 Page SqlToS3Operator like GenericTransfer (#75730)
add 55b3c58dea7 Return None from relative_path_from_logger for logs
outside base_log_folder (#75572)
add 4d9fb9e841f Remove unused airflowctl lowercase argument helper (#75768)
add da767b24133 Bump the fab-ui-package-updates group across 1 directory
with 2 updates (#75807)
add a462d683469 UI: Scope partitioned Dag run asset list to readable
assets (#75213)
add 891e83dce5d Tell contributors when their fork CI workflow stops
running (#75814)
add a9a04a52f5e Clarify which Snowflake connectors need the
session_parameters copy (#75457)
add 8058c889b27 Harden the fork CI reconciler and protect the fork CI gate
(#74909)
add 8442ef02563 Remove unused Dataflow job state checker (#75784)
add ba6750c2fd0 Remove unused Cloud SQL OS bitness helper (#75788)
add eb2e644bec3 Remove unused Dataproc job template helper (#75790)
add 850466814ba Remove unused SDK variable result converter (#75766)
add a6eb4900ed9 Close German Translation Gaps 2026-10-27 (#75813)
add 12489292d1c Remove unused SQLAlchemy dialect keyword wrapper (#75782)
add 0135f75e6c1 Remove unused datetime to nanoseconds converter (#75781)
add 674f39115da Remove unused log filename template renderer (#75780)
add 5f8b01416ea Remove unused CLI Dag file location loader (#75779)
add 2dffae53785 Remove unused active asset query helpers (#75778)
add 9a0ee6f0c66 Remove unused task deferral logging bridge (#75777)
add db06a68a791 Remove unused Dag processor path converter (#75776)
add 347343ca259 Remove unused ExecuteTaskActivity model (#75767)
add e539a1b051c Remove unused shared provider discovery definitions
(#75783)
add 62df1cc8bb3 Remove unused Teradata operation classifier (#75785)
add d2c865ff014 Remove unused Postgres cursor name generator (#75786)
add b785c05164e Remove unused Spark pod try number helper (#75787)
add e401fafafb2 Remove unused Cloud SQL settings version helper (#75789)
add fccfbf8ad2b Skip airflowctl state store tests on servers older than
3.3 (#75753)
add d17f1213630 Widen the Spot pool for RunsOn runners: more families,
capacity-optimized, size ranges (#75822)
add 312cf280191 Complete Arabic translations for the UI 2026-10-27 (#75575)
add b5ce03962cc Convert finished TIs into a lightweight read-only view
during scheduling decisions (#71737)
add 881f3622304 Run the flynt prek hook in parallel batches (#75274)
add 4c1c1af00dd Rewrite the Common AI sandbox configuration page around
what users set up (#75826)
add e31f52e0a05 Stop running OpenLineage e2e compat tests when full tests
are derived (#75262)
add 50065c3ac94 Fix flaky OpenShell background-child wrapper test (#75823)
add 09d0ea1c97a Ignore the runner's OTEL_* variables in the observability
shared tests (#75828)
add ee62251fc26 Show why external contributors' workflow runs wait for
approval (#75832)
add b4320026a31 Stop importing airflow.utils.email in the SendGrid emailer
(#75771)
add c24242eea52 Load the serialized Dag in ti_run only for stub tasks
(#75795)
add 819902bb943 Accept datetime in InletEventsAccessor.after() and
before() (#75773)
add 5df209d1835 Isolate otel config-priority test from ambient OTEL env
vars (#75842)
add 41519146043 Skip spotless and the Java SDK Dag schema sync on
unrelated PRs (#75268)
add 402ab11a4b0 Avoid loading timetables for dags in Execution API
endpoints (#75765)
add 27c7624430a Support multimodal prompts with require_approval in LLM
operators (#74388)
add ce75cee3b44 Use task instance end date as OpenLineage terminal event
time (#75328)
add 62934e405ed Support Python 3.11.0 in prek cache test (#75520)
add ea2aae77d1e Keep extra cookies set by a route in JWTRefreshMiddleware
(#75411)
add ddb02d81b26 Remove unused Breeze snippet helpers (#75854)
add fd9298bf795 Chart: Bump PgBouncer to 1.25.2 and exporter to 0.21.0 to
fix CVEs (#74647)
add 7839f4a2da0 Type the durable default of the common.compat
ResumableJobMixin stand-in as bool | None (#75271)
add ec9d0df48c9 Remove unused selective checks exclusion helper (#75855)
add 60d692ba674 Stop requesting the details of an empty Dag id after a
bulk selection (#75862)
add 2f5c1c4b26b Remove unused UI page-object methods (#75853)
add 320b0c5d03d Let Claude Agent SDK agent loops use common.ai toolsets
through a new AirflowTools adapter (#74026)
add 863440537b7 Keep service logs and OpenLineage e2e noise out of the job
output (#75811)
add 49bdd34d922 Add async aget_conn and acreate_agent to PydanticAIHook
(#74150)
add d60e8d39408 i18n(ko): Add missing translations (Oct 23) (#75415)
add 7c75cd9d036 Make refresh_token optional in Keycloak login and token
services (#75871)
add 54171ff7cc8 Fix MSGraphSensor timeout being reset on every re-defer
(#75774)
add 3293ced6410 [AIP-94] Add airflowctl providers get (#68854)
add d8532e28ac6 Remove duplicate Keycloak token-binding test (#75882)
add af2c3efed7b Remove unused FAB test log assertion helpers (#75876)
add 107c2c0a447 Remove obsolete SQLAlchemy 1 driver compatibility check
(#75892)
add c84db2fa3a2 Fix async SmtpHook connections failing when STARTTLS is
enabled (#75529)
add 3722c7f84d7 Add unit tests for auth manager login datamodels (#72265)
(#75544)
add d5ca289f414 Add CLI login discovery to auth managers (#75672)
add 71bdce5fa51 Run lang-SDK serialization conformance checks in CI
instead of prek (#75872)
add 2c560aad523 Let a generic pydanticai connection set a default model
provider (#75909)
add eeae004bd25 Keep release-candidate provider pins until each is
released or yanked (#75919)
add aec750da2e4 Remove duplicate GCS wildcard transfer test (#75897)
add 5376be8924c Remove duplicate Calendar-to-GCS transfer test (#75895)
add 0a07c9ac1f1 Remove unused milestone selection helpers (#75848)
add f7abf6fec2d Remove unused decorator default comparison helper (#75849)
add a7e1de351a4 Remove unused HITL browser workflow helpers (#75851)
add ef1162a158b Remove duplicate default Kerberos chart tests (#75878)
add 8bf71ce1069 Parametrize Spark sensor waiting-state tests (#75879)
add 50189f81dfe Remove unused operator-helper test scaffolding (#75880)
add 983b387136e Remove unused S3 bundle test upload helper (#75888)
add 6edfe624bc9 Remove duplicate Teradata suspend-success test (#75881)
add 6056deb572e Remove unused CLI process test helpers (#75883)
add 5f337adeb19 Remove unused API and SDK test helpers (#75884)
add 7e1a4504fcc Remove unused Sphinx snippet renderer (#75886)
add d72dd42520a Remove orphaned model, asset and timetable test helpers
(#75887)
add 69b1ce81da3 Remove duplicate Databricks retry test (#75889)
add 67301393a50 Remove unrequested core test fixtures (#75890)
add 1387cd96177 Remove duplicate Databricks timeout retry test (#75891)
add 99bd160d063 Remove empty Databricks mixin test placeholders (#75893)
add 652da05dc1e Remove duplicate task-instance 404 tests (#75894)
add eb4803e6d63 Remove duplicate HTTP header override test (#75899)
add 7e6bccecd8e Parametrize airflowctl environment output tests (#75900)
add 6061e081f6c Remove duplicate SFTP missing-file sensor test (#75901)
add c6690015a28 Parametrize airflowctl partition-date tests (#75902)
add ddb89d5e006 Run the slow root prek checks in parallel (#75437)
add a211be1c115 Fix MySQL HITL responded-by filters (#67323)
add 24f33707582 Add query and report inspection operators for Google Bid
Manager (#71947)
add 6a8e8642939 Don't force dags reserialize in e2e startup (races
dag-processor) (#75739)
add dac3da4ccfd Add missing tests for google.cloud.utils BigQuery helpers
(#72276) (#72448)
add d561f37ea54 Fix OpenLineage task events lost for Dags with mapped
tasks (#75860)
add d9ca6241562 Match file datasets in exclude_datasets without a doubled
slash (#75921)
add 20e4e570971 Avoid unbounded IN lists for queued asset events (#75943)
add fa160f83538 Fix dashboard Active Dags filtering (#75350)
add eafb6ed8a7d Reject non-object JSON files when importing variables
(#75384)
add e0a95793c95 Preserve XCom value types when editing in the UI (#75496)
add 226de8a1911 Publish usage, run id and model name from LLMOperator's
subclasses (#75208)
add b394b884046 Add OpenLineage system tests for the emission policy
(#75678)
add 1040a319e0e Fix the durable MSGraph and PowerBI operators from
post-merge review (#75272)
add 6f0a4b5d519 Fix hourly cron schedules running an hour off across a DST
change (#75847)
add fb6534f1db4 Prepare deferred providers RC2 for 2026-10-29 (#75947)
add 97d4d4e2aa9 Skip log accumulator disk spill when reading finished task
logs (#70671)
add 7468d3145cc Show UI doc screenshots in synced dark/light tabs (#75957)
add cd1ed360b9a Refresh Dag cards after deleting Dag runs (#75931)
add 040173d818a Refresh the Magpie reconciliation stamp (#75952)
add 34ad14c27b3 i18n(ko): add missing translations(Oct 27) (#75740)
add 9b37c269b4a Use only file:// URIs in the OpenLineage exclude_datasets
authoring system test (#75961)
add f605f1040f3 UI: Fix the Dag filters test that fails lint and vitest
(#75963)
add 5761c2ac1ea Remove the unused React SWC plugin from the UI (#75875)
add 90628f4fbdc Preserve task instance bulk selections across pages
(#75905)
add 38b3c45415b Make the bundle name less prominent in the Dag import
error modals (#75958)
add 92bbf67c362 Refuse to publish constraints when the branch moved during
generation (#75989)
add 7a6acca54be Allow selecting several task instances in the Grid view
(#75221)
add 37b6b04e723 Add name filtering to the Deadline Alerts API (#74127)
add 083b82d7c4d Size CI test jobs on RunsOn runners to the parallelism
they can use (#75833)
add 6e6ae1ab7d2 UI: Show a loop's iterations and why each one decided
(#75984)
add 212fe09e1d0 UI: Stop Recent Configurations flashing on the trigger
form (#75991)
add 0f2563f232b Document the zh-TW translation workflow (#75702)
add 406474723a2 Add an end-to-end test for a Dag written in YAML (#75928)
add 8401a190fa8 Run the lang-SDK native Dag tests on Kubernetes (#75930)
add c6a077b0efe Serialise the workflows that publish shared state (#75996)
add 9e662c23fc0 Fix stale queued asset rows in scheduler cleanup and
readiness (#76002)
add 56b44decc8f Sync the session's copy with the DB for removed task
instances when scheduling (#75974)
add 1df83c5dff6 Type the ORM declarative base as a value of type Any
(#76025)
add 155560df668 Store and show the retry deadline; start retries with
empty run fields (#76027)
add 5af4c5bf12d Freeze the GC before the triggerer's forks so memory stays
flat (#76016)
add 5cc2413925a Honor Airflow logging levels in TypeScript SDK (#76005)
add acb2208f15f Let the ECS executor start tasks in parallel (#75907)
add 48435351c42 Pin the hardened base images to digests the CI has passed
on (#76023)
add a3a4f4f168e Stop bundling the ELK worker twice in the UI (#75864)
add ecb95734544 UI: Fix select filter pills staying open in Safari (#76013)
add 527f92e15ca Allow selecting task groups in the Grid view (#75856)
add d2e60aefea2 Retry GitHub calls that drop the connection in the Spot
interruption notices (#75829)
add 460f7a08bf8 Close fork CI pull requests that change jobs running in
gated runs (#75827)
add aa3a5239652 Fix 404 error on looped task group breadcrump and add test
(#76050)
add 411dd947638 Bump the java-sdk-security-updates group across 1
directory with 2 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 (139324e3c99)
\
N -- N -- N
refs/heads/dependabot/gradle/java-sdk/java-sdk-security-updates-b5969151e9
(411dd947638)
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/airflow-translations/locales/zh-TW.md | 71 +-
.../setup-isolated-setup-install.md | 5 +
.apache-magpie.lock | 43 +-
.asf.yaml | 64 +-
.github/AGENTS.md | 38 +
.github/actions/breeze/action.yml | 8 +
.../actions/prepare_breeze_and_image/action.yml | 10 +-
.github/actions/prepare_single_ci_image/action.yml | 5 +-
.../runs-on-cost-summary/action.yml} | 31 +-
.github/actions/stash-restore/action.yml | 137 +
.github/actions/stash-save/action.yml | 129 +
.github/fork-ci-gate.toml | 52 +
.github/workflows/additional-ci-image-checks.yml | 2 +-
.github/workflows/additional-prod-image-tests.yml | 98 +-
.github/workflows/airflow-e2e-tests.yml | 12 +-
.github/workflows/auto-approve-workflow-runs.yml | 73 +
.github/workflows/basic-tests.yml | 52 +-
.github/workflows/cancel-merged-pr-runs.yml | 119 +
.github/workflows/check-newsfragment-pr-number.yml | 60 -
.github/workflows/ci-amd.yml | 497 ++-
.github/workflows/ci-arm.yml | 378 +-
.github/workflows/ci-image-build.yml | 36 +-
.github/workflows/ci-image-checks.yml | 25 +-
.github/workflows/finalize-tests.yml | 12 +-
.github/workflows/fork-ci-monitor.yml | 238 ++
.github/workflows/generate-constraints.yml | 20 +-
.github/workflows/helm-tests.yml | 8 +-
.github/workflows/integration-system-tests.yml | 6 +-
.github/workflows/k8s-tests.yml | 4 +-
.github/workflows/kustomize-overlays-tests.yml | 2 +-
.github/workflows/mark-workflow-runs-approved.yml | 85 +
.github/workflows/mirror-hardened-base-images.yml | 84 +-
.github/workflows/prod-image-build.yml | 8 +-
.github/workflows/publish-docs-to-s3.yml | 75 +-
.github/workflows/push-image-cache.yml | 4 +-
.github/workflows/refresh-image-registry-cache.yml | 7 +-
.github/workflows/registry-backfill.yml | 6 +
.github/workflows/registry-build.yml | 9 +
.github/workflows/release-constraints.yml | 61 +-
.github/workflows/release_dockerhub_image.yml | 11 +-
.../scheduled-legacy-prod-image-canary.yml | 10 +-
.github/workflows/scheduled-upgrade-check-main.yml | 2 +
.../scheduled-upgrade-check-v3-4-test.yml | 2 +
.github/workflows/special-tests.yml | 38 +-
.github/workflows/spot-interruption-notice.yml | 57 +
.github/workflows/stale.yml | 1 +
.github/workflows/test-providers.yml | 6 +-
.github/workflows/ui-e2e-tests.yml | 2 +-
.../update-constraints-on-push-stable.yml | 11 +-
.github/workflows/update-constraints-on-push.yml | 40 +-
.github/workflows/upgrade-check.yml | 78 +-
.pre-commit-config.yaml | 127 +-
AGENTS.md | 4 +-
Dockerfile | 83 +-
Dockerfile.ci | 79 +-
README.md | 2 +
.../docs/authoring-and-scheduling/assets.rst | 7 +-
.../authoring-and-scheduling/language-sdks/go.rst | 2 +-
.../language-sdks/typescript.rst | 2 +-
.../docs/authoring-and-scheduling/loops.rst | 10 +-
.../docs/core-concepts/auth-manager/index.rst | 25 +
airflow-core/docs/howto/deadline-alerts.rst | 3 +
airflow-core/docs/howto/email-config.rst | 80 +-
airflow-core/docs/howto/set-up-database.rst | 28 +-
airflow-core/docs/howto/usage-cli.rst | 9 +
.../docs/img/diagram_task_lifecycle.md5sum | 2 +-
airflow-core/docs/img/diagram_task_lifecycle.png | Bin 671852 -> 643516
bytes
airflow-core/docs/img/diagram_task_lifecycle.py | 18 +-
airflow-core/docs/migrations-ref.rst | 6 +-
airflow-core/docs/security/api_permissions_ref.rst | 8 +
airflow-core/docs/ui.rst | 438 +-
airflow-core/newsfragments/75218.significant.rst | 13 +
airflow-core/newsfragments/75414.significant.rst | 20 +
airflow-core/newsfragments/75493.bugfix.rst | 1 +
airflow-core/pyproject.toml | 11 +-
airflow-core/src/airflow/api_fastapi/app.py | 2 +
.../api_fastapi/auth/managers/base_auth_manager.py | 11 +-
.../auth/managers/simple/ui/package.json | 2 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 30 +-
.../api_fastapi/auth/middlewares/refresh_token.py | 24 +-
.../src/airflow/api_fastapi/common/http_metrics.py | 25 +-
.../common/telemetry.py} | 29 +-
.../src/airflow/api_fastapi/common/types.py | 21 +-
.../api_fastapi/core_api/datamodels/assets.py | 8 +-
.../core_api/datamodels/{providers.py => auth.py} | 21 +-
.../api_fastapi/core_api/datamodels/common.py | 16 +
.../api_fastapi/core_api/datamodels/config.py | 8 +-
.../api_fastapi/core_api/datamodels/providers.py | 168 +
.../core_api/datamodels/task_instance_history.py | 8 +-
.../core_api/datamodels/task_instances.py | 7 +-
.../api_fastapi/core_api/datamodels/ui/grid.py | 1 +
.../core_api/datamodels/ui/partitioned_dag_runs.py | 12 +-
.../api_fastapi/core_api/openapi/_private_ui.yaml | 56 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 676 ++-
.../api_fastapi/core_api/routes/public/auth.py | 14 +
.../api_fastapi/core_api/routes/public/dags.py | 25 +-
.../api_fastapi/core_api/routes/public/hitl.py | 32 +-
.../core_api/routes/public/providers.py | 23 +-
.../airflow/api_fastapi/core_api/routes/ui/dags.py | 8 +-
.../api_fastapi/core_api/routes/ui/deadlines.py | 10 +-
.../airflow/api_fastapi/core_api/routes/ui/grid.py | 2 +
.../core_api/routes/ui/partitioned_dag_runs.py | 28 +-
.../core_api/services/public/providers.py | 17 +-
.../api_fastapi/core_api/services/ui/grid.py | 5 +
.../src/airflow/api_fastapi/execution_api/app.py | 41 +-
.../execution_api/datamodels/taskinstance.py | 8 +-
.../execution_api/routes/task_instances.py | 24 +-
.../airflow/api_fastapi/execution_api/security.py | 10 +-
airflow-core/src/airflow/assets/manager.py | 27 +-
.../airflow/callbacks/database_callback_sink.py | 14 +-
airflow-core/src/airflow/cli/cli_config.py | 7 +
.../src/airflow/cli/commands/db_command.py | 1 +
.../src/airflow/cli/commands/triggerer_command.py | 9 +-
airflow-core/src/airflow/dag_processing/manager.py | 25 +-
.../src/airflow/executors/base_executor.py | 2 +
.../src/airflow/jobs/scheduler_job_runner.py | 436 +-
.../src/airflow/jobs/triggerer_job_runner.py | 7 +
.../0142_3_4_0_unify_task_attempt_ownership.py | 3 +-
.../0149_3_4_0_add_is_stub_to_task_instance.py | 54 +
..._job.py => 0150_3_5_0_add_session_id_to_job.py} | 4 +-
...51_3_5_0_add_dag_run_dag_id_run_after_index.py} | 39 +-
airflow-core/src/airflow/models/asset.py | 66 +-
airflow-core/src/airflow/models/base.py | 13 +-
airflow-core/src/airflow/models/dag.py | 13 +-
airflow-core/src/airflow/models/dagrun.py | 250 +-
airflow-core/src/airflow/models/hitl.py | 17 +-
.../src/airflow/models/task_coordinates.py | 59 +-
airflow-core/src/airflow/models/taskinstance.py | 111 +-
.../serialization/definitions/baseoperator.py | 2 +-
.../src/airflow/serialization/definitions/dag.py | 29 +-
.../serialization/definitions/mappedoperator.py | 2 +-
.../airflow/serialization/serialized_objects.py | 28 +-
airflow-core/src/airflow/settings.py | 7 +-
airflow-core/src/airflow/ti_deps/dep_context.py | 12 +-
.../ti_deps/deps/not_in_retry_period_dep.py | 6 +-
.../ti_deps/deps/not_previously_skipped_dep.py | 3 +-
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 5 +-
airflow-core/src/airflow/timetables/_cron.py | 69 +-
airflow-core/src/airflow/timetables/base.py | 4 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 15 +-
.../ui/openapi-gen/queries/ensureQueryData.ts | 26 +-
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 26 +-
.../src/airflow/ui/openapi-gen/queries/queries.ts | 26 +-
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 26 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 1362 +++++-
.../ui/openapi-gen/requests/services.gen.ts | 43 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 262 +-
airflow-core/src/airflow/ui/package.json | 2 -
airflow-core/src/airflow/ui/pnpm-lock.yaml | 181 -
.../airflow/ui/public/i18n/locales/ar/admin.json | 33 +-
.../airflow/ui/public/i18n/locales/ar/assets.json | 24 +-
.../airflow/ui/public/i18n/locales/ar/browse.json | 45 +
.../airflow/ui/public/i18n/locales/ar/common.json | 127 +-
.../ui/public/i18n/locales/ar/components.json | 57 +-
.../src/airflow/ui/public/i18n/locales/ar/dag.json | 153 +-
.../airflow/ui/public/i18n/locales/ar/dags.json | 44 +-
.../ui/public/i18n/locales/ar/dashboard.json | 21 +-
.../airflow/ui/public/i18n/locales/ar/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/ca/common.json | 1 -
.../ui/public/i18n/locales/ca/components.json | 7 +
.../src/airflow/ui/public/i18n/locales/ca/dag.json | 2 -
.../airflow/ui/public/i18n/locales/de/browse.json | 1 +
.../airflow/ui/public/i18n/locales/de/common.json | 2 +-
.../ui/public/i18n/locales/de/components.json | 14 +
.../src/airflow/ui/public/i18n/locales/de/dag.json | 6 +-
.../airflow/ui/public/i18n/locales/de/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/el/common.json | 1 -
.../ui/public/i18n/locales/el/components.json | 7 +
.../src/airflow/ui/public/i18n/locales/el/dag.json | 2 -
.../airflow/ui/public/i18n/locales/en/browse.json | 1 +
.../airflow/ui/public/i18n/locales/en/common.json | 5 +-
.../ui/public/i18n/locales/en/components.json | 8 +
.../src/airflow/ui/public/i18n/locales/en/dag.json | 2 -
.../ui/public/i18n/locales/en/dashboard.json | 1 +
.../airflow/ui/public/i18n/locales/en/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/es/common.json | 1 -
.../ui/public/i18n/locales/es/components.json | 7 +
.../airflow/ui/public/i18n/locales/fr/common.json | 1 -
.../ui/public/i18n/locales/fr/components.json | 7 +
.../src/airflow/ui/public/i18n/locales/fr/dag.json | 2 -
.../airflow/ui/public/i18n/locales/he/common.json | 1 -
.../ui/public/i18n/locales/he/components.json | 7 +
.../src/airflow/ui/public/i18n/locales/he/dag.json | 2 -
.../airflow/ui/public/i18n/locales/hi/common.json | 1 -
.../ui/public/i18n/locales/hi/components.json | 7 +
.../src/airflow/ui/public/i18n/locales/hi/dag.json | 2 -
.../airflow/ui/public/i18n/locales/hu/common.json | 1 -
.../ui/public/i18n/locales/hu/components.json | 7 +
.../airflow/ui/public/i18n/locales/it/common.json | 1 -
.../ui/public/i18n/locales/it/components.json | 7 +
.../airflow/ui/public/i18n/locales/ja/common.json | 1 -
.../ui/public/i18n/locales/ja/components.json | 7 +
.../airflow/ui/public/i18n/locales/ko/admin.json | 2 +
.../airflow/ui/public/i18n/locales/ko/browse.json | 1 +
.../airflow/ui/public/i18n/locales/ko/common.json | 13 +-
.../ui/public/i18n/locales/ko/components.json | 16 +
.../src/airflow/ui/public/i18n/locales/ko/dag.json | 49 +-
.../airflow/ui/public/i18n/locales/ko/dags.json | 1 +
.../airflow/ui/public/i18n/locales/ko/hitl.json | 1 +
.../airflow/ui/public/i18n/locales/nl/common.json | 1 -
.../ui/public/i18n/locales/nl/components.json | 7 +
.../airflow/ui/public/i18n/locales/pl/common.json | 1 -
.../ui/public/i18n/locales/pl/components.json | 7 +
.../src/airflow/ui/public/i18n/locales/pl/dag.json | 2 -
.../airflow/ui/public/i18n/locales/pt/common.json | 1 -
.../ui/public/i18n/locales/pt/components.json | 7 +
.../airflow/ui/public/i18n/locales/ru/common.json | 1 -
.../ui/public/i18n/locales/ru/components.json | 7 +
.../airflow/ui/public/i18n/locales/th/common.json | 1 -
.../ui/public/i18n/locales/th/components.json | 7 +
.../airflow/ui/public/i18n/locales/tr/common.json | 1 -
.../ui/public/i18n/locales/tr/components.json | 7 +
.../ui/public/i18n/locales/zh-CN/common.json | 1 -
.../ui/public/i18n/locales/zh-CN/components.json | 7 +
.../ui/public/i18n/locales/zh-TW/common.json | 7 +-
.../ui/public/i18n/locales/zh-TW/components.json | 9 +-
.../airflow/ui/public/i18n/locales/zh-TW/dag.json | 12 +-
.../ui/public/i18n/locales/zh-TW/dashboard.json | 4 +-
.../airflow/ui/public/i18n/locales/zh-TW/hitl.json | 5 +-
.../ui/src/components/AssetProgressCell.test.tsx | 63 +-
.../ui/src/components/AssetProgressCell.tsx | 54 +-
...learTaskInstanceDialog.emptySelection.test.tsx} | 47 +-
.../Clear/TaskInstance/ClearTaskInstanceDialog.tsx | 9 +-
.../src/airflow/ui/src/components/ConfigForm.tsx | 2 +-
.../airflow/ui/src/components/DAGWarningsModal.tsx | 62 +-
.../ui/src/components/DagDeactivatedChip.test.tsx | 154 -
.../ui/src/components/DagDeactivatedChip.tsx | 70 -
...ortErrorModal.tsx => DagImportErrorDetails.tsx} | 34 +-
.../ui/src/components/DagImportErrorModal.test.tsx | 27 +-
.../ui/src/components/DagImportErrorModal.tsx | 52 +-
.../ui/src/components/DagStatusChip.test.tsx | 161 +
.../airflow/ui/src/components/DagStatusChip.tsx | 90 +
.../ui/src/components/DataTable/DataTable.tsx | 1 +
.../components/DataTable/useRowSelection.test.tsx | 86 +
.../src/components/DataTable/useRowSelection.tsx | 19 +-
.../src/airflow/ui/src/components/ErrorAlert.tsx | 15 +-
.../ui/src/components/FilterBar/FilterBar.test.tsx | 35 +
.../ui/src/components/FilterBar/FilterPill.tsx | 29 +-
.../components/FilterBar/filters/LoopFilter.tsx | 17 +-
.../FilterBar/filters/RunStateFilter.tsx | 27 +-
.../components/FilterBar/filters/SelectFilter.tsx | 21 +-
.../FilterBar/filters/pausedStateParams.ts | 19 +-
.../ui/src/components/Graph/useGraphLayout.ts | 3 +-
.../ui/src/components/QuickFilterButton.tsx | 40 -
.../airflow/ui/src/components/StatusMessage.tsx | 52 +
.../ui/src/components/TaskInstanceTooltip.test.tsx | 46 +-
.../ui/src/components/TaskInstanceTooltip.tsx | 7 +
.../TriggerDag/RecentConfigSelect.test.tsx | 39 +-
.../components/TriggerDag/RecentConfigSelect.tsx | 79 +-
.../components/TriggerDag/TriggerDAGForm.test.tsx | 4 +-
.../src/airflow/ui/src/components/WarningAlert.tsx | 28 +-
.../src/airflow/ui/src/constants/filterConfigs.tsx | 2 +
.../ui/src/context/gridSelection/Context.ts | 56 +
.../gridSelection/GridSelectionProvider.tsx} | 25 +-
.../gridSelection/index.ts} | 10 +-
.../ui/src/context/keyboardShortcuts/shortcuts.ts | 10 +
.../src/context/timezone/TimezoneProvider.test.tsx | 59 +
.../ui/src/context/timezone/TimezoneProvider.tsx | 17 +-
.../ui/src/hooks/useRequiredActionTabs.test.tsx | 66 +
.../airflow/ui/src/hooks/useRequiredActionTabs.ts | 31 +-
.../src/airflow/ui/src/hooks/useShortcut.test.tsx | 64 +-
.../src/airflow/ui/src/hooks/useShortcut.ts | 16 +-
.../src/airflow/ui/src/i18n/locales.test.ts | 60 +-
.../src/airflow/ui/src/layouts/BaseLayout.tsx | 3 +-
.../ui/src/layouts/Details/DagBreadcrumb.test.tsx | 21 +-
.../ui/src/layouts/Details/DagBreadcrumb.tsx | 1 -
.../ui/src/layouts/Details/DetailsLayout.tsx | 46 +-
.../ui/src/layouts/Details/Gantt/utils.test.ts | 18 +-
.../airflow/ui/src/layouts/Details/Gantt/utils.ts | 13 +-
.../ui/src/layouts/Details/Grid/Grid.test.tsx | 17 +-
.../airflow/ui/src/layouts/Details/Grid/Grid.tsx | 38 +-
.../Details/Grid/GridSelectionActionBar.test.tsx | 69 +
.../Details/Grid/GridSelectionActionBar.tsx | 98 +
.../ui/src/layouts/Details/Grid/GridTI.test.tsx | 19 +
.../airflow/ui/src/layouts/Details/Grid/GridTI.tsx | 9 +-
.../ui/src/layouts/Details/Grid/RunTypeLegend.tsx | 7 +-
.../layouts/Details/Grid/TaskInstancesColumn.tsx | 16 +-
.../Grid/useGridSelectedTaskInstances.test.tsx | 139 +
.../Details/Grid/useGridSelectedTaskInstances.ts | 79 +
.../layouts/Details/Grid/useGridSelection.test.tsx | 324 ++
.../src/layouts/Details/Grid/useGridSelection.ts | 258 ++
.../ui/src/layouts/Nav/BrowseButton.test.tsx | 83 +
.../airflow/ui/src/layouts/Nav/BrowseButton.tsx | 32 +-
.../airflow/ui/src/layouts/Nav/DagsButton.test.tsx | 54 +-
.../src/airflow/ui/src/layouts/Nav/DagsButton.tsx | 41 +-
.../src/airflow/ui/src/mocks/handlers/dags.ts | 4 +
.../ui/src/pages/AssetsList/AssetsList.test.tsx | 14 +-
.../ui/src/pages/Connections/ConnectionForm.tsx | 3 +-
.../ui/src/pages/Dag/Versions/VersionDiff.test.tsx | 8 -
.../ui/src/pages/Dag/Versions/VersionDiff.tsx | 22 +-
.../src/airflow/ui/src/pages/DagsList/DagCard.tsx | 8 +-
.../DagsList/DagsFilters/DagsFilters.test.tsx | 30 +-
.../src/airflow/ui/src/pages/DagsList/DagsList.tsx | 4 +-
.../ui/src/pages/DagsList/RecentRuns.test.tsx | 58 +
.../airflow/ui/src/pages/DagsList/RecentRuns.tsx | 10 +-
.../src/airflow/ui/src/pages/DagsList/Schedule.tsx | 14 +-
.../pages/Dashboard/Stats/DagImportErrorsModal.tsx | 14 +-
.../pages/GroupTaskInstance/GroupTaskInstance.tsx | 11 +-
.../ui/src/pages/GroupTaskInstance/Header.tsx | 26 +-
.../LoopIterations/LoopIterations.test.tsx | 136 +
.../LoopIterations/LoopIterations.tsx | 137 +
.../GroupTaskInstance/LoopIterations/loopUtils.ts | 2 +-
.../ui/src/pages/GroupTaskInstance/index.ts | 1 +
.../HITLTaskInstances/HITLResponseForm.test.tsx | 193 +-
.../pages/HITLTaskInstances/HITLResponseForm.tsx | 33 +-
.../ui/src/pages/MappedTaskInstance/Header.tsx | 23 +-
.../src/airflow/ui/src/pages/Pools/PoolForm.tsx | 2 +-
.../src/airflow/ui/src/pages/Run/Header.tsx | 13 +-
.../ui/src/pages/TaskInstance/Details.test.tsx | 24 +
.../airflow/ui/src/pages/TaskInstance/Details.tsx | 8 +
.../ui/src/pages/TaskInstance/Header.test.tsx | 21 +
.../airflow/ui/src/pages/TaskInstance/Header.tsx | 28 +-
.../src/pages/TaskInstances/TaskInstances.test.tsx | 50 +-
.../ui/src/pages/TaskInstances/TaskInstances.tsx | 19 +-
.../pages/Variables/ImportVariablesForm.test.tsx | 83 +
.../ui/src/pages/Variables/ImportVariablesForm.tsx | 12 +-
.../src/airflow/ui/src/pages/XCom/XCom.tsx | 2 +-
.../airflow/ui/src/pages/XCom/XComModal.test.tsx | 60 +
.../src/airflow/ui/src/pages/XCom/XComModal.tsx | 6 +-
.../airflow/ui/src/queries/useBulkDeleteDagRuns.ts | 6 +
.../ui/src/queries/useDeleteDagRun.test.tsx | 82 +
.../src/airflow/ui/src/queries/useDeleteDagRun.ts | 6 +
.../useHasMultipleDagBundles.ts} | 19 +-
.../src/airflow/ui/src/queries/useLogs.test.ts | 38 +
.../src/airflow/ui/src/queries/useLogs.tsx | 11 +-
.../src/queries/useRecentTaskStateCounts.test.tsx | 20 +
.../ui/src/queries/useRecentTaskStateCounts.tsx | 9 +-
.../airflow/ui/src/queries/useUpdateHITLDetail.ts | 16 +-
airflow-core/src/airflow/ui/src/router.tsx | 7 +-
.../airflow/ui/src/system-components/Clipboard.tsx | 42 +-
.../src/airflow/ui/src/utils/dagStatus.test.ts | 84 +
airflow-core/src/airflow/ui/src/utils/dagStatus.ts | 75 +
.../src/airflow/ui/src/utils/errorHandling.ts | 23 +
.../src/airflow/ui/src/utils/filterUtils.test.ts | 106 -
airflow-core/src/airflow/ui/src/utils/index.ts | 3 +-
.../src/airflow/ui/src/utils/query.test.ts | 50 +
airflow-core/src/airflow/ui/src/utils/query.ts | 7 +-
.../airflow/ui/tests/e2e/pages/DagCalendarTab.ts | 11 -
.../src/airflow/ui/tests/e2e/pages/DagsPage.ts | 8 +-
.../airflow/ui/tests/e2e/pages/ProvidersPage.ts | 13 -
.../ui/tests/e2e/pages/RequiredActionsPage.ts | 357 +-
.../airflow/ui/tests/e2e/pages/TaskInstancePage.ts | 36 +-
airflow-core/src/airflow/ui/testsSetup.ts | 29 +
airflow-core/src/airflow/utils/cli.py | 17 -
airflow-core/src/airflow/utils/dates.py | 15 -
airflow-core/src/airflow/utils/db.py | 12 +-
airflow-core/src/airflow/utils/db_cleanup.py | 24 +-
airflow-core/src/airflow/utils/email.py | 350 +-
airflow-core/src/airflow/utils/helpers.py | 23 -
.../src/airflow/utils/log/file_task_handler.py | 59 +-
.../src/airflow/utils/serve_logs/log_server.py | 3 +-
airflow-core/src/airflow/utils/sqlalchemy.py | 20 +-
airflow-core/tests/conftest.py | 36 -
.../tests/unit/always/test_project_structure.py | 4 -
.../auth/managers/test_base_auth_manager.py | 5 +-
.../auth/middlewares/test_refresh_token.py | 92 +-
.../unit/api_fastapi/common/test_exceptions.py | 11 -
.../unit/api_fastapi/common/test_http_metrics.py | 13 +-
.../core_api/datamodels/test_providers.py | 50 +
.../core_api/routes/public/test_assets.py | 15 +-
.../core_api/routes/public/test_auth.py | 47 +-
.../core_api/routes/public/test_dags.py | 41 +
.../core_api/routes/public/test_hitl.py | 136 +-
.../core_api/routes/public/test_providers.py | 149 +
.../core_api/routes/public/test_task_instances.py | 110 +-
.../core_api/routes/public/test_variables.py | 6 -
.../api_fastapi/core_api/routes/test_routes.py | 9 +-
.../api_fastapi/core_api/routes/ui/test_dags.py | 36 +
.../core_api/routes/ui/test_deadlines.py | 91 +-
.../api_fastapi/core_api/routes/ui/test_grid.py | 25 +
.../routes/ui/test_partitioned_dag_runs.py | 122 +-
.../unit/api_fastapi/execution_api/test_app.py | 29 +-
.../execution_api/test_token_scope_boundaries.py | 27 +-
.../versions/head/test_task_instances.py | 89 +-
.../unit/api_fastapi/logging/test_decorators.py | 18 +-
airflow-core/tests/unit/api_fastapi/test_app.py | 25 +
airflow-core/tests/unit/assets/test_manager.py | 14 +-
.../tests/unit/cli/commands/_common_cli_classes.py | 43 -
.../tests/unit/cli/commands/test_db_command.py | 84 +
.../unit/cli/commands/test_triggerer_command.py | 27 +
airflow-core/tests/unit/core/test_settings.py | 26 +-
.../lang_sdk_fixtures/go_native.json | 2 +
.../lang_sdk_fixtures/java_native.json | 3 +
.../tests/unit/dag_processing/test_dagbag.py | 9 +
.../tests/unit/dag_processing/test_manager.py | 112 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 780 +++-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 24 +
airflow-core/tests/unit/models/test_dag.py | 65 +-
airflow-core/tests/unit/models/test_dagrun.py | 245 +-
.../tests/unit/models/test_dynamic_region.py | 2 +-
airflow-core/tests/unit/models/test_hitl.py | 55 +
.../tests/unit/models/test_mappedoperator.py | 9 +-
.../tests/unit/models/test_taskinstance.py | 233 +-
airflow-core/tests/unit/models/test_trigger.py | 4 +-
.../tests/unit/partition_mappers/test_init.py | 4 +-
.../unit/serialization/test_dag_serialization.py | 25 +-
.../tests/unit/timetables/test_assets_timetable.py | 18 -
.../tests/unit/timetables/test_cron_mixin.py | 279 +-
.../tests/unit/utils/log/test_log_reader.py | 4 +-
airflow-core/tests/unit/utils/test_db_cleanup.py | 178 +
airflow-core/tests/unit/utils/test_email.py | 447 +-
airflow-core/tests/unit/utils/test_log_handlers.py | 109 +-
.../tests/unit/utils/test_operator_helpers.py | 37 -
airflow-core/tests/unit/utils/test_sqlalchemy.py | 60 +-
.../tests/airflowctl_tests/conftest.py | 8 +
.../airflowctl_tests/test_airflowctl_commands.py | 47 +-
airflow-ctl/docs/images/command_hashes.txt | 4 +-
airflow-ctl/docs/images/output_providers.svg | 70 +-
airflow-ctl/docs/images/output_taskinstances.svg | 82 +-
airflow-ctl/src/airflowctl/api/client.py | 22 +-
.../src/airflowctl/api/datamodels/generated.py | 237 +-
airflow-ctl/src/airflowctl/api/operations.py | 137 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 150 +-
airflow-ctl/src/airflowctl/ctl/cli_parser.py | 2 +
.../src/airflowctl/ctl/commands/config_command.py | 16 +-
.../airflowctl/ctl/commands/provider_command.py | 32 +-
.../src/airflowctl/ctl/commands/version_command.py | 3 +-
airflow-ctl/src/airflowctl/ctl/help_texts.yaml | 10 +
airflow-ctl/tests/airflow_ctl/api/test_client.py | 118 +-
.../tests/airflow_ctl/api/test_operations.py | 228 +
.../airflow_ctl/ctl/commands/test_auth_command.py | 40 +-
.../ctl/commands/test_config_command.py | 96 +
.../airflow_ctl/ctl/commands/test_dag_command.py | 46 +-
.../ctl/commands/test_provider_command.py | 107 +
.../ctl/commands/test_version_command.py | 10 +-
.../tests/airflow_ctl/ctl/test_cli_config.py | 164 +-
airflow-e2e-tests/docker/openlineage.yml | 88 +-
airflow-e2e-tests/docker/ts.yml | 6 +
.../docker/yaml-dag.yml | 32 +-
.../tests/airflow_e2e_tests/conftest.py | 115 +-
.../tests/airflow_e2e_tests/constants.py | 6 +
.../airflow_e2e_tests/openlineage_tests/README.md | 16 +-
.../airflow_e2e_tests/openlineage_tests/harness.py | 7 +-
.../openlineage_tests/prepare_dags.py | 3 +
.../openlineage_tests/task_logs.py | 59 +-
.../ts_sdk_tests/test_ts_sdk_dynamic_dag.py | 89 +
.../airflow_e2e_tests/yaml_dag_tests}/__init__.py | 0
.../yaml_dag_tests/test_yaml_dag.py | 204 +
airflow-e2e-tests/yaml-dags/yaml_s3_roundtrip.yaml | 88 +
chart/dockerfiles/pgbouncer-exporter/Dockerfile | 9 +-
.../pgbouncer-exporter/build_and_push.sh | 8 +-
chart/dockerfiles/pgbouncer/Dockerfile | 8 +-
chart/dockerfiles/pgbouncer/build_and_push.sh | 8 +-
chart/newsfragments/74647.significant.rst | 19 +
.../airflow_aux/test_pod_template_file.py | 8 -
chart/tests/helm_tests/airflow_core/test_worker.py | 10 -
chart/values.schema.json | 4 +-
chart/values.yaml | 4 +-
contributing-docs/03_contributors_quick_start.rst | 13 +
.../03a_contributors_quick_start_beginners.rst | 5 +
contributing-docs/05_pull_requests.rst | 59 +-
contributing-docs/08_static_code_checks.rst | 6 +
contributing-docs/10_working_with_git.rst | 3 +
contributing-docs/11_documentation_building.rst | 11 +
contributing-docs/18_contribution_workflow.rst | 78 +-
contributing-docs/25_maintainer_pr_triage.md | 39 +
contributing-docs/mprocs/mprocs.yaml | 14 +-
contributing-docs/testing/unit_tests.rst | 7 +
dev/AGENTS.md | 17 +
...UALLY_GENERATING_IMAGE_CACHE_AND_CONSTRAINTS.md | 6 +
dev/README_AIRFLOW3_DEV.md | 47 +
dev/README_RELEASE_AIRFLOW.md | 109 +-
dev/breeze/doc/05_test_commands.rst | 2 +-
dev/breeze/doc/08_ci_tasks.rst | 63 +
dev/breeze/doc/09_release_management_tasks.rst | 62 +-
...0-run-ci-for-external-contributions-in-forks.md | 173 +
dev/breeze/doc/ci/02_images.md | 2 +-
dev/breeze/doc/ci/04_selective_checks.md | 279 +-
dev/breeze/doc/ci/05_workflows.md | 182 +
dev/breeze/doc/ci/06_debugging.md | 6 +-
.../doc/ci/08_fork_ci_for_external_contributors.md | 1172 ++++++
dev/breeze/doc/ci/README.md | 1 +
dev/breeze/doc/images/output_build-docs.svg | 52 +-
dev/breeze/doc/images/output_build-docs.txt | 2 +-
dev/breeze/doc/images/output_ci.svg | 46 +-
dev/breeze/doc/images/output_ci.txt | 2 +-
.../doc/images/output_ci_approve-workflow-runs.svg | 150 +
.../doc/images/output_ci_approve-workflow-runs.txt | 1 +
dev/breeze/doc/images/output_ci_audit.svg | 116 +
dev/breeze/doc/images/output_ci_audit.txt | 1 +
.../doc/images/output_ci_fork-ci-reconcile.svg | 148 +
.../doc/images/output_ci_fork-ci-reconcile.txt | 1 +
dev/breeze/doc/images/output_ci_upgrade.svg | 114 +-
dev/breeze/doc/images/output_ci_upgrade.txt | 2 +-
.../doc/images/output_k8s_build-k8s-image.svg | 48 +-
.../doc/images/output_k8s_build-k8s-image.txt | 2 +-
.../doc/images/output_k8s_deploy-airflow.svg | 46 +-
.../doc/images/output_k8s_deploy-airflow.txt | 2 +-
.../doc/images/output_k8s_deploy-cluster.svg | 30 +-
.../doc/images/output_k8s_deploy-cluster.txt | 2 +-
dev/breeze/doc/images/output_k8s_dev.svg | 22 +-
dev/breeze/doc/images/output_k8s_dev.txt | 2 +-
.../doc/images/output_k8s_run-complete-tests.svg | 84 +-
.../doc/images/output_k8s_run-complete-tests.txt | 2 +-
.../doc/images/output_k8s_setup-lang-sdk-test.svg | 22 +-
.../doc/images/output_k8s_setup-lang-sdk-test.txt | 2 +-
.../doc/images/output_k8s_upload-k8s-image.svg | 46 +-
.../doc/images/output_k8s_upload-k8s-image.txt | 2 +-
...put_release-management_generate-constraints.svg | 78 +-
...put_release-management_generate-constraints.txt | 2 +-
...utput_release-management_publish-docs-to-s3.svg | 64 +-
...utput_release-management_publish-docs-to-s3.txt | 2 +-
.../output_setup_check-all-params-in-groups.svg | 100 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 104 +-
.../output_setup_regenerate-command-images.txt | 2 +-
.../images/output_testing_airflow-e2e-tests.svg | 2 +-
.../images/output_testing_airflow-e2e-tests.txt | 2 +-
dev/breeze/doc/images/output_workflow-run.svg | 34 +-
dev/breeze/doc/images/output_workflow-run.txt | 2 +-
.../output_workflow-run_mirror-base-images.svg | 111 +
.../output_workflow-run_mirror-base-images.txt | 1 +
.../images/output_workflow-run_upgrade-check.svg | 116 +
.../images/output_workflow-run_upgrade-check.txt | 1 +
.../src/airflow_breeze/commands/ci_commands.py | 401 +-
.../airflow_breeze/commands/ci_commands_config.py | 42 +
.../src/airflow_breeze/commands/common_options.py | 7 +
.../airflow_breeze/commands/developer_commands.py | 27 +
.../commands/developer_commands_config.py | 1 +
.../airflow_breeze/commands/kubernetes_commands.py | 182 +-
.../commands/kubernetes_commands_config.py | 11 +-
.../commands/kubernetes_kustomize_commands.py | 2 +-
.../commands/release_management_commands.py | 129 +-
.../commands/release_management_commands_config.py | 3 +
.../airflow_breeze/commands/testing_commands.py | 30 +-
.../src/airflow_breeze/commands/verify_commands.py | 10 +-
.../airflow_breeze/commands/workflow_commands.py | 72 +-
.../commands/workflow_commands_config.py | 24 +-
.../files/hardened_python_image_digests.json | 10 +
.../files/legacy_python_versions.json | 6 +
dev/breeze/src/airflow_breeze/global_constants.py | 102 +-
.../src/airflow_breeze/params/build_prod_params.py | 11 +-
.../src/airflow_breeze/params/shell_params.py | 9 +
dev/breeze/src/airflow_breeze/utils/cdxgen.py | 74 +-
dev/breeze/src/airflow_breeze/utils/ci_audit.py | 391 ++
.../airflow_breeze/utils/ci_minutes_estimate.py | 228 +
.../src/airflow_breeze/utils/fork_ci_gate.py | 347 ++
.../src/airflow_breeze/utils/fork_ci_github.py | 238 ++
.../src/airflow_breeze/utils/fork_ci_messages.py | 342 ++
.../src/airflow_breeze/utils/fork_ci_reconcile.py | 1960 +++++++++
.../src/airflow_breeze/utils/fork_compare.py | 151 +
.../src/airflow_breeze/utils/gh_workflow_utils.py | 42 +
dev/breeze/src/airflow_breeze/utils/git_remotes.py | 79 +
.../src/airflow_breeze/utils/kubernetes_utils.py | 3 +-
dev/breeze/src/airflow_breeze/utils/path_utils.py | 3 +
.../airflow_breeze/utils/publish_docs_helpers.py | 32 -
.../src/airflow_breeze/utils/publish_docs_to_s3.py | 6 +-
dev/breeze/src/airflow_breeze/utils/run_tests.py | 101 +-
.../src/airflow_breeze/utils/selective_checks.py | 533 ++-
.../src/airflow_breeze/utils/verification_plan.py | 3 +
.../airflow_breeze/utils/workflow_run_approval.py | 920 ++++
.../src/airflow_breeze/utils/workflow_status.py | 4 +
dev/breeze/tests/conftest.py | 15 +
dev/breeze/tests/test_build_prod_params.py | 44 +-
.../tests/test_calibrate_ci_minutes_estimates.py | 101 +
dev/breeze/tests/test_cdxgen.py | 73 +
dev/breeze/tests/test_ci_audit.py | 440 ++
dev/breeze/tests/test_ci_commands.py | 52 +
dev/breeze/tests/test_ci_minutes_estimate.py | 229 +
dev/breeze/tests/test_ci_upgrade.py | 100 +
dev/breeze/tests/test_developer_commands.py | 96 +-
dev/breeze/tests/test_fork_ci_gate.py | 430 ++
dev/breeze/tests/test_fork_ci_github.py | 236 ++
dev/breeze/tests/test_fork_ci_messages.py | 174 +
dev/breeze/tests/test_fork_ci_reconcile.py | 2721 ++++++++++++
dev/breeze/tests/test_fork_compare.py | 134 +
dev/breeze/tests/test_gh_workflow_utils.py | 54 +
dev/breeze/tests/test_git_remotes.py | 103 +
dev/breeze/tests/test_kubernetes_commands.py | 144 +
.../tests/test_kubernetes_kustomize_commands.py | 20 +
.../tests/test_kubernetes_lang_sdk_commands.py | 62 +-
dev/breeze/tests/test_kubernetes_utils.py | 7 +
dev/breeze/tests/test_mirror_base_images.py | 142 +-
dev/breeze/tests/test_publish_docs_to_s3.py | 25 +
.../tests/test_pytest_args_for_test_types.py | 65 +-
.../tests/test_release_management_commands.py | 70 +
dev/breeze/tests/test_run_test_args.py | 93 +
dev/breeze/tests/test_selective_checks.py | 1274 +++++-
dev/breeze/tests/test_set_milestone.py | 48 -
dev/breeze/tests/test_shell_params.py | 35 +-
dev/breeze/tests/test_verify_commands.py | 15 +
dev/breeze/tests/test_workflow_commands.py | 57 +
dev/breeze/tests/test_workflow_run_approval.py | 1310 ++++++
.../breeze/tests/test_workflow_status.py | 24 +-
dev/calibrate_ci_minutes_estimates.py | 270 ++
dev/registry/extract_parameters.py | 12 +-
dev/registry/tests/test_extract_parameters.py | 97 +
.../tests/test_registry_contract_models.py | 10 +-
dev/skill-evals/last-eval-hash.txt | 2 +-
.../src/sphinx_exts/docs_build/code_utils.py | 45 -
.../src/tests_common/test_utils/api_fastapi.py | 23 +
docker-stack-docs/build-arg-ref.rst | 26 +-
docker-stack-docs/build.rst | 21 +-
.../customizing/add-build-essential-custom.sh | 3 +-
.../docker-examples/customizing/custom-sources.sh | 3 +-
.../customizing/pypi-dev-runtime-deps.sh | 3 +-
.../customizing/pypi-extras-and-deps.sh | 3 +-
.../customizing/pypi-selected-version.sh | 3 +-
.../restricted/restricted_environments.sh | 3 +-
.../test_examples_of_prod_image_building.py | 2 +
docs/README.md | 4 +-
docs/spelling_wordlist.txt | 4 +
generated/known_airflow_exceptions.txt | 8 +-
generated/provider_metadata.json | 140 +-
go-sdk/DEVELOPMENT.md | 10 +-
go-sdk/README.md | 2 +-
go-sdk/airflow/conformance_test.go | 4 +-
go-sdk/airflow/serialize.go | 9 +-
go-sdk/airflow/serialize_test.go | 3 +-
.../cmd/airflow-go-pack/pack_integration_test.go | 3 +
go-sdk/cmd/airflow-go-pack/sources.go | 2 +-
go-sdk/example/bundle/main.go | 5 +
go-sdk/example/bundle/yamldag/handlers.go | 43 +
go-sdk/internal/bundlefooter/footer.go | 5 +-
go-sdk/pkg/execution/client.go | 7 +-
go-sdk/pkg/execution/client_test.go | 17 +-
go-sdk/pkg/execution/frames.go | 16 +-
go-sdk/pkg/execution/frames_oversized_test.go | 4 +-
go-sdk/pkg/execution/frames_test.go | 14 +
go-sdk/pkg/execution/logger.go | 36 +-
go-sdk/pkg/execution/logger_test.go | 38 +
java-sdk/sdk/build.gradle.kts | 2 +-
.../org/apache/airflow/sdk/execution/Serde.kt | 11 +-
.../org/apache/airflow/sdk/TriggerDagRunTest.kt | 5 +-
kubernetes-tests/lang_sdk/README.md | 18 +-
kubernetes-tests/lang_sdk/config/values.yaml | 9 +-
.../kubernetes_tests/test_lang_sdk_native_dag.py | 110 +-
providers/.last_release_date.txt | 2 +-
providers/amazon/docs/changelog.rst | 6 +
providers/amazon/docs/executors/ecs-executor.rst | 4 +
providers/amazon/docs/executors/eks-executor.rst | 52 +-
providers/amazon/docs/transfer/sql_to_s3.rst | 19 +
providers/amazon/provider.yaml | 9 +
providers/amazon/pyproject.toml | 2 +-
.../amazon/aws/executors/ecs/ecs_executor.py | 230 +-
.../providers/amazon/aws/executors/ecs/utils.py | 3 +
.../amazon/aws/executors/eks/_client_factory.py | 38 +-
.../amazon/aws/executors/eks/eks_executor.py | 106 +-
.../providers/amazon/aws/executors/eks/utils.py | 5 +
.../src/airflow/providers/amazon/aws/hooks/ses.py | 80 +-
.../providers/amazon/aws/operators/batch.py | 5 +-
.../providers/amazon/aws/operators/bedrock.py | 50 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 19 +-
.../airflow/providers/amazon/aws/operators/eks.py | 68 +-
.../airflow/providers/amazon/aws/operators/emr.py | 78 +-
.../airflow/providers/amazon/aws/operators/glue.py | 19 +-
.../providers/amazon/aws/operators/glue_crawler.py | 11 +-
.../amazon/aws/operators/glue_databrew.py | 8 +-
.../amazon/aws/operators/kinesis_analytics.py | 15 +-
.../amazon/aws/operators/lambda_function.py | 7 +-
.../airflow/providers/amazon/aws/operators/mwaa.py | 8 +-
.../providers/amazon/aws/operators/neptune.py | 13 +-
.../amazon/aws/operators/neptune_analytics.py | 43 +-
.../providers/amazon/aws/operators/quicksight.py | 7 +-
.../airflow/providers/amazon/aws/operators/rds.py | 33 +-
.../amazon/aws/operators/redshift_cluster.py | 17 +-
.../providers/amazon/aws/operators/sagemaker.py | 19 +-
.../aws/operators/sagemaker_unified_studio.py | 7 +-
.../operators/sagemaker_unified_studio_notebook.py | 8 +-
.../airflow/providers/amazon/aws/operators/ssm.py | 9 +-
.../providers/amazon/aws/sensors/bedrock.py | 4 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 130 +-
.../airflow/providers/amazon/get_provider_info.py | 7 +
.../src/airflow/providers/amazon/version_compat.py | 2 -
.../tests/system/amazon/aws/example_sql_to_s3.py | 13 +
.../aws/auth_manager/datamodels}/__init__.py | 0
.../aws/auth_manager/datamodels/test_login.py | 46 +
.../tests/unit/amazon/aws/bundles/test_s3.py | 10 -
.../amazon/aws/executors/ecs/test_ecs_executor.py | 265 +-
.../aws/executors/eks/test__client_factory.py | 61 +-
.../amazon/aws/executors/eks/test_eks_executor.py | 330 +-
.../amazon/tests/unit/amazon/aws/hooks/test_ses.py | 66 +-
.../unit/amazon/aws/log/test_s3_task_handler.py | 4 +-
.../tests/unit/amazon/aws/operators/test_batch.py | 10 +-
.../unit/amazon/aws/operators/test_bedrock.py | 52 +-
.../tests/unit/amazon/aws/operators/test_ecs.py | 28 +-
.../tests/unit/amazon/aws/operators/test_eks.py | 111 +-
.../amazon/aws/operators/test_emr_add_steps.py | 51 +-
.../amazon/aws/operators/test_emr_containers.py | 11 +-
.../amazon/aws/operators/test_emr_serverless.py | 58 +-
.../tests/unit/amazon/aws/operators/test_glue.py | 39 +-
.../unit/amazon/aws/operators/test_glue_crawler.py | 27 +-
.../amazon/aws/operators/test_glue_databrew.py | 16 +
.../amazon/aws/operators/test_kinesis_analytics.py | 11 +-
.../amazon/aws/operators/test_lambda_function.py | 10 +-
.../tests/unit/amazon/aws/operators/test_mwaa.py | 11 +-
.../unit/amazon/aws/operators/test_neptune.py | 26 +-
.../amazon/aws/operators/test_neptune_analytics.py | 65 +-
.../unit/amazon/aws/operators/test_quicksight.py | 6 +-
.../tests/unit/amazon/aws/operators/test_rds.py | 57 +-
.../amazon/aws/operators/test_redshift_cluster.py | 47 +-
.../aws/operators/test_sagemaker_endpoint.py | 11 +-
.../aws/operators/test_sagemaker_pipeline.py | 21 +-
.../amazon/aws/operators/test_sagemaker_tuning.py | 11 +-
.../aws/operators/test_sagemaker_unified_studio.py | 9 +-
.../test_sagemaker_unified_studio_notebook.py | 9 +-
.../tests/unit/amazon/aws/operators/test_ssm.py | 6 +-
.../tests/unit/amazon/aws/sensors/test_bedrock.py | 12 +
.../unit/amazon/aws/transfers/test_sql_to_s3.py | 188 +
providers/cncf/kubernetes/docs/changelog.rst | 6 +
.../cncf/kubernetes/docs/kubernetes_executor.rst | 44 +
providers/cncf/kubernetes/provider.yaml | 16 +-
.../providers/cncf/kubernetes/cli/definition.py | 35 +-
.../cncf/kubernetes/cli/kubernetes_command.py | 79 +-
.../kubernetes/executors/kubernetes_executor.py | 39 +-
.../executors/kubernetes_executor_utils.py | 19 +-
.../providers/cncf/kubernetes/get_provider_info.py | 4 +-
.../providers/cncf/kubernetes/kube_client.py | 89 +-
.../providers/cncf/kubernetes/operators/job.py | 19 +-
.../providers/cncf/kubernetes/operators/pod.py | 16 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 6 -
.../cncf/kubernetes/cli/test_kubernetes_command.py | 219 +-
.../executors/test_kubernetes_executor.py | 119 +-
.../unit/cncf/kubernetes/operators/test_job.py | 30 +
.../unit/cncf/kubernetes/operators/test_pod.py | 138 +-
.../kubernetes/sensors/test_spark_kubernetes.py | 78 +-
.../tests/unit/cncf/kubernetes/test_client.py | 79 +
.../tests/unit/cncf/kubernetes/test_kube_client.py | 124 +-
providers/common/ai/README.rst | 55 +-
providers/common/ai/docs/changelog.rst | 91 +
providers/common/ai/docs/connections/mcp.rst | 3 +-
.../common/ai/docs/connections/pydantic_ai.rst | 61 +-
.../ai/docs/connections/pydantic_ai_azure.rst | 13 +-
.../ai/docs/connections/pydantic_ai_vertex.rst | 10 +-
providers/common/ai/docs/examples.rst | 4 +
providers/common/ai/docs/features.rst | 12 +-
.../common/ai/docs/frameworks/claude_agent_sdk.rst | 282 ++
providers/common/ai/docs/frameworks/index.rst | 39 +-
providers/common/ai/docs/hooks/pydantic_ai.rst | 20 +
providers/common/ai/docs/index.rst | 57 +-
providers/common/ai/docs/model_providers.rst | 4 +-
providers/common/ai/docs/observability.rst | 47 +-
providers/common/ai/docs/operators/agent.rst | 15 +-
providers/common/ai/docs/operators/llm.rst | 6 +-
providers/common/ai/docs/operators/llm_batch.rst | 8 +-
providers/common/ai/docs/operators/llm_branch.rst | 10 +-
.../common/ai/docs/operators/llm_file_analysis.rst | 10 +
.../ai/docs/operators/llm_schema_compare.rst | 13 +-
providers/common/ai/docs/operators/llm_sql.rst | 7 +-
providers/common/ai/docs/provider_fallback.rst | 24 +-
providers/common/ai/docs/sandbox/backends.rst | 9 +-
providers/common/ai/docs/sandbox/configuration.rst | 789 ++--
providers/common/ai/docs/sandbox/index.rst | 2 +-
providers/common/ai/docs/self_hosted_models.rst | 29 +-
providers/common/ai/docs/stability.rst | 14 +-
providers/common/ai/docs/structured_output.rst | 48 +-
providers/common/ai/docs/supported_services.rst | 2 +-
providers/common/ai/docs/toolsets/index.rst | 20 +-
providers/common/ai/docs/toolsets/logging.rst | 35 +-
providers/common/ai/docs/troubleshooting.rst | 9 +-
providers/common/ai/docs/use_cases/index.rst | 4 +
.../use_cases/refine_a_draft_within_a_budget.rst | 202 +
providers/common/ai/provider.yaml | 14 +-
providers/common/ai/pyproject.toml | 11 +-
.../src/airflow/providers/common/ai/batch/base.py | 14 +-
.../airflow/providers/common/ai/batch/dispatch.py | 13 +-
.../airflow/providers/common/ai/decorators/llm.py | 11 +-
.../providers/common/ai/decorators/llm_branch.py | 11 +-
.../common/ai/decorators/llm_schema_compare.py | 11 +-
.../providers/common/ai/decorators/llm_sql.py | 11 +-
.../ai/example_dags/example_agent_loop_budget.py | 141 +
.../ai/example_dags/example_claude_agent_sdk.py | 90 +
.../ai/example_dags/example_llm_retry_policy.py | 7 +-
.../providers/common/ai/get_provider_info.py | 10 +-
.../airflow/providers/common/ai/hooks/langchain.py | 29 +-
.../providers/common/ai/hooks/llamaindex.py | 46 +-
.../src/airflow/providers/common/ai/hooks/mcp.py | 55 +-
.../providers/common/ai/hooks/pydantic_ai.py | 267 +-
.../airflow/providers/common/ai/mixins/approval.py | 20 +-
.../airflow/providers/common/ai/operators/agent.py | 63 +-
.../airflow/providers/common/ai/operators/llm.py | 107 +-
.../providers/common/ai/operators/llm_batch.py | 31 +-
.../providers/common/ai/operators/llm_branch.py | 3 +-
.../common/ai/operators/llm_schema_compare.py | 7 +-
.../providers/common/ai/operators/llm_sql.py | 4 +
.../providers/common/ai/plugins/_plugin_urls.py | 13 +-
.../providers/common/ai/plugins/model_panel.py | 14 +-
.../providers/common/ai/plugins/www/package.json | 1 +
.../providers/common/ai/plugins/www/pnpm-lock.yaml | 131 +-
.../providers/common/ai/plugins/www/src/api.ts | 7 +-
.../ai/plugins/www/src/components/ChatPage.tsx | 2 +-
.../ai/plugins/www/src/components/ModelPanel.tsx | 24 +-
.../ai/plugins/www/src/hooks/useModelInfo.ts | 44 +-
.../common/ai/plugins/www/src/hooks/useSession.ts | 3 +-
.../providers/common/ai/plugins/www/src/main.tsx | 9 +-
.../common/ai/plugins/www/src/model-api.ts | 17 +-
.../providers/common/ai/plugins/www/src/model.tsx | 42 +-
.../providers/common/ai/plugins/www/src/region.ts | 49 +
.../common/ai/plugins/www/tests/main.test.mjs | 2 +-
.../common/ai/plugins/www/tests/model-api.test.ts | 68 +
.../common/ai/plugins/www/tests/model.test.mjs | 121 +
.../common/ai/plugins/www/tests/region.test.ts | 45 +
.../airflow/providers/common/ai/policies/retry.py | 5 +-
.../airflow/providers/common/ai/tools/__init__.py | 5 +-
.../providers/common/ai/tools/claude_agent_sdk.py | 369 ++
.../providers/common/ai/toolsets/__init__.py | 2 -
.../providers/common/ai/toolsets/logging.py | 19 +-
.../airflow/providers/common/ai/utils/prompt.py | 65 +
.../providers/common/ai/utils/tool_metrics.py | 4 +-
.../ai/tests/unit/common/ai/batch/test_base.py | 8 +
.../ai/tests/unit/common/ai/batch/test_dispatch.py | 4 +
.../common/ai/tests/unit/common/ai/conftest.py | 57 +
.../ai/tests/unit/common/ai/decorators/test_llm.py | 93 +-
.../unit/common/ai/decorators/test_llm_branch.py | 34 +-
.../common/ai/decorators/test_llm_file_analysis.py | 8 +-
.../ai/decorators/test_llm_schema_compare.py | 26 +-
.../unit/common/ai/decorators/test_llm_sql.py | 30 +-
.../tests/unit/common/ai/hooks/test_langchain.py | 74 +
.../tests/unit/common/ai/hooks/test_llamaindex.py | 84 +
.../ai/tests/unit/common/ai/hooks/test_mcp.py | 128 +
.../tests/unit/common/ai/hooks/test_pydantic_ai.py | 567 ++-
.../tests/unit/common/ai/mixins/test_approval.py | 26 +-
.../tests/unit/common/ai/operators/test_agent.py | 295 +-
.../ai/tests/unit/common/ai/operators/test_llm.py | 100 +-
.../unit/common/ai/operators/test_llm_batch.py | 80 +
.../unit/common/ai/operators/test_llm_branch.py | 100 +-
.../common/ai/operators/test_llm_file_analysis.py | 42 +-
.../common/ai/operators/test_llm_schema_compare.py | 62 +-
.../tests/unit/common/ai/operators/test_llm_sql.py | 44 +-
.../unit/common/ai/plugins/test__plugin_urls.py | 22 +-
.../unit/common/ai/plugins/test_model_panel.py | 34 +-
.../ai/tests/unit/common/ai/policies/test_retry.py | 65 +-
.../tests/unit/common/ai/sandbox/test_openshell.py | 9 +-
.../tests/unit/common/ai/test_provider_metadata.py | 38 +-
.../unit/common/ai/tools/test_claude_agent_sdk.py | 1060 +++++
.../tests/unit/common/ai/toolsets/test_logging.py | 6 +-
.../ai/tests/unit/common/ai/utils/test_prompt.py | 92 +
.../common/compat/_resumable_job_mixin.py | 10 +-
.../common/compat/openlineage/utils/sql.py | 29 +-
.../common/compat/openlineage/utils/test_sql.py | 60 +
.../common/compat/test__resumable_job_mixin.py | 5 +-
.../airflow/providers/common/sql/operators/sql.py | 55 +-
.../unit/common/sql/operators/test_sql_execute.py | 89 +
.../tests/unit/databricks/hooks/test_databricks.py | 19 -
.../unit/databricks/hooks/test_databricks_base.py | 4 -
.../tests/unit/databricks/utils/test_mixins.py | 10 -
.../tests/unit/dbt/cloud/utils/test_openlineage.py | 4 +-
.../edge3/tests/unit/edge3/worker_api/test_app.py | 5 +-
providers/fab/docs/auth-manager/access-control.rst | 8 +
.../fab/auth_manager/security_manager/override.py | 7 +-
.../providers/fab/auth_manager/views/auth_login.py | 67 +
.../providers/fab/auth_manager/views/auth_oauth.py | 9 +
.../fab/src/airflow/providers/fab/www/package.json | 4 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 850 ++--
.../api_fastapi/datamodels/test_login.py | 45 +
.../unit/fab/auth_manager/views/test_auth_login.py | 146 +
providers/fab/tests/unit/fab/utils.py | 109 -
.../tests/unit/fab/www/views/test_views_login.py | 90 +
providers/google/README.rst | 2 +-
providers/google/docs/index.rst | 2 +-
providers/google/docs/operators/cloud/dataproc.rst | 51 +
.../operators/marketing_platform/bid_manager.rst | 76 +-
providers/google/pyproject.toml | 2 +-
.../providers/google/cloud/hooks/cloud_sql.py | 4 -
.../providers/google/cloud/hooks/dataflow.py | 49 -
.../google/cloud/log/cloud_logging_task_handler.py | 18 +-
.../providers/google/cloud/operators/bigquery.py | 41 +-
.../providers/google/cloud/operators/cloud_sql.py | 4 -
.../providers/google/cloud/operators/dataproc.py | 6 -
.../google/cloud/transfers/bigquery_to_bigquery.py | 22 +-
.../google/marketing_platform/hooks/bid_manager.py | 21 +-
.../marketing_platform/operators/bid_manager.py | 237 +-
.../marketing_platform/sensors/bid_manager.py | 6 +-
.../example_dataproc_cluster_high_obtainability.py | 162 +
.../marketing_platform/example_bid_manager.py | 37 +-
.../cloud/log/test_cloud_logging_task_handler.py | 30 +-
.../unit/google/cloud/log/test_gcs_task_handler.py | 4 +-
.../unit/google/cloud/openlineage/test_mixins.py | 3 +-
.../unit/google/cloud/operators/test_bigquery.py | 311 +-
.../unit/google/cloud/operators/test_dataproc.py | 36 +-
.../cloud/transfers/test_bigquery_to_bigquery.py | 42 +
.../google/cloud/transfers/test_calendar_to_gcs.py | 54 -
.../unit/google/cloud/transfers/test_gcs_to_gcs.py | 18 -
.../tests/unit/google/cloud/utils/test_bigquery.py | 58 +
.../google/cloud/utils/test_bigquery_get_data.py | 77 +
.../marketing_platform/hooks/test_bid_manager.py | 37 +-
.../operators/test_bid_manager.py | 135 +-
.../marketing_platform/sensors/test_bid_manager.py | 23 +-
providers/http/tests/unit/http/hooks/test_http.py | 4 -
.../keycloak/auth_manager/routes/login.py | 13 +-
.../keycloak/auth_manager/services/token.py | 2 +-
.../keycloak/auth_manager/routes/test_login.py | 34 +
.../keycloak/auth_manager/services/test_token.py | 25 +
.../auth_manager/test_keycloak_auth_manager.py | 23 -
providers/microsoft/azure/docs/changelog.rst | 20 +-
.../microsoft/azure/docs/operators/msgraph.rst | 5 +-
.../microsoft/azure/docs/operators/powerbi.rst | 14 +-
providers/microsoft/azure/provider.yaml | 2 +-
.../providers/microsoft/azure/exceptions.py | 9 +
.../providers/microsoft/azure/hooks/powerbi.py | 58 +-
.../providers/microsoft/azure/operators/msgraph.py | 124 +-
.../providers/microsoft/azure/operators/powerbi.py | 70 +-
.../providers/microsoft/azure/sensors/msgraph.py | 44 +-
.../providers/microsoft/azure/version_compat.py | 2 +
.../unit/microsoft/azure/hooks/test_powerbi.py | 191 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 2 +-
.../unit/microsoft/azure/operators/test_msgraph.py | 145 +-
.../unit/microsoft/azure/operators/test_powerbi.py | 182 +-
.../azure/resources/powerbi_completed_refresh.json | 122 +
.../azure/resources/powerbi_completed_refresh.md | 36 +
.../unit/microsoft/azure/sensors/test_msgraph.py | 161 +-
.../unit/microsoft/azure/triggers/test_powerbi.py | 94 +
providers/mysql/README.rst | 2 +
providers/mysql/docs/changelog.rst | 11 +
providers/mysql/docs/index.rst | 4 +-
providers/mysql/pyproject.toml | 8 +-
providers/openlineage/docs/changelog.rst | 24 +
providers/openlineage/docs/emission_policy.rst | 154 +-
providers/openlineage/docs/macros.rst | 32 +
providers/openlineage/provider.yaml | 2 +-
.../airflow/providers/openlineage/api/datasets.py | 11 +
.../providers/openlineage/api/emission_policy.py | 27 +-
.../src/airflow/providers/openlineage/api/sql.py | 4 +-
.../providers/openlineage/extractors/manager.py | 69 +-
.../openlineage/facets/AirflowJobFacet.json | 56 +-
.../openlineage/facets/AirflowRunFacet.json | 112 +
.../providers/openlineage/plugins/adapter.py | 5 +-
.../providers/openlineage/plugins/listener.py | 91 +-
.../providers/openlineage/plugins/macros.py | 50 +-
.../providers/openlineage/plugins/openlineage.py | 4 +
.../src/airflow/providers/openlineage/sqlparser.py | 45 +-
.../providers/openlineage/utils/emission_policy.py | 316 +-
.../openlineage/utils/sql_hook_lineage.py | 41 +-
.../airflow/providers/openlineage/utils/utils.py | 518 ++-
.../providers/openlineage/version_compat.py | 9 +-
.../example_openlineage_base_complex_dag.py | 2 +
.../example_openlineage_defer_simple_dag.py | 2 +
...le_openlineage_policy_authoring_controls_dag.py | 140 +
...example_openlineage_policy_conf_controls_dag.py | 200 +
..._openlineage_policy_conf_locked_controls_dag.py | 156 +
.../example_openlineage_policy_conf_locked_dag.py | 2 +-
...mple_openlineage_policy_conf_source_code_dag.py | 2 +-
...xample_openlineage_policy_dag_emit_false_dag.py | 2 +-
...mple_openlineage_policy_dag_events_false_dag.py | 4 +-
...le_openlineage_policy_dag_events_trigger_dag.py | 123 +
...ple_openlineage_policy_dag_override_task_dag.py | 2 +-
...ineage_policy_exclude_datasets_authoring_dag.py | 285 ++
...openlineage_policy_exclude_datasets_conf_dag.py | 246 ++
...enlineage_policy_exclude_datasets_global_dag.py | 224 +
...nlineage_policy_exclude_datasets_sources_dag.py | 342 ++
...ineage_policy_exclude_datasets_versioned_dag.py | 125 +
...mple_openlineage_policy_extract_metadata_dag.py | 2 +-
...xample_openlineage_policy_full_task_info_dag.py | 2 +-
.../example_openlineage_policy_hook_lineage_dag.py | 2 +-
.../example_openlineage_policy_source_code_dag.py | 2 +-
...ample_openlineage_policy_task_emit_false_dag.py | 7 +-
...ups_dag.py => example_openlineage_retry_dag.py} | 31 +-
...> example_openlineage_sensor_reschedule_dag.py} | 18 +-
.../example_openlineage_task_groups_dag.py | 2 +-
.../example_openlineage_task_loop_dag.py | 152 +
.../example_openlineage_task_loop_groups_dag.py | 104 +
...g.py => example_openlineage_task_states_dag.py} | 41 +-
.../openlineage/example_openlineage_trigger_dag.py | 8 +-
.../example_openlineage_trigger_dag_deferrable.py | 2 +-
.../system/openlineage/expected_events/__init__.py | 26 +-
.../openlineage_base_complex_dag__af2.json | 77 +-
.../openlineage_base_complex_dag__af3.json | 84 +-
.../openlineage_base_simple_dag__af2.json | 36 +-
.../openlineage_base_simple_dag__af3.json | 36 +-
.../openlineage_custom_operator_failure_dag.json | 5 +-
...json => openlineage_defer_simple_dag__af2.json} | 10 +-
...json => openlineage_defer_simple_dag__af3.json} | 10 +-
...penlineage_defer_simple_dag__af3_2_2_plus.json} | 10 +-
.../openlineage_manual_lineage_dag.json | 388 +-
.../openlineage_policy_authoring_controls_dag.json | 455 ++
.../openlineage_policy_conf_controls_dag.json | 759 ++++
...penlineage_policy_conf_locked_controls_dag.json | 308 ++
.../openlineage_policy_dag_events_trigger_dag.json | 487 +++
...eage_policy_exclude_datasets_authoring_dag.json | 494 +++
...enlineage_policy_exclude_datasets_conf_dag.json | 614 +++
...lineage_policy_exclude_datasets_global_dag.json | 410 ++
...ineage_policy_exclude_datasets_sources_dag.json | 765 ++++
...eage_policy_exclude_datasets_versioned_dag.json | 172 +
...exclude_datasets_versioned_dag__af3_1_plus.json | 201 +
...exclude_datasets_versioned_dag__af3_2_plus.json | 201 +
.../openlineage_policy_hook_lineage_dag.json | 52 +
.../openlineage_policy_task_emit_false_dag.json | 17 +-
.../expected_events/openlineage_retry_dag.json | 239 ++
.../openlineage_retry_dag__af2.json | 239 ++
.../openlineage_retry_dag__af3_0.json | 239 ++
.../openlineage_sensor_reschedule_dag.json | 127 +
.../openlineage_sensor_reschedule_dag__af2.json | 127 +
.../openlineage_sensor_reschedule_dag__af3_0.json | 127 +
.../openlineage_task_groups_dag.json | 4 +
.../expected_events/openlineage_task_loop_dag.json | 4406 ++++++++++++++++++++
.../openlineage_task_loop_groups_dag.json | 2237 ++++++++++
.../openlineage_task_states_dag.json | 262 ++
.../openlineage_task_states_dag__af3_0.json | 161 +
.../expected_events/openlineage_trigger_dag.json | 132 +-
.../openlineage_trigger_dag__af3_3_plus.json | 132 +-
.../openlineage_trigger_dag_deferrable.json | 228 +-
...lineage_trigger_dag_deferrable__af3_3_plus.json | 228 +-
.../openlineage_trigger_failed_dag.json | 54 +-
...openlineage_trigger_failed_dag__af3_3_plus.json | 54 +-
.../tests/system/openlineage/operator.py | 311 +-
.../tests/unit/openlineage/api/test_datasets.py | 28 +
.../unit/openlineage/api/test_emission_policy.py | 29 +
.../tests/unit/openlineage/api/test_sql.py | 25 +-
.../unit/openlineage/extractors/test_manager.py | 167 +-
.../unit/openlineage/plugins/test_listener.py | 333 +-
.../tests/unit/openlineage/plugins/test_macros.py | 85 +
.../tests/unit/openlineage/plugins/test_utils.py | 48 +-
.../tests/unit/openlineage/test_sqlparser.py | 53 +-
.../test_system_tests_run_id_integrity.py | 373 ++
.../unit/openlineage/utils/test_emission_policy.py | 260 ++
.../openlineage/utils/test_sql_hook_lineage.py | 158 +
.../tests/unit/openlineage/utils/test_utils.py | 1309 +++++-
.../airflow/providers/postgres/hooks/postgres.py | 6 -
.../airflow/providers/sendgrid/utils/emailer.py | 23 +-
.../tests/unit/sendgrid/utils/test_emailer.py | 35 +-
.../sftp/tests/unit/sftp/sensors/test_sftp.py | 13 -
providers/smtp/README.rst | 2 +-
providers/smtp/docs/index.rst | 2 +-
providers/smtp/pyproject.toml | 2 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 6 +-
providers/smtp/tests/unit/smtp/hooks/test_smtp.py | 31 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 5 +-
.../unit/snowflake/hooks/test_cortex_model.py | 18 +-
.../providers/standard/utils/openlineage.py | 24 +-
.../tests/unit/standard/utils/test_openlineage.py | 153 +-
.../teradata/operators/teradata_compute_cluster.py | 16 -
.../triggers/test_teradata_compute_cluster.py | 21 -
registry/package.json | 2 +-
registry/pnpm-lock.yaml | 10 +-
scripts/ci/analyze_e2e_flaky_tests.py | 19 +-
scripts/ci/configure_runner_for_parallel_tests.sh | 46 +
.../docker-compose/mount-sphinx-airflow-theme.yml | 25 +-
.../check_go_sdk.py} | 2 +-
.../ci/lang_sdk_serialization/check_java_sdk.py | 4 +-
.../ci/lang_sdk_serialization/check_ts_sdk.py | 7 +-
scripts/ci/lang_sdk_serialization/compare.py | 4 +-
scripts/ci/make_mnt_writeable.sh | 21 +-
scripts/ci/move_docker_to_mnt.sh | 7 +-
scripts/ci/prek/AGENTS.md | 30 +-
.../ci/prek/check_airflowctl_command_coverage.py | 24 +-
scripts/ci/prek/check_ci_gate_needs.py | 85 +
scripts/ci/prek/check_ci_workflows_in_sync.py | 175 +-
scripts/ci/prek/check_fork_ci_gate_config.py | 149 +
scripts/ci/prek/check_init_decorator_arguments.py | 15 -
scripts/ci/prek/check_prek_parallel_hooks.py | 97 +
scripts/ci/prek/newsfragments.py | 69 +
...un_mypy_full_dist_local_venv_or_breeze_in_ci.py | 4 +-
scripts/ci/prek/upgrade_important_versions.py | 141 +-
scripts/ci/spot_interruptions.py | 431 ++
scripts/docker/entrypoint_ci.sh | 2 +
scripts/docker/install_os_dependencies.sh | 62 +-
scripts/docker/install_postgres.sh | 6 +
scripts/in_container/bin/generate_mprocs_config.py | 18 +-
scripts/in_container/in_container_utils.py | 18 +-
scripts/in_container/run_docs_build.sh | 6 +
scripts/in_container/run_generate_constraints.py | 129 +-
.../in_container/run_provider_yaml_files_check.py | 2 +-
.../test_check_go_sdk.py} | 4 +-
scripts/tests/ci/prek/test_check_ci_gate_needs.py | 83 +
.../ci/prek/test_check_fork_ci_gate_config.py | 115 +
.../ci/prek/test_check_prek_parallel_hooks.py | 75 +
scripts/tests/ci/prek/test_newsfragments.py | 128 +-
.../ci/prek/test_upgrade_important_versions.py | 153 +
scripts/tests/ci/test_analyze_e2e_flaky_tests.py | 16 +
scripts/tests/ci/test_prek_cache_optimizations.py | 38 +-
scripts/tests/ci/test_spot_interruptions.py | 479 +++
.../in_container/test_generate_mprocs_config.py | 30 +
.../in_container/test_run_generate_constraints.py | 167 +-
.../observability/metrics/metrics_template.yaml | 94 +-
shared/observability/tests/conftest.py | 11 +
.../observability/metrics/test_otel_logger.py | 9 +
.../providers_discovery/providers_discovery.py | 72 +-
task-sdk/pyproject.toml | 2 +-
task-sdk/src/airflow/sdk/__init__.py | 227 +-
task-sdk/src/airflow/sdk/api/client.py | 10 +-
.../src/airflow/sdk/bases/resumablejobmixin.py | 7 +-
.../src/airflow/sdk/coordinators/_subprocess.py | 332 +-
.../sdk/execution_time/callback_supervisor.py | 50 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 77 +-
.../src/airflow/sdk/execution_time/coordinator.py | 14 +-
.../src/airflow/sdk/execution_time/supervisor.py | 60 +-
.../src/airflow/sdk/execution_time/task_runner.py | 12 +-
.../src/airflow/sdk/importers/python_importer.py | 8 +-
task-sdk/src/airflow/sdk/log.py | 6 +-
.../src/airflow/sdk/serde/serializers/timezone.py | 8 +-
task-sdk/tests/task_sdk/api/test_client.py | 29 +
.../tests/task_sdk/bases/test_resumablejobmixin.py | 47 +-
.../tests/task_sdk/coordinators/test_subprocess.py | 485 ++-
.../task_sdk/definitions/test_asset_decorators.py | 7 -
task-sdk/tests/task_sdk/docs/test_public_api.py | 26 +-
.../execution_time/test_callback_supervisor.py | 66 +
.../tests/task_sdk/execution_time/test_context.py | 165 +-
.../task_sdk/execution_time/test_task_runner.py | 16 +-
.../task_sdk/importers/test_python_importer.py | 37 +
task-sdk/tests/task_sdk/serde/test_serializers.py | 17 +-
task-sdk/tests/task_sdk/test_log.py | 20 +
ts-sdk/.pre-commit-config.yaml | 16 -
ts-sdk/example/package.json | 1 +
ts-sdk/example/src/dynamic.ts | 51 +
ts-sdk/example/src/main.ts | 8 +-
ts-sdk/pnpm-lock.yaml | 137 +-
ts-sdk/src/cli/pack.ts | 6 +
ts-sdk/src/coordinator/log-channel.ts | 94 +-
ts-sdk/src/coordinator/serde.ts | 8 +-
ts-sdk/src/sdk/dag.ts | 9 +
ts-sdk/tests/cli/pack.test.ts | 31 +
ts-sdk/tests/conformance/serialize_typescript.ts | 2 +-
ts-sdk/tests/coordinator/log-channel.test.ts | 173 +
ts-sdk/tests/sdk/dag.test.ts | 14 +
uv.lock | 127 +-
1105 files changed, 74514 insertions(+), 10252 deletions(-)
create mode 100644 .github/AGENTS.md
copy .github/{workflows/scheduled-upgrade-check-v3-4-test.yml =>
actions/runs-on-cost-summary/action.yml} (53%)
create mode 100644 .github/actions/stash-restore/action.yml
create mode 100644 .github/actions/stash-save/action.yml
create mode 100644 .github/fork-ci-gate.toml
create mode 100644 .github/workflows/auto-approve-workflow-runs.yml
create mode 100644 .github/workflows/cancel-merged-pr-runs.yml
delete mode 100644 .github/workflows/check-newsfragment-pr-number.yml
create mode 100644 .github/workflows/fork-ci-monitor.yml
create mode 100644 .github/workflows/mark-workflow-runs-approved.yml
create mode 100644 .github/workflows/spot-interruption-notice.yml
create mode 100644 airflow-core/newsfragments/75218.significant.rst
create mode 100644 airflow-core/newsfragments/75414.significant.rst
create mode 100644 airflow-core/newsfragments/75493.bugfix.rst
copy airflow-core/src/airflow/{callbacks/database_callback_sink.py =>
api_fastapi/common/telemetry.py} (55%)
copy airflow-core/src/airflow/api_fastapi/core_api/datamodels/{providers.py =>
auth.py} (72%)
create mode 100644
airflow-core/src/airflow/migrations/versions/0149_3_4_0_add_is_stub_to_task_instance.py
rename
airflow-core/src/airflow/migrations/versions/{0149_3_5_0_add_session_id_to_job.py
=> 0150_3_5_0_add_session_id_to_job.py} (97%)
copy airflow-core/src/airflow/{callbacks/database_callback_sink.py =>
migrations/versions/0151_3_5_0_add_dag_run_dag_id_run_after_index.py} (52%)
copy
airflow-core/src/airflow/ui/src/{pages/GroupTaskInstance/LoopIterations/loopUtils.ts
=>
components/Clear/TaskInstance/ClearTaskInstanceDialog.emptySelection.test.tsx}
(51%)
delete mode 100644
airflow-core/src/airflow/ui/src/components/DagDeactivatedChip.test.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/components/DagDeactivatedChip.tsx
copy airflow-core/src/airflow/ui/src/components/{DagImportErrorModal.tsx =>
DagImportErrorDetails.tsx} (80%)
create mode 100644
airflow-core/src/airflow/ui/src/components/DagStatusChip.test.tsx
create mode 100644 airflow-core/src/airflow/ui/src/components/DagStatusChip.tsx
create mode 100644
airflow-core/src/airflow/ui/src/components/DataTable/useRowSelection.test.tsx
delete mode 100644
airflow-core/src/airflow/ui/src/components/QuickFilterButton.tsx
create mode 100644 airflow-core/src/airflow/ui/src/components/StatusMessage.tsx
create mode 100644
airflow-core/src/airflow/ui/src/context/gridSelection/Context.ts
copy airflow-core/src/airflow/ui/src/{components/WarningAlert.tsx =>
context/gridSelection/GridSelectionProvider.tsx} (60%)
rename airflow-core/src/airflow/ui/src/{utils/filterUtils.ts =>
context/gridSelection/index.ts} (72%)
create mode 100644
airflow-core/src/airflow/ui/src/context/timezone/TimezoneProvider.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/hooks/useRequiredActionTabs.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Details/Grid/GridSelectionActionBar.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Details/Grid/GridSelectionActionBar.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Details/Grid/useGridSelectedTaskInstances.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Details/Grid/useGridSelectedTaskInstances.ts
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Details/Grid/useGridSelection.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Details/Grid/useGridSelection.ts
create mode 100644
airflow-core/src/airflow/ui/src/layouts/Nav/BrowseButton.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/DagsList/RecentRuns.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/GroupTaskInstance/LoopIterations/LoopIterations.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/GroupTaskInstance/LoopIterations/LoopIterations.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Variables/ImportVariablesForm.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/queries/useDeleteDagRun.test.tsx
rename airflow-core/src/airflow/ui/src/{components/DAGWarningsModal.test.tsx
=> queries/useHasMultipleDagBundles.ts} (64%)
create mode 100644 airflow-core/src/airflow/ui/src/utils/dagStatus.test.ts
create mode 100644 airflow-core/src/airflow/ui/src/utils/dagStatus.ts
delete mode 100644 airflow-core/src/airflow/ui/src/utils/filterUtils.test.ts
create mode 100644 airflow-core/src/airflow/ui/src/utils/query.test.ts
create mode 100644
airflow-core/tests/unit/api_fastapi/core_api/datamodels/test_providers.py
create mode 100644 airflow-core/tests/unit/models/test_hitl.py
copy airflow-core/src/airflow/callbacks/database_callback_sink.py =>
airflow-ctl/src/airflowctl/ctl/commands/provider_command.py (52%)
create mode 100644
airflow-ctl/tests/airflow_ctl/ctl/commands/test_provider_command.py
copy .github/workflows/scheduled-upgrade-check-v3-4-test.yml =>
airflow-e2e-tests/docker/yaml-dag.yml (54%)
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_dynamic_dag.py
copy {airflow-core/src/airflow/_shared =>
airflow-e2e-tests/tests/airflow_e2e_tests/yaml_dag_tests}/__init__.py (100%)
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/yaml_dag_tests/test_yaml_dag.py
create mode 100644 airflow-e2e-tests/yaml-dags/yaml_s3_roundtrip.yaml
create mode 100644 chart/newsfragments/74647.significant.rst
create mode 100644
dev/breeze/doc/adr/0020-run-ci-for-external-contributions-in-forks.md
create mode 100644 dev/breeze/doc/ci/08_fork_ci_for_external_contributors.md
create mode 100644 dev/breeze/doc/images/output_ci_approve-workflow-runs.svg
create mode 100644 dev/breeze/doc/images/output_ci_approve-workflow-runs.txt
create mode 100644 dev/breeze/doc/images/output_ci_audit.svg
create mode 100644 dev/breeze/doc/images/output_ci_audit.txt
create mode 100644 dev/breeze/doc/images/output_ci_fork-ci-reconcile.svg
create mode 100644 dev/breeze/doc/images/output_ci_fork-ci-reconcile.txt
create mode 100644
dev/breeze/doc/images/output_workflow-run_mirror-base-images.svg
create mode 100644
dev/breeze/doc/images/output_workflow-run_mirror-base-images.txt
create mode 100644 dev/breeze/doc/images/output_workflow-run_upgrade-check.svg
create mode 100644 dev/breeze/doc/images/output_workflow-run_upgrade-check.txt
create mode 100644
dev/breeze/src/airflow_breeze/files/hardened_python_image_digests.json
create mode 100644
dev/breeze/src/airflow_breeze/files/legacy_python_versions.json
create mode 100644 dev/breeze/src/airflow_breeze/utils/ci_audit.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/ci_minutes_estimate.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/fork_ci_gate.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/fork_ci_github.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/fork_ci_messages.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/fork_ci_reconcile.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/fork_compare.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/git_remotes.py
create mode 100644 dev/breeze/src/airflow_breeze/utils/workflow_run_approval.py
create mode 100644 dev/breeze/tests/test_calibrate_ci_minutes_estimates.py
create mode 100644 dev/breeze/tests/test_cdxgen.py
create mode 100644 dev/breeze/tests/test_ci_audit.py
create mode 100644 dev/breeze/tests/test_ci_minutes_estimate.py
create mode 100644 dev/breeze/tests/test_fork_ci_gate.py
create mode 100644 dev/breeze/tests/test_fork_ci_github.py
create mode 100644 dev/breeze/tests/test_fork_ci_messages.py
create mode 100644 dev/breeze/tests/test_fork_ci_reconcile.py
create mode 100644 dev/breeze/tests/test_fork_compare.py
create mode 100644 dev/breeze/tests/test_git_remotes.py
create mode 100644 dev/breeze/tests/test_kubernetes_commands.py
create mode 100644 dev/breeze/tests/test_workflow_run_approval.py
copy
airflow-core/src/airflow/api_fastapi/core_api/services/public/providers.py =>
dev/breeze/tests/test_workflow_status.py (57%)
create mode 100644 dev/calibrate_ci_minutes_estimates.py
create mode 100644 go-sdk/example/bundle/yamldag/handlers.go
copy {airflow-core/src/airflow/_shared =>
providers/amazon/tests/unit/amazon/aws/auth_manager/datamodels}/__init__.py
(100%)
create mode 100644
providers/amazon/tests/unit/amazon/aws/auth_manager/datamodels/test_login.py
create mode 100644 providers/common/ai/docs/frameworks/claude_agent_sdk.rst
create mode 100644
providers/common/ai/docs/use_cases/refine_a_draft_within_a_budget.rst
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_agent_loop_budget.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/example_dags/example_claude_agent_sdk.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/src/region.ts
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/tests/model-api.test.ts
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/tests/model.test.mjs
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/plugins/www/tests/region.test.ts
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/tools/claude_agent_sdk.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/prompt.py
create mode 100644
providers/common/ai/tests/unit/common/ai/tools/test_claude_agent_sdk.py
create mode 100644
providers/common/ai/tests/unit/common/ai/utils/test_prompt.py
create mode 100644
providers/fab/src/airflow/providers/fab/auth_manager/views/auth_login.py
create mode 100644
providers/fab/tests/unit/fab/auth_manager/api_fastapi/datamodels/test_login.py
create mode 100644
providers/fab/tests/unit/fab/auth_manager/views/test_auth_login.py
create mode 100644 providers/fab/tests/unit/fab/www/views/test_views_login.py
create mode 100644
providers/google/tests/system/google/cloud/dataproc/example_dataproc_cluster_high_obtainability.py
create mode 100644
providers/google/tests/unit/google/cloud/utils/test_bigquery.py
create mode 100644
providers/google/tests/unit/google/cloud/utils/test_bigquery_get_data.py
create mode 100644
providers/microsoft/azure/tests/unit/microsoft/azure/resources/powerbi_completed_refresh.json
create mode 100644
providers/microsoft/azure/tests/unit/microsoft/azure/resources/powerbi_completed_refresh.md
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_authoring_controls_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_conf_controls_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_conf_locked_controls_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_dag_events_trigger_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_exclude_datasets_authoring_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_exclude_datasets_conf_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_exclude_datasets_global_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_exclude_datasets_sources_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_policy_exclude_datasets_versioned_dag.py
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_task_groups_dag.py
=> example_openlineage_retry_dag.py} (59%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_defer_simple_dag.py
=> example_openlineage_sensor_reschedule_dag.py} (73%)
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_task_loop_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_task_loop_groups_dag.py
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_defer_simple_dag.py
=> example_openlineage_task_states_dag.py} (54%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_defer_simple_dag.json
=> openlineage_defer_simple_dag__af2.json} (58%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_defer_simple_dag.json
=> openlineage_defer_simple_dag__af3.json} (62%)
rename
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_defer_simple_dag.json
=> openlineage_defer_simple_dag__af3_2_2_plus.json} (58%)
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_authoring_controls_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_conf_controls_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_conf_locked_controls_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_dag_events_trigger_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_exclude_datasets_authoring_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_exclude_datasets_conf_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_exclude_datasets_global_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_exclude_datasets_sources_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_exclude_datasets_versioned_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_exclude_datasets_versioned_dag__af3_1_plus.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_policy_exclude_datasets_versioned_dag__af3_2_plus.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_retry_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_retry_dag__af2.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_retry_dag__af3_0.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_sensor_reschedule_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_sensor_reschedule_dag__af2.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_sensor_reschedule_dag__af3_0.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_loop_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_loop_groups_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_states_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_task_states_dag__af3_0.json
create mode 100644
providers/openlineage/tests/unit/openlineage/test_system_tests_run_id_integrity.py
create mode 100755 scripts/ci/configure_runner_for_parallel_tests.sh
rename task-sdk/src/airflow/sdk/api/datamodels/activities.py =>
scripts/ci/docker-compose/mount-sphinx-airflow-theme.yml (68%)
rename scripts/ci/{prek/check_go_sdk_serialization_conformance.py =>
lang_sdk_serialization/check_go_sdk.py} (96%)
rename java-sdk/scripts/ci/prek/check_serialization_conformance.py =>
scripts/ci/lang_sdk_serialization/check_java_sdk.py (94%)
rename ts-sdk/scripts/ci/prek/check_serialization_conformance.py =>
scripts/ci/lang_sdk_serialization/check_ts_sdk.py (92%)
create mode 100755 scripts/ci/prek/check_ci_gate_needs.py
create mode 100755 scripts/ci/prek/check_fork_ci_gate_config.py
create mode 100755 scripts/ci/prek/check_prek_parallel_hooks.py
create mode 100755 scripts/ci/spot_interruptions.py
rename scripts/tests/ci/{prek/test_check_go_sdk_serialization_conformance.py
=> lang_sdk_serialization/test_check_go_sdk.py} (94%)
create mode 100644 scripts/tests/ci/prek/test_check_ci_gate_needs.py
create mode 100644 scripts/tests/ci/prek/test_check_fork_ci_gate_config.py
create mode 100644 scripts/tests/ci/prek/test_check_prek_parallel_hooks.py
create mode 100644 scripts/tests/ci/test_spot_interruptions.py
create mode 100644 ts-sdk/example/src/dynamic.ts
