This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/airflow-core/src/airflow/ui/core-ui-package-updates-2987ba7054
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard d643036e9bd Bump the core-ui-package-updates group across 1 directory
with 59 updates
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 9293d185d67 Bump the core-ui-package-updates group across 1 directory
with 59 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 (d643036e9bd)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/core-ui-package-updates-2987ba7054
(9293d185d67)
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 | 5 +-
.rat-excludes | 2 +-
Dockerfile | 2 +-
Dockerfile.ci | 8 +-
INTHEWILD.md | 1 +
airflow-core/docs/conf.py | 4 +
airflow-core/src/airflow/assets/manager.py | 2 +-
.../src/airflow/cli/commands/info_command.py | 7 +-
.../src/airflow/dag_processing/bundles/manager.py | 21 +-
airflow-core/src/airflow/dag_processing/manager.py | 2 +-
.../src/airflow/executors/local_executor.py | 38 +-
.../src/airflow/jobs/scheduler_job_runner.py | 40 +-
airflow-core/src/airflow/models/taskinstance.py | 1 +
.../src/airflow/secrets/local_filesystem.py | 39 +-
airflow-core/src/airflow/serialization/helpers.py | 14 +
airflow-core/src/airflow/ui/package.json | 24 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 708 ++++++++----------
.../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 | 2 +-
.../ui/public/i18n/locales/hu/components.json | 4 +-
.../src/airflow/ui/public/i18n/locales/hu/dag.json | 4 +-
.../ui/public/i18n/locales/ko/components.json | 5 +-
.../ui/public/i18n/locales/nl/components.json | 4 +-
.../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/src/layouts/Nav/UserSettingsButton.tsx | 15 +
.../airflow/ui/src/pages/AssetsList/AssetsList.tsx | 43 +-
.../src/pages/DagsList/DagsFilters/DagsFilters.tsx | 14 +-
.../src/airflow/ui/src/pages/Events/Events.tsx | 6 +-
.../src/airflow/ui/src/pages/XCom/XCom.tsx | 4 +-
.../unit/always/test_secrets_local_filesystem.py | 75 ++
.../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 | 91 ++-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 32 +
airflow-core/tests/unit/models/test_cleartasks.py | 5 +
airflow-core/tests/unit/models/test_dag.py | 7 +-
.../tests/unit/models/test_serialized_dag.py | 53 ++
.../airflowctl_tests/test_airflowctl_commands.py | 24 +-
chart/.pre-commit-config.yaml | 2 +-
chart/templates/NOTES.txt | 17 +-
chart/templates/_helpers.yaml | 15 +
...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 +
dev/README_RELEASE_AIRFLOW.md | 3 +-
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 | 10 +-
.../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 +-
dev/breeze/uv.lock | 290 ++++----
dev/pyproject.toml | 3 +
dev/verify_release_calendar.py | 600 +++++++++++++++
devel-common/sphinx_design/static/custom.css | 26 +-
devel-common/src/tests_common/test_utils/db.py | 6 +-
go-sdk/.pre-commit-config.yaml | 2 +-
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_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/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 +-
.../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 +-
.../providers/amazon/aws/hooks/quicksight.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/rds.py | 2 +-
.../providers/amazon/aws/hooks/redshift_sql.py | 2 +-
.../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 +-
.../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 | 4 +-
.../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 +-
.../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/pyproject.toml | 2 +-
.../celery/executors/celery_executor_utils.py | 3 +-
.../providers/celery/executors/default_celery.py | 3 +-
.../integration/celery/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/pyproject.toml | 4 +
.../backcompat/backwards_compat_converters.py | 2 +-
.../providers/cncf/kubernetes/exceptions.py | 6 +
.../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 +-
.../src/airflow/providers/common/compat/sdk.py | 13 +-
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 | 2 +-
.../airflow/providers/common/sql/sensors/sql.py | 3 +-
.../airflow/providers/common/sql/triggers/sql.py | 3 +-
.../tests/unit/common/sql/operators/test_sql.py | 13 +-
.../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/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 | 2 +-
providers/edge3/README.rst | 2 +-
providers/edge3/docs/architecture.rst | 4 +-
providers/edge3/docs/changelog.rst | 8 +
providers/edge3/docs/deployment.rst | 4 +-
providers/edge3/docs/index.rst | 4 +-
providers/edge3/docs/ui_plugin.rst | 6 +-
providers/edge3/pyproject.toml | 2 +-
.../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 | 67 +-
.../airflow/providers/edge3/models/edge_worker.py | 3 +-
.../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 | 18 +-
.../providers/edge3/worker_api/routes/logs.py | 13 +-
.../providers/edge3/worker_api/routes/worker.py | 14 +-
.../{openapi => worker_api}/v2-edge-generated.yaml | 3 +-
.../edge3/tests/unit/edge3/cli/test_worker.py | 68 +-
.../unit/edge3/executors/test_edge_executor.py | 174 +----
.../edge3/plugins/test_edge_executor_plugin.py | 48 +-
.../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/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 +-
.../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/pyproject.toml | 2 +-
.../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 +-
.../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 | 2 +-
.../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_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/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 | 8 +-
.../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 | 2 +-
.../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/pyproject.toml | 2 +
.../keycloak/auth_manager/keycloak_auth_manager.py | 2 +-
.../auth_manager/test_keycloak_auth_manager.py | 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/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 +-
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 +-
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 | 7 +-
.../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 | 2 +-
.../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/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/pyproject.toml | 2 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 4 +-
.../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 | 2 +-
.../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/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/pyproject.toml | 2 +-
.../src/airflow/providers/standard/exceptions.py | 2 +-
.../airflow/providers/standard/operators/bash.py | 7 +-
.../providers/standard/operators/datetime.py | 3 +-
.../airflow/providers/standard/operators/python.py | 3 +-
.../providers/standard/operators/trigger_dagrun.py | 15 +-
.../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 | 7 +-
.../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 +-
.../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 | 2 +-
scripts/docker/entrypoint_ci.sh | 6 +-
.../run_generate_openapi_spec_providers.py | 2 +-
scripts/tools/setup_breeze | 2 +-
.../src/airflow_shared/configuration/parser.py | 1 +
.../src/airflow_shared/observability/__init__.py | 10 +
.../observability/metrics/protocols.py | 2 +-
.../observability/traces/base_tracer.py | 2 +-
task-sdk/docs/api.rst | 6 +
task-sdk/src/airflow/sdk/__init__.py | 5 +
task-sdk/src/airflow/sdk/__init__.pyi | 4 +
task-sdk/src/airflow/sdk/configuration.py | 2 +-
.../tests/task_sdk/docs/test_docs_inventory.py | 3 +-
.../tests/task_sdk/execution_time/test_sentry.py | 5 +-
982 files changed, 3748 insertions(+), 4111 deletions(-)
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%)
