This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/uv/dev/breeze/uv-dependency-updates-b8f00a7f1d
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 00d3ec8a44b Bump the uv-dependency-updates group in /dev/breeze with 2
updates
add c9d0fab18d5 Select deadlines by id so that deadlines associated with
other dagruns of same run_id are not pruned. (#58574)
add 32afc282eab Move BaseSecretsBackend to shared library for client
server separation (#58621)
add b0057c29de1 Prepare ad-hoc release for 2025-12-01 wave of providers
(#58878)
add b30bfa34fae Remove global from openlineage provider (#58868)
add 1c142ec5e64 Support optional scope in OAuth token request (#58871)
add 29ace334ac9 chore: Move OpenLineage methods to BaseSQLOperator (#58897)
add c116edcd5c7 Fix `breeze setup autocomplete` references (#58898)
add 9ad99263314 feat(google): add enable_open_telemetry_tracing to
PubSubHook and PubSubPublishMessageOperator (#58766)
add 43606160c76 fix string to datetime pydantic and test (#58791)
add 78cc12f77f0 Small updates to release process (PMC provider check)
(#58913)
add 7f81bc0f46f Improve XCom documentation by clarifying usage of
XCOM_RETURN_KEY constant (#58356)
add 6c50b62ab72 Improve startup information printed when Breeze starts
(#58926)
add 2c7de9768ff Adding Task SDK integration tests for Xcom operations
(#58638)
add 1c53e0844d5 Fix the serialization issue of AwaitMessageTrigger with
Redis. (#58746)
add d490d09fc11 CI: Upgrade important CI environment (#58915)
add c5e70a92210 Fix mypy errors in sql_to_s3 due to pandas stub bump
(#58923)
add baec49a13bb Fix LocalExecutor memory spike by applying gc.freeze
(#58365)
add e8480587885 nit: rename TriggerDagRunOperator._defer to deferrable
(#58925)
add 22af27ea5a7 Fix backfill max_active_runs race condition with
concurrent schedulers (#58807)
add bcda5080b8f Do not remove .pyc and .pyo files after building Python
(#58944)
add c811833d32e Update badges of Airflow: add prek and use nicer table
formatting (#58930)
add 7f07c312319 UI Unify trash icons (#58953)
add 1f1cbec33eb Fix remaining mypy issues in amazon provider (#58950)
add 74c2044f303 Add translations for PL. (#58940)
add 586fe930791 Fix exception when logging stdout with a custom %-fmt
string. (#58959)
add 46472e5fbba Fix depreccated DagBag import from models.dagbag (#58938)
add 1f575ab700a tests: Add OL system tests for deferrable
TriggerDagRunOperator (#58933)
add b95fca4dbdf Bump minimum prek version to 0.2.0 (#58952)
add 438dbfd8e06 Add license header to test_percent_formatter.py (#58975)
add 28e08fc9970 Make shared timezone library standalone by getting rid of
`airflow.*` imports (#58888)
add 8ab288a4d50 Fix Liveness / Readiness / Startup probe path for Airflow
3.x #58129 (#58734)
add 27b5e58a61e Update providers metadata 2025-12-02 (#58978)
add a5f1c4edf51 Update asset manager to be partition-aware (#58289)
add fe99a32f27d Version cap fastapi due to is_coroutine changes in 0.123.5
(#58980)
add 1e8d0a198ed [main] Upgrade important CI environment (#58976)
add 24e682c593c Fix assets used only as inlets being incorrectly orphaned
(#58303) (#58368)
add 729e74be2e0 Add pandas as an optional dependency to the AMPP (#58984)
add dcc88f1d4ec fix(i18n): Trasnalte trigger as 觸發器, triggerer as 觸發者 and
dagRun.triggeredBy as 觸發來源 (#58988)
add 5aa90c0cda3 Fix NotMapped exception when clearing task instances with
downstream/upstream (#58922)
add f3af770842d Implement timetables in SDK (#58669)
add 08813da0d69 Add prek check before compiling assets in start-airflow
(#58979)
add ab8820e2d71 Fix go back button from fab iframe (#58997)
add 4970ea2978e Fix task instance and runs tooltips in Grid view (#58359)
add 1b30bf90a58 Bump the fab-ui-package-updates group across 1 directory
with 2 updates (#58954)
add 76fe18d9883 Adding Task SDK integration tests for asset operations
(#59000)
add c97dbbdf263 Refactor FavoriteDags layout for improved responsiveness
(#59014)
add b653efa9556 Refactor Dashboard layout and Health component
responsiveness (#59015)
add c02ae15f953 Bump the core-ui-package-updates group across 1 directory
with 10 updates (#59009)
add 28e6122df05 Remove global from celery provider (#58869)
add 2017714aebe Retry on `RedshiftSQLHook.get_conn` (#59017)
add 729571b1a8d Update the documentation for the LocalExecutor (#58990)
add ab71473d29e Update logging documentation for Azure Blob Storage
(#59016)
add 4a5451632ea Fix CloudwatchTaskHandler display error (#54054)
add 02c49379153 fix(sftp): add default port to SFTPHookAsync (#58945)
add 3a9fad1667d Decouple xcom public API from using XcomEncoder (#58900)
add caa3d0d21e9 provide a clear naming and description for the attribute
caching get_template_context (#59023)
add 430f0e08d30 Fixing LLM providers tests (#59031)
add d024a46ce7d Change task log source display to hidden by default
(#58749)
add 0a1e798fb71 Add UI/API performance tips (#59004)
add ba7e2fb4685 feat: added toasters for permission denied (#57966)
(#58016)
add d3bc5b96e8f Move HTTPAuthorizationCredentials import from
TYPE_CHECKING block to (#59048)
add d3fecc2bffc Update prek badge URL in README (#59055)
add 8ec7601eab6 Fix TI overview trend count link (#59059)
add 462f71fa6eb i18n(Ko): add missing translations in common.json (Dec 4)
(#59039)
add f0b2ae95a61 i18n(Ko): add missing translations in hitl.json (#59037)
add 36ecfe20b82 i18n(Ko): add missing translations in assets.json (Nov 26)
(#58709)
add fe26bfe0575 Uncomment Python version pin in `check-lazy-logging`
(#59047)
add cd255d7bffe Bump ruff to 0.14.8, uv to 0.9.15 (#59058)
add c63de7b0701 i18n(ko): translating in components.json (Dec 4) (#59040)
add 5bf9983746d i18n(Ko) : add mission translations in dags.json (Dec 4)
(#59041)
add be38f92ed8f Fix readme from generated code (#59070)
add 52526b3f605 Link AIP-76 todos to issues (#59063)
add 337aee896a9 Move the traces and metrics code under a common
observability package (#56187)
add 65ca7d337d4 chore: Adjust AirflowRunFacet and docs after moving OL
methods to BaseSQLOperator (#58903)
add 056efdbc1ad keycloak: enable client_secret retrieval from secrets
backend (#59065)
add b698b7b5c6b Update scheduler to create dag runs for
partitioned-asset-driven dags (#59006)
add 64102a08080 Shorten the path to import conf from airflow task sdk
(#59029)
add 8b63199e1fb CI: Upgrade important CI environment (#59101)
add 0ecd95f7dd1 docs(INTHEWILD.md): add Numberly to the list of companies
using Apache Airflow (#59098)
add 52987f42ffc Limit urllib3 to < 2.6.0 to handle kubernetes client
breaking with it (#59108)
add d51e5723c63 Add sensitive keycloak value to fix failing tests. (#59107)
add 15aeed9a8ae Rename dag to serdag where appropriate in scheduler
(#59118)
add 28b89563a19 Fix flaky test_next_dagrun_after_fake_scheduled_previous
(#59035)
add 5c942e6c67c Bump python 3.13 to 3.13.11 (#59125)
add 1d6bd9d8add Add dag bundles to `airflow info` command (#59124)
add 40ee29ce3cd Limit urllib3 to <2.6.0 during latest boto tests (#59130)
add 5845599cb74 Fix newly introduced mypy error (#59112)
add 97cf3c786af fix flaky TestEmrCreateJobFlowOperator (#59128)
add f496fc035ba Update include @noeunkim for Korean translations (#59096)
add 519e1ef7000 i18n(Ko): add missing translation in components.json (Dec
5) (#59076)
add 6b4867e8169 Update uv version to 0.9.16 (#59138)
add 0ee0dafd956 Move Self to observability shared package (#59140)
add bc38090507e CI: Upgrade important CI environment (#59144)
add 24a334ff1ba Fix typo in Failed to Trigger DAG -> Failed to Trigger Dag
(#59077)
add 236dab6406e Breeze exit on incompatible arguments (#59148)
add a129c2cbd71 Also limit urllib3 to < 2.6.0 in k8s tests - for use in
v3-1-tests (#59152)
add f0d0b2fb993 Add script that verifies consistency: Release Page with
Release Calendar (#59142)
add bdabf46d964 Remove global statement from Fab provider (#59018)
add bc7ce10582a Fix breeze check-release-files Command for Core+Task SDK
checks (#59159)
add 53a721cc59d improved logging & exitcode check (#59146)
add ad6961dc447 Fix airflow/task-sdk relase PMC checks (#59164)
add 5c41f2ee293 Prevent dag processor crash on encountering excel files in
the DAG directory (#59069)
add 8879eb8cf23 Fix mypy error on version check in dev (#59171)
add d46a9d12065 Fix inconsistent Dag hashes when template fields contain
unordered dicts (#59091)
add f58548101b8 AIP 67 - Multi-Team: Update LocalExecutor to support
running in a multi-team config (#59021)
add 80b49311651 Correct header parameter description in HTTP operator
(#59105)
add 0bf581e2a28 Handle mid line chunking when writing docker stream to
logs (#59071)
add 2b38b194633 Fix DagRun.queued_at not updating when clearing (#59066)
add 908e6c28435 Create an explicit control for createUserJob (#56057)
add 7e9787265ac Allow teams to use global executors by default (#59116)
add 7446e41feb5 Fix ingress notes (#59122)
add 31e4381eff1 helm: correctly derive celery sync_parallelism from
scheduler CPU limits (#58733)
add 0f8d79a4852 fix uv venv fail without direct internet access (#59046)
add ef14b9a618f update missing catalan translations (#59110)
add d96ff621ae5 Fix finally return handling (#58998)
add 3935c86a69d fix: scheduler, triggerer, worker airflow components have
inconsistent log volume (#56418)
add 15ddf8d1b9a Close German translation gaps for full UI translation
2025-12-07 (#59162)
add fffab39f996 Drop Airflow 2 Support in Edge Provider (#59143)
add 6208a479924 Implement get_config in LocalFilesystemBackend (#59062)
add 9023c38adc4 Add Horizontal Pod Autoscaler (HPA) Support for Airflow
API Server (#52392)
add 25179391926 docs: Fix broken permalink icon (#58763)
add 501f724b64f Update release candidate commands (#59186)
add d9c826eb77f Repurpose imports from sdk for sdk tests for sentry
(#59034)
add 3b8ed158d94 CHG: fix address (#59193)
add 7510322789e feat: display logged in within UserSettingsButton (#58981)
add c2b20ae7c58 Align the term Dag in all translations (#59153)
add bfb99f5f524 Add backcompat for exceptions in providers (#58727)
add 38db2defa23 Show asset extra in asset list (#59195)
add 92d2f87572a Add toggle functionality to Dags state filters (#59089)
add 217fc5f59a6 Remove global from providers amazon tests (#59178)
add 85b65eb3961 Fix misleading error message when GitHook creation fails
(#59084)
add 0beaf2d3cca Adding retries and pool to Weaviate dags to handle
connection latency issues (#59198)
add a59d2ecdc39 chore: use OL macros instead of building OL ids from
scratch (#59197)
add dd31202e8c4 Convert the exclusion on urllib3 to != for 2.6.0 (#59203)
add 5e42d871732 Bump the uv-dependency-updates group in /dev/breeze 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 (00d3ec8a44b)
\
N -- N -- N
refs/heads/dependabot/uv/dev/breeze/uv-dependency-updates-b8f00a7f1d
(5e42d871732)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/CODEOWNERS | 2 +-
.github/actions/breeze/action.yml | 2 +-
.github/actions/install-prek/action.yml | 2 +-
.github/workflows/airflow-distributions-tests.yml | 2 +-
.github/workflows/basic-tests.yml | 2 +-
.github/workflows/ci-amd-arm.yml | 17 +
.github/workflows/release_dockerhub_image.yml | 2 +-
.pre-commit-config.yaml | 11 +-
.rat-excludes | 2 +-
Dockerfile | 4 +-
Dockerfile.ci | 12 +-
INTHEWILD.md | 1 +
README.md | 26 +-
airflow-core/.pre-commit-config.yaml | 6 +-
airflow-core/docs/best-practices.rst | 2 +-
airflow-core/docs/conf.py | 4 +
airflow-core/docs/core-concepts/executor/local.rst | 23 +-
airflow-core/docs/core-concepts/xcoms.rst | 10 +-
.../docs/howto/docker-compose/docker-compose.yaml | 2 +-
airflow-core/docs/howto/index.rst | 1 +
airflow-core/docs/howto/performance.rst | 55 +
.../howto/run-with-self-signed-certificate.rst | 2 +-
airflow-core/pyproject.toml | 7 +-
airflow-core/src/airflow/__init__.py | 4 +
airflow-core/src/airflow/_shared/observability | 1 +
airflow-core/src/airflow/_shared/secrets_backend | 1 +
.../auth/managers/simple/ui/package-lock.json | 1653 ++++++++++----------
.../auth/managers/simple/ui/package.json | 16 +-
.../auth/managers/simple/ui/pnpm-lock.yaml | 322 ++--
.../src/airflow/api_fastapi/common/parameters.py | 7 +-
.../api_fastapi/core_api/routes/public/xcom.py | 7 +-
.../src/airflow/api_fastapi/core_api/security.py | 3 +-
airflow-core/src/airflow/assets/manager.py | 146 +-
.../src/airflow/cli/commands/daemon_utils.py | 2 +-
.../src/airflow/cli/commands/dag_command.py | 23 +-
.../src/airflow/cli/commands/info_command.py | 7 +-
.../src/airflow/dag_processing/bundles/manager.py | 21 +-
.../src/airflow/dag_processing/collection.py | 4 +-
airflow-core/src/airflow/dag_processing/manager.py | 6 +-
.../src/airflow/dag_processing/processor.py | 2 +-
.../src/airflow/example_dags/example_assets.py | 4 +-
.../example_dags/example_outlet_event_extra.py | 6 +
airflow-core/src/airflow/exceptions.py | 52 +-
.../src/airflow/executors/base_executor.py | 15 +-
.../src/airflow/executors/local_executor.py | 75 +-
.../src/airflow/jobs/dag_processor_job_runner.py | 2 +-
airflow-core/src/airflow/jobs/job.py | 4 +-
.../src/airflow/jobs/scheduler_job_runner.py | 154 +-
.../src/airflow/jobs/triggerer_job_runner.py | 6 +-
airflow-core/src/airflow/models/__init__.py | 5 +-
airflow-core/src/airflow/models/callback.py | 2 +-
airflow-core/src/airflow/models/dagrun.py | 7 +-
airflow-core/src/airflow/models/deadline.py | 2 +-
airflow-core/src/airflow/models/taskinstance.py | 22 +-
.../airflow/{metrics => observability}/__init__.py | 0
.../{_shared => observability/metrics}/__init__.py | 0
.../observability/metrics/datadog_logger.py | 40 +
.../airflow/observability/metrics/otel_logger.py | 43 +
.../airflow/observability/metrics/statsd_logger.py | 63 +
.../src/airflow/{ => observability}/stats.py | 10 +-
airflow-core/src/airflow/observability/trace.py | 122 ++
.../common => observability/traces}/__init__.py | 0
.../airflow/observability/traces/otel_tracer.py | 33 +-
airflow-core/src/airflow/plugins_manager.py | 2 +-
airflow-core/src/airflow/secrets/base_secrets.py | 82 +-
.../src/airflow/secrets/local_filesystem.py | 39 +-
airflow-core/src/airflow/serialization/decoders.py | 132 ++
.../definitions/assets.py} | 13 +-
airflow-core/src/airflow/serialization/encoders.py | 308 ++++
airflow-core/src/airflow/serialization/helpers.py | 50 +-
airflow-core/src/airflow/serialization/serde.py | 2 +-
.../airflow/serialization/serialized_objects.py | 251 +--
airflow-core/src/airflow/settings.py | 14 +-
airflow-core/src/airflow/timetables/_cron.py | 4 +-
airflow-core/src/airflow/timetables/_delta.py | 15 +
airflow-core/src/airflow/timetables/assets.py | 18 +-
airflow-core/src/airflow/timetables/base.py | 50 +-
airflow-core/src/airflow/timetables/events.py | 15 +-
airflow-core/src/airflow/timetables/interval.py | 25 +-
airflow-core/src/airflow/timetables/simple.py | 80 +-
airflow-core/src/airflow/timetables/trigger.py | 70 +-
airflow-core/src/airflow/traces/utils.py | 114 --
.../airflow/ui/public/i18n/locales/ca/assets.json | 4 +
.../airflow/ui/public/i18n/locales/ca/common.json | 7 +-
.../ui/public/i18n/locales/ca/components.json | 10 +
.../src/airflow/ui/public/i18n/locales/ca/dag.json | 12 +
.../airflow/ui/public/i18n/locales/ca/dags.json | 5 +
.../airflow/ui/public/i18n/locales/ca/hitl.json | 3 +-
.../ui/public/i18n/locales/de/components.json | 9 +-
.../airflow/ui/public/i18n/locales/en/assets.json | 1 +
.../airflow/ui/public/i18n/locales/en/browse.json | 4 -
.../airflow/ui/public/i18n/locales/en/common.json | 3 +
.../ui/public/i18n/locales/en/components.json | 3 +
.../ui/public/i18n/locales/hu/components.json | 4 +-
.../src/airflow/ui/public/i18n/locales/hu/dag.json | 4 +-
.../airflow/ui/public/i18n/locales/ko/assets.json | 1 +
.../airflow/ui/public/i18n/locales/ko/common.json | 6 +-
.../ui/public/i18n/locales/ko/components.json | 12 +-
.../airflow/ui/public/i18n/locales/ko/dags.json | 5 +
.../airflow/ui/public/i18n/locales/ko/hitl.json | 3 +-
.../ui/public/i18n/locales/nl/components.json | 4 +-
.../airflow/ui/public/i18n/locales/pl/common.json | 1 +
.../airflow/ui/public/i18n/locales/pt/assets.json | 10 +-
.../airflow/ui/public/i18n/locales/pt/browse.json | 2 +-
.../airflow/ui/public/i18n/locales/pt/common.json | 38 +-
.../ui/public/i18n/locales/pt/components.json | 28 +-
.../src/airflow/ui/public/i18n/locales/pt/dag.json | 12 +-
.../airflow/ui/public/i18n/locales/pt/dags.json | 16 +-
.../ui/public/i18n/locales/pt/dashboard.json | 28 +-
.../airflow/ui/public/i18n/locales/th/common.json | 2 +-
.../src/airflow/ui/public/i18n/locales/th/dag.json | 4 +-
.../ui/public/i18n/locales/zh-CN/components.json | 2 +-
.../ui/public/i18n/locales/zh-TW/common.json | 8 +-
.../ui/public/i18n/locales/zh-TW/dashboard.json | 2 +-
.../src/airflow/ui/src/components/BasicTooltip.tsx | 127 ++
.../src/airflow/ui/src/components/DagRunInfo.tsx | 2 +-
.../src/airflow/ui/src/components/HoverTooltip.tsx | 63 -
.../ui/src/components/TaskInstanceTooltip.tsx | 5 +-
.../src/components/TriggerDag/TriggerDAGForm.tsx | 6 +-
.../ui/src/layouts/Details/Grid/GridButton.tsx | 66 +-
.../airflow/ui/src/layouts/Details/Grid/GridTI.tsx | 65 +-
.../ui/src/layouts/Nav/UserSettingsButton.tsx | 15 +
.../airflow/ui/src/pages/AssetsList/AssetsList.tsx | 43 +-
.../pages/Connections/DeleteConnectionButton.tsx | 6 +-
.../pages/Connections/DeleteConnectionsButton.tsx | 4 +-
.../ui/src/pages/Dag/Calendar/CalendarCell.tsx | 15 +-
.../ui/src/pages/Dag/Calendar/CalendarTooltip.tsx | 104 +-
.../src/pages/DagsList/DagsFilters/DagsFilters.tsx | 14 +-
.../airflow/ui/src/pages/Dashboard/Dashboard.tsx | 4 +-
.../Dashboard/FavoriteDags/FavoriteDagCard.tsx | 4 +-
.../pages/Dashboard/FavoriteDags/FavoriteDags.tsx | 22 +-
.../ui/src/pages/Dashboard/Health/Health.tsx | 2 +-
.../src/airflow/ui/src/pages/Events/Events.tsx | 6 +-
airflow-core/src/airflow/ui/src/pages/Security.tsx | 23 +-
.../ui/src/pages/Task/Overview/Overview.tsx | 2 +-
.../ui/src/pages/TaskInstance/Logs/Logs.test.tsx | 22 +-
.../ui/src/pages/TaskInstance/Logs/Logs.tsx | 2 +-
.../src/pages/Variables/DeleteVariablesButton.tsx | 4 +-
.../ManageVariable/DeleteVariableButton.tsx | 6 +-
.../src/airflow/ui/src/pages/XCom/XCom.tsx | 4 +-
.../src/airflow/ui/src/queries/useTrigger.ts | 13 +-
.../tests/integration/otel/dags/otel_test_dag.py | 4 +-
.../dags/otel_test_dag_with_pause_between_tasks.py | 4 +-
.../otel/dags/otel_test_dag_with_pause_in_task.py | 4 +-
airflow-core/tests/integration/otel/test_otel.py | 2 +-
.../unit/always/test_secrets_local_filesystem.py | 75 +
.../core_api/routes/public/test_dags.py | 80 +-
.../core_api/routes/public/test_event_logs.py | 53 +-
.../core_api/routes/public/test_hitl.py | 4 +
.../core_api/routes/public/test_task_instances.py | 4 +-
.../tests/unit/cli/commands/test_dag_command.py | 1 -
.../tests/unit/cli/commands/test_db_command.py | 2 +-
.../tests/unit/cli/commands/test_info_command.py | 2 +-
airflow-core/tests/unit/core/test_configuration.py | 1 +
.../bundles/test_dag_bundle_manager.py | 51 +
.../tests/unit/executors/test_local_executor.py | 118 +-
.../executors/test_local_executor_check_workers.py | 4 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 244 ++-
airflow-core/tests/unit/models/test_cleartasks.py | 5 +
airflow-core/tests/unit/models/test_dag.py | 60 +-
airflow-core/tests/unit/models/test_dagrun.py | 61 +-
.../tests/unit/models/test_serialized_dag.py | 53 +
.../tests/unit/models/test_taskinstance.py | 151 +-
.../unit/observability}/__init__.py | 0
.../unit/observability/metrics}/__init__.py | 0
.../{core => observability/metrics}/test_stats.py | 124 +-
.../unit/observability/traces}/__init__.py | 0
.../traces}/test_otel_tracer.py | 36 +-
.../unit/serialization/test_dag_serialization.py | 11 +-
.../tests/unit/timetables/test_assets_timetable.py | 6 +-
.../tests/unit/timetables/test_events_timetable.py | 4 +-
.../airflowctl_tests/test_airflowctl_commands.py | 24 +-
airflow-ctl/.pre-commit-config.yaml | 2 +-
.../tests/airflow_e2e_tests/conftest.py | 2 +-
chart/.pre-commit-config.yaml | 4 +-
chart/templates/NOTES.txt | 17 +-
chart/templates/_helpers.yaml | 15 +
.../api-server/api-server-deployment.yaml | 6 +-
...oddisruptionbudget.yaml => api-server-hpa.yaml} | 31 +-
chart/templates/jobs/create-user-job.yaml | 2 +-
.../templates/scheduler/scheduler-deployment.yaml | 5 +
.../templates/triggerer/triggerer-deployment.yaml | 5 +
chart/templates/workers/worker-deployment.yaml | 5 +
chart/values.schema.json | 54 +-
chart/values.yaml | 30 +
clients/python/pyproject.toml | 2 +-
contributing-docs/05_pull_requests.rst | 4 +-
dev/README_RELEASE_AIRFLOW.md | 3 +-
dev/README_RELEASE_PROVIDERS.md | 6 +-
dev/breeze/doc/01_installation.rst | 2 +-
dev/breeze/doc/ci/02_images.md | 2 +-
...tput_release-management_check-release-files.svg | 26 +-
...tput_release-management_check-release-files.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 2 +-
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
dev/breeze/pyproject.toml | 2 +-
.../airflow_breeze/commands/developer_commands.py | 15 +-
.../commands/release_candidate_command.py | 29 +-
.../commands/release_management_commands.py | 25 +-
dev/breeze/src/airflow_breeze/global_constants.py | 6 +-
.../airflow_breeze/utils/check_release_files.py | 8 +-
.../airflow_breeze/utils/docker_command_utils.py | 6 +-
dev/breeze/src/airflow_breeze/utils/visuals.py | 2 +-
.../tests/test_pytest_args_for_test_types.py | 1 +
dev/breeze/uv.lock | 554 +++----
dev/pyproject.toml | 3 +
dev/verify_release_calendar.py | 600 +++++++
devel-common/pyproject.toml | 2 +-
devel-common/sphinx_design/static/custom.css | 26 +-
.../src/sphinx_exts/providers_extensions.py | 49 +-
.../sphinx_exts/templates/openlineage.rst.jinja2 | 41 +-
devel-common/src/tests_common/pytest_plugin.py | 33 +-
devel-common/src/tests_common/test_utils/db.py | 30 +-
docker-stack-docs/changelog.rst | 12 +
.../test_docker_compose_quick_start.py | 4 +
generated/PYPI_README.md | 26 +-
generated/provider_metadata.json | 44 +
go-sdk/.pre-commit-config.yaml | 4 +-
go-sdk/pkg/edgeapi/client.go | 2 +-
.../tests/helm_tests/airflow_aux/test_configmap.py | 27 +
.../helm_tests/airflow_aux/test_create_user_job.py | 50 +
.../helm_tests/airflow_core/test_api_server.py | 9 +
.../helm_tests/airflow_core/test_scheduler.py | 31 +
.../helm_tests/airflow_core/test_triggerer.py | 32 +
.../tests/helm_tests/airflow_core/test_worker.py | 32 +
.../test_hpa_apiserver.py} | 36 +-
kubernetes-tests/pyproject.toml | 4 +
providers/.last_release_date.txt | 2 +-
providers/.pre-commit-config.yaml | 2 +-
providers/airbyte/pyproject.toml | 2 +-
.../src/airflow/providers/airbyte/hooks/airbyte.py | 3 +-
.../airflow/providers/airbyte/operators/airbyte.py | 3 +-
.../airflow/providers/airbyte/sensors/airbyte.py | 3 +-
.../tests/unit/airbyte/hooks/test_airbyte.py | 2 +-
.../tests/unit/airbyte/sensors/test_airbyte.py | 2 +-
providers/alibaba/pyproject.toml | 2 +-
.../alibaba/cloud/hooks/analyticdb_spark.py | 3 +-
.../airflow/providers/alibaba/cloud/hooks/oss.py | 3 +-
.../alibaba/cloud/operators/analyticdb_spark.py | 3 +-
.../providers/alibaba/cloud/sensors/oss_key.py | 4 +-
.../cloud/operators/test_analyticdb_spark.py | 2 +-
.../unit/alibaba/cloud/sensors/test_oss_key.py | 2 +-
providers/amazon/README.rst | 2 +-
providers/amazon/docs/changelog.rst | 7 +
providers/amazon/docs/index.rst | 2 +-
providers/amazon/pyproject.toml | 6 +-
.../amazon/aws/auth_manager/avp/facade.py | 2 +-
.../src/airflow/providers/amazon/aws/bundles/s3.py | 2 +-
.../src/airflow/providers/amazon/aws/exceptions.py | 2 +-
.../aws/executors/aws_lambda/lambda_executor.py | 3 +-
.../amazon/aws/executors/batch/batch_executor.py | 3 +-
.../amazon/aws/executors/ecs/ecs_executor.py | 3 +-
.../airflow/providers/amazon/aws/hooks/athena.py | 2 +-
.../providers/amazon/aws/hooks/athena_sql.py | 2 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 8 +-
.../providers/amazon/aws/hooks/batch_client.py | 2 +-
.../providers/amazon/aws/hooks/batch_waiters.py | 2 +-
.../airflow/providers/amazon/aws/hooks/chime.py | 2 +-
.../providers/amazon/aws/hooks/comprehend.py | 2 +-
.../airflow/providers/amazon/aws/hooks/datasync.py | 4 +-
.../airflow/providers/amazon/aws/hooks/dynamodb.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/ec2.py | 2 +-
.../aws/hooks/elasticache_replication_group.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/emr.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/glue.py | 3 +-
.../providers/amazon/aws/hooks/glue_catalog.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/logs.py | 12 +-
.../providers/amazon/aws/hooks/quicksight.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/rds.py | 2 +-
.../providers/amazon/aws/hooks/redshift_sql.py | 13 +-
.../src/airflow/providers/amazon/aws/hooks/s3.py | 3 +-
.../providers/amazon/aws/hooks/sagemaker.py | 2 +-
.../amazon/aws/hooks/sagemaker_unified_studio.py | 3 +-
.../src/airflow/providers/amazon/aws/links/emr.py | 2 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 70 +-
.../providers/amazon/aws/operators/appflow.py | 2 +-
.../providers/amazon/aws/operators/athena.py | 2 +-
.../providers/amazon/aws/operators/batch.py | 2 +-
.../providers/amazon/aws/operators/bedrock.py | 2 +-
.../providers/amazon/aws/operators/comprehend.py | 2 +-
.../providers/amazon/aws/operators/datasync.py | 3 +-
.../airflow/providers/amazon/aws/operators/dms.py | 2 +-
.../airflow/providers/amazon/aws/operators/ec2.py | 2 +-
.../airflow/providers/amazon/aws/operators/ecs.py | 2 +-
.../airflow/providers/amazon/aws/operators/eks.py | 3 +-
.../airflow/providers/amazon/aws/operators/emr.py | 3 +-
.../providers/amazon/aws/operators/eventbridge.py | 2 +-
.../airflow/providers/amazon/aws/operators/glue.py | 2 +-
.../providers/amazon/aws/operators/glue_crawler.py | 2 +-
.../amazon/aws/operators/glue_databrew.py | 2 +-
.../amazon/aws/operators/kinesis_analytics.py | 2 +-
.../amazon/aws/operators/lambda_function.py | 2 +-
.../airflow/providers/amazon/aws/operators/mwaa.py | 2 +-
.../providers/amazon/aws/operators/neptune.py | 2 +-
.../airflow/providers/amazon/aws/operators/rds.py | 2 +-
.../amazon/aws/operators/redshift_cluster.py | 2 +-
.../amazon/aws/operators/redshift_data.py | 2 +-
.../airflow/providers/amazon/aws/operators/s3.py | 2 +-
.../providers/amazon/aws/operators/sagemaker.py | 2 +-
.../aws/operators/sagemaker_unified_studio.py | 3 +-
.../amazon/aws/operators/step_function.py | 2 +-
.../airflow/providers/amazon/aws/sensors/athena.py | 2 +-
.../airflow/providers/amazon/aws/sensors/batch.py | 2 +-
.../providers/amazon/aws/sensors/bedrock.py | 2 +-
.../providers/amazon/aws/sensors/comprehend.py | 2 +-
.../airflow/providers/amazon/aws/sensors/dms.py | 2 +-
.../airflow/providers/amazon/aws/sensors/ec2.py | 2 +-
.../airflow/providers/amazon/aws/sensors/ecs.py | 2 +-
.../airflow/providers/amazon/aws/sensors/eks.py | 3 +-
.../airflow/providers/amazon/aws/sensors/emr.py | 4 +-
.../providers/amazon/aws/sensors/glacier.py | 2 +-
.../airflow/providers/amazon/aws/sensors/glue.py | 2 +-
.../amazon/aws/sensors/glue_catalog_partition.py | 2 +-
.../providers/amazon/aws/sensors/glue_crawler.py | 2 +-
.../amazon/aws/sensors/kinesis_analytics.py | 2 +-
.../amazon/aws/sensors/lambda_function.py | 2 +-
.../airflow/providers/amazon/aws/sensors/mwaa.py | 2 +-
.../amazon/aws/sensors/opensearch_serverless.py | 2 +-
.../providers/amazon/aws/sensors/quicksight.py | 2 +-
.../airflow/providers/amazon/aws/sensors/rds.py | 2 +-
.../amazon/aws/sensors/redshift_cluster.py | 2 +-
.../src/airflow/providers/amazon/aws/sensors/s3.py | 3 +-
.../providers/amazon/aws/sensors/sagemaker.py | 2 +-
.../amazon/aws/sensors/sagemaker_unified_studio.py | 3 +-
.../airflow/providers/amazon/aws/sensors/sqs.py | 2 +-
.../providers/amazon/aws/sensors/step_function.py | 2 +-
.../providers/amazon/aws/transfers/gcs_to_s3.py | 3 +-
.../amazon/aws/transfers/redshift_to_s3.py | 3 +-
.../amazon/aws/transfers/s3_to_dynamodb.py | 3 +-
.../amazon/aws/transfers/s3_to_redshift.py | 3 +-
.../providers/amazon/aws/transfers/s3_to_sql.py | 3 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 10 +-
.../airflow/providers/amazon/aws/triggers/ecs.py | 2 +-
.../airflow/providers/amazon/aws/triggers/eks.py | 2 +-
.../providers/amazon/aws/triggers/sagemaker.py | 2 +-
.../airflow/providers/amazon/aws/triggers/sqs.py | 2 +-
.../airflow/providers/amazon/aws/utils/__init__.py | 2 +-
.../amazon/aws/utils/connection_wrapper.py | 2 +-
.../airflow/providers/amazon/aws/utils/waiter.py | 2 +-
.../amazon/aws/utils/waiter_with_logging.py | 2 +-
.../system/amazon/aws/example_dynamodb_to_s3.py | 2 +-
.../amazon/aws/tests/test_aws_auth_manager.py | 13 +-
.../amazon/aws/auth_manager/avp/test_facade.py | 2 +-
.../tests/unit/amazon/aws/bundles/test_s3.py | 2 +-
.../executors/aws_lambda/test_lambda_executor.py | 2 +-
.../aws/executors/batch/test_batch_executor.py | 2 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_base_aws.py | 2 +-
.../unit/amazon/aws/hooks/test_batch_client.py | 2 +-
.../unit/amazon/aws/hooks/test_batch_waiters.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_chime.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_comprehend.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_datasync.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_dynamodb.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_ec2.py | 2 +-
.../hooks/test_elasticache_replication_group.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_emr.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_glue.py | 2 +-
.../unit/amazon/aws/hooks/test_glue_catalog.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_quicksight.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_rds.py | 2 +-
.../unit/amazon/aws/hooks/test_redshift_sql.py | 2 +-
.../amazon/tests/unit/amazon/aws/hooks/test_s3.py | 2 +-
.../tests/unit/amazon/aws/hooks/test_sagemaker.py | 2 +-
.../aws/hooks/test_sagemaker_unified_studio.py | 2 +-
.../unit/amazon/aws/hooks/test_step_function.py | 2 +-
.../amazon/tests/unit/amazon/aws/links/test_emr.py | 2 +-
.../amazon/aws/log/test_cloudwatch_task_handler.py | 34 +-
.../tests/unit/amazon/aws/operators/test_athena.py | 2 +-
.../tests/unit/amazon/aws/operators/test_batch.py | 2 +-
.../unit/amazon/aws/operators/test_datasync.py | 2 +-
.../tests/unit/amazon/aws/operators/test_dms.py | 2 +-
.../tests/unit/amazon/aws/operators/test_ec2.py | 2 +-
.../tests/unit/amazon/aws/operators/test_ecs.py | 2 +-
.../tests/unit/amazon/aws/operators/test_eks.py | 3 +-
.../amazon/aws/operators/test_emr_add_steps.py | 2 +-
.../amazon/aws/operators/test_emr_containers.py | 2 +-
.../aws/operators/test_emr_create_job_flow.py | 3 +-
.../aws/operators/test_emr_modify_cluster.py | 2 +-
.../aws/operators/test_emr_notebook_execution.py | 2 +-
.../amazon/aws/operators/test_emr_serverless.py | 2 +-
.../aws/operators/test_emr_terminate_job_flow.py | 2 +-
.../unit/amazon/aws/operators/test_eventbridge.py | 2 +-
.../tests/unit/amazon/aws/operators/test_glue.py | 2 +-
.../amazon/aws/operators/test_kinesis_analytics.py | 2 +-
.../amazon/aws/operators/test_lambda_function.py | 2 +-
.../unit/amazon/aws/operators/test_neptune.py | 2 +-
.../tests/unit/amazon/aws/operators/test_rds.py | 2 +-
.../amazon/aws/operators/test_redshift_cluster.py | 2 +-
.../amazon/aws/operators/test_redshift_data.py | 2 +-
.../tests/unit/amazon/aws/operators/test_s3.py | 2 +-
.../amazon/aws/operators/test_sagemaker_base.py | 2 +-
.../aws/operators/test_sagemaker_endpoint.py | 2 +-
.../operators/test_sagemaker_endpoint_config.py | 2 +-
.../amazon/aws/operators/test_sagemaker_model.py | 2 +-
.../aws/operators/test_sagemaker_pipeline.py | 2 +-
.../aws/operators/test_sagemaker_processing.py | 2 +-
.../aws/operators/test_sagemaker_training.py | 2 +-
.../aws/operators/test_sagemaker_transform.py | 2 +-
.../amazon/aws/operators/test_sagemaker_tuning.py | 2 +-
.../aws/operators/test_sagemaker_unified_studio.py | 2 +-
.../amazon/aws/operators/test_step_function.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_athena.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_batch.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_bedrock.py | 2 +-
.../unit/amazon/aws/sensors/test_comprehend.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_dms.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_ec2.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_ecs.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_eks.py | 3 +-
.../tests/unit/amazon/aws/sensors/test_emr_base.py | 2 +-
.../unit/amazon/aws/sensors/test_emr_containers.py | 2 +-
.../unit/amazon/aws/sensors/test_emr_job_flow.py | 2 +-
.../aws/sensors/test_emr_notebook_execution.py | 2 +-
.../aws/sensors/test_emr_serverless_application.py | 2 +-
.../amazon/aws/sensors/test_emr_serverless_job.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_emr_step.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_glacier.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_glue.py | 2 +-
.../aws/sensors/test_glue_catalog_partition.py | 2 +-
.../unit/amazon/aws/sensors/test_glue_crawler.py | 2 +-
.../amazon/aws/sensors/test_glue_data_quality.py | 2 +-
.../amazon/aws/sensors/test_kinesis_analytics.py | 2 +-
.../amazon/aws/sensors/test_lambda_function.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_mwaa.py | 2 +-
.../aws/sensors/test_opensearch_serverless.py | 2 +-
.../unit/amazon/aws/sensors/test_quicksight.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_rds.py | 2 +-
.../amazon/aws/sensors/test_redshift_cluster.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_s3.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_automl.py | 2 +-
.../unit/amazon/aws/sensors/test_sagemaker_base.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_endpoint.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_pipeline.py | 2 +-
.../aws/sensors/test_sagemaker_processing.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_training.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_transform.py | 2 +-
.../amazon/aws/sensors/test_sagemaker_tuning.py | 2 +-
.../aws/sensors/test_sagemaker_unified_studio.py | 2 +-
.../tests/unit/amazon/aws/sensors/test_sqs.py | 2 +-
.../unit/amazon/aws/sensors/test_step_function.py | 2 +-
.../amazon/aws/transfers/test_redshift_to_s3.py | 2 +-
.../amazon/aws/transfers/test_s3_to_dynamodb.py | 2 +-
.../amazon/aws/transfers/test_s3_to_redshift.py | 2 +-
.../unit/amazon/aws/transfers/test_s3_to_sql.py | 2 +-
.../unit/amazon/aws/transfers/test_sql_to_s3.py | 3 +-
.../tests/unit/amazon/aws/triggers/test_ecs.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_eks.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_glue.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_neptune.py | 2 +-
.../tests/unit/amazon/aws/triggers/test_ssm.py | 2 +-
.../amazon/aws/utils/test_connection_wrapper.py | 2 +-
.../tests/unit/amazon/aws/utils/test_waiter.py | 2 +-
.../amazon/aws/utils/test_waiter_with_logging.py | 2 +-
providers/apache/beam/pyproject.toml | 4 +-
.../airflow/providers/apache/beam/hooks/beam.py | 4 +-
.../providers/apache/beam/operators/beam.py | 4 +-
.../beam/tests/unit/apache/beam/hooks/test_beam.py | 2 +-
.../tests/unit/apache/beam/operators/test_beam.py | 3 +-
providers/apache/druid/pyproject.toml | 2 +-
.../airflow/providers/apache/druid/hooks/druid.py | 3 +-
.../tests/unit/apache/druid/hooks/test_druid.py | 2 +-
providers/apache/flink/pyproject.toml | 8 +-
.../apache/flink/sensors/flink_kubernetes.py | 3 +-
.../apache/flink/sensors/test_flink_kubernetes.py | 2 +-
providers/apache/hdfs/pyproject.toml | 8 +-
.../airflow/providers/apache/hdfs/hooks/webhdfs.py | 3 +-
providers/apache/hive/pyproject.toml | 2 +-
.../airflow/providers/apache/hive/hooks/hive.py | 3 +-
.../providers/apache/hive/operators/hive_stats.py | 3 +-
.../providers/apache/hive/transfers/s3_to_hive.py | 3 +-
.../hive/tests/unit/apache/hive/hooks/test_hive.py | 3 +-
.../unit/apache/hive/operators/test_hive_stats.py | 2 +-
.../hive/sensors/test_named_hive_partition.py | 2 +-
.../unit/apache/hive/transfers/test_s3_to_hive.py | 2 +-
providers/apache/kafka/pyproject.toml | 4 +-
.../providers/apache/kafka/operators/consume.py | 3 +-
.../providers/apache/kafka/operators/produce.py | 3 +-
.../apache/kafka/triggers/await_message.py | 2 +-
.../unit/apache/kafka/operators/test_consume.py | 2 +-
.../tests/unit/apache/kafka/sensors/test_kafka.py | 2 +-
providers/apache/kylin/pyproject.toml | 2 +-
.../airflow/providers/apache/kylin/hooks/kylin.py | 3 +-
.../providers/apache/kylin/operators/kylin_cube.py | 3 +-
.../tests/unit/apache/kylin/hooks/test_kylin.py | 2 +-
.../unit/apache/kylin/operators/test_kylin_cube.py | 2 +-
providers/apache/livy/pyproject.toml | 2 +-
.../airflow/providers/apache/livy/hooks/livy.py | 2 +-
.../providers/apache/livy/operators/livy.py | 3 +-
.../livy/tests/unit/apache/livy/hooks/test_livy.py | 2 +-
.../tests/unit/apache/livy/operators/test_livy.py | 2 +-
providers/apache/pig/pyproject.toml | 8 +-
.../src/airflow/providers/apache/pig/hooks/pig.py | 3 +-
.../pig/tests/unit/apache/pig/hooks/test_pig.py | 2 +-
providers/apache/pinot/pyproject.toml | 8 +-
.../airflow/providers/apache/pinot/hooks/pinot.py | 3 +-
.../tests/unit/apache/pinot/hooks/test_pinot.py | 2 +-
providers/apache/spark/pyproject.toml | 2 +-
.../providers/apache/spark/hooks/spark_jdbc.py | 2 +-
.../providers/apache/spark/hooks/spark_sql.py | 3 +-
.../providers/apache/spark/hooks/spark_submit.py | 3 +-
.../unit/apache/spark/hooks/test_spark_sql.py | 2 +-
.../unit/apache/spark/hooks/test_spark_submit.py | 2 +-
providers/arangodb/pyproject.toml | 2 +-
.../airflow/providers/arangodb/hooks/arangodb.py | 3 +-
.../providers/arangodb/operators/arangodb.py | 3 +-
providers/atlassian/jira/pyproject.toml | 2 +-
.../airflow/providers/atlassian/jira/hooks/jira.py | 3 +-
providers/celery/README.rst | 2 +-
providers/celery/docs/changelog.rst | 2 +
providers/celery/docs/index.rst | 2 +-
providers/celery/pyproject.toml | 2 +-
.../providers/celery/executors/celery_executor.py | 3 +-
.../celery/executors/celery_executor_utils.py | 27 +-
.../providers/celery/executors/default_celery.py | 3 +-
.../integration/celery/test_celery_executor.py | 6 +-
.../unit/celery/executors/test_celery_executor.py | 2 +-
providers/cloudant/pyproject.toml | 2 +-
.../airflow/providers/cloudant/hooks/cloudant.py | 3 +-
.../tests/unit/cloudant/hooks/test_cloudant.py | 2 +-
providers/cncf/kubernetes/README.rst | 2 +-
providers/cncf/kubernetes/docs/changelog.rst | 4 +
providers/cncf/kubernetes/docs/index.rst | 2 +-
providers/cncf/kubernetes/pyproject.toml | 6 +-
.../backcompat/backwards_compat_converters.py | 2 +-
.../providers/cncf/kubernetes/exceptions.py | 6 +
.../kubernetes/executors/kubernetes_executor.py | 3 +-
.../executors/kubernetes_executor_utils.py | 2 +-
.../providers/cncf/kubernetes/hooks/kubernetes.py | 3 +-
.../cncf/kubernetes/kubernetes_helper_functions.py | 2 +-
.../kubernetes/operators/custom_object_launcher.py | 2 +-
.../providers/cncf/kubernetes/operators/job.py | 3 +-
.../providers/cncf/kubernetes/operators/kueue.py | 2 +-
.../providers/cncf/kubernetes/operators/pod.py | 7 +-
.../cncf/kubernetes/operators/resource.py | 2 +-
.../cncf/kubernetes/operators/spark_kubernetes.py | 2 +-
.../kubernetes/resource_convert/env_variable.py | 2 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 3 +-
.../cncf/kubernetes/template_rendering.py | 2 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 2 +-
.../backcompat/test_backwards_compat_converters.py | 2 +-
.../executors/test_kubernetes_executor.py | 2 +-
.../unit/cncf/kubernetes/hooks/test_kubernetes.py | 2 +-
.../operators/test_custom_object_launcher.py | 2 +-
.../unit/cncf/kubernetes/operators/test_job.py | 3 +-
.../unit/cncf/kubernetes/operators/test_kueue.py | 2 +-
.../unit/cncf/kubernetes/operators/test_pod.py | 20 +-
.../kubernetes/operators/test_spark_kubernetes.py | 2 +-
.../kubernetes/sensors/test_spark_kubernetes.py | 2 +-
.../unit/cncf/kubernetes/utils/test_pod_manager.py | 2 +-
providers/common/compat/.pre-commit-config.yaml | 2 +-
.../src/airflow/providers/common/compat/sdk.py | 19 +-
providers/common/sql/README.rst | 17 +-
providers/common/sql/docs/changelog.rst | 2 +
providers/common/sql/docs/index.rst | 2 +-
providers/common/sql/pyproject.toml | 2 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 8 +-
.../common/sql/operators/generic_transfer.py | 3 +-
.../airflow/providers/common/sql/operators/sql.py | 211 +--
.../airflow/providers/common/sql/sensors/sql.py | 3 +-
.../airflow/providers/common/sql/triggers/sql.py | 3 +-
.../tests/unit/common/sql/operators/test_sql.py | 33 +-
.../sql/tests/unit/common/sql/sensors/test_sql.py | 2 +-
providers/databricks/pyproject.toml | 2 +-
.../src/airflow/providers/databricks/exceptions.py | 2 +-
.../providers/databricks/hooks/databricks.py | 2 +-
.../providers/databricks/hooks/databricks_base.py | 3 +-
.../providers/databricks/hooks/databricks_sql.py | 2 +-
.../providers/databricks/operators/databricks.py | 3 +-
.../databricks/operators/databricks_repos.py | 3 +-
.../databricks/operators/databricks_sql.py | 3 +-
.../databricks/operators/databricks_workflow.py | 3 +-
.../databricks/plugins/databricks_workflow.py | 4 +-
.../providers/databricks/sensors/databricks.py | 3 +-
.../databricks/sensors/databricks_partition.py | 3 +-
.../providers/databricks/sensors/databricks_sql.py | 3 +-
.../providers/databricks/utils/databricks.py | 2 +-
.../airflow/providers/databricks/utils/mixins.py | 2 +-
.../providers/databricks/utils/openlineage.py | 88 +-
.../tests/unit/databricks/hooks/test_databricks.py | 2 +-
.../unit/databricks/hooks/test_databricks_base.py | 2 +-
.../unit/databricks/hooks/test_databricks_sql.py | 5 +-
.../unit/databricks/operators/test_databricks.py | 2 +-
.../databricks/operators/test_databricks_copy.py | 2 +-
.../databricks/operators/test_databricks_repos.py | 2 +-
.../operators/test_databricks_workflow.py | 2 +-
.../databricks/plugins/test_databricks_workflow.py | 2 +-
.../unit/databricks/sensors/test_databricks.py | 2 +-
.../sensors/test_databricks_partition.py | 2 +-
.../unit/databricks/sensors/test_databricks_sql.py | 2 +-
.../tests/unit/databricks/utils/test_databricks.py | 2 +-
.../tests/unit/databricks/utils/test_mixins.py | 2 +-
.../unit/databricks/utils/test_openlineage.py | 60 +-
providers/datadog/pyproject.toml | 2 +-
.../src/airflow/providers/datadog/hooks/datadog.py | 3 +-
.../airflow/providers/datadog/sensors/datadog.py | 3 +-
.../tests/unit/datadog/hooks/test_datadog.py | 2 +-
.../tests/unit/datadog/sensors/test_datadog.py | 2 +-
providers/dbt/cloud/docs/index.rst | 2 +-
providers/dbt/cloud/pyproject.toml | 2 +-
.../src/airflow/providers/dbt/cloud/hooks/dbt.py | 2 +-
.../src/airflow/providers/dbt/cloud/sensors/dbt.py | 3 +-
.../providers/dbt/cloud/utils/openlineage.py | 79 +-
.../cloud/tests/unit/dbt/cloud/hooks/test_dbt.py | 2 +-
.../tests/unit/dbt/cloud/operators/test_dbt.py | 3 +-
.../cloud/tests/unit/dbt/cloud/sensors/test_dbt.py | 5 +-
.../tests/unit/dbt/cloud/utils/test_openlineage.py | 41 +-
providers/dingding/pyproject.toml | 2 +-
.../airflow/providers/dingding/hooks/dingding.py | 2 +-
providers/discord/pyproject.toml | 2 +-
.../providers/discord/operators/discord_webhook.py | 2 +-
providers/docker/README.rst | 2 +-
providers/docker/docs/changelog.rst | 2 +
providers/docker/docs/index.rst | 2 +-
providers/docker/pyproject.toml | 2 +-
.../airflow/providers/docker/decorators/docker.py | 2 +-
.../src/airflow/providers/docker/exceptions.py | 3 +-
.../src/airflow/providers/docker/hooks/docker.py | 3 +-
.../airflow/providers/docker/operators/docker.py | 22 +-
.../providers/docker/operators/docker_swarm.py | 2 +-
.../tests/unit/docker/decorators/test_docker.py | 2 +-
.../docker/tests/unit/docker/hooks/test_docker.py | 2 +-
.../tests/unit/docker/operators/test_docker.py | 30 +-
.../unit/docker/operators/test_docker_swarm.py | 2 +-
.../docker/tests/unit/docker/test_exceptions.py | 4 +-
providers/edge3/.pre-commit-config.yaml | 4 +-
providers/edge3/README.rst | 4 +-
providers/edge3/docs/architecture.rst | 4 +-
providers/edge3/docs/changelog.rst | 10 +
providers/edge3/docs/deployment.rst | 4 +-
providers/edge3/docs/index.rst | 6 +-
providers/edge3/docs/ui_plugin.rst | 6 +-
providers/edge3/pyproject.toml | 4 +-
.../edge3/src/airflow/providers/edge3/__init__.py | 4 +-
.../src/airflow/providers/edge3/cli/api_client.py | 35 +-
.../src/airflow/providers/edge3/cli/worker.py | 28 +-
.../edge3/example_dags/integration_test.py | 2 +-
.../providers/edge3/example_dags/win_test.py | 7 +-
.../providers/edge3/executors/edge_executor.py | 70 +-
.../airflow/providers/edge3/models/edge_worker.py | 4 +-
.../airflow/providers/edge3/openapi/__init__.py | 19 -
.../edge3/openapi/edge_worker_api_v1.yaml | 808 ----------
.../edge3/plugins/edge_executor_plugin.py | 231 +--
.../providers/edge3/plugins/www/package.json | 2 +-
.../src/airflow/providers/edge3/version_compat.py | 2 -
.../src/airflow/providers/edge3/worker_api/auth.py | 46 +-
.../providers/edge3/worker_api/datamodels.py | 5 +-
.../edge3/worker_api/routes/_v2_compat.py | 144 --
.../edge3/worker_api/routes/_v2_routes.py | 237 ---
.../providers/edge3/worker_api/routes/health.py | 2 +-
.../providers/edge3/worker_api/routes/jobs.py | 21 +-
.../providers/edge3/worker_api/routes/logs.py | 13 +-
.../providers/edge3/worker_api/routes/worker.py | 17 +-
.../{openapi => worker_api}/v2-edge-generated.yaml | 3 +-
.../edge3/tests/unit/edge3/cli/test_worker.py | 68 +-
.../unit/edge3/executors/test_edge_executor.py | 178 +--
.../edge3/plugins/test_edge_executor_plugin.py | 48 +-
.../unit/edge3/worker_api/routes/test_jobs.py | 3 +-
.../unit/edge3/worker_api/routes/test_worker.py | 2 +-
providers/edge3/www-hash.txt | 2 +-
providers/elasticsearch/pyproject.toml | 2 +-
.../providers/elasticsearch/log/es_task_handler.py | 3 +-
providers/fab/.pre-commit-config.yaml | 2 +-
providers/fab/pyproject.toml | 2 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 3 +-
.../providers/fab/auth_manager/models/db.py | 2 +-
.../fab/auth_manager/security_manager/override.py | 2 +-
providers/fab/src/airflow/providers/fab/www/app.py | 12 +-
.../providers/fab/www/extensions/init_security.py | 2 +-
.../airflow/providers/fab/www/package-lock.json | 40 +-
.../fab/src/airflow/providers/fab/www/package.json | 4 +-
.../tests/unit/fab/auth_manager/test_security.py | 2 +-
.../unit/fab/db_manager/test_fab_db_manager.py | 2 +-
providers/fab/www-hash.txt | 2 +-
providers/facebook/pyproject.toml | 2 +-
.../airflow/providers/facebook/ads/hooks/ads.py | 3 +-
providers/git/pyproject.toml | 2 +-
.../git/src/airflow/providers/git/bundles/git.py | 7 +-
.../git/src/airflow/providers/git/hooks/git.py | 3 +-
providers/git/tests/unit/git/bundles/test_git.py | 37 +-
providers/git/tests/unit/git/hooks/test_git.py | 2 +-
providers/github/pyproject.toml | 2 +-
.../airflow/providers/github/operators/github.py | 3 +-
.../src/airflow/providers/github/sensors/github.py | 3 +-
.../github/tests/system/github/example_github.py | 2 +-
providers/google/README.rst | 4 +-
providers/google/docs/changelog.rst | 9 +-
providers/google/docs/index.rst | 4 +-
providers/google/pyproject.toml | 4 +-
.../src/airflow/providers/google/ads/hooks/ads.py | 3 +-
.../airflow/providers/google/cloud/bundles/gcs.py | 2 +-
.../providers/google/cloud/hooks/alloy_db.py | 2 +-
.../providers/google/cloud/hooks/bigquery.py | 7 +-
.../providers/google/cloud/hooks/cloud_batch.py | 2 +-
.../providers/google/cloud/hooks/cloud_build.py | 2 +-
.../providers/google/cloud/hooks/cloud_composer.py | 2 +-
.../google/cloud/hooks/cloud_memorystore.py | 2 +-
.../providers/google/cloud/hooks/cloud_run.py | 2 +-
.../providers/google/cloud/hooks/cloud_sql.py | 2 +-
.../cloud/hooks/cloud_storage_transfer_service.py | 3 +-
.../providers/google/cloud/hooks/compute.py | 2 +-
.../providers/google/cloud/hooks/compute_ssh.py | 2 +-
.../providers/google/cloud/hooks/datacatalog.py | 3 +-
.../providers/google/cloud/hooks/dataflow.py | 4 +-
.../providers/google/cloud/hooks/dataform.py | 2 +-
.../providers/google/cloud/hooks/datafusion.py | 2 +-
.../providers/google/cloud/hooks/dataplex.py | 2 +-
.../providers/google/cloud/hooks/dataproc.py | 2 +-
.../google/cloud/hooks/dataproc_metastore.py | 2 +-
.../airflow/providers/google/cloud/hooks/dlp.py | 2 +-
.../providers/google/cloud/hooks/functions.py | 2 +-
.../airflow/providers/google/cloud/hooks/gcs.py | 4 +-
.../airflow/providers/google/cloud/hooks/gdm.py | 2 +-
.../google/cloud/hooks/kubernetes_engine.py | 2 +-
.../airflow/providers/google/cloud/hooks/looker.py | 3 +-
.../providers/google/cloud/hooks/managed_kafka.py | 2 +-
.../providers/google/cloud/hooks/mlengine.py | 2 +-
.../airflow/providers/google/cloud/hooks/pubsub.py | 3 +
.../providers/google/cloud/hooks/spanner.py | 2 +-
.../providers/google/cloud/hooks/stackdriver.py | 2 +-
.../airflow/providers/google/cloud/hooks/tasks.py | 2 +-
.../providers/google/cloud/hooks/translate.py | 2 +-
.../google/cloud/hooks/vertex_ai/auto_ml.py | 3 +-
.../cloud/hooks/vertex_ai/batch_prediction_job.py | 2 +-
.../google/cloud/hooks/vertex_ai/custom_job.py | 2 +-
.../google/cloud/hooks/vertex_ai/feature_store.py | 2 +-
.../hooks/vertex_ai/hyperparameter_tuning_job.py | 2 +-
.../google/cloud/hooks/vertex_ai/model_service.py | 2 +-
.../google/cloud/hooks/vertex_ai/pipeline_job.py | 2 +-
.../airflow/providers/google/cloud/hooks/vision.py | 2 +-
.../providers/google/cloud/log/gcs_task_handler.py | 2 +-
.../providers/google/cloud/operators/alloy_db.py | 2 +-
.../providers/google/cloud/operators/bigquery.py | 4 +-
.../google/cloud/operators/bigquery_dts.py | 2 +-
.../providers/google/cloud/operators/bigtable.py | 2 +-
.../google/cloud/operators/cloud_batch.py | 2 +-
.../google/cloud/operators/cloud_build.py | 2 +-
.../google/cloud/operators/cloud_composer.py | 2 +-
.../google/cloud/operators/cloud_logging_sink.py | 2 +-
.../providers/google/cloud/operators/cloud_run.py | 2 +-
.../providers/google/cloud/operators/cloud_sql.py | 3 +-
.../operators/cloud_storage_transfer_service.py | 2 +-
.../providers/google/cloud/operators/compute.py | 2 +-
.../providers/google/cloud/operators/dataflow.py | 2 +-
.../providers/google/cloud/operators/datafusion.py | 2 +-
.../providers/google/cloud/operators/dataplex.py | 2 +-
.../providers/google/cloud/operators/dataproc.py | 3 +-
.../google/cloud/operators/dataproc_metastore.py | 2 +-
.../providers/google/cloud/operators/datastore.py | 2 +-
.../providers/google/cloud/operators/functions.py | 2 +-
.../providers/google/cloud/operators/gcs.py | 3 +-
.../google/cloud/operators/kubernetes_engine.py | 3 +-
.../providers/google/cloud/operators/looker.py | 2 +-
.../google/cloud/operators/managed_kafka.py | 2 +-
.../providers/google/cloud/operators/pubsub.py | 9 +-
.../providers/google/cloud/operators/spanner.py | 2 +-
.../google/cloud/operators/speech_to_text.py | 2 +-
.../google/cloud/operators/text_to_speech.py | 2 +-
.../providers/google/cloud/operators/translate.py | 2 +-
.../google/cloud/operators/translate_speech.py | 2 +-
.../operators/vertex_ai/batch_prediction_job.py | 2 +-
.../google/cloud/operators/vertex_ai/custom_job.py | 2 +-
.../google/cloud/operators/vertex_ai/dataset.py | 2 +-
.../operators/vertex_ai/experiment_service.py | 2 +-
.../cloud/operators/vertex_ai/feature_store.py | 2 +-
.../cloud/operators/vertex_ai/generative_model.py | 3 +-
.../vertex_ai/hyperparameter_tuning_job.py | 2 +-
.../cloud/operators/vertex_ai/pipeline_job.py | 2 +-
.../google/cloud/operators/vertex_ai/ray.py | 2 +-
.../google/cloud/secrets/secret_manager.py | 2 +-
.../providers/google/cloud/sensors/bigquery.py | 4 +-
.../providers/google/cloud/sensors/bigquery_dts.py | 3 +-
.../google/cloud/sensors/cloud_composer.py | 3 +-
.../sensors/cloud_storage_transfer_service.py | 3 +-
.../providers/google/cloud/sensors/dataflow.py | 3 +-
.../providers/google/cloud/sensors/dataform.py | 3 +-
.../providers/google/cloud/sensors/datafusion.py | 3 +-
.../providers/google/cloud/sensors/dataplex.py | 3 +-
.../providers/google/cloud/sensors/dataproc.py | 3 +-
.../google/cloud/sensors/dataproc_metastore.py | 3 +-
.../airflow/providers/google/cloud/sensors/gcs.py | 3 +-
.../providers/google/cloud/sensors/looker.py | 3 +-
.../providers/google/cloud/sensors/pubsub.py | 3 +-
.../cloud/sensors/vertex_ai/feature_store.py | 3 +-
.../providers/google/cloud/sensors/workflows.py | 3 +-
.../cloud/transfers/azure_fileshare_to_gcs.py | 3 +-
.../google/cloud/transfers/bigquery_to_gcs.py | 2 +-
.../google/cloud/transfers/cassandra_to_gcs.py | 2 +-
.../google/cloud/transfers/facebook_ads_to_gcs.py | 2 +-
.../google/cloud/transfers/gcs_to_bigquery.py | 2 +-
.../providers/google/cloud/transfers/gcs_to_gcs.py | 3 +-
.../google/cloud/transfers/gcs_to_local.py | 2 +-
.../google/cloud/transfers/gcs_to_sftp.py | 2 +-
.../providers/google/cloud/transfers/s3_to_gcs.py | 2 +-
.../google/cloud/transfers/sftp_to_gcs.py | 2 +-
.../providers/google/cloud/triggers/bigquery.py | 2 +-
.../google/cloud/triggers/cloud_composer.py | 2 +-
.../providers/google/cloud/triggers/cloud_run.py | 2 +-
.../triggers/cloud_storage_transfer_service.py | 2 +-
.../providers/google/cloud/triggers/dataproc.py | 2 +-
.../google/cloud/triggers/kubernetes_engine.py | 3 +-
.../providers/google/cloud/triggers/vertex_ai.py | 2 +-
.../google/cloud/utils/credentials_provider.py | 2 +-
.../google/cloud/utils/field_sanitizer.py | 2 +-
.../google/cloud/utils/field_validator.py | 2 +-
.../providers/google/common/hooks/base_google.py | 3 +-
.../google/common/hooks/operation_helpers.py | 2 +-
.../providers/google/firebase/hooks/firestore.py | 2 +-
.../google/firebase/operators/firestore.py | 2 +-
.../providers/google/leveldb/hooks/leveldb.py | 4 +-
.../marketing_platform/hooks/campaign_manager.py | 2 +-
.../google/marketing_platform/hooks/search_ads.py | 2 +-
.../operators/analytics_admin.py | 2 +-
.../operators/campaign_manager.py | 2 +-
.../marketing_platform/sensors/display_video.py | 3 +-
.../providers/google/suite/hooks/calendar.py | 2 +-
.../airflow/providers/google/suite/hooks/sheets.py | 2 +-
.../google/suite/transfers/gcs_to_gdrive.py | 2 +-
.../cloud_build/example_cloud_build_trigger.py | 2 +-
.../cloud/composer/example_cloud_composer.py | 2 +-
.../example_dataflow_native_python_async.py | 2 +-
.../example_dataflow_sensors_deferrable.py | 2 +-
.../google/tests/unit/google/ads/hooks/test_ads.py | 2 +-
.../tests/unit/google/cloud/hooks/test_alloy_db.py | 2 +-
.../tests/unit/google/cloud/hooks/test_bigquery.py | 3 +-
.../unit/google/cloud/hooks/test_cloud_batch.py | 2 +-
.../unit/google/cloud/hooks/test_cloud_build.py | 2 +-
.../google/cloud/hooks/test_cloud_memorystore.py | 2 +-
.../unit/google/cloud/hooks/test_cloud_run.py | 2 +-
.../unit/google/cloud/hooks/test_cloud_sql.py | 2 +-
.../hooks/test_cloud_storage_transfer_service.py | 2 +-
.../test_cloud_storage_transfer_service_async.py | 2 +-
.../tests/unit/google/cloud/hooks/test_compute.py | 2 +-
.../unit/google/cloud/hooks/test_compute_ssh.py | 2 +-
.../unit/google/cloud/hooks/test_datacatalog.py | 3 +-
.../tests/unit/google/cloud/hooks/test_dataflow.py | 2 +-
.../tests/unit/google/cloud/hooks/test_dataform.py | 2 +-
.../unit/google/cloud/hooks/test_datafusion.py | 2 +-
.../tests/unit/google/cloud/hooks/test_dataproc.py | 2 +-
.../unit/google/cloud/hooks/test_datastore.py | 2 +-
.../tests/unit/google/cloud/hooks/test_dlp.py | 2 +-
.../unit/google/cloud/hooks/test_functions.py | 2 +-
.../tests/unit/google/cloud/hooks/test_gcs.py | 2 +-
.../tests/unit/google/cloud/hooks/test_gdm.py | 2 +-
.../google/cloud/hooks/test_kubernetes_engine.py | 2 +-
.../tests/unit/google/cloud/hooks/test_looker.py | 2 +-
.../tests/unit/google/cloud/hooks/test_mlengine.py | 2 +-
.../tests/unit/google/cloud/hooks/test_os_login.py | 2 +-
.../tests/unit/google/cloud/hooks/test_pubsub.py | 50 +-
.../tests/unit/google/cloud/hooks/test_vision.py | 2 +-
.../hooks/vertex_ai/test_batch_prediction_job.py | 2 +-
.../cloud/hooks/vertex_ai/test_custom_job.py | 2 +-
.../vertex_ai/test_hyperparameter_tuning_job.py | 2 +-
.../cloud/hooks/vertex_ai/test_pipeline_job.py | 2 +-
.../unit/google/cloud/openlineage/test_utils.py | 37 +-
.../unit/google/cloud/operators/test_alloy_db.py | 2 +-
.../unit/google/cloud/operators/test_bigquery.py | 12 +-
.../unit/google/cloud/operators/test_bigtable.py | 2 +-
.../google/cloud/operators/test_cloud_batch.py | 2 +-
.../google/cloud/operators/test_cloud_build.py | 2 +-
.../google/cloud/operators/test_cloud_composer.py | 2 +-
.../cloud/operators/test_cloud_logging_sink.py | 2 +-
.../unit/google/cloud/operators/test_cloud_run.py | 2 +-
.../unit/google/cloud/operators/test_cloud_sql.py | 2 +-
.../test_cloud_storage_transfer_service.py | 2 +-
.../unit/google/cloud/operators/test_compute.py | 2 +-
.../unit/google/cloud/operators/test_dataflow.py | 2 +-
.../unit/google/cloud/operators/test_datafusion.py | 2 +-
.../unit/google/cloud/operators/test_dataplex.py | 2 +-
.../unit/google/cloud/operators/test_dataproc.py | 98 +-
.../unit/google/cloud/operators/test_functions.py | 2 +-
.../cloud/operators/test_kubernetes_engine.py | 6 +-
.../unit/google/cloud/operators/test_looker.py | 2 +-
.../unit/google/cloud/operators/test_pubsub.py | 45 +-
.../unit/google/cloud/operators/test_spanner.py | 2 +-
.../google/cloud/operators/test_speech_to_text.py | 2 +-
.../google/cloud/operators/test_text_to_speech.py | 2 +-
.../cloud/operators/test_translate_speech.py | 2 +-
.../unit/google/cloud/operators/test_vertex_ai.py | 3 +-
.../google/cloud/secrets/test_secret_manager.py | 2 +-
.../unit/google/cloud/sensors/test_bigquery.py | 5 +-
.../unit/google/cloud/sensors/test_bigquery_dts.py | 2 +-
.../unit/google/cloud/sensors/test_bigtable.py | 2 +-
.../sensors/test_cloud_storage_transfer_service.py | 2 +-
.../unit/google/cloud/sensors/test_dataflow.py | 2 +-
.../unit/google/cloud/sensors/test_dataform.py | 2 +-
.../unit/google/cloud/sensors/test_datafusion.py | 2 +-
.../unit/google/cloud/sensors/test_dataplex.py | 2 +-
.../unit/google/cloud/sensors/test_dataproc.py | 2 +-
.../cloud/sensors/test_dataproc_metastore.py | 2 +-
.../tests/unit/google/cloud/sensors/test_gcs.py | 2 +-
.../tests/unit/google/cloud/sensors/test_looker.py | 2 +-
.../tests/unit/google/cloud/sensors/test_pubsub.py | 2 +-
.../unit/google/cloud/sensors/test_vertex_ai.py | 2 +-
.../unit/google/cloud/sensors/test_workflows.py | 2 +-
.../google/cloud/transfers/test_bigquery_to_gcs.py | 2 +-
.../google/cloud/transfers/test_gcs_to_bigquery.py | 2 +-
.../unit/google/cloud/transfers/test_gcs_to_gcs.py | 3 +-
.../google/cloud/transfers/test_gcs_to_local.py | 2 +-
.../google/cloud/transfers/test_gcs_to_sftp.py | 2 +-
.../unit/google/cloud/transfers/test_s3_to_gcs.py | 2 +-
.../google/cloud/transfers/test_sftp_to_gcs.py | 2 +-
.../test_cloud_storage_transfer_service.py | 2 +-
.../unit/google/cloud/triggers/test_vertex_ai.py | 2 +-
.../unit/google/cloud/utils/gcp_authenticator.py | 2 +-
.../cloud/utils/test_credentials_provider.py | 2 +-
.../unit/google/common/hooks/test_base_google.py | 2 +-
.../unit/google/firebase/hooks/test_firestore.py | 2 +-
.../operators/test_analytics_admin.py | 2 +-
.../sensors/test_display_video.py | 2 +-
.../tests/unit/google/suite/hooks/test_sheets.py | 2 +-
.../google/suite/transfers/test_gcs_to_gdrive.py | 2 +-
providers/http/pyproject.toml | 2 +-
.../http/src/airflow/providers/http/exceptions.py | 2 +-
.../http/src/airflow/providers/http/hooks/http.py | 3 +-
.../src/airflow/providers/http/operators/http.py | 5 +-
.../src/airflow/providers/http/sensors/http.py | 3 +-
.../src/airflow/providers/http/triggers/http.py | 2 +-
providers/http/tests/unit/http/hooks/test_http.py | 2 +-
.../http/tests/unit/http/operators/test_http.py | 2 +-
.../http/tests/unit/http/sensors/test_http.py | 2 +-
providers/imap/pyproject.toml | 2 +-
.../imap/src/airflow/providers/imap/hooks/imap.py | 3 +-
providers/imap/tests/unit/imap/hooks/test_imap.py | 2 +-
providers/jdbc/pyproject.toml | 2 +-
.../jdbc/src/airflow/providers/jdbc/hooks/jdbc.py | 2 +-
providers/jdbc/tests/unit/jdbc/hooks/test_jdbc.py | 2 +-
providers/jenkins/pyproject.toml | 2 +-
.../jenkins/operators/jenkins_job_trigger.py | 3 +-
.../airflow/providers/jenkins/sensors/jenkins.py | 3 +-
.../jenkins/operators/test_jenkins_job_trigger.py | 2 +-
.../tests/unit/jenkins/sensors/test_jenkins.py | 2 +-
providers/keycloak/.pre-commit-config.yaml | 2 +-
providers/keycloak/provider.yaml | 1 +
providers/keycloak/pyproject.toml | 2 +
.../keycloak/auth_manager/keycloak_auth_manager.py | 2 +-
.../providers/keycloak/get_provider_info.py | 1 +
.../auth_manager/test_keycloak_auth_manager.py | 2 +-
providers/microsoft/azure/README.rst | 2 +-
providers/microsoft/azure/docs/changelog.rst | 2 +
providers/microsoft/azure/docs/index.rst | 2 +-
providers/microsoft/azure/docs/logging/index.rst | 2 +-
providers/microsoft/azure/pyproject.toml | 2 +-
.../airflow/providers/microsoft/azure/hooks/adx.py | 3 +-
.../providers/microsoft/azure/hooks/base_azure.py | 3 +-
.../providers/microsoft/azure/hooks/batch.py | 3 +-
.../microsoft/azure/hooks/container_instance.py | 2 +-
.../providers/microsoft/azure/hooks/cosmos.py | 4 +-
.../microsoft/azure/hooks/data_factory.py | 3 +-
.../providers/microsoft/azure/hooks/data_lake.py | 3 +-
.../providers/microsoft/azure/hooks/msgraph.py | 10 +-
.../providers/microsoft/azure/hooks/powerbi.py | 2 +-
.../providers/microsoft/azure/hooks/synapse.py | 3 +-
.../providers/microsoft/azure/hooks/wasb.py | 3 +-
.../providers/microsoft/azure/operators/batch.py | 3 +-
.../azure/operators/container_instances.py | 3 +-
.../microsoft/azure/operators/data_factory.py | 9 +-
.../providers/microsoft/azure/operators/msgraph.py | 4 +-
.../providers/microsoft/azure/operators/powerbi.py | 3 +-
.../providers/microsoft/azure/operators/synapse.py | 9 +-
.../microsoft/azure/sensors/data_factory.py | 3 +-
.../providers/microsoft/azure/sensors/msgraph.py | 3 +-
.../providers/microsoft/azure/sensors/wasb.py | 3 +-
.../microsoft/azure/transfers/local_to_adls.py | 3 +-
.../microsoft/azure/transfers/sftp_to_wasb.py | 3 +-
.../tests/unit/microsoft/azure/hooks/test_adx.py | 2 +-
.../unit/microsoft/azure/hooks/test_cosmos.py | 2 +-
.../microsoft/azure/hooks/test_data_factory.py | 2 +-
.../unit/microsoft/azure/hooks/test_msgraph.py | 9 +-
.../unit/microsoft/azure/hooks/test_powerbi.py | 2 +-
.../unit/microsoft/azure/hooks/test_synapse.py | 2 +-
.../tests/unit/microsoft/azure/hooks/test_wasb.py | 2 +-
.../unit/microsoft/azure/operators/test_batch.py | 2 +-
.../azure/operators/test_container_instances.py | 2 +-
.../microsoft/azure/operators/test_data_factory.py | 2 +-
.../unit/microsoft/azure/operators/test_msgraph.py | 4 +-
.../unit/microsoft/azure/operators/test_powerbi.py | 3 +-
.../microsoft/azure/operators/test_powerbi_list.py | 3 +-
.../unit/microsoft/azure/operators/test_synapse.py | 2 +-
.../microsoft/azure/sensors/test_data_factory.py | 2 +-
.../unit/microsoft/azure/sensors/test_wasb.py | 2 +-
.../azure/transfers/test_local_to_adls.py | 2 +-
.../microsoft/azure/transfers/test_sftp_to_wasb.py | 2 +-
.../unit/microsoft/azure/triggers/test_msgraph.py | 2 +-
providers/microsoft/psrp/pyproject.toml | 2 +-
.../airflow/providers/microsoft/psrp/hooks/psrp.py | 3 +-
.../providers/microsoft/psrp/operators/psrp.py | 3 +-
.../tests/unit/microsoft/psrp/hooks/test_psrp.py | 2 +-
.../unit/microsoft/psrp/operators/test_psrp.py | 3 +-
providers/microsoft/winrm/pyproject.toml | 2 +-
.../providers/microsoft/winrm/hooks/winrm.py | 3 +-
.../providers/microsoft/winrm/operators/winrm.py | 3 +-
.../tests/unit/microsoft/winrm/hooks/test_winrm.py | 2 +-
.../unit/microsoft/winrm/operators/test_winrm.py | 2 +-
providers/neo4j/pyproject.toml | 2 +-
.../src/airflow/providers/neo4j/sensors/neo4j.py | 3 +-
.../neo4j/tests/unit/neo4j/sensors/test_neo4j.py | 3 +-
providers/openai/pyproject.toml | 2 +-
.../src/airflow/providers/openai/exceptions.py | 2 +-
.../tests/unit/openai/operators/test_openai.py | 3 +-
providers/openfaas/pyproject.toml | 2 +-
.../airflow/providers/openfaas/hooks/openfaas.py | 3 +-
.../tests/unit/openfaas/hooks/test_openfaas.py | 2 +-
providers/openlineage/pyproject.toml | 2 +-
.../providers/openlineage/plugins/adapter.py | 2 +-
.../providers/openlineage/plugins/listener.py | 12 +-
.../airflow/providers/openlineage/utils/utils.py | 44 +-
.../example_openlineage_defer_simple_dag.py | 10 +-
.../example_openlineage_mapped_simple_dag.py | 4 +-
... example_openlineage_trigger_dag_deferrable.py} | 51 +-
.../expected_events/openlineage_trigger_dag.json | 298 ++--
.../openlineage_trigger_dag_deferrable.json | 660 ++++++++
.../tests/system/openlineage/operator.py | 16 +-
.../tests/unit/openlineage/utils/test_spark.py | 31 +-
.../tests/unit/openlineage/utils/test_utils.py | 150 +-
providers/opensearch/pyproject.toml | 2 +-
.../providers/opensearch/hooks/opensearch.py | 3 +-
.../providers/opensearch/log/os_task_handler.py | 2 +-
.../providers/opensearch/operators/opensearch.py | 3 +-
.../tests/unit/opensearch/hooks/test_opensearch.py | 2 +-
providers/pagerduty/pyproject.toml | 2 +-
.../airflow/providers/pagerduty/hooks/pagerduty.py | 3 +-
.../providers/pagerduty/hooks/pagerduty_events.py | 3 +-
.../system/pinecone/example_create_pod_index.py | 13 +-
.../system/pinecone/example_pinecone_cohere.py | 32 +-
.../system/pinecone/example_pinecone_openai.py | 10 +-
providers/postgres/pyproject.toml | 2 +-
.../airflow/providers/postgres/hooks/postgres.py | 7 +-
.../tests/unit/postgres/hooks/test_postgres.py | 3 +-
providers/presto/pyproject.toml | 2 +-
.../src/airflow/providers/presto/hooks/presto.py | 7 +-
.../presto/tests/unit/presto/hooks/test_presto.py | 2 +-
.../tests/unit/presto/hooks/test_presto_sql.py | 2 +-
providers/redis/pyproject.toml | 2 +-
.../redis/triggers/redis_await_message.py | 4 +
.../redis/triggers/test_redis_await_message.py | 23 +
providers/salesforce/pyproject.toml | 2 +-
.../tests/unit/salesforce/operators/test_bulk.py | 2 +-
providers/samba/pyproject.toml | 2 +-
.../providers/samba/transfers/gcs_to_samba.py | 3 +-
.../samba/tests/unit/samba/hooks/test_samba.py | 2 +-
.../unit/samba/transfers/test_gcs_to_samba.py | 2 +-
providers/segment/pyproject.toml | 2 +-
.../src/airflow/providers/segment/hooks/segment.py | 3 +-
.../tests/unit/segment/hooks/test_segment.py | 2 +-
.../segment/operators/test_segment_track_event.py | 2 +-
providers/sftp/pyproject.toml | 2 +-
.../sftp/src/airflow/providers/sftp/exceptions.py | 2 +-
.../sftp/src/airflow/providers/sftp/hooks/sftp.py | 34 +-
.../src/airflow/providers/sftp/operators/sftp.py | 3 +-
.../src/airflow/providers/sftp/sensors/sftp.py | 3 +-
.../src/airflow/providers/sftp/triggers/sftp.py | 2 +-
providers/sftp/tests/unit/sftp/hooks/test_sftp.py | 63 +-
.../sftp/tests/unit/sftp/operators/test_sftp.py | 2 +-
.../sftp/tests/unit/sftp/sensors/test_sftp.py | 2 +-
.../sftp/tests/unit/sftp/triggers/test_sftp.py | 2 +-
providers/singularity/pyproject.toml | 2 +-
.../providers/singularity/operators/singularity.py | 3 +-
.../unit/singularity/operators/test_singularity.py | 2 +-
providers/slack/README.rst | 2 +-
providers/slack/docs/changelog.rst | 2 +
providers/slack/docs/index.rst | 2 +-
providers/slack/pyproject.toml | 2 +-
.../src/airflow/providers/slack/hooks/slack.py | 3 +-
.../airflow/providers/slack/hooks/slack_webhook.py | 3 +-
.../providers/slack/transfers/base_sql_to_slack.py | 3 +-
.../providers/slack/transfers/sql_to_slack.py | 4 +-
.../slack/transfers/sql_to_slack_webhook.py | 2 +-
.../slack/tests/unit/slack/hooks/test_slack.py | 2 +-
.../tests/unit/slack/hooks/test_slack_webhook.py | 2 +-
.../unit/slack/transfers/test_base_sql_to_slack.py | 2 +-
.../unit/slack/transfers/test_sql_to_slack.py | 2 +-
providers/smtp/pyproject.toml | 2 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 3 +-
.../src/airflow/providers/smtp/operators/smtp.py | 3 +-
providers/smtp/tests/unit/smtp/hooks/test_smtp.py | 2 +-
providers/snowflake/docs/connections/snowflake.rst | 1 +
providers/snowflake/pyproject.toml | 2 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 12 +-
.../providers/snowflake/hooks/snowflake_sql_api.py | 3 +-
.../providers/snowflake/operators/snowflake.py | 2 +-
.../providers/snowflake/utils/openlineage.py | 88 +-
.../tests/unit/snowflake/hooks/test_snowflake.py | 110 +-
.../unit/snowflake/hooks/test_snowflake_sql_api.py | 3 +-
.../unit/snowflake/operators/test_snowflake.py | 2 +-
.../tests/unit/snowflake/utils/test_openlineage.py | 59 +-
providers/ssh/README.rst | 2 +-
providers/ssh/docs/changelog.rst | 2 +
providers/ssh/docs/index.rst | 2 +-
providers/ssh/pyproject.toml | 2 +-
.../ssh/src/airflow/providers/ssh/hooks/ssh.py | 3 +-
.../ssh/src/airflow/providers/ssh/operators/ssh.py | 3 +-
providers/ssh/tests/unit/ssh/hooks/test_ssh.py | 2 +-
providers/ssh/tests/unit/ssh/operators/test_ssh.py | 8 +-
providers/standard/README.rst | 2 +-
providers/standard/docs/changelog.rst | 4 +
providers/standard/docs/index.rst | 2 +-
providers/standard/pyproject.toml | 2 +-
.../src/airflow/providers/standard/exceptions.py | 2 +-
.../airflow/providers/standard/operators/bash.py | 7 +-
.../providers/standard/operators/datetime.py | 3 +-
.../providers/standard/operators/latest_only.py | 25 +-
.../airflow/providers/standard/operators/python.py | 3 +-
.../providers/standard/operators/trigger_dagrun.py | 24 +-
.../providers/standard/sensors/filesystem.py | 3 +-
.../providers/standard/utils/python_virtualenv.py | 3 +-
.../airflow/providers/standard/utils/skipmixin.py | 2 +-
.../tests/unit/standard/decorators/test_bash.py | 2 +-
.../decorators/test_branch_external_python.py | 2 +-
.../unit/standard/decorators/test_branch_python.py | 2 +-
.../standard/decorators/test_branch_virtualenv.py | 2 +-
.../tests/unit/standard/decorators/test_python.py | 6 +-
.../tests/unit/standard/decorators/test_sensor.py | 2 +-
.../unit/standard/decorators/test_short_circuit.py | 2 +-
.../tests/unit/standard/operators/test_bash.py | 2 +-
.../standard/operators/test_branch_operator.py | 2 +-
.../tests/unit/standard/operators/test_datetime.py | 16 +-
.../tests/unit/standard/operators/test_hitl.py | 2 +-
.../operators/test_latest_only_operator.py | 2 +-
.../tests/unit/standard/operators/test_python.py | 61 +-
.../unit/standard/operators/test_trigger_dagrun.py | 5 +-
.../tests/unit/standard/operators/test_weekday.py | 10 +-
.../tests/unit/standard/sensors/test_bash.py | 2 +-
.../standard/sensors/test_external_task_sensor.py | 14 +-
.../tests/unit/standard/sensors/test_filesystem.py | 2 +-
.../tests/unit/standard/sensors/test_python.py | 2 +-
.../tests/unit/standard/sensors/test_time.py | 2 +-
.../tests/unit/standard/sensors/test_time_delta.py | 3 +-
.../tests/unit/standard/sensors/test_weekday.py | 2 +-
.../unit/standard/utils/test_python_virtualenv.py | 48 +-
.../unit/standard/utils/test_sensor_helper.py | 14 +-
.../tests/unit/standard/utils/test_skipmixin.py | 4 +-
providers/tableau/pyproject.toml | 2 +-
.../src/airflow/providers/tableau/hooks/tableau.py | 3 +-
.../airflow/providers/tableau/operators/tableau.py | 3 +-
.../tests/unit/tableau/hooks/test_tableau.py | 2 +-
.../tests/unit/tableau/operators/test_tableau.py | 2 +-
.../tests/unit/tableau/sensors/test_tableau.py | 2 +-
providers/telegram/pyproject.toml | 2 +-
.../airflow/providers/telegram/hooks/telegram.py | 3 +-
.../providers/telegram/operators/telegram.py | 3 +-
providers/teradata/pyproject.toml | 2 +-
.../src/airflow/providers/teradata/hooks/bteq.py | 2 +-
.../src/airflow/providers/teradata/hooks/ttu.py | 3 +-
.../teradata/operators/teradata_compute_cluster.py | 2 +-
.../teradata/triggers/teradata_compute_cluster.py | 2 +-
.../airflow/providers/teradata/utils/bteq_util.py | 2 +-
.../tests/unit/teradata/hooks/test_bteq.py | 2 +-
.../teradata/tests/unit/teradata/hooks/test_ttu.py | 2 +-
.../tests/unit/teradata/operators/test_teradata.py | 2 +-
.../operators/test_teradata_compute_cluster.py | 2 +-
.../tests/unit/teradata/utils/test_bteq_util.py | 2 +-
providers/trino/pyproject.toml | 2 +-
.../src/airflow/providers/trino/hooks/trino.py | 7 +-
.../trino/tests/unit/trino/hooks/test_trino.py | 2 +-
.../tests/unit/vertica/hooks/test_vertica_sql.py | 2 +-
.../system/weaviate/example_weaviate_cohere.py | 9 +
.../example_weaviate_dynamic_mapping_dag.py | 9 +
.../system/weaviate/example_weaviate_openai.py | 8 +
.../system/weaviate/example_weaviate_operator.py | 10 +
.../system/weaviate/example_weaviate_using_hook.py | 9 +
.../weaviate/example_weaviate_vectorizer_dag.py | 9 +
.../example_weaviate_without_vectorizer_dag.py | 9 +
providers/ydb/pyproject.toml | 2 +
.../ydb/src/airflow/providers/ydb/hooks/ydb.py | 2 +-
.../ydb/src/airflow/providers/ydb/operators/ydb.py | 2 +-
pyproject.toml | 15 +-
scripts/ci/prek/check_imports_in_providers.py | 2 +-
scripts/ci/prek/check_lazy_logging.py | 2 +-
.../check_template_context_variable_in_sync.py | 4 +-
scripts/ci/prek/check_tests_in_right_folders.py | 1 +
scripts/ci/prek/ruff_format.py | 2 +-
scripts/ci/prek/update_airflow_pyproject_toml.py | 8 +-
scripts/docker/entrypoint_ci.sh | 6 +-
scripts/docker/install_os_dependencies.sh | 2 +-
.../run_generate_openapi_spec_providers.py | 2 +-
scripts/in_container/run_schema_defaults_check.py | 5 +
scripts/tools/setup_breeze | 4 +-
.../src/airflow_shared/configuration/parser.py | 1 +
.../airflow_shared/logging/percent_formatter.py | 10 +
.../tests/logging/test_percent_formatter.py | 14 +-
shared/{timezones => observability}/pyproject.toml | 20 +-
.../src/airflow_shared/observability}/__init__.py | 10 +-
.../src/airflow_shared/observability/exceptions.py | 7 +-
.../observability/metrics}/__init__.py | 0
.../observability}/metrics/base_stats_logger.py | 4 +-
.../observability}/metrics/datadog_logger.py | 49 +-
.../observability}/metrics/otel_logger.py | 47 +-
.../observability}/metrics/protocols.py | 2 +-
.../observability}/metrics/statsd_logger.py | 70 +-
.../observability}/metrics/validators.py | 40 +-
.../observability}/traces/__init__.py | 0
.../observability/traces/base_tracer.py | 108 +-
.../observability}/traces/otel_tracer.py | 53 +-
.../airflow_shared/observability/traces/utils.py | 36 +-
.../tests/conftest.py | 0
.../observability/tests/observability}/__init__.py | 0
.../tests/observability/metrics}/__init__.py | 0
.../observability/metrics}/test_otel_logger.py | 9 +-
.../tests/observability}/test_otel_utils.py | 8 +-
.../pyproject.toml | 15 +-
.../src/airflow_shared/secrets_backend/__init__.py | 5 +-
.../src/airflow_shared/secrets_backend/base.py | 82 +-
.../tests/conftest.py | 16 +
.../tests/secrets_backend}/__init__.py | 0
.../tests/secrets_backend/test_base.py | 95 ++
.../src/airflow_shared/timezones/timezone.py | 26 +-
task-sdk-integration-tests/dags/test_dag.py | 11 +-
task-sdk-integration-tests/docker-compose.yaml | 2 +-
.../tests/task_sdk_tests/test_asset_operations.py | 36 +-
.../tests/task_sdk_tests/test_xcom_operations.py | 235 ++-
task-sdk/.pre-commit-config.yaml | 2 +-
task-sdk/docs/api.rst | 26 +
task-sdk/pyproject.toml | 17 +-
task-sdk/src/airflow/sdk/__init__.py | 34 +
task-sdk/src/airflow/sdk/__init__.pyi | 24 +-
task-sdk/src/airflow/sdk/_shared/observability | 1 +
task-sdk/src/airflow/sdk/_shared/secrets_backend | 1 +
task-sdk/src/airflow/sdk/api/client.py | 2 +-
.../src/airflow/sdk/bases/secrets_backend.py | 6 +-
task-sdk/src/airflow/sdk/bases/timetable.py | 102 ++
task-sdk/src/airflow/sdk/configuration.py | 4 +-
.../src/airflow/sdk/definitions/asset/__init__.py | 2 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 61 +-
.../sdk/definitions/timetables}/__init__.py | 0
.../{asset/metadata.py => timetables/_cron.py} | 25 +-
.../{asset/metadata.py => timetables/_delta.py} | 22 +-
.../airflow/sdk/definitions/timetables/assets.py | 68 +
.../airflow/sdk/definitions/timetables/events.py | 68 +
.../airflow/sdk/definitions/timetables/interval.py | 54 +
.../airflow/sdk/definitions/timetables/simple.py | 32 +-
.../airflow/sdk/definitions/timetables/trigger.py | 116 ++
task-sdk/src/airflow/sdk/exceptions.py | 4 +
.../sdk/execution_time/secrets/execution_api.py | 2 +-
.../src/airflow/sdk/execution_time/supervisor.py | 2 +-
.../src/airflow/sdk/execution_time/task_runner.py | 14 +-
task-sdk/src/airflow/sdk/io/fs.py | 2 +-
.../src/airflow/sdk/observability}/__init__.py | 0
.../airflow/sdk/observability/metrics}/__init__.py | 0
.../sdk/observability/metrics/datadog_logger.py | 40 +
.../sdk/observability/metrics/otel_logger.py | 43 +
.../sdk/observability/metrics/statsd_logger.py | 63 +
.../src/airflow/sdk/observability}/stats.py | 12 +-
task-sdk/src/airflow/sdk/observability/trace.py | 122 ++
.../airflow/sdk/observability/traces}/__init__.py | 0
.../sdk/observability/traces/otel_tracer.py | 38 +-
task-sdk/src/airflow/sdk/timezone.py | 9 +
task-sdk/tests/task_sdk/api/test_client.py | 2 +-
task-sdk/tests/task_sdk/definitions/test_dag.py | 4 +-
.../tests/task_sdk/docs/test_docs_inventory.py | 3 +-
task-sdk/tests/task_sdk/docs/test_public_api.py | 1 +
.../tests/task_sdk/execution_time/test_sentry.py | 7 +-
1252 files changed, 10656 insertions(+), 7120 deletions(-)
create mode 100644 airflow-core/docs/howto/performance.rst
create mode 120000 airflow-core/src/airflow/_shared/observability
create mode 120000 airflow-core/src/airflow/_shared/secrets_backend
rename airflow-core/src/airflow/{metrics => observability}/__init__.py (100%)
copy airflow-core/src/airflow/{_shared => observability/metrics}/__init__.py
(100%)
create mode 100644
airflow-core/src/airflow/observability/metrics/datadog_logger.py
create mode 100644
airflow-core/src/airflow/observability/metrics/otel_logger.py
create mode 100644
airflow-core/src/airflow/observability/metrics/statsd_logger.py
copy airflow-core/src/airflow/{ => observability}/stats.py (87%)
create mode 100644 airflow-core/src/airflow/observability/trace.py
copy airflow-core/src/airflow/{api/common => observability/traces}/__init__.py
(100%)
copy
providers/fab/src/airflow/providers/fab/www/extensions/init_wsgi_middlewares.py
=> airflow-core/src/airflow/observability/traces/otel_tracer.py (55%)
create mode 100644 airflow-core/src/airflow/serialization/decoders.py
copy airflow-core/src/airflow/{api_fastapi/auth/managers/models/base_user.py
=> serialization/definitions/assets.py} (80%)
create mode 100644 airflow-core/src/airflow/serialization/encoders.py
delete mode 100644 airflow-core/src/airflow/traces/utils.py
create mode 100644 airflow-core/src/airflow/ui/src/components/BasicTooltip.tsx
delete mode 100644 airflow-core/src/airflow/ui/src/components/HoverTooltip.tsx
copy airflow-core/{src/airflow/_shared =>
tests/unit/observability}/__init__.py (100%)
copy airflow-core/{src/airflow/_shared =>
tests/unit/observability/metrics}/__init__.py (100%)
rename airflow-core/tests/unit/{core => observability/metrics}/test_stats.py
(80%)
copy airflow-core/{src/airflow/_shared =>
tests/unit/observability/traces}/__init__.py (100%)
rename airflow-core/tests/unit/{core =>
observability/traces}/test_otel_tracer.py (90%)
copy chart/templates/api-server/{api-server-poddisruptionbudget.yaml =>
api-server-hpa.yaml} (63%)
create mode 100755 dev/verify_release_calendar.py
copy helm-tests/tests/helm_tests/{webserver/test_hpa_webserver.py =>
apiserver/test_hpa_apiserver.py} (83%)
delete mode 100644
providers/edge3/src/airflow/providers/edge3/openapi/__init__.py
delete mode 100644
providers/edge3/src/airflow/providers/edge3/openapi/edge_worker_api_v1.yaml
delete mode 100644
providers/edge3/src/airflow/providers/edge3/worker_api/routes/_v2_compat.py
delete mode 100644
providers/edge3/src/airflow/providers/edge3/worker_api/routes/_v2_routes.py
rename providers/edge3/src/airflow/providers/edge3/{openapi =>
worker_api}/v2-edge-generated.yaml (99%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_trigger_dag.py
=> example_openlineage_trigger_dag_deferrable.py} (64%)
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_trigger_dag_deferrable.json
copy providers/slack/tests/unit/slack/transfers/conftest.py =>
shared/logging/tests/logging/test_percent_formatter.py (70%)
copy shared/{timezones => observability}/pyproject.toml (72%)
copy {providers/edge3/src/airflow/providers/edge3/executors =>
shared/observability/src/airflow_shared/observability}/__init__.py (85%)
copy airflow-core/src/airflow/version.py =>
shared/observability/src/airflow_shared/observability/exceptions.py (86%)
copy {airflow-core/src/airflow/_shared =>
shared/observability/src/airflow_shared/observability/metrics}/__init__.py
(100%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/metrics/base_stats_logger.py
(96%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/metrics/datadog_logger.py
(80%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/metrics/otel_logger.py
(92%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/metrics/protocols.py
(98%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/metrics/statsd_logger.py
(73%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/metrics/validators.py
(91%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/traces/__init__.py (100%)
rename airflow-core/src/airflow/traces/tracer.py =>
shared/observability/src/airflow_shared/observability/traces/base_tracer.py
(60%)
rename {airflow-core/src/airflow =>
shared/observability/src/airflow_shared/observability}/traces/otel_tracer.py
(92%)
copy airflow-core/src/airflow/utils/dates.py =>
shared/observability/src/airflow_shared/observability/traces/utils.py (57%)
copy shared/{secrets_masker => observability}/tests/conftest.py (100%)
copy {airflow-core/src/airflow/_shared =>
shared/observability/tests/observability}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
shared/observability/tests/observability/metrics}/__init__.py (100%)
rename {airflow-core/tests/unit/core =>
shared/observability/tests/observability/metrics}/test_otel_logger.py (97%)
rename {airflow-core/tests/unit/utils =>
shared/observability/tests/observability}/test_otel_utils.py (98%)
copy shared/{secrets_masker => secrets_backend}/pyproject.toml (83%)
copy airflow-core/src/airflow/example_dags/libs/helper.py =>
shared/secrets_backend/src/airflow_shared/secrets_backend/__init__.py (92%)
copy airflow-core/src/airflow/secrets/base_secrets.py =>
shared/secrets_backend/src/airflow_shared/secrets_backend/base.py (68%)
copy shared/{configuration => secrets_backend}/tests/conftest.py (68%)
copy {airflow-core/src/airflow/api/common =>
shared/secrets_backend/tests/secrets_backend}/__init__.py (100%)
create mode 100644 shared/secrets_backend/tests/secrets_backend/test_base.py
create mode 120000 task-sdk/src/airflow/sdk/_shared/observability
create mode 120000 task-sdk/src/airflow/sdk/_shared/secrets_backend
copy airflow-core/src/airflow/models/skipmixin.py =>
task-sdk/src/airflow/sdk/bases/secrets_backend.py (87%)
create mode 100644 task-sdk/src/airflow/sdk/bases/timetable.py
copy {airflow-core/src/airflow/_shared =>
task-sdk/src/airflow/sdk/definitions/timetables}/__init__.py (100%)
copy task-sdk/src/airflow/sdk/definitions/{asset/metadata.py =>
timetables/_cron.py} (61%)
copy task-sdk/src/airflow/sdk/definitions/{asset/metadata.py =>
timetables/_delta.py} (64%)
create mode 100644 task-sdk/src/airflow/sdk/definitions/timetables/assets.py
create mode 100644 task-sdk/src/airflow/sdk/definitions/timetables/events.py
create mode 100644 task-sdk/src/airflow/sdk/definitions/timetables/interval.py
copy airflow-core/src/airflow/listeners/spec/lifecycle.py =>
task-sdk/src/airflow/sdk/definitions/timetables/simple.py (59%)
create mode 100644 task-sdk/src/airflow/sdk/definitions/timetables/trigger.py
copy {airflow-core/src/airflow/_shared =>
task-sdk/src/airflow/sdk/observability}/__init__.py (100%)
copy {airflow-core/src/airflow/_shared =>
task-sdk/src/airflow/sdk/observability/metrics}/__init__.py (100%)
create mode 100644
task-sdk/src/airflow/sdk/observability/metrics/datadog_logger.py
create mode 100644
task-sdk/src/airflow/sdk/observability/metrics/otel_logger.py
create mode 100644
task-sdk/src/airflow/sdk/observability/metrics/statsd_logger.py
rename {airflow-core/src/airflow =>
task-sdk/src/airflow/sdk/observability}/stats.py (85%)
create mode 100644 task-sdk/src/airflow/sdk/observability/trace.py
copy {airflow-core/src/airflow/api/common =>
task-sdk/src/airflow/sdk/observability/traces}/__init__.py (100%)
copy devel-common/src/sphinx_exts/providers_packages_ref.py =>
task-sdk/src/airflow/sdk/observability/traces/otel_tracer.py (54%)
