This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/npm_and_yarn/registry/registry-package-updates-4bcf68a93c
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 412f81498c7 Bump the registry-package-updates group across 1 directory
with 3 updates
add e838a5a9d91 Add `MwaaServerlessStopWorkflowRunOperator` (#66548)
add c6cca1c93fd Add `S3TablesRenameTableOperator` (#66544)
add 4364908da2c Add --error-on-cleanup-failure flag to airflow db clean
(#65239)
add 0a034706ea5 Fix `DatabricksWorkflowTaskGroup` leaking TaskGroupContext
on internal exception (#66582)
add 9c483aeab58 Warn when SimpleAuthManager runs in a production-shaped
deployment (#66563)
add d89af71ebd2 Stop passing `project_id` to the Pinecone client
constructor (#66601)
add 9575fb3bf9b Fix flaky test_celery_integration with deterministic task
registration (#66602)
add 7c50c50923e Fix session cookie serialization when using securecookie
backend (#66565)
add 179a2adb62e Bump the auth-ui-package-updates group across 1 directory
with 2 updates (#66603)
add 828b5454b6f fix: default AIRFLOW_UID to 50000 in airflow-init chown
lines (#66481)
add aef7817750a Bump mistune from 3.2.0 to 3.2.1 (#66615)
add c51127ef435 Fix kubernetes cleanup-pods ignoring --verbose (#65955)
add 34d6f4c33f8 fix/issue-66592: Respecting unwrap_single for
non-deferrable execution (#66596)
add db2c6b18aa1 Add checksum for api-server config in API server
deployment (#66468)
add eab2938f4ef Bump the edge-ui-package-updates group across 1 directory
with 6 updates (#66532)
add 00400a5e5ef Change job/pod role bindings rendering & refactor related
tests (#66626)
add 8a5507625be [main] CI: Upgrade important CI environment (#66600)
add c5da9502deb Create Airflow CLI implementation guide (#66566)
add d5efa6224c7 fix: update dependencies to fix dependabot alarms in
providers.common.ai (#66628)
add 8c882543807 Adjust log message header for expandable sources (#66570)
add 068d6db8e90 Update backport status cherry pick link (#66638)
add 393b74fb935 feat: add code quality rule to flag new usage of
AirflowException (#66640)
add 2c7d77a98e2 Fix triggerer to support memray memory profiling (#65994)
add 7a87418549c Combine noisy serde registration debug logs into one line
(#66298)
add fa55b7cabeb Load USFederalHolidayCalendar lazily to reduce memory
usage when LOAD_EXAMPLES (#66303)
add 1dc7c393c08 fix stmp email callback to use email_conn_id (#65072)
add 8310049a654 Stringify task_instance.id when setting OTEL span
attribute (#66053)
add 76c5131df51 Fix XCom prior-dates lookup for duplicate run_id across
Dags (#65227)
add 03d3a8b41a0 simplify new provider acceptance policy to discussion-only
(#66010)
add e090a12608b capitalization of pycharm fix (#65439)
add 6ba54ae3561 Docs: clarify removal of --subdir argument in Airflow 3
CLI (#66136)
add 7fef6c1b84f Prefer gh auth over GitHub tokens for Breeze (#66255)
add 0f98f88d38e Examples: add measurement correction storyline DAGs
(continuation of #61953) (#66257)
add 45f7f5d9e58 Docs: add review checklist for example DAGs (continuation
of #61786) (#66256)
add dcb19a9103a Add deferrable mode to AzureContainerInstancesOperator
(#62772)
add 61f933354d1 Add how-to for Dag-level retry via on_failure_callback
(#66277)
add eb341bee29c Convert RUNTIME_VARYING_CALLS to frozenset for O(1)
membership lookup (#66306)
add 10d1e6ea1e7 Convert STATES_SENT_DIRECTLY to frozenset for O(1)
membership lookup (#66317)
add 4c96fb6f2ec replace AirflowExceptions with native exceptions in
Snowflake provider (#66279)
add 50a115299d5 Add to list dbt Cloud job runs with support for filtering
by status, ordering, and job_definition_id, and optionally returning only the
most recent run via latest_only. Unit tests have been included. (#66150)
add f3a3d4e4194 Avoid rebuilding callback field list on every
serialization loop (#66343)
add b94f36f2d01 Add tests for ti:self JWT scope enforcement on execution
API (#66071)
add cb23988b8bd Make _parse_raw_log resilient to malformed or non-JSON log
lines by introducing best-effort parsing with a fallback structure. Add unit
tests. (#66383)
add 0f8a64ce38f Fix scheduler healthcheck command in docker-compose.yaml
(#62280)
add e2cf316fc36 Fix race condition in AsyncKubernetesHook corrupting
global kubernetes_asyncio config (#65566)
add 5d1f434f956 Use shared Zulu datetime formatter in remaining FastAPI
tests (#66439)
add 1298b23136e Add CeleryExecutor callback workload routing test (#66435)
add b37d512f0c3 Downgrade logging on parsing json in query and add
condition on json load (#62044)
add 7fa87bc4ec4 Fix Triggerer runner_health_check_threshold log formatting
(#66486)
add 31d4837c5dc Fix /tmp file leak when API server streams large task logs
(#66450)
add f3be42ed42e Fix SparkPipelinesHook for Spark Connect (sc://)
connections (#66498)
add 6977fbf4f7f Strip CR/LF from MySQL URL query values before forwarding
to my.cnf (#66325)
add 0868f751c57 Fix deprecated sentry scope function calls (#66587)
add e0da9b6cde8 Remove stray debug output from asset event registration
(#66434)
add e192f7cdbf2 Fix smtp connection test for noop tuple response (#66406)
add 3e974f09162 Fix AwaitMessageTrigger missing _task_instance attribute
(#66302)
add e6bd1e23bca Remove MLEngine from google provider (#66526)
add 1941d11dde2 Add Razorpay to the list of companies (#62953)
add 26ee5c2fdc1 Add memray_detailed_tracing option for deeper memory
profiling (#65996)
add 1aff9b69343 [main] CI: Upgrade important CI environment (#66631)
add 55fa89fc4fc fix RFC 2047 filename decoding (#65875)
add 4d30db62c4e Clarify HttpOperator response_filter XCom usage (#66597)
add 120c189f15c Validate DAG trigger conf as JSON object or null (#66617)
add f3796805f86 Added statement timeout support in SnowflakeSqlApiHook &
Operator (#63575)
add f38982cf3dd Add system tests for Dataproc trigger on_kill cancel
behavior (#65982)
add 45d241314ec fix: update dependencies to fix dependabot alarms in core
(#66629)
add 0c13e8e169a fix: update dependencies to fix dependabot alarms in
registry (#66630)
add f24c9a51995 Document numbering in contrib docs (#66656)
add c6bdb9171ad SFTP: add async retrieve_file / store_file / mkdir to
SFTPHookAsync and introduce SFTPClientPool (#64465)
add a32eff04a5a docs: add Hinge Health to INTHEWILD.md (#66620)
add 4fc7a532542 Fix Kubernetes worker service account values (#66598)
add 04a058ad80b fix: report duplicate plugin names as import errors
(#66649)
add 19e86725d60 Fix DockerOperator init crash on dict mount entries
(#66553)
add adfecd99f97 Fix flaky databricks token-expiry test by freezing
time_machine (#66660)
add bccbcbf7a15 Fix KubernetesPodTrigger pod terminal state handling
(#66650)
add 022e35d9719 Restore AMD scheduled canary, split README badges, fix
Slack-state collision (#66662)
add 5b30aca9386 Registry: make tomllib fallback version-aware (#66666)
add 167d7cc0310 Add maintainer dashboard, trends, and recommendations to
pr-stats skill (#66464)
add 1abd9594cb6 Surface LogStreamAccumulator temp-file removal failures as
warnings (#66663)
add 409895ad174 Support BaseExecutor.run_workload() for Airflow 3.3 in
Edge Worker (#65847)
add a8d67bd6d9a Bump the github-actions-updates group across 1 directory
with 3 updates (#66535)
add 6073ddb1a33 Fix broken GKEStartPodOperator extra link (#66657)
add fd28c9d3afc Bump eslint (#66529)
add 27a539f9737 Lazy-load Alembic in db_manager imports (#65655)
add 3e819876532 Handle mixed plaintext and RFC 2047 encoded attachment
filenames in ImapHook. Add unit test covering mixed plaintext and encoded
filename decoding. (#66672)
add 0b8c6431949 ci: also build ARM on pushes to release-prep / providers
branches (#66668)
add df0b684ffd7 fix(k8s): pre-load postgresql image to prevent Docker Hub
rate-limit flakes (#66507)
add a6798ab8d83 Fix triggerer file handle leak when remote log upload
fails (#66675)
add 8a70185d680 Bump the typescript group across 1 directory with 5
updates (#65800)
add a1eef777380 Add doc_md to Python and LatestOnly example DAGs (#66670)
add 2c9e759c7a4 Fix SFTPHookAsync test fixture to return async context
managers (#66678)
add 231b3e056b2 Squash unreleased execution API version entries into
2026-06-16 (#66693)
add c92e541208f feat: Add uri sanitizers and asset factories for new
schemes (#66426)
add b2305e1eea6 Add `S3VectorsPutVectorsOperator` (#66545)
add 23f1772772f fix(fab): clean up FK associations before deleting role
(#65375) (#66686)
add 505924feaa4 UI: Fix "Mark state as..." buttons grayed out when
task/DAGRun already in target state (#66198)
add 2bccb39c84e chore: Some nits in asset normalization (#66710)
add ec32cca6547 Fix DAG run trigger to surface errors instead of
swallowing them (#64130)
add cc8f0232759 Update providers metadata 2026-05-11 (#66725)
add 162b199b804 Google: Use Kubernetes models in GKE link tests (#66683)
add dcfa2715632 fix(scheduler): catch StaleDataError in verify_integrity
to prevent scheduler crash (#64503)
add 15d297af194 Bump urllib3 from 2.6.3 to 2.7.0 in /dev/breeze (#66723)
add 7ce44e903cd Revert "Apply AIR201-style replacements (#65197)" (#66712)
add ff53593e698 Document Dataproc limitations in Sovereign Cloud from
Google (#66706)
add a9764afd3fc Docs: add doc_md and task docstrings to measurement
correction example Dags (#66707)
add 84420e02156 Add binding for workers.kubernetes & condition workers SA
(#66730)
add 3c127881959 Add doc_md to branch and short-circuit examples (#66691)
add 502c8b91feb Prek: Prefer gh auth over GitHub token env (#66692)
add b13129fcd20 Fix Alibaba OSS provider: configurable endpoint and task
handler log … (#66479)
add 3ccf468a2ad fix: handle PermissionError in init_log_folder for mounted
filesystems (#63878)
add 74abe586d7f Zendesk: support API & OAuth tokens; unhide extra in
Connection UI (#64591)
add 10494a30b69 Add self-diagnosis guide for Dag version inflation in FAQ
(#66697)
add fc40cfb1dbe Fix TaskFlow context docs example (#66698)
add ef695fa9217 Update health endpoint in security docs (#66701)
add 6d831a85180 Add Chakra UI license to airflow-core (#66703)
add 0cc1b92bd72 Adds async support to SageMakerNotebookJobTrigger (#65571)
add 3db657080f6 Bump urllib3 from 2.6.3 to 2.7.0 (#66719)
add e2486701a1f Restrict owner-link and extra-link href to safe schemes
(http, https, mailto, relative) (#66741)
add 0cf92e38614 Add Auster Nutrição Animal to INTHEWILD.md (#66709)
add 354391bbccc Check sensitive key names before applying recursion-depth
cutoff in secrets masker (#65912)
add a3a2b740c18 Support all bq load job and ext table config options in
GCSToBigQueryOperator (#64505)
add c60edf762aa Skip S3 folder-marker keys in S3ToGCSOperator (#65724)
add 57141585e86 Add BigQuery routine operators and existence sensor
(#65499)
add 60b571b452d Bump the fab-ui-package-updates group across 1 directory
with 2 updates (#66742)
add 0f606e0f1da Add aliases for rebranded Google services (#66344)
add 13ee1f1cfb0 Add `S3VectorsQueryVectorsOperator` (#66724)
add d75c079f0a9 Add `S3TablesPutTableBucketPolicyOperator` (#66720)
add bfec6cfaa16 Add Cloud SQL Auth Proxy IAM authentication (#66510)
add d8865dd4249 Fix log server path extraction to use removeprefix (#66749)
add 944e1311416 Migrate BigQueryInsertJobTrigger to on_kill() for
user-initiated kills (#66704)
add 6425fb72203 Improve error message when publish-docs ref is a branch
not a tag (#66250)
add 07bf075b94f Update provider release doc to direct to security issues
board (#66769)
add 4b1995d5d62 Fix system test bugs: bedrock_guardrail, glue_catalog,
s3_vectors (#66758)
add 25bdaf417b4 [main] Upgrade important CI environment (#66700)
add 0528893ac0e UI: Add hover feedback to Checkbox (#66714)
add 2064a76d46c Fix Edit Connection dialog missing lazyMount causing JSON
editor infinite loading (#65969)
add bd2c948498a Fix ConnectionForm crashing when connection has invalid
extra JSON (#66593)
add 4510a0f630b Install airflowctl into airflow core (#64943)
add 1b1c637a0d1 Re-defer task when Kubernetes pod is not completed (#66705)
add 8900f8b2caa Fix CloudSecretManagerBackend regression with explicit
project_id (#61654)
add ffa426b64d7 airflowctl: make required CLI params positional, keep
optional as --flag (#66768)
add 2956c98ecb6 feat(metrics): wrap executor.heartbeat() in a timer to
localize loop slowdowns (#66808)
add f8baa0a8a05 fix(metrics/otel): bracket IPv6 host literals in exporter
endpoint URL (#66813)
add 19d6c5a0007 Emit dagrun.first_task_start_delay separate from
scheduling_delay (#66807)
add 0dd171f09aa Implement fetchmany support for ElasticsearchSQLCursor
using an internal row buffer. (#66658)
add 562d62e9355 add 'teams sync' cli command (#66418)
add 09ea5bf9b10 Add `MwaaServerlessUpdateWorkflowOperator` (#66833)
add 07873fbc47c UI: Handle Dags state filter overflow on mobile (#66812)
add 692728371f8 Fix dag processor callback cleanup for versioned bundle
files (#66484)
add 43cd2b8c092 UI: Use link styling for Dag tags (#66750)
add c533ba1a6d8 Validate dag run conf in backfill dry-run (#66196)
add 089b2e2c289 UI: Preserve Grid limit and filters when redirecting after
manual Dag trigger (#66717)
add 5b9efa7ae3a UI: Fix relative React plugin bundle URLs in dev mode
(#66618)
add 25ef835185c UI: Preserve proxied URL on login redirect (#66690)
add 4f9174e554f UI: Change queued Dag runs color to grey in Calendar
(#66623)
add 79a7a418178 Pin pyjwt>=2.11.0 in FAB provider and stabilise JWT tests
under PyJWT 2.12 (#66840)
add a2c97daac1f Align Dag capitalization in EventsFilters comments (#66879)
add e94cc4dd96e Task SDK: Add Variable.keys() to list variable keys by
prefix (#66022)
add c0fba188de4 Close German Translation Gaps 2026-05-12 (#66829)
add ba8a36d7e7d feat: add callback support to aws batch executor (#62984)
add da89a6cc4f5 Bump terser-webpack-plugin (#66834)
add 77ee105c602 Fix misleading pod scheduling log message ("Waiting until"
→ "Waiting up to") (#66164)
add 671dd4cb293 Fix external DB manager upgrades with existing tables
(#66674)
add d711e88dc63 Add persist_xcom option to BigQueryInsertJobOperator
(#66760)
add 1bfa1f35760 Add BigQueryStreamingBufferEmptySensor for DML on
streaming tables (#66652)
add ddbe0429f09 Fix provider DB upgrades with existing tables (#66883)
add 82b3c924dce Fix memory leak in LocalExecutor caused by unreleased file
descriptor locks (#65121)
add 41e16d5b0a3 fix(k8s-executor): add latency + status metrics around pod
API calls (#66806)
add bda472db1be Fix deferrable KPO trigger_reentry crash when pod is GC'd
before re-entry (#66716)
add 120dbed3462 Add `host_key_policy` option to `ComputeEngineSSHHook`
(#66746)
add 7e22395c530 Add session param to BaseStateBackend interface to fix
custom backends (#66708)
add 50fa403ed61 Add e2e test suite for Airflow event-driven DAGs with
Apache Kafka (#64833)
add 0cf6462459e AIP-103: Adding periodic task state garbage collection and
retention support (#66463)
add a641d83da9c Improve Post-Task logs to show exception in failure
(#66735)
add 8a76a8926e0 [main] CI: Upgrade important CI environment (#66843)
add 7d615cff9e9 AIP-103: Implement clear_on_success config to wipe task
state on success (#66586)
add 1455f326031 feat: Add standardized SQL check representation for
listeners (#66849)
add 8e51e6867ad Add support for influx3 (#58929)
add e29b44f0a40 Show expected duration based on historical avg in DAG Run
details (#65722)
add a1470a949bc Neutralize path separator in IMAP (#66951)
add 9b1d58aedb2 Allow using fresh interpreter besides fork() in Edge
Worker (#65943)
add c5041604dc2 Allow pasting full datetime strings into date picker
inputs (#66251)
add f575da4a80d Fix KafkaError.name() called as property instead of method
in create_topic (#65734)
add 90051561e72 fix serialize_template_field handling callable value in
dict (#63871)
add 25b96669630 Add MwaaServerlessDeleteWorkflowOperator (#66891)
add beea114b0f1 added parent info injection to EMR operator (#66816)
add 2fe52abc2c0 AGENTS.md: Require batching for bulk DELETE/UPDATE in
scheduler (#66908)
add 28e82d24c97 Enforce supervisor schema class name matches its `type`
literal (#66899)
add d74039c0751 fix `BigQueryStreamingBufferEmptySensor.poke()` always
raise `NotFound` (#66962)
add 767b72b5652 Fix no-op equality checks in Vertex AI trigger tests
(#66894)
add 4d5649349ff Add PAT connection to snowflake in SnowflakeHook (#66953)
add 01be07a4571 Mark Dags stale when their bundle is removed from config
(#66948)
add f9119133f66 Fix TableauOperator tasks.run AttributeError (#66682)
add 2e886a4dac7 cache connections in OpenLineage SQL hook lineage (#64843)
add 32ac8ad5132 Extend DEFAULT_SENSITIVE_FIELDS with common credential
field names (#66673)
add 171f6130247 Fix s3_tables system test: use CDK-provided ACCOUNT_ID for
bucket policy (#66972)
add 332fb1e2673 Bump axios in UI packages to patched release (#66770)
add 0c4c1f81ac6 [main] Upgrade important CI environment (#66980)
add f50036846eb Add function naming convention to AGENTS.md (action verbs,
not nouns) (#66997)
add 775b7e4cfdb Serialize poll_interval and impersonation_chain on
DataFusionStartPipelineTrigger (#66968)
add 37b05e43693 Bump the registry-package-updates group across 1 directory
with 3 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 (412f81498c7)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/registry/registry-package-updates-4bcf68a93c
(37b05e43693)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/instructions/code-review.instructions.md | 1 +
.github/skills/airflow-translations/locales/de.md | 1 +
.github/skills/pr-stats/SKILL.md | 151 +-
.github/skills/pr-stats/aggregate.md | 186 +-
.github/skills/pr-stats/classify.md | 27 +
.github/skills/pr-stats/fetch.md | 39 +-
.github/skills/pr-stats/render.md | 522 +++-
.github/workflows/additional-prod-image-tests.yml | 16 +
.github/workflows/airflow-e2e-tests.yml | 4 +-
.github/workflows/basic-tests.yml | 2 +-
.github/workflows/ci-amd.yml | 30 +-
.github/workflows/ci-arm.yml | 21 +-
.github/workflows/ci-image-checks.yml | 12 +-
.github/workflows/ci-notification.yml | 6 +-
.github/workflows/codeql-analysis.yml | 6 +-
.github/workflows/e2e-flaky-tests-report.yml | 2 +-
.github/workflows/registry-backfill.yml | 2 +-
.github/workflows/registry-build.yml | 2 +-
.../scheduled-verify-release-calendar.yml | 2 +-
.github/workflows/ui-e2e-tests.yml | 2 +-
.../update-constraints-on-push-stable.yml | 2 +-
.github/workflows/update-constraints-on-push.yml | 2 +-
.github/workflows/upgrade-check.yml | 4 +-
AGENTS.md | 2 +
Dockerfile | 4 +-
Dockerfile.ci | 8 +-
INTHEWILD.md | 3 +
PROVIDERS.rst | 9 +-
README.md | 5 +-
...LICENSE-normalize.txt => LICENSE-chakra-ui.txt} | 21 +-
airflow-core/LICENSE | 1 +
airflow-core/docs/faq.rst | 21 +
.../docs/howto/dag-level-retry-via-callback.rst | 228 ++
.../docs/howto/docker-compose/docker-compose.yaml | 10 +-
airflow-core/docs/howto/index.rst | 1 +
airflow-core/docs/howto/memory-profiling.rst | 35 +-
airflow-core/docs/howto/usage-cli.rst | 42 +-
airflow-core/docs/security/security_model.rst | 6 +-
airflow-core/newsfragments/63878.bugfix.rst | 1 +
airflow-core/newsfragments/64503.bugfix.rst | 1 +
airflow-core/newsfragments/66807.feature.rst | 1 +
airflow-core/pyproject.toml | 6 +-
airflow-core/src/airflow/api/common/trigger_dag.py | 17 +-
.../auth/managers/simple/simple_auth_manager.py | 57 +
.../auth/managers/simple/ui/package.json | 4 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 57 +-
.../api_fastapi/core_api/datamodels/ui/dag_runs.py | 17 +
.../api_fastapi/core_api/openapi/_private_ui.yaml | 86 +
.../core_api/routes/public/backfills.py | 1 +
.../api_fastapi/core_api/routes/public/dag_run.py | 25 +-
.../api_fastapi/core_api/routes/ui/__init__.py | 2 +
.../api_fastapi/core_api/routes/ui/dag_runs.py | 63 +
.../core_api/services/public/task_instances.py | 39 +
.../api_fastapi/core_api/services/ui/dag_run.py | 59 +
.../src/airflow/api_fastapi/execution_api/app.py | 4 +-
.../execution_api/datamodels/variable.py | 7 +
.../execution_api/routes/asset_state.py | 16 +-
.../execution_api/routes/task_instances.py | 28 +
.../api_fastapi/execution_api/routes/task_state.py | 8 +-
.../api_fastapi/execution_api/routes/variables.py | 55 +-
.../api_fastapi/execution_api/versions/__init__.py | 10 +-
.../execution_api/versions/v2026_04_17.py | 65 -
.../execution_api/versions/v2026_06_16.py | 51 +-
.../versions/v2026_06_30.py} | 16 +-
airflow-core/src/airflow/cli/cli_config.py | 32 +
.../src/airflow/cli/commands/db_command.py | 19 +-
.../airflow/cli/commands/state_store_command.py | 49 +
.../src/airflow/cli/commands/team_command.py | 28 +
.../src/airflow/cli/commands/triggerer_command.py | 2 +
.../src/airflow/config_templates/config.yml | 49 +-
airflow-core/src/airflow/dag_processing/manager.py | 79 +-
.../src/airflow/dag_processing/processor.py | 8 +
.../src/airflow/example_dags/plugins/workday.py | 24 +-
airflow-core/src/airflow/exceptions.py | 4 +
.../src/airflow/executors/base_executor.py | 4 +-
.../src/airflow/jobs/scheduler_job_runner.py | 38 +-
.../src/airflow/jobs/triggerer_job_runner.py | 20 +-
..._3_3_0_add_task_state_and_asset_state_tables.py | 7 +-
airflow-core/src/airflow/models/backfill.py | 3 +-
airflow-core/src/airflow/models/connection.py | 7 +-
airflow-core/src/airflow/models/dagrun.py | 12 +-
airflow-core/src/airflow/models/task_state.py | 21 +-
airflow-core/src/airflow/models/taskinstance.py | 1 -
airflow-core/src/airflow/models/xcom.py | 13 +-
airflow-core/src/airflow/plugins_manager.py | 5 +-
.../src/airflow/serialization/definitions/param.py | 3 +-
airflow-core/src/airflow/serialization/helpers.py | 123 +-
.../airflow/serialization/serialized_objects.py | 16 +-
airflow-core/src/airflow/state/metastore.py | 137 +-
.../src/airflow/ui/openapi-gen/queries/common.ts | 7 +
.../ui/openapi-gen/queries/ensureQueryData.ts | 13 +
.../src/airflow/ui/openapi-gen/queries/prefetch.ts | 13 +
.../src/airflow/ui/openapi-gen/queries/queries.ts | 13 +
.../src/airflow/ui/openapi-gen/queries/suspense.ts | 13 +
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 59 +
.../ui/openapi-gen/requests/services.gen.ts | 26 +-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 45 +
airflow-core/src/airflow/ui/package.json | 17 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 528 ++--
.../airflow/ui/public/i18n/locales/ar/common.json | 5 +
.../airflow/ui/public/i18n/locales/ca/common.json | 5 +
.../airflow/ui/public/i18n/locales/de/common.json | 13 +
.../ui/public/i18n/locales/de/components.json | 6 +-
.../src/airflow/ui/public/i18n/locales/de/dag.json | 43 +
.../airflow/ui/public/i18n/locales/de/dags.json | 5 +
.../airflow/ui/public/i18n/locales/el/common.json | 5 +
.../airflow/ui/public/i18n/locales/en/common.json | 5 +
.../airflow/ui/public/i18n/locales/es/common.json | 5 +
.../airflow/ui/public/i18n/locales/fr/common.json | 5 +
.../airflow/ui/public/i18n/locales/he/common.json | 5 +
.../airflow/ui/public/i18n/locales/hi/common.json | 5 +
.../airflow/ui/public/i18n/locales/hu/common.json | 5 +
.../airflow/ui/public/i18n/locales/it/common.json | 5 +
.../airflow/ui/public/i18n/locales/ja/common.json | 5 +
.../airflow/ui/public/i18n/locales/ko/common.json | 5 +
.../airflow/ui/public/i18n/locales/nl/common.json | 5 +
.../airflow/ui/public/i18n/locales/pl/common.json | 5 +
.../airflow/ui/public/i18n/locales/pt/common.json | 5 +
.../airflow/ui/public/i18n/locales/ru/common.json | 5 +
.../airflow/ui/public/i18n/locales/th/common.json | 5 +
.../airflow/ui/public/i18n/locales/tr/common.json | 5 +
.../ui/public/i18n/locales/zh-CN/common.json | 5 +
.../ui/public/i18n/locales/zh-TW/common.json | 5 +
.../src/airflow/ui/src/components/BasicTooltip.tsx | 8 +-
.../src/airflow/ui/src/components/ConfigForm.tsx | 4 +-
.../ui/src/components/DateTimeInput.test.tsx | 129 +
.../airflow/ui/src/components/DateTimeInput.tsx | 55 +-
.../ui/src/components/FilterBar/FilterPill.tsx | 6 +-
.../ui/src/components/Graph/DirectionDropdown.tsx | 8 +-
.../src/components/MarkAs/Run/MarkRunAsButton.tsx | 14 +-
.../MarkAs/TaskGroup/MarkTaskGroupAsButton.tsx | 14 +-
.../TaskInstance/MarkTaskInstanceAsButton.tsx | 14 +-
.../src/airflow/ui/src/components/ui/Checkbox.tsx | 4 +-
.../layouts/Details/Gantt/GanttTimeline.test.tsx | 4 +-
.../ui/src/layouts/Details/Gantt/utils.test.ts | 4 +-
.../ui/src/layouts/Details/Grid/utils.test.ts | 12 +-
.../ui/src/layouts/Nav/UserSettingsButton.tsx | 7 +-
airflow-core/src/airflow/ui/src/main.tsx | 4 +-
.../src/airflow/ui/src/mocks/handlers/log.ts | 15 +-
.../ui/src/pages/Connections/ConnectionForm.tsx | 9 +-
.../src/pages/Connections/EditConnectionButton.tsx | 2 +-
.../src/pages/Dag/Calendar/calendarUtils.test.ts | 186 ++
.../ui/src/pages/Dag/Calendar/calendarUtils.ts | 39 +-
.../airflow/ui/src/pages/DagsList/DagOwners.tsx | 4 +-
.../src/airflow/ui/src/pages/DagsList/DagTags.tsx | 7 +-
.../src/pages/DagsList/DagsFilters/DagsFilters.tsx | 6 +-
.../airflow/ui/src/pages/Events/EventsFilters.tsx | 2 +-
.../src/airflow/ui/src/pages/ReactPlugin.tsx | 2 +-
.../src/airflow/ui/src/pages/Run/Details.tsx | 29 +-
.../ui/src/pages/TaskInstance/ExtraLinks.tsx | 11 +-
.../ui/src/pages/TaskInstance/Logs/Logs.test.tsx | 14 +-
.../ui/src/pages/TaskInstance/Logs/utils.test.ts | 10 +-
.../src/airflow/ui/src/queries/useTrigger.ts | 22 +-
.../src/airflow/ui/src/utils/links.test.ts | 88 +-
airflow-core/src/airflow/ui/src/utils/links.ts | 56 +
airflow-core/src/airflow/ui/tsconfig.app.json | 9 +-
airflow-core/src/airflow/ui/tsconfig.node.json | 1 +
.../airflow/utils/dag_version_inflation_checker.py | 38 +-
airflow-core/src/airflow/utils/db_cleanup.py | 40 +-
airflow-core/src/airflow/utils/db_manager.py | 57 +-
.../src/airflow/utils/log/file_task_handler.py | 7 +-
airflow-core/src/airflow/utils/log/log_reader.py | 5 +-
.../airflow/utils/log/log_stream_accumulator.py | 52 +-
airflow-core/src/airflow/utils/memray_utils.py | 6 +-
airflow-core/src/airflow/utils/retries.py | 5 +-
.../src/airflow/utils/serve_logs/log_server.py | 2 +-
airflow-core/tests/unit/always/test_connection.py | 13 +
.../tests/unit/always/test_project_structure.py | 2 -
.../managers/simple/test_simple_auth_manager.py | 101 +
.../tests/unit/api_fastapi/auth/test_tokens.py | 28 +-
.../core_api/routes/public/test_auth.py | 8 +-
.../core_api/routes/public/test_backfills.py | 33 +
.../core_api/routes/public/test_dag_run.py | 27 +-
.../core_api/routes/public/test_hitl.py | 2 +-
.../api_fastapi/core_api/routes/public/test_log.py | 6 +-
.../core_api/routes/public/test_task_instances.py | 74 +
.../api_fastapi/execution_api/test_security.py | 57 +
.../versions/head/test_task_instances.py | 88 +
.../execution_api/versions/head/test_variables.py | 64 +
.../versions/v2026_04_06/test_task_instances.py | 3 +-
.../versions/v2026_06_30}/__init__.py | 0
.../test_dags.py => v2026_06_30/test_variables.py} | 8 +-
.../tests/unit/cli/commands/test_dag_command.py | 60 +-
.../tests/unit/cli/commands/test_db_command.py | 61 +
.../unit/cli/commands/test_state_store_command.py | 65 +
.../tests/unit/cli/commands/test_team_command.py | 41 +
.../tests/unit/dag_processing/test_manager.py | 221 ++
.../tests/unit/dags/test_dag_decorator_version.py | 63 +
airflow-core/tests/unit/jobs/test_scheduler_job.py | 16 +
airflow-core/tests/unit/jobs/test_triggerer_job.py | 23 +
.../tests/unit/listeners/asset_listener.py | 7 +-
.../unit/listeners/dag_import_error_listener.py | 4 +-
airflow-core/tests/unit/models/test_backfill.py | 24 +
airflow-core/tests/unit/models/test_dagrun.py | 104 +
.../tests/unit/models/test_renderedtifields.py | 4 +-
airflow-core/tests/unit/models/test_xcom.py | 53 +-
.../tests/unit/plugins/test_plugins_manager.py | 29 +-
.../unit/serialization/test_dag_serialization.py | 39 +
.../tests/unit/serialization/test_helpers.py | 606 +++++
airflow-core/tests/unit/state/test_metastore.py | 152 +-
.../unit/timetables/test_workday_timetable.py | 24 +
.../tests/unit/utils/log/test_log_reader.py | 32 +-
.../unit/utils/log/test_stream_accumulator.py | 96 +-
airflow-core/tests/unit/utils/test_db_cleanup.py | 114 +-
airflow-core/tests/unit/utils/test_db_manager.py | 74 +-
airflow-core/tests/unit/utils/test_log_handlers.py | 46 +-
airflow-core/tests/unit/utils/test_memray_utils.py | 52 +-
airflow-core/tests/unit/utils/test_retries.py | 29 +-
airflow-core/tests/unit/utils/test_serve_logs.py | 13 +
airflow-ctl-tests/pyproject.toml | 2 +-
.../airflowctl_tests/test_airflowctl_commands.py | 60 +-
.../test_config_sensitive_masking.py | 4 +-
airflow-ctl/RELEASE_NOTES.rst | 11 +
airflow-ctl/pyproject.toml | 2 +-
airflow-ctl/src/airflowctl/ctl/cli_config.py | 75 +-
.../tests/airflow_ctl/ctl/test_cli_config.py | 148 +-
.../docker/kafka.yml | 8 -
.../docker}/kafka/update_run.sh | 0
airflow-e2e-tests/pyproject.toml | 2 +-
.../basic_tests/test_airflowctl_imports.py | 24 +-
.../tests/airflow_e2e_tests/conftest.py | 105 +
.../tests/airflow_e2e_tests/constants.py | 15 +
.../airflow_e2e_tests/dags/example_event_driven.py | 177 ++
.../airflow_e2e_tests/e2e_test_utils/clients.py | 30 +
.../event_driven_tests}/__init__.py | 0
.../event_driven_tests/test_event_driven.py | 229 ++
.../remote_log_tests/test_remote_logging.py | 4 +-
chart/files/pod-template-file.kubernetes-helm-yaml | 2 +-
chart/pyproject.toml | 2 +-
.../api-server/api-server-deployment.yaml | 3 +
chart/templates/rbac/job-launcher-rolebinding.yaml | 18 +-
chart/templates/rbac/pod-launcher-rolebinding.yaml | 18 +-
.../security-context-constraint-rolebinding.yaml | 7 +-
chart/templates/workers/worker-serviceaccount.yaml | 3 +-
.../airflow_aux/test_job_launcher_role.py | 297 ++-
.../airflow_aux/test_pod_launcher_role.py | 340 ++-
.../airflow_aux/test_pod_template_file.py | 19 +
chart/tests/helm_tests/airflow_core/test_worker.py | 18 +
.../helm_tests/security/test_scc_rolebinding.py | 344 ++-
clients/python/pyproject.toml | 2 +-
contributing-docs/03_contributors_quick_start.rst | 2 +-
.../03a_contributors_quick_start_beginners.rst | 8 +
contributing-docs/27_cli_implementation_guide.rst | 144 ++
.../28_example_dag_review_checklist.rst | 113 +
contributing-docs/README.rst | 4 +
dev/README_RELEASE_PROVIDERS.md | 2 +-
dev/backport/update_backport_status.py | 2 +-
dev/breeze/doc/ci/02_images.md | 6 +-
.../images/output_testing_airflow-e2e-tests.svg | 2 +-
.../images/output_testing_airflow-e2e-tests.txt | 2 +-
dev/breeze/pyproject.toml | 2 +-
.../src/airflow_breeze/commands/ci_commands.py | 14 +-
.../src/airflow_breeze/commands/issues_commands.py | 15 +-
.../airflow_breeze/commands/kubernetes_commands.py | 5 +-
.../commands/release_management_commands.py | 39 +-
.../airflow_breeze/commands/testing_commands.py | 9 +-
.../airflow_breeze/commands/workflow_commands.py | 38 +-
dev/breeze/src/airflow_breeze/global_constants.py | 4 +-
.../prepare_providers/provider_documentation.py | 2 +-
.../src/airflow_breeze/utils/functools_cache.py | 4 +-
.../src/airflow_breeze/utils/gh_workflow_utils.py | 8 +-
dev/breeze/src/airflow_breeze/utils/github.py | 81 +
.../airflow_breeze/utils/provider_dependencies.py | 17 +-
.../src/airflow_breeze/utils/selective_checks.py | 14 +
dev/breeze/tests/test_github_utils.py | 165 ++
dev/breeze/tests/test_workflow_commands.py | 101 +
dev/breeze/uv.lock | 476 ++--
dev/mypy/pyproject.toml | 2 +-
dev/pyproject.toml | 2 +-
.../react_plugin_template/package.json | 5 +-
.../react_plugin_template/pnpm-lock.yaml | 19 +-
dev/registry/extract_metadata.py | 7 +-
dev/registry/extract_parameters.py | 2 +-
dev/registry/extract_versions.py | 6 +-
dev/registry/pyproject.toml | 2 +-
devel-common/pyproject.toml | 2 +-
.../shared/template-examples/taskflow-kwargs.rst | 10 +-
.../src/docs/shared/template-examples/taskflow.rst | 10 +-
devel-common/src/tests_common/pytest_plugin.py | 11 +-
.../tests_common/test_utils/file_task_handler.py | 8 +-
.../src/tests_common/test_utils/version_compat.py | 1 +
docker-stack-docs/pyproject.toml | 2 +-
docker-tests/pyproject.toml | 2 +-
.../test_docker_compose_quick_start.py | 27 +
generated/PYPI_README.md | 5 +-
generated/provider_metadata.json | 68 +
kubernetes-tests/pyproject.toml | 2 +-
.../test_kubernetes_pod_operator.py | 18 +-
providers-summary-docs/pyproject.toml | 2 +-
providers/ACCEPTING_PROVIDERS.rst | 94 +-
providers/SUSPENDING_AND_REMOVING_PROVIDERS.rst | 3 +-
providers/THIRD_PARTY_PROVIDERS.rst | 52 -
.../airflow/providers/alibaba/cloud/hooks/oss.py | 3 +-
.../alibaba/cloud/log/oss_task_handler.py | 4 +-
.../tests/unit/alibaba/cloud/hooks/test_oss.py | 26 +
.../alibaba/cloud/log/test_oss_task_handler.py | 21 +
.../amazon/docs/operators/mwaa_serverless.rst | 42 +
providers/amazon/docs/operators/s3_tables.rst | 29 +
providers/amazon/docs/operators/s3_vectors.rst | 29 +
providers/amazon/provider.yaml | 8 +
.../providers/amazon/aws/assets/redshift.py} | 23 +-
.../amazon/aws/executors/batch/batch_executor.py | 128 +-
.../providers/amazon/aws/executors/batch/utils.py | 33 +-
.../amazon/aws/hooks/sagemaker_unified_studio.py | 100 +-
.../airflow/providers/amazon/aws/operators/emr.py | 30 +-
.../amazon/aws/operators/mwaa_serverless.py | 137 +
.../providers/amazon/aws/operators/s3_tables.py | 92 +
.../providers/amazon/aws/operators/s3_vectors.py | 118 +
.../aws/triggers/sagemaker_unified_studio.py | 94 +-
.../airflow/providers/amazon/get_provider_info.py | 16 +-
.../system/amazon/aws/example_bedrock_guardrail.py | 6 +
.../system/amazon/aws/example_dms_serverless.py | 9 +-
.../system/amazon/aws/example_glue_catalog.py | 1 +
.../tests/system/amazon/aws/example_http_to_s3.py | 2 +-
.../system/amazon/aws/example_mwaa_serverless.py | 63 +-
.../tests/system/amazon/aws/example_s3_tables.py | 31 +-
.../tests/system/amazon/aws/example_s3_vectors.py | 25 +-
.../tests/unit/amazon/aws/assets/test_redshift.py | 90 +
.../aws/executors/batch/test_batch_executor.py | 117 +-
.../unit/amazon/aws/executors/batch/test_utils.py | 20 +-
.../aws/hooks/test_sagemaker_unified_studio.py | 12 +-
.../unit/amazon/aws/log/test_s3_task_handler.py | 14 +-
.../amazon/aws/operators/test_emr_containers.py | 228 ++
.../amazon/aws/operators/test_mwaa_serverless.py | 168 ++
.../unit/amazon/aws/operators/test_s3_tables.py | 107 +
.../unit/amazon/aws/operators/test_s3_vectors.py | 75 +
.../test_sagemaker_unified_studio_trigger.py | 105 +
.../system/apache/beam/example_go_dataflow.py | 5 +-
.../system/apache/beam/example_python_dataflow.py | 5 +-
providers/apache/hdfs/provider.yaml | 14 +
providers/apache/hdfs/pyproject.toml | 1 +
.../providers/apache/hdfs/assets}/__init__.py | 0
.../airflow/providers/apache/hdfs/assets/hdfs.py} | 22 +-
.../providers/apache/hdfs/get_provider_info.py | 16 +
.../tests/unit/apache/hdfs/assets}/__init__.py | 0
.../tests/unit/apache/hdfs/assets/test_hdfs.py | 92 +
providers/apache/hive/provider.yaml | 14 +
providers/apache/hive/pyproject.toml | 3 +-
.../providers/apache/hive/assets}/__init__.py | 0
.../airflow/providers/apache/hive/assets/hive.py} | 20 +-
.../providers/apache/hive/get_provider_info.py | 16 +
.../tests/unit/apache/hive/assets}/__init__.py | 0
.../tests/unit/apache/hive/assets/test_hive.py | 84 +
providers/apache/kafka/provider.yaml | 14 +
providers/apache/kafka/pyproject.toml | 1 +
.../providers/apache/kafka/assets}/__init__.py | 0
.../providers/apache/kafka/assets/kafka.py} | 22 +-
.../providers/apache/kafka/get_provider_info.py | 16 +
.../airflow/providers/apache/kafka/hooks/client.py | 2 +-
.../apache/kafka/triggers/await_message.py | 1 +
.../tests/unit/apache/kafka/assets}/__init__.py | 0
.../tests/unit/apache/kafka/assets/test_kafka.py | 77 +
.../tests/unit/apache/kafka/hooks/test_client.py | 11 +-
.../apache/kafka/triggers/test_await_message.py | 16 +
.../apache/spark/hooks/spark_pipelines.py | 96 +-
.../apache/spark/hooks/test_spark_pipelines.py | 130 +
.../providers/celery/executors/celery_executor.py | 4 +-
.../integration/celery/test_celery_executor.py | 23 +-
.../unit/celery/executors/test_celery_executor.py | 37 +
.../unit/celery/log_handlers/test_log_handlers.py | 9 +-
.../cncf/kubernetes/cli/kubernetes_command.py | 13 +-
.../executors/kubernetes_executor_utils.py | 58 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 23 +-
.../providers/cncf/kubernetes/operators/job.py | 2 +-
.../providers/cncf/kubernetes/operators/pod.py | 99 +-
.../providers/cncf/kubernetes/triggers/pod.py | 21 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 2 +-
.../cncf/kubernetes/utils/xcom_sidecar.py | 2 +-
.../system/cncf/kubernetes/example_kubernetes.py | 2 +-
.../cncf/kubernetes/example_kubernetes_async.py | 2 +-
.../unit/cncf/kubernetes/cli/test_definition.py | 3 +
.../executors/test_kubernetes_executor.py | 49 +
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 112 +
.../unit/cncf/kubernetes/operators/test_job.py | 42 +
.../unit/cncf/kubernetes/operators/test_pod.py | 305 ++-
.../unit/cncf/kubernetes/triggers/test_pod.py | 109 +-
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 4 +-
providers/common/ai/pyproject.toml | 2 +-
.../providers/common/ai/plugins/www/package.json | 4 +-
.../providers/common/ai/plugins/www/pnpm-lock.yaml | 10 +-
.../airflow/providers/common/sql/operators/sql.py | 475 +++-
.../tests/unit/common/sql/operators/test_sql.py | 1263 +++++++++
providers/databricks/provider.yaml | 14 +
.../providers/databricks/assets}/__init__.py | 0
.../providers/databricks/assets/databricks.py} | 21 +-
.../providers/databricks/get_provider_info.py | 16 +
.../databricks/operators/databricks_workflow.py | 35 +-
.../tests/unit/databricks/assets}/__init__.py | 0
.../unit/databricks/assets/test_databricks.py | 77 +
.../unit/databricks/hooks/test_databricks_base.py | 42 +-
.../operators/test_databricks_workflow.py | 28 +
providers/dbt/cloud/docs/operators.rst | 21 +
.../airflow/providers/dbt/cloud/operators/dbt.py | 91 +
.../tests/system/dbt/cloud/example_dbt_cloud.py | 9 +-
.../tests/unit/dbt/cloud/operators/test_dbt.py | 201 ++
.../airflow/providers/docker/operators/docker.py | 13 +-
.../tests/unit/docker/operators/test_docker.py | 30 +
providers/edge3/pyproject.toml | 2 +-
.../src/airflow/providers/edge3/cli/dataclasses.py | 28 +-
.../src/airflow/providers/edge3/cli/worker.py | 167 +-
.../edge3/src/airflow/providers/edge3/models/db.py | 63 +
.../providers/edge3/plugins/www/package.json | 12 +-
.../providers/edge3/plugins/www/pnpm-lock.yaml | 537 ++--
.../src/airflow/providers/edge3/version_compat.py | 2 +
.../edge3/tests/unit/edge3/cli/test_worker.py | 384 ++-
providers/edge3/tests/unit/edge3/models/test_db.py | 45 +
.../providers/elasticsearch/hooks/elasticsearch.py | 58 +-
.../providers/elasticsearch/log/es_task_handler.py | 36 +-
.../unit/elasticsearch/hooks/test_elasticsearch.py | 92 +-
.../unit/elasticsearch/log/test_es_task_handler.py | 51 +-
providers/fab/docs/index.rst | 1 +
providers/fab/pyproject.toml | 8 +-
.../providers/fab/auth_manager/models/db.py | 50 +-
.../fab/auth_manager/security_manager/override.py | 15 +-
.../fab/src/airflow/providers/fab/www/package.json | 6 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 172 +-
.../fab/src/airflow/providers/fab/www/session.py | 14 +-
.../tests/unit/fab/auth_manager/models/test_db.py | 41 +-
.../auth_manager/security_manager/test_override.py | 40 +-
providers/ftp/provider.yaml | 14 +
.../src/airflow/providers/ftp/assets}/__init__.py | 0
.../src/airflow/providers/ftp/assets/ftp.py} | 20 +-
.../src/airflow/providers/ftp/get_provider_info.py | 16 +
.../ftp/tests/unit/ftp/assets}/__init__.py | 0
providers/ftp/tests/unit/ftp/assets/test_ftp.py | 88 +
providers/google/docs/changelog.rst | 17 +
providers/google/docs/connections/gcp_looker.rst | 32 +-
providers/google/docs/connections/gcp_sql.rst | 73 +-
.../google/docs/integration-logos/AI-Platform.png | Bin 6284 -> 0 bytes
.../docs/integration-logos/Google-Data-Proc.png | Bin 24546 -> 0 bytes
providers/google/docs/operators/cloud/bigquery.rst | 30 +
.../docs/operators/cloud/bigquery_routines.rst | 164 ++
providers/google/docs/operators/cloud/dataplex.rst | 204 +-
providers/google/docs/operators/cloud/dataproc.rst | 166 +-
providers/google/docs/operators/cloud/looker.rst | 24 +-
providers/google/docs/operators/cloud/mlengine.rst | 86 -
providers/google/provider.yaml | 54 +-
.../providers/google/cloud/hooks/bigquery.py | 257 +-
.../providers/google/cloud/hooks/cloud_sql.py | 39 +-
.../providers/google/cloud/hooks/compute_ssh.py | 56 +-
.../providers/google/cloud/hooks/mlengine.py | 605 -----
.../providers/google/cloud/links/mlengine.py | 71 -
.../providers/google/cloud/operators/bigquery.py | 499 +++-
.../google/cloud/operators/knowledge_catalog.py | 112 +
.../google/cloud/operators/kubernetes_engine.py | 84 +-
.../providers/google/cloud/operators/looker.py | 7 +-
.../google/cloud/operators/managed_spark.py | 56 +
.../google/cloud/secrets/secret_manager.py | 7 +
.../providers/google/cloud/sensors/bigquery.py | 171 ++
.../google/cloud/transfers/gcs_to_bigquery.py | 43 +-
.../providers/google/cloud/transfers/s3_to_gcs.py | 32 +
.../providers/google/cloud/triggers/bigquery.py | 225 +-
.../providers/google/cloud/triggers/datafusion.py | 2 +
.../providers/google/cloud/triggers/mlengine.py | 125 -
.../google/cloud/utils/credentials_provider.py | 5 +-
.../airflow/providers/google/get_provider_info.py | 71 +-
providers/google/tests/deprecations_ignore.yml | 1 +
.../cloud/bigquery/example_bigquery_routines.py | 219 ++
.../cloud/bigquery/example_bigquery_sensors.py | 85 +-
.../cloud_sql/example_cloud_sql_query_proxy_iam.py | 204 ++
.../example_dlp_deidentify_content.py | 3 +-
.../google/cloud/dataflow/example_dataflow_go.py | 9 +-
.../example_dataflow_native_python_async.py | 12 +-
.../example_dataflow_sensors_deferrable.py | 12 +-
.../google/cloud/dataplex/example_dataplex.py | 4 +-
.../cloud/dataplex/example_dataplex_catalog.py | 2 +-
.../google/cloud/dataplex/example_dataplex_dp.py | 4 +-
.../google/cloud/dataplex/example_dataplex_dq.py | 4 +-
.../cloud/dataproc/example_dataproc_batch.py | 7 +-
.../dataproc/example_dataproc_batch_deferrable.py | 2 +-
.../dataproc/example_dataproc_batch_persistent.py | 4 +-
...igger.py => example_dataproc_cancel_on_kill.py} | 103 +-
...proc_cluster_create_existing_stopped_cluster.py | 6 +-
.../example_dataproc_cluster_deferrable.py | 2 +-
.../dataproc/example_dataproc_cluster_diagnose.py | 2 +-
.../dataproc/example_dataproc_cluster_generator.py | 4 +-
.../example_dataproc_cluster_start_stop.py | 6 +-
.../dataproc/example_dataproc_cluster_update.py | 2 +-
.../cloud/dataproc/example_dataproc_flink.py | 2 +-
.../google/cloud/dataproc/example_dataproc_gke.py | 4 +-
.../cloud/dataproc/example_dataproc_hadoop.py | 2 +-
.../google/cloud/dataproc/example_dataproc_hive.py | 2 +-
.../google/cloud/dataproc/example_dataproc_pig.py | 2 +-
.../cloud/dataproc/example_dataproc_presto.py | 2 +-
.../cloud/dataproc/example_dataproc_pyspark.py | 2 +-
.../cloud/dataproc/example_dataproc_spark.py | 2 +-
.../cloud/dataproc/example_dataproc_spark_async.py | 2 +-
.../dataproc/example_dataproc_spark_deferrable.py | 2 +-
.../cloud/dataproc/example_dataproc_spark_sql.py | 2 +-
.../cloud/dataproc/example_dataproc_sparkr.py | 2 +-
.../example_dataproc_start_from_trigger.py | 2 +-
.../cloud/dataproc/example_dataproc_trino.py | 2 +-
.../cloud/dataproc/example_dataproc_workflow.py | 4 +-
.../example_dataproc_workflow_deferrable.py | 4 +-
...ple_dataproc_metastore_hive_partition_sensor.py | 4 +-
.../cloud/datastore/example_datastore_commit.py | 10 +-
.../system/google/cloud/looker/example_looker.py | 4 +-
.../example_cloud_storage_transfer_service_aws.py | 33 +-
.../example_cloud_storage_transfer_service_gcp.py | 20 +-
.../example_vertex_ai_batch_prediction_job.py | 4 +-
.../cloud/vertex_ai/example_vertex_ai_endpoint.py | 2 +-
.../vertex_ai/example_vertex_ai_feature_store.py | 5 +-
.../vertex_ai/example_vertex_ai_model_service.py | 4 +-
.../example_video_intelligence.py | 7 +-
.../cloud/vision/example_vision_annotate_image.py | 3 +-
.../cloud/vision/example_vision_autogenerated.py | 17 +-
.../tests/unit/google/cloud/hooks/test_bigquery.py | 178 +-
.../unit/google/cloud/hooks/test_cloud_sql.py | 142 +
.../unit/google/cloud/hooks/test_compute_ssh.py | 37 +
.../tests/unit/google/cloud/hooks/test_mlengine.py | 1128 --------
.../unit/google/cloud/log/test_gcs_task_handler.py | 20 +-
.../unit/google/cloud/operators/test_bigquery.py | 211 ++
.../unit/google/cloud/operators/test_dataproc.py | 1 +
.../cloud/operators/test_knowledge_catalog.py | 171 ++
.../cloud/operators/test_kubernetes_engine.py | 391 ++-
.../unit/google/cloud/operators/test_looker.py | 9 +-
.../google/cloud/operators/test_managed_spark.py | 31 +-
.../google/cloud/secrets/test_secret_manager.py | 20 +
.../unit/google/cloud/sensors/test_bigquery.py | 153 ++
.../google/cloud/transfers/test_gcs_to_bigquery.py | 259 +-
.../unit/google/cloud/transfers/test_s3_to_gcs.py | 157 ++
.../unit/google/cloud/triggers/test_bigquery.py | 299 ++-
.../unit/google/cloud/triggers/test_datafusion.py | 18 +
.../cloud/triggers/test_kubernetes_engine.py | 2 +-
.../unit/google/cloud/triggers/test_mlengine.py | 142 -
.../unit/google/cloud/triggers/test_vertex_ai.py | 8 +-
.../cloud/utils/test_credentials_provider.py | 9 +
providers/http/docs/operators.rst | 7 +-
providers/http/tests/system/http/example_http.py | 3 +-
.../imap/src/airflow/providers/imap/hooks/imap.py | 26 +-
providers/imap/tests/unit/imap/hooks/test_imap.py | 51 +
providers/influxdb/docs/connections/influxdb3.rst | 51 +
providers/influxdb/docs/index.rst | 4 +-
providers/influxdb/docs/operators/index.rst | 15 +
providers/influxdb/provider.yaml | 41 +
providers/influxdb/pyproject.toml | 1 +
.../providers/influxdb/get_provider_info.py | 42 +-
.../airflow/providers/influxdb/hooks/influxdb3.py | 247 ++
.../operators/{influxdb.py => influxdb3.py} | 43 +-
.../{example_influxdb.py => example_influxdb3.py} | 59 +-
.../tests/unit/influxdb/hooks/test_influxdb3.py | 123 +
.../unit/influxdb/operators/test_influxdb3.py | 59 +
providers/microsoft/azure/provider.yaml | 3 +
.../providers/microsoft/azure/get_provider_info.py | 4 +
.../microsoft/azure/hooks/container_instance.py | 96 +-
.../azure/operators/container_instances.py | 92 +-
.../microsoft/azure/triggers/container_instance.py | 130 +
.../azure/hooks/test_container_instance.py | 265 +-
.../microsoft/azure/log/test_wasb_task_handler.py | 11 +-
.../azure/operators/test_container_instances.py | 288 +++
.../azure/triggers/test_container_instance.py | 248 ++
providers/microsoft/mssql/docs/index.rst | 34 +-
providers/microsoft/mssql/provider.yaml | 14 +
providers/microsoft/mssql/pyproject.toml | 2 +
.../providers/microsoft/mssql/assets}/__init__.py | 0
.../providers/microsoft/mssql/assets/mssql.py} | 23 +-
.../providers/microsoft/mssql/get_provider_info.py | 16 +
.../tests/unit/microsoft/mssql/assets}/__init__.py | 0
.../unit/microsoft/mssql/assets/test_mssql.py | 125 +
providers/mongo/provider.yaml | 14 +
providers/mongo/pyproject.toml | 3 +-
.../airflow/providers/mongo/assets}/__init__.py | 0
.../src/airflow/providers/mongo/assets/mongo.py} | 23 +-
.../airflow/providers/mongo/get_provider_info.py | 16 +
.../mongo/tests/unit/mongo/assets}/__init__.py | 0
.../mongo/tests/unit/mongo/assets/test_mongo.py | 97 +
providers/mysql/provider.yaml | 4 +
.../src/airflow/providers/mysql/assets/mysql.py | 21 +
.../airflow/providers/mysql/get_provider_info.py | 14 +-
.../mysql/tests/unit/mysql/assets/test_mysql.py | 37 +-
providers/openlineage/docs/index.rst | 4 +-
providers/openlineage/pyproject.toml | 4 +-
.../providers/openlineage/extractors/manager.py | 20 +-
.../providers/openlineage/plugins/listener.py | 17 +-
.../src/airflow/providers/openlineage/sqlparser.py | 27 +-
.../openlineage/utils/sql_hook_lineage.py | 62 +-
.../tests/unit/openlineage/test_sqlparser.py | 67 +
.../openlineage/utils/test_sql_hook_lineage.py | 73 +-
.../providers/opensearch/log/os_task_handler.py | 6 +-
.../unit/opensearch/log/test_os_task_handler.py | 7 +-
providers/oracle/provider.yaml | 14 +
.../airflow/providers/oracle/assets}/__init__.py | 0
.../src/airflow/providers/oracle/assets/oracle.py} | 31 +-
.../airflow/providers/oracle/get_provider_info.py | 16 +
.../oracle/tests/unit/oracle/assets}/__init__.py | 0
.../oracle/tests/unit/oracle/assets/test_oracle.py | 125 +
providers/pinecone/provider.yaml | 6 -
.../providers/pinecone/get_provider_info.py | 1 -
.../airflow/providers/pinecone/hooks/pinecone.py | 130 +-
providers/postgres/provider.yaml | 4 +
.../airflow/providers/postgres/assets/postgres.py | 21 +
.../providers/postgres/get_provider_info.py | 4 +
.../tests/unit/postgres/assets/test_postgres.py | 61 +-
providers/presto/provider.yaml | 14 +
providers/presto/pyproject.toml | 1 +
.../airflow/providers/presto/assets}/__init__.py | 0
.../src/airflow/providers/presto/assets/presto.py} | 23 +-
.../airflow/providers/presto/get_provider_info.py | 16 +
.../presto/tests/unit/presto/assets}/__init__.py | 0
.../presto/tests/unit/presto/assets/test_presto.py | 96 +
providers/sftp/README.rst | 1 +
providers/sftp/docs/changelog.rst | 8 +
providers/sftp/docs/index.rst | 1 +
providers/sftp/provider.yaml | 14 +
providers/sftp/pyproject.toml | 1 +
.../src/airflow/providers/sftp/assets}/__init__.py | 0
.../src/airflow/providers/sftp/assets/sftp.py} | 20 +-
.../airflow/providers/sftp/get_provider_info.py | 16 +
.../sftp/src/airflow/providers/sftp/hooks/sftp.py | 245 +-
.../src/airflow/providers/sftp/pools}/__init__.py | 0
.../sftp/src/airflow/providers/sftp/pools/sftp.py | 282 ++
providers/sftp/tests/conftest.py | 41 +
.../sftp/tests/unit/sftp/assets}/__init__.py | 0
providers/sftp/tests/unit/sftp/assets/test_sftp.py | 88 +
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 420 ++-
.../sftp/tests/unit/sftp/pools}/__init__.py | 0
providers/sftp/tests/unit/sftp/pools/test_sftp.py | 372 +++
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 5 +-
.../airflow/providers/smtp/notifications/smtp.py | 7 +-
providers/smtp/tests/unit/smtp/hooks/test_smtp.py | 23 +
.../tests/unit/smtp/notifications/test_smtp.py | 25 +
providers/snowflake/docs/connections/snowflake.rst | 27 +-
providers/snowflake/provider.yaml | 14 +
.../providers/snowflake/assets}/__init__.py | 0
.../providers/snowflake/assets/snowflake.py} | 18 +-
.../providers/snowflake/get_provider_info.py | 16 +
.../airflow/providers/snowflake/hooks/snowflake.py | 3 +-
.../providers/snowflake/hooks/snowflake_sql_api.py | 20 +-
.../providers/snowflake/operators/snowflake.py | 17 +-
.../tests/unit/snowflake/assets}/__init__.py | 0
.../tests/unit/snowflake/assets/test_snowflake.py} | 45 +-
.../unit/snowflake/hooks/test_snowflake_sql_api.py | 35 +-
.../unit/snowflake/operators/test_snowflake.py | 14 +-
.../example_branch_day_of_week_operator.py | 6 +-
.../standard/example_dags/example_latest_only.py | 14 +-
.../example_measurement_correction_decorator.py | 125 +
.../example_measurement_correction_operator.py | 134 +
.../example_dags/example_python_operator.py | 18 +-
.../example_dags/example_short_circuit_operator.py | 9 +-
.../airflow/providers/tableau/operators/tableau.py | 15 +-
.../tests/unit/tableau/operators/test_tableau.py | 86 +-
providers/teradata/provider.yaml | 14 +
providers/teradata/pyproject.toml | 3 +-
.../airflow/providers/teradata/assets}/__init__.py | 0
.../airflow/providers/teradata/assets/teradata.py} | 23 +-
.../providers/teradata/get_provider_info.py | 16 +
.../tests/unit/teradata/assets}/__init__.py | 0
.../tests/unit/teradata/assets/test_teradata.py | 60 +
providers/trino/provider.yaml | 4 +
.../src/airflow/providers/trino/assets/trino.py | 21 +
.../airflow/providers/trino/get_provider_info.py | 14 +-
.../trino/tests/unit/trino/assets/test_trino.py | 20 +-
providers/vertica/provider.yaml | 14 +
providers/vertica/pyproject.toml | 3 +-
.../airflow/providers/vertica/assets}/__init__.py | 0
.../airflow/providers/vertica/assets/vertica.py} | 23 +-
.../airflow/providers/vertica/get_provider_info.py | 16 +
.../vertica/tests/unit/vertica/assets}/__init__.py | 0
.../tests/unit/vertica/assets/test_vertica.py | 98 +
.../airflow/providers/weaviate/hooks/weaviate.py | 6 +-
providers/zendesk/provider.yaml | 26 +-
.../airflow/providers/zendesk/get_provider_info.py | 25 +-
.../src/airflow/providers/zendesk/hooks/zendesk.py | 182 +-
.../tests/unit/zendesk/hooks/test_zendesk.py | 164 +-
pyproject.toml | 4 +-
registry/pnpm-lock.yaml | 41 +-
registry/pnpm-workspace.yaml | 1 +
scripts/ci/install_breeze.sh | 2 +-
scripts/ci/prek/check_ci_workflows_in_sync.py | 28 +-
scripts/ci/prek/common_prek_utils.py | 42 +-
scripts/ci/prek/download_k8s_schemas.py | 19 +-
scripts/ci/prek/known_airflow_exceptions.txt | 8 +-
scripts/pyproject.toml | 2 +-
scripts/tests/ci/prek/test_common_prek_utils.py | 90 +
scripts/tools/setup_breeze | 2 +-
shared/configuration/pyproject.toml | 2 +-
.../src/airflow_shared/configuration/parser.py | 4 +-
shared/dagnode/pyproject.toml | 2 +-
shared/listeners/pyproject.toml | 2 +-
shared/logging/pyproject.toml | 2 +-
.../src/airflow_shared/logging/structlog.py | 24 +-
shared/logging/tests/logging/test_structlog.py | 11 +-
shared/module_loading/pyproject.toml | 2 +-
shared/observability/pyproject.toml | 2 +-
.../src/airflow_shared/observability/common.py | 17 +-
.../observability/metrics/metrics_template.yaml | 53 +
.../observability/metrics/test_otel_logger.py | 32 +
shared/plugins_manager/pyproject.toml | 2 +-
shared/providers_discovery/pyproject.toml | 2 +-
shared/secrets_backend/pyproject.toml | 2 +-
shared/secrets_masker/pyproject.toml | 2 +-
.../secrets_masker/secrets_masker.py | 25 +-
.../tests/secrets_masker/test_secrets_masker.py | 55 +
shared/serialization/pyproject.toml | 2 +-
shared/state/pyproject.toml | 2 +-
shared/state/src/airflow_shared/state/__init__.py | 66 +-
shared/template_rendering/pyproject.toml | 2 +-
shared/timezones/pyproject.toml | 2 +-
task-sdk-integration-tests/pyproject.toml | 2 +-
task-sdk/pyproject.toml | 2 +-
task-sdk/src/airflow/sdk/api/client.py | 9 +
.../src/airflow/sdk/api/datamodels/_generated.py | 14 +-
task-sdk/src/airflow/sdk/definitions/variable.py | 25 +
task-sdk/src/airflow/sdk/exceptions.py | 2 +-
.../sdk/execution_time/callback_supervisor.py | 6 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 19 +-
task-sdk/src/airflow/sdk/execution_time/context.py | 29 +
.../airflow/sdk/execution_time/request_handlers.py | 13 +
.../sdk/execution_time/sentry/configured.py | 18 +-
.../src/airflow/sdk/execution_time/supervisor.py | 20 +-
.../src/airflow/sdk/execution_time/task_runner.py | 151 +-
task-sdk/src/airflow/sdk/serde/__init__.py | 11 +-
task-sdk/tests/task_sdk/definitions/test_asset.py | 4 +-
.../tests/task_sdk/definitions/test_variables.py | 105 +-
.../execution_time/test_callback_supervisor.py | 11 +
.../tests/task_sdk/execution_time/test_sentry.py | 22 +-
.../task_sdk/execution_time/test_supervisor.py | 18 +-
.../test_supervisor_schemas_name_type_sync.py | 78 +
.../task_sdk/execution_time/test_task_runner.py | 13 +-
uv.lock | 2717 ++++++++++----------
720 files changed, 28737 insertions(+), 7621 deletions(-)
copy airflow-core/3rd-party-licenses/{LICENSE-normalize.txt =>
LICENSE-chakra-ui.txt} (51%)
create mode 100644 airflow-core/docs/howto/dag-level-retry-via-callback.rst
create mode 100644 airflow-core/newsfragments/63878.bugfix.rst
create mode 100644 airflow-core/newsfragments/64503.bugfix.rst
create mode 100644 airflow-core/newsfragments/66807.feature.rst
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/routes/ui/dag_runs.py
create mode 100644
airflow-core/src/airflow/api_fastapi/core_api/services/ui/dag_run.py
delete mode 100644
airflow-core/src/airflow/api_fastapi/execution_api/versions/v2026_04_17.py
copy airflow-core/src/airflow/api_fastapi/{core_api/datamodels/ui/teams.py =>
execution_api/versions/v2026_06_30.py} (72%)
create mode 100644 airflow-core/src/airflow/cli/commands/state_store_command.py
create mode 100644
airflow-core/src/airflow/ui/src/components/DateTimeInput.test.tsx
create mode 100644
airflow-core/src/airflow/ui/src/pages/Dag/Calendar/calendarUtils.test.ts
copy airflow-core/{src/airflow/_shared =>
tests/unit/api_fastapi/execution_api/versions/v2026_06_30}/__init__.py (100%)
copy
airflow-core/tests/unit/api_fastapi/execution_api/versions/{v2026_04_06/test_dags.py
=> v2026_06_30/test_variables.py} (77%)
create mode 100644
airflow-core/tests/unit/cli/commands/test_state_store_command.py
create mode 100644 airflow-core/tests/unit/dags/test_dag_decorator_version.py
copy scripts/ci/docker-compose/integration-kafka.yml =>
airflow-e2e-tests/docker/kafka.yml (94%)
copy {scripts/ci/docker-compose =>
airflow-e2e-tests/docker}/kafka/update_run.sh (100%)
copy providers/google/tests/unit/google/cloud/utils/test_dataproc.py =>
airflow-e2e-tests/tests/airflow_e2e_tests/basic_tests/test_airflowctl_imports.py
(64%)
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/dags/example_event_driven.py
copy {airflow-core/src/airflow/_shared =>
airflow-e2e-tests/tests/airflow_e2e_tests/event_driven_tests}/__init__.py (100%)
create mode 100644
airflow-e2e-tests/tests/airflow_e2e_tests/event_driven_tests/test_event_driven.py
create mode 100644 contributing-docs/27_cli_implementation_guide.rst
create mode 100644 contributing-docs/28_example_dag_review_checklist.rst
create mode 100644 dev/breeze/tests/test_github_utils.py
create mode 100644 dev/breeze/tests/test_workflow_commands.py
delete mode 100644 providers/THIRD_PARTY_PROVIDERS.rst
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
amazon/src/airflow/providers/amazon/aws/assets/redshift.py} (61%)
create mode 100644
providers/amazon/tests/unit/amazon/aws/assets/test_redshift.py
create mode 100644
providers/amazon/tests/unit/amazon/aws/triggers/test_sagemaker_unified_studio_trigger.py
copy {airflow-core/src/airflow/_shared =>
providers/apache/hdfs/src/airflow/providers/apache/hdfs/assets}/__init__.py
(100%)
copy providers/{google/src/airflow/providers/google/assets/gcs.py =>
apache/hdfs/src/airflow/providers/apache/hdfs/assets/hdfs.py} (71%)
copy {airflow-core/src/airflow/_shared =>
providers/apache/hdfs/tests/unit/apache/hdfs/assets}/__init__.py (100%)
create mode 100644
providers/apache/hdfs/tests/unit/apache/hdfs/assets/test_hdfs.py
copy {airflow-core/src/airflow/_shared =>
providers/apache/hive/src/airflow/providers/apache/hive/assets}/__init__.py
(100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
apache/hive/src/airflow/providers/apache/hive/assets/hive.py} (70%)
copy {airflow-core/src/airflow/_shared =>
providers/apache/hive/tests/unit/apache/hive/assets}/__init__.py (100%)
create mode 100644
providers/apache/hive/tests/unit/apache/hive/assets/test_hive.py
copy {airflow-core/src/airflow/_shared =>
providers/apache/kafka/src/airflow/providers/apache/kafka/assets}/__init__.py
(100%)
copy providers/{google/src/airflow/providers/google/assets/gcs.py =>
apache/kafka/src/airflow/providers/apache/kafka/assets/kafka.py} (70%)
copy {airflow-core/src/airflow/_shared =>
providers/apache/kafka/tests/unit/apache/kafka/assets}/__init__.py (100%)
create mode 100644
providers/apache/kafka/tests/unit/apache/kafka/assets/test_kafka.py
copy {airflow-core/src/airflow/_shared =>
providers/databricks/src/airflow/providers/databricks/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
databricks/src/airflow/providers/databricks/assets/databricks.py} (65%)
copy {airflow-core/src/airflow/_shared =>
providers/databricks/tests/unit/databricks/assets}/__init__.py (100%)
create mode 100644
providers/databricks/tests/unit/databricks/assets/test_databricks.py
copy {airflow-core/src/airflow/_shared =>
providers/ftp/src/airflow/providers/ftp/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
ftp/src/airflow/providers/ftp/assets/ftp.py} (68%)
copy {airflow-core/src/airflow/_shared =>
providers/ftp/tests/unit/ftp/assets}/__init__.py (100%)
create mode 100644 providers/ftp/tests/unit/ftp/assets/test_ftp.py
delete mode 100644 providers/google/docs/integration-logos/AI-Platform.png
delete mode 100644 providers/google/docs/integration-logos/Google-Data-Proc.png
create mode 100644 providers/google/docs/operators/cloud/bigquery_routines.rst
delete mode 100644 providers/google/docs/operators/cloud/mlengine.rst
delete mode 100644
providers/google/src/airflow/providers/google/cloud/hooks/mlengine.py
delete mode 100644
providers/google/src/airflow/providers/google/cloud/links/mlengine.py
create mode 100644
providers/google/src/airflow/providers/google/cloud/operators/knowledge_catalog.py
create mode 100644
providers/google/src/airflow/providers/google/cloud/operators/managed_spark.py
delete mode 100644
providers/google/src/airflow/providers/google/cloud/triggers/mlengine.py
create mode 100644
providers/google/tests/system/google/cloud/bigquery/example_bigquery_routines.py
create mode 100644
providers/google/tests/system/google/cloud/cloud_sql/example_cloud_sql_query_proxy_iam.py
copy
providers/google/tests/system/google/cloud/dataproc/{example_dataproc_start_from_trigger.py
=> example_dataproc_cancel_on_kill.py} (50%)
delete mode 100644
providers/google/tests/unit/google/cloud/hooks/test_mlengine.py
create mode 100644
providers/google/tests/unit/google/cloud/operators/test_knowledge_catalog.py
copy airflow-core/src/airflow/api_fastapi/auth/managers/simple/middleware.py
=> providers/google/tests/unit/google/cloud/operators/test_managed_spark.py
(55%)
delete mode 100644
providers/google/tests/unit/google/cloud/triggers/test_mlengine.py
create mode 100644 providers/influxdb/docs/connections/influxdb3.rst
create mode 100644
providers/influxdb/src/airflow/providers/influxdb/hooks/influxdb3.py
copy providers/influxdb/src/airflow/providers/influxdb/operators/{influxdb.py
=> influxdb3.py} (50%)
copy providers/influxdb/tests/system/influxdb/{example_influxdb.py =>
example_influxdb3.py} (58%)
create mode 100644
providers/influxdb/tests/unit/influxdb/hooks/test_influxdb3.py
create mode 100644
providers/influxdb/tests/unit/influxdb/operators/test_influxdb3.py
create mode 100644
providers/microsoft/azure/src/airflow/providers/microsoft/azure/triggers/container_instance.py
create mode 100644
providers/microsoft/azure/tests/unit/microsoft/azure/triggers/test_container_instance.py
copy {airflow-core/src/airflow/_shared =>
providers/microsoft/mssql/src/airflow/providers/microsoft/mssql/assets}/__init__.py
(100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
microsoft/mssql/src/airflow/providers/microsoft/mssql/assets/mssql.py} (62%)
copy {airflow-core/src/airflow/_shared =>
providers/microsoft/mssql/tests/unit/microsoft/mssql/assets}/__init__.py (100%)
create mode 100644
providers/microsoft/mssql/tests/unit/microsoft/mssql/assets/test_mssql.py
copy {airflow-core/src/airflow/_shared =>
providers/mongo/src/airflow/providers/mongo/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
mongo/src/airflow/providers/mongo/assets/mongo.py} (66%)
copy {airflow-core/src/airflow/_shared =>
providers/mongo/tests/unit/mongo/assets}/__init__.py (100%)
create mode 100644 providers/mongo/tests/unit/mongo/assets/test_mongo.py
copy {airflow-core/src/airflow/_shared =>
providers/oracle/src/airflow/providers/oracle/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
oracle/src/airflow/providers/oracle/assets/oracle.py} (60%)
copy {airflow-core/src/airflow/_shared =>
providers/oracle/tests/unit/oracle/assets}/__init__.py (100%)
create mode 100644 providers/oracle/tests/unit/oracle/assets/test_oracle.py
copy {airflow-core/src/airflow/_shared =>
providers/presto/src/airflow/providers/presto/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
presto/src/airflow/providers/presto/assets/presto.py} (62%)
copy {airflow-core/src/airflow/_shared =>
providers/presto/tests/unit/presto/assets}/__init__.py (100%)
create mode 100644 providers/presto/tests/unit/presto/assets/test_presto.py
copy {airflow-core/src/airflow/_shared =>
providers/sftp/src/airflow/providers/sftp/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
sftp/src/airflow/providers/sftp/assets/sftp.py} (68%)
copy {airflow-core/src/airflow/_shared =>
providers/sftp/src/airflow/providers/sftp/pools}/__init__.py (100%)
create mode 100644 providers/sftp/src/airflow/providers/sftp/pools/sftp.py
copy {airflow-core/src/airflow/_shared =>
providers/sftp/tests/unit/sftp/assets}/__init__.py (100%)
create mode 100644 providers/sftp/tests/unit/sftp/assets/test_sftp.py
copy {airflow-core/src/airflow/_shared =>
providers/sftp/tests/unit/sftp/pools}/__init__.py (100%)
create mode 100644 providers/sftp/tests/unit/sftp/pools/test_sftp.py
copy {airflow-core/src/airflow/_shared =>
providers/snowflake/src/airflow/providers/snowflake/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
snowflake/src/airflow/providers/snowflake/assets/snowflake.py} (65%)
copy {airflow-core/src/airflow/_shared =>
providers/snowflake/tests/unit/snowflake/assets}/__init__.py (100%)
copy providers/{postgres/tests/unit/postgres/assets/test_postgres.py =>
snowflake/tests/unit/snowflake/assets/test_snowflake.py} (52%)
create mode 100644
providers/standard/src/airflow/providers/standard/example_dags/example_measurement_correction_decorator.py
create mode 100644
providers/standard/src/airflow/providers/standard/example_dags/example_measurement_correction_operator.py
copy {airflow-core/src/airflow/_shared =>
providers/teradata/src/airflow/providers/teradata/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
teradata/src/airflow/providers/teradata/assets/teradata.py} (66%)
copy {airflow-core/src/airflow/_shared =>
providers/teradata/tests/unit/teradata/assets}/__init__.py (100%)
create mode 100644
providers/teradata/tests/unit/teradata/assets/test_teradata.py
copy {airflow-core/src/airflow/_shared =>
providers/vertica/src/airflow/providers/vertica/assets}/__init__.py (100%)
copy providers/{google/src/airflow/providers/google/assets/bigquery.py =>
vertica/src/airflow/providers/vertica/assets/vertica.py} (62%)
copy {airflow-core/src/airflow/_shared =>
providers/vertica/tests/unit/vertica/assets}/__init__.py (100%)
create mode 100644 providers/vertica/tests/unit/vertica/assets/test_vertica.py
create mode 100644
task-sdk/tests/task_sdk/execution_time/test_supervisor_schemas_name_type_sync.py
