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-bcc31f1fc6
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 18ee4503d21 Bump the core-ui-package-updates group across 1 directory
with 45 updates
add 121a31f0647 Add React Apps to plugin (#52255)
add 9275f7b284b Skip test that needs the .git folder when it is missing
(#52305)
add 1c0c01d99ba Python versions in shell params are strings (#52306)
add 4a9067621fc Bump pymssql version to 2.3.5 (#52307)
add 9c7c72c6dd4 Remove pre-commit check-daysago-import-from-utils (#52304)
add feab705264b Use proper show-only value in test_worker.py (#52300)
add c3f9da4846c Revert "Enable Serde for Pydantic BaseModel and Subclasses
(#51059)" (#52312)
add c16b88a0009 Fix GlueJobOperator deferred waiting (#52314)
add 8da059aeb60 cleanup stale dependency of methodtools (#52310)
add a3a6fe95cef Enable DatabricksJobRunLink for Databricks plugin, skip
provide_session usage in Airflow3 (#52228)
add dd2bcacdc9f Fix mypy errors in GCP `generative_model` (#52321)
add ac9e968fe85 fix: task-sdk AssetEventOperations.get to use alias_name
when specified (#52303)
add 3c1568ae773 Fix: Unclosed aiohttp ClientSession and TCPConnector in
DatabricksRunNowOperator (deferrable=True) (#52119)
add 266c1ce2e8a Use BaseSensorOperator from task sdk in providers (#52296)
add 40a3c7e21ca feat: Add new query related methods to SnowflakeSqlApiHook
(#52157)
add 85a06653155 Attempt2: Fix mypy in gcp generative_model (#52331)
add 57307609c4f Replace occurences of 'get_password' with 'password' to
ease migration (#52333)
add 78e4cb4c670 Replace `models.BaseOperator` to Task SDK one for Standard
Provider (#52292)
add e7e89a07ff2 Drop support for Python 3.9 (#52072)
add 26dbca59471 Replace usage of 'set_extra' with 'extra' for athena sql
hook (#52340)
add c1c8173af69 Replace `models.BaseOperator` to Task SDK one for Alibaba
& Airbyte (#52335)
add 8c86c5e9e52 chore: use task_instance as source for all airflow
identifiers used in listener (#52339)
add 490947d1b63 Bump google-cloud-bigquery>=3.24.0 (#52337)
add 830c24d82be Cleanup stale Python3.9 dependencies (#52344)
add 82819b982d8 Bump the core-ui-package-updates group across 1 directory
with 45 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 (18ee4503d21)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/airflow-core/src/airflow/ui/core-ui-package-updates-bcc31f1fc6
(82819b982d8)
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/actions/breeze/action.yml | 2 +-
.github/actions/prepare_all_ci_images/action.yml | 8 +-
.github/workflows/test-providers.yml | 4 -
.pre-commit-config.yaml | 6 -
Dockerfile | 2 +-
Dockerfile.ci | 2 +-
README.md | 2 +-
.../docs/administration-and-deployment/plugins.rst | 42 +-
airflow-core/docs/extra-packages-ref.rst | 2 +-
airflow-core/docs/howto/custom-view-plugin.rst | 12 +-
.../docs/installation/installing-from-pypi.rst | 10 +-
airflow-core/docs/start.rst | 4 +-
airflow-core/hatch_build.py | 4 +-
airflow-core/pyproject.toml | 6 +-
.../src/airflow/api_fastapi/auth/tokens.py | 6 +-
.../src/airflow/api_fastapi/common/parameters.py | 21 +-
.../src/airflow/api_fastapi/common/router.py | 3 +-
.../api_fastapi/core_api/datamodels/plugins.py | 22 +-
.../api_fastapi/core_api/datamodels/pools.py | 3 +-
.../core_api/openapi/v2-rest-api-generated.yaml | 59 ++-
.../src/airflow/api_fastapi/core_api/security.py | 3 +-
.../core_api/services/public/variables.py | 2 +-
.../api_fastapi/core_api/services/ui/grid.py | 2 +-
.../execution_api/datamodels/taskinstance.py | 16 +-
.../src/airflow/api_fastapi/execution_api/deps.py | 8 +-
.../execution_api/routes/task_instances.py | 2 +-
.../execution_api/versions/v2025_05_20.py | 4 +-
.../src/airflow/callbacks/callback_requests.py | 4 +-
.../src/airflow/callbacks/pipe_callback_sink.py | 3 +-
airflow-core/src/airflow/cli/cli_config.py | 6 +-
.../src/airflow/cli/commands/daemon_utils.py | 2 +-
.../src/airflow/cli/commands/plugins_command.py | 2 +-
airflow-core/src/airflow/cli/simple_table.py | 6 +-
airflow-core/src/airflow/configuration.py | 6 +-
.../src/airflow/dag_processing/processor.py | 7 +-
airflow-core/src/airflow/exceptions.py | 2 +-
.../src/airflow/executors/base_executor.py | 4 +-
.../src/airflow/executors/local_executor.py | 4 +-
airflow-core/src/airflow/executors/workloads.py | 4 +-
airflow-core/src/airflow/io/__init__.py | 3 +-
airflow-core/src/airflow/jobs/job.py | 3 +-
.../src/airflow/jobs/scheduler_job_runner.py | 4 +-
.../src/airflow/jobs/triggerer_job_runner.py | 42 +-
airflow-core/src/airflow/lineage/hook.py | 4 +-
airflow-core/src/airflow/metrics/otel_logger.py | 5 +-
airflow-core/src/airflow/metrics/protocols.py | 4 +-
airflow-core/src/airflow/metrics/statsd_logger.py | 3 +-
airflow-core/src/airflow/metrics/validators.py | 4 +-
airflow-core/src/airflow/models/asset.py | 4 +-
airflow-core/src/airflow/models/dag.py | 18 +-
airflow-core/src/airflow/models/dagbag.py | 4 +-
airflow-core/src/airflow/models/dagrun.py | 17 +-
airflow-core/src/airflow/models/expandinput.py | 6 +-
airflow-core/src/airflow/models/operator.py | 4 +-
airflow-core/src/airflow/models/serialized_dag.py | 4 +-
airflow-core/src/airflow/models/taskmap.py | 2 +-
airflow-core/src/airflow/plugins_manager.py | 8 +-
airflow-core/src/airflow/providers_manager.py | 4 +-
airflow-core/src/airflow/serialization/serde.py | 19 +-
.../airflow/serialization/serialized_objects.py | 27 +-
.../airflow/serialization/serializers/bignum.py | 8 +-
.../airflow/serialization/serializers/builtin.py | 12 +-
.../airflow/serialization/serializers/datetime.py | 12 +-
.../airflow/serialization/serializers/deltalake.py | 6 +-
.../airflow/serialization/serializers/iceberg.py | 6 +-
.../serialization/serializers/kubernetes.py | 2 +-
.../src/airflow/serialization/serializers/numpy.py | 36 +-
.../airflow/serialization/serializers/pandas.py | 13 +-
.../airflow/serialization/serializers/pydantic.py | 79 ----
.../airflow/serialization/serializers/timezone.py | 8 +-
airflow-core/src/airflow/serialization/typing.py | 32 --
airflow-core/src/airflow/settings.py | 3 +-
airflow-core/src/airflow/stats.py | 3 +-
airflow-core/src/airflow/timetables/interval.py | 4 +-
airflow-core/src/airflow/traces/tracer.py | 3 +-
airflow-core/src/airflow/triggers/base.py | 12 +-
airflow-core/src/airflow/typing_compat.py | 7 +-
.../airflow/ui/openapi-gen/requests/schemas.gen.ts | 87 +++-
.../airflow/ui/openapi-gen/requests/types.gen.ts | 19 +-
airflow-core/src/airflow/ui/package.json | 12 +-
airflow-core/src/airflow/ui/pnpm-lock.yaml | 524 ++++++++++-----------
airflow-core/src/airflow/utils/cli.py | 3 +-
.../src/airflow/utils/cli_action_loggers.py | 3 +-
airflow-core/src/airflow/utils/db.py | 3 +-
airflow-core/src/airflow/utils/decorators.py | 3 +-
airflow-core/src/airflow/utils/dot_renderer.py | 2 +-
airflow-core/src/airflow/utils/event_scheduler.py | 2 +-
airflow-core/src/airflow/utils/helpers.py | 8 +-
airflow-core/src/airflow/utils/log/colored_log.py | 4 +-
.../src/airflow/utils/log/file_task_handler.py | 8 +-
airflow-core/src/airflow/utils/log/log_reader.py | 4 +-
airflow-core/src/airflow/utils/module_loading.py | 3 +-
airflow-core/src/airflow/utils/operator_helpers.py | 4 +-
.../utils/providers_configuration_loader.py | 3 +-
airflow-core/src/airflow/utils/retries.py | 3 +-
airflow-core/src/airflow/utils/session.py | 4 +-
airflow-core/src/airflow/utils/setup_teardown.py | 2 +-
airflow-core/src/airflow/utils/sqlalchemy.py | 4 +-
airflow-core/src/airflow/utils/task_group.py | 3 +-
.../tests/unit/always/test_project_structure.py | 19 +-
.../core_api/routes/public/test_variables.py | 2 +-
.../unit/cli/commands/test_plugins_command.py | 10 +
.../tests/unit/cluster_policies/__init__.py | 3 +-
airflow-core/tests/unit/core/test_core.py | 24 +-
.../tests/unit/dag_processing/test_processor.py | 3 +-
airflow-core/tests/unit/models/test_cleartasks.py | 9 +-
.../tests/unit/models/test_taskinstance.py | 68 +--
airflow-core/tests/unit/plugins/test_plugin.py | 10 +
.../serialization/serializers/test_serializers.py | 115 +----
.../unit/serialization/test_dag_serialization.py | 4 +-
.../tests/unit/serialization/test_serde.py | 15 -
airflow-ctl/docs/images/command_hashes.txt | 28 +-
airflow-ctl/docs/images/output_assets.svg | 116 ++---
airflow-ctl/docs/images/output_auth.svg | 60 +--
airflow-ctl/docs/images/output_auth_login.svg | 72 +--
airflow-ctl/docs/images/output_backfills.svg | 80 ++--
airflow-ctl/docs/images/output_config.svg | 62 +--
airflow-ctl/docs/images/output_connections.svg | 80 ++--
airflow-ctl/docs/images/output_dag.svg | 104 ++--
airflow-ctl/docs/images/output_dagrun.svg | 60 +--
airflow-ctl/docs/images/output_jobs.svg | 52 +-
airflow-ctl/docs/images/output_main.svg | 112 ++---
airflow-ctl/docs/images/output_pools.svg | 76 +--
airflow-ctl/docs/images/output_providers.svg | 52 +-
airflow-ctl/docs/images/output_variables.svg | 76 +--
airflow-ctl/docs/images/output_version.svg | 36 +-
.../src/airflowctl/api/datamodels/generated.py | 92 ++--
chart/pyproject.toml | 2 +-
clients/python/pyproject.toml | 2 +-
contributing-docs/08_static_code_checks.rst | 2 -
.../13_airflow_dependencies_and_extras.rst | 10 +-
dev/README_RELEASE_AIRFLOW.md | 2 +-
dev/airflow_mypy/plugin/outputs.py | 2 +-
dev/breeze/README.md | 2 +-
dev/breeze/doc/images/output-commands.svg | 8 +-
dev/breeze/doc/images/output_ci-image_build.svg | 6 +-
dev/breeze/doc/images/output_ci-image_build.txt | 2 +-
dev/breeze/doc/images/output_ci-image_load.svg | 4 +-
dev/breeze/doc/images/output_ci-image_load.txt | 2 +-
dev/breeze/doc/images/output_ci-image_pull.svg | 6 +-
dev/breeze/doc/images/output_ci-image_pull.txt | 2 +-
dev/breeze/doc/images/output_ci-image_save.svg | 4 +-
dev/breeze/doc/images/output_ci-image_save.txt | 2 +-
dev/breeze/doc/images/output_ci-image_verify.svg | 6 +-
dev/breeze/doc/images/output_ci-image_verify.txt | 2 +-
.../doc/images/output_k8s_build-k8s-image.svg | 6 +-
.../doc/images/output_k8s_build-k8s-image.txt | 2 +-
.../doc/images/output_k8s_configure-cluster.svg | 6 +-
.../doc/images/output_k8s_configure-cluster.txt | 2 +-
.../doc/images/output_k8s_create-cluster.svg | 62 ++-
.../doc/images/output_k8s_create-cluster.txt | 2 +-
.../doc/images/output_k8s_delete-cluster.svg | 4 +-
.../doc/images/output_k8s_delete-cluster.txt | 2 +-
.../doc/images/output_k8s_deploy-airflow.svg | 76 ++-
.../doc/images/output_k8s_deploy-airflow.txt | 2 +-
dev/breeze/doc/images/output_k8s_k9s.svg | 4 +-
dev/breeze/doc/images/output_k8s_k9s.txt | 2 +-
dev/breeze/doc/images/output_k8s_logs.svg | 4 +-
dev/breeze/doc/images/output_k8s_logs.txt | 2 +-
.../doc/images/output_k8s_run-complete-tests.svg | 6 +-
.../doc/images/output_k8s_run-complete-tests.txt | 2 +-
dev/breeze/doc/images/output_k8s_shell.svg | 4 +-
dev/breeze/doc/images/output_k8s_shell.txt | 2 +-
dev/breeze/doc/images/output_k8s_status.svg | 36 +-
dev/breeze/doc/images/output_k8s_status.txt | 2 +-
dev/breeze/doc/images/output_k8s_tests.svg | 6 +-
dev/breeze/doc/images/output_k8s_tests.txt | 2 +-
.../doc/images/output_k8s_upload-k8s-image.svg | 6 +-
.../doc/images/output_k8s_upload-k8s-image.txt | 2 +-
dev/breeze/doc/images/output_prod-image_build.svg | 196 ++++----
dev/breeze/doc/images/output_prod-image_build.txt | 2 +-
dev/breeze/doc/images/output_prod-image_load.svg | 4 +-
dev/breeze/doc/images/output_prod-image_load.txt | 2 +-
dev/breeze/doc/images/output_prod-image_pull.svg | 6 +-
dev/breeze/doc/images/output_prod-image_pull.txt | 2 +-
dev/breeze/doc/images/output_prod-image_save.svg | 4 +-
dev/breeze/doc/images/output_prod-image_save.txt | 2 +-
dev/breeze/doc/images/output_prod-image_verify.svg | 6 +-
dev/breeze/doc/images/output_prod-image_verify.txt | 2 +-
...put_release-management_generate-constraints.svg | 48 +-
...put_release-management_generate-constraints.txt | 2 +-
...e-management_install-provider-distributions.svg | 4 +-
...e-management_install-provider-distributions.txt | 2 +-
...output_release-management_merge-prod-images.svg | 2 +-
...output_release-management_merge-prod-images.txt | 2 +-
...tput_release-management_release-prod-images.svg | 2 +-
...tput_release-management_release-prod-images.txt | 2 +-
...se-management_verify-provider-distributions.svg | 4 +-
...se-management_verify-provider-distributions.txt | 2 +-
.../output_sbom_export-dependency-information.svg | 4 +-
.../output_sbom_export-dependency-information.txt | 2 +-
dev/breeze/doc/images/output_setup_config.svg | 4 +-
dev/breeze/doc/images/output_setup_config.txt | 2 +-
dev/breeze/doc/images/output_shell.svg | 4 +-
dev/breeze/doc/images/output_shell.txt | 2 +-
dev/breeze/doc/images/output_start-airflow.svg | 146 +++---
dev/breeze/doc/images/output_start-airflow.txt | 2 +-
dev/breeze/doc/images/output_static-checks.svg | 160 +++----
dev/breeze/doc/images/output_static-checks.txt | 2 +-
.../images/output_testing_airflow-ctl-tests.svg | 4 +-
.../images/output_testing_airflow-ctl-tests.txt | 2 +-
.../output_testing_core-integration-tests.svg | 4 +-
.../output_testing_core-integration-tests.txt | 2 +-
.../doc/images/output_testing_core-tests.svg | 4 +-
.../doc/images/output_testing_core-tests.txt | 2 +-
.../images/output_testing_docker-compose-tests.svg | 4 +-
.../images/output_testing_docker-compose-tests.txt | 2 +-
.../output_testing_providers-integration-tests.svg | 4 +-
.../output_testing_providers-integration-tests.txt | 2 +-
.../doc/images/output_testing_providers-tests.svg | 4 +-
.../doc/images/output_testing_providers-tests.txt | 2 +-
.../output_testing_python-api-client-tests.svg | 4 +-
.../output_testing_python-api-client-tests.txt | 2 +-
.../doc/images/output_testing_system-tests.svg | 4 +-
.../doc/images/output_testing_system-tests.txt | 2 +-
.../doc/images/output_testing_task-sdk-tests.svg | 4 +-
.../doc/images/output_testing_task-sdk-tests.txt | 2 +-
dev/breeze/pyproject.toml | 2 +-
.../commands/minor_release_command.py | 2 +-
.../commands/release_management_commands.py | 4 +-
dev/breeze/src/airflow_breeze/global_constants.py | 25 +-
.../airflow_breeze/params/common_build_params.py | 2 +-
dev/breeze/src/airflow_breeze/pre_commit_ids.py | 1 -
dev/breeze/src/airflow_breeze/utils/image.py | 3 +-
dev/breeze/src/airflow_breeze/utils/packages.py | 2 +-
dev/breeze/src/airflow_breeze/utils/parallel.py | 2 +-
dev/breeze/src/airflow_breeze/utils/path_utils.py | 8 +-
dev/breeze/src/airflow_breeze/utils/run_utils.py | 6 +-
dev/breeze/tests/test_cache.py | 6 +-
dev/breeze/tests/test_selective_checks.py | 49 +-
dev/breeze/tests/test_shell_params.py | 24 +-
dev/pyproject.toml | 2 +-
dev/refresh_images.sh | 2 +-
dev/retag_docker_images.py | 2 +-
devel-common/src/docs/build_docs.py | 4 +-
.../src/sphinx_exts/operators_and_hooks_ref.py | 2 +-
.../src/sphinx_exts/providers_extensions.py | 6 +-
.../src/sphinx_exts/removemarktransform.py | 2 +-
.../src/sphinx_exts/substitution_extensions.py | 2 +-
.../tests_common/_internals/capture_warnings.py | 4 +-
.../tests_common/_internals/forbidden_warnings.py | 2 +-
devel-common/src/tests_common/pytest_plugin.py | 55 ++-
.../src/tests_common/test_utils/mock_plugins.py | 1 +
.../test_utils/perf/perf_kit/sqlalchemy.py | 2 +-
.../src/tests_common/test_utils/system_tests.py | 3 +-
docs/spelling_wordlist.txt | 1 +
generated/PYPI_README.md | 2 +-
.../tests/helm_tests/airflow_core/test_worker.py | 2 +-
.../performance_dag/performance_dag_utils.py | 2 +-
providers-summary-docs/installing-from-pypi.rst | 2 +-
providers/airbyte/pyproject.toml | 3 +-
.../airflow/providers/airbyte/operators/airbyte.py | 7 +-
.../airflow/providers/airbyte/sensors/airbyte.py | 7 +-
.../airflow/providers/airbyte}/version_compat.py | 0
providers/alibaba/pyproject.toml | 3 +-
.../alibaba/cloud/hooks/analyticdb_spark.py | 6 +-
.../providers/alibaba/cloud/hooks/maxcompute.py | 3 +-
.../airflow/providers/alibaba/cloud/hooks/oss.py | 3 +-
.../providers/alibaba/cloud/links/maxcompute.py | 5 +-
.../alibaba/cloud/operators/analyticdb_spark.py | 7 +-
.../alibaba/cloud/operators/maxcompute.py | 11 +-
.../providers/alibaba/cloud/operators/oss.py | 7 +-
.../alibaba/cloud/sensors/analyticdb_spark.py | 7 +-
.../providers/alibaba/cloud/sensors/oss_key.py | 7 +-
.../unit/alibaba/cloud/links/test_maxcompute.py | 4 +-
.../alibaba/cloud/operators/test_maxcompute.py | 1 -
.../tests/unit/alibaba/cloud/utils/test_utils.py | 3 +-
providers/amazon/pyproject.toml | 3 +-
.../providers/amazon/aws/executors/ecs/utils.py | 4 +-
.../executors/utils/exponential_backoff_retry.py | 2 +-
.../src/airflow/providers/amazon/aws/fs/s3.py | 3 +-
.../providers/amazon/aws/hooks/athena_sql.py | 9 +-
.../airflow/providers/amazon/aws/hooks/base_aws.py | 18 +-
.../providers/amazon/aws/hooks/batch_client.py | 3 +-
.../providers/amazon/aws/hooks/batch_waiters.py | 3 +-
.../airflow/providers/amazon/aws/hooks/chime.py | 2 +-
.../src/airflow/providers/amazon/aws/hooks/ec2.py | 3 +-
.../src/airflow/providers/amazon/aws/hooks/eks.py | 3 +-
.../src/airflow/providers/amazon/aws/hooks/rds.py | 3 +-
.../src/airflow/providers/amazon/aws/hooks/s3.py | 6 +-
.../providers/amazon/aws/hooks/sagemaker.py | 4 +-
.../src/airflow/providers/amazon/aws/hooks/sns.py | 2 +-
.../amazon/aws/log/cloudwatch_task_handler.py | 2 +-
.../airflow/providers/amazon/aws/operators/glue.py | 17 +-
.../airflow/providers/amazon/aws/operators/s3.py | 2 +-
.../providers/amazon/aws/operators/sagemaker.py | 4 +-
.../providers/amazon/aws/sensors/base_aws.py | 8 +-
.../src/airflow/providers/amazon/aws/sensors/s3.py | 4 +-
.../amazon/aws/sensors/sagemaker_unified_studio.py | 7 +-
.../amazon/aws/transfers/dynamodb_to_s3.py | 4 +-
.../amazon/aws/transfers/hive_to_dynamodb.py | 4 +-
.../providers/amazon/aws/transfers/s3_to_sql.py | 4 +-
.../providers/amazon/aws/transfers/sql_to_s3.py | 4 +-
.../airflow/providers/amazon/aws/triggers/base.py | 1 -
.../amazon/aws/utils/connection_wrapper.py | 2 +-
.../airflow/providers/amazon/aws/utils/suppress.py | 3 +-
.../airflow/providers/amazon/aws/utils/waiter.py | 2 +-
.../amazon/tests/system/amazon/aws/utils/k8s.py | 7 +-
.../amazon/aws/executors/ecs/test_ecs_executor.py | 2 +-
.../tests/unit/amazon/aws/utils/eks_test_utils.py | 4 +-
providers/apache/beam/pyproject.toml | 3 +-
.../airflow/providers/apache/beam/hooks/beam.py | 3 +-
.../providers/apache/beam/operators/beam.py | 4 +-
providers/apache/cassandra/pyproject.toml | 3 +-
.../providers/apache/cassandra/hooks/cassandra.py | 4 +-
.../providers/apache/cassandra/sensors/record.py | 7 +-
.../providers/apache/cassandra/sensors/table.py | 7 +-
.../providers/apache/cassandra}/version_compat.py | 0
providers/apache/drill/pyproject.toml | 3 +-
providers/apache/druid/pyproject.toml | 3 +-
providers/apache/flink/pyproject.toml | 3 +-
.../apache/flink/sensors/flink_kubernetes.py | 7 +-
.../providers/apache/flink}/version_compat.py | 0
providers/apache/hdfs/pyproject.toml | 3 +-
.../providers/apache/hdfs/sensors/web_hdfs.py | 7 +-
.../providers/apache/hdfs}/version_compat.py | 0
providers/apache/hive/pyproject.toml | 3 +-
.../airflow/providers/apache/hive/hooks/hive.py | 4 +-
.../providers/apache/hive/operators/hive_stats.py | 4 +-
.../apache/hive/sensors/hive_partition.py | 7 +-
.../apache/hive/sensors/named_hive_partition.py | 7 +-
.../providers/apache/hive}/version_compat.py | 0
providers/apache/iceberg/pyproject.toml | 3 +-
providers/apache/impala/pyproject.toml | 3 +-
providers/apache/kafka/pyproject.toml | 3 +-
.../providers/apache/kafka/operators/consume.py | 4 +-
.../providers/apache/kafka/operators/produce.py | 4 +-
.../providers/apache/kafka/sensors/kafka.py | 4 +-
providers/apache/kylin/pyproject.toml | 3 +-
providers/apache/livy/pyproject.toml | 3 +-
.../airflow/providers/apache/livy/hooks/livy.py | 12 +-
.../airflow/providers/apache/livy/sensors/livy.py | 7 +-
.../providers/apache/livy}/version_compat.py | 0
providers/apache/pig/pyproject.toml | 3 +-
providers/apache/pinot/pyproject.toml | 3 +-
providers/apache/spark/pyproject.toml | 3 +-
.../providers/apache/spark/decorators/pyspark.py | 4 +-
.../unit/apache/spark/decorators/test_pyspark.py | 16 +-
providers/apache/tinkerpop/pyproject.toml | 3 +-
providers/apprise/pyproject.toml | 3 +-
providers/arangodb/pyproject.toml | 3 +-
.../providers/arangodb/operators/arangodb.py | 4 +-
.../airflow/providers/arangodb/sensors/arangodb.py | 7 +-
.../airflow/providers/arangodb}/version_compat.py | 0
providers/asana/pyproject.toml | 3 +-
providers/atlassian/jira/pyproject.toml | 3 +-
.../providers/atlassian/jira/operators/jira.py | 4 +-
.../providers/atlassian/jira/sensors/jira.py | 11 +-
.../providers/atlassian/jira}/version_compat.py | 0
providers/celery/pyproject.toml | 3 +-
.../celery/executors/celery_executor_utils.py | 8 +-
.../providers/celery/sensors/celery_queue.py | 7 +-
providers/cloudant/provider.yaml | 7 -
providers/cloudant/pyproject.toml | 2 +-
.../airflow/providers/cloudant/hooks/cloudant.py | 6 +-
.../tests/unit/cloudant/hooks/test_cloudant.py | 13 +-
providers/cncf/kubernetes/pyproject.toml | 3 +-
.../airflow/providers/cncf/kubernetes/callbacks.py | 4 +-
.../cncf/kubernetes/decorators/kubernetes.py | 4 +-
.../cncf/kubernetes/decorators/kubernetes_cmd.py | 4 +-
.../executors/kubernetes_executor_types.py | 8 +-
.../providers/cncf/kubernetes/kube_client.py | 13 +-
.../providers/cncf/kubernetes/operators/pod.py | 4 +-
.../cncf/kubernetes/sensors/spark_kubernetes.py | 7 +-
.../cncf/kubernetes/utils/k8s_resource_iterator.py | 3 +-
.../providers/cncf/kubernetes/utils/pod_manager.py | 3 +-
.../decorators/test_kubernetes_commons.py | 2 +-
providers/cohere/pyproject.toml | 3 +-
providers/common/compat/pyproject.toml | 3 +-
providers/common/io/pyproject.toml | 3 +-
providers/common/messaging/pyproject.toml | 3 +-
providers/common/sql/pyproject.toml | 3 +-
.../providers/common/sql/dialects/dialect.py | 4 +-
.../providers/common/sql/dialects/dialect.pyi | 4 +-
.../src/airflow/providers/common/sql/hooks/sql.py | 5 +-
.../src/airflow/providers/common/sql/hooks/sql.pyi | 4 +-
.../airflow/providers/common/sql/operators/sql.py | 4 +-
.../airflow/providers/common/sql/sensors/sql.py | 11 +-
.../airflow/providers/common/sql/sensors/sql.pyi | 12 +-
.../providers/common/sql}/version_compat.py | 0
providers/databricks/pyproject.toml | 3 +-
.../providers/databricks/hooks/databricks_base.py | 13 +-
.../providers/databricks/hooks/databricks_sql.py | 3 +-
.../providers/databricks/operators/databricks.py | 24 +-
.../databricks/operators/databricks_workflow.py | 22 +-
.../databricks/plugins/databricks_workflow.py | 175 ++++---
.../databricks/sensors/databricks_partition.py | 15 +-
.../providers/databricks/sensors/databricks_sql.py | 11 +-
.../providers/databricks/utils/databricks.py | 6 +-
.../tests/unit/databricks/hooks/test_databricks.py | 56 ++-
.../operators/test_databricks_workflow.py | 1 +
.../databricks/plugins/test_databricks_workflow.py | 245 ++++++++--
providers/datadog/pyproject.toml | 3 +-
.../airflow/providers/datadog/sensors/datadog.py | 10 +-
.../airflow/providers/datadog}/version_compat.py | 0
providers/dbt/cloud/pyproject.toml | 3 +-
.../src/airflow/providers/dbt/cloud/hooks/dbt.py | 6 +-
.../src/airflow/providers/dbt/cloud/sensors/dbt.py | 2 +-
providers/dingding/pyproject.toml | 3 +-
providers/discord/pyproject.toml | 3 +-
providers/docker/pyproject.toml | 3 +-
.../airflow/providers/docker/decorators/docker.py | 4 +-
.../airflow/providers/docker/operators/docker.py | 3 +-
providers/edge3/pyproject.toml | 3 +-
.../providers/edge3/example_dags/win_test.py | 4 +-
.../providers/edge3/executors/edge_executor.py | 4 +-
.../edge3/worker_api/routes/_v2_compat.py | 2 +-
providers/elasticsearch/pyproject.toml | 3 +-
.../providers/elasticsearch/log/es_response.py | 2 +-
.../providers/elasticsearch/log/es_task_handler.py | 7 +-
.../log/elasticmock/utilities/__init__.py | 6 +-
providers/exasol/pyproject.toml | 3 +-
.../src/airflow/providers/exasol/hooks/exasol.py | 4 +-
providers/fab/pyproject.toml | 3 +-
.../auth_manager/api/auth/backend/basic_auth.py | 3 +-
.../auth_manager/api/auth/backend/kerberos_auth.py | 3 +-
.../fab/auth_manager/api/auth/backend/session.py | 3 +-
.../providers/fab/www/api_connexion/parameters.py | 4 +-
.../providers/fab/www/api_connexion/security.py | 3 +-
.../providers/fab/www/api_connexion/types.py | 12 +-
.../fab/src/airflow/providers/fab/www/auth.py | 4 +-
.../airflow/providers/fab/www/security_manager.py | 2 +-
.../api_endpoints/remote_user_api_auth_backend.py | 3 +-
providers/fab/www-hash.txt | 2 +-
providers/facebook/pyproject.toml | 3 +-
providers/ftp/pyproject.toml | 3 +-
.../ftp/src/airflow/providers/ftp/hooks/ftp.py | 3 +-
.../ftp/src/airflow/providers/ftp/sensors/ftp.py | 7 +-
.../src/airflow/providers/ftp}/version_compat.py | 0
providers/git/pyproject.toml | 3 +-
providers/github/pyproject.toml | 3 +-
.../airflow/providers/github/operators/github.py | 3 +-
.../src/airflow/providers/github/sensors/github.py | 10 +-
.../airflow/providers/github}/version_compat.py | 0
providers/google/pyproject.toml | 6 +-
.../providers/google/cloud/hooks/bigquery.py | 5 +-
.../providers/google/cloud/hooks/dataflow.py | 4 +-
.../airflow/providers/google/cloud/hooks/gcs.py | 4 +-
.../providers/google/cloud/hooks/mlengine.py | 3 +-
.../providers/google/cloud/hooks/spanner.py | 4 +-
.../cloud/hooks/vertex_ai/generative_model.py | 19 +-
.../providers/google/cloud/hooks/vertex_ai/ray.py | 2 +-
.../airflow/providers/google/cloud/hooks/vision.py | 4 +-
.../airflow/providers/google/cloud/links/base.py | 2 +-
.../providers/google/cloud/operators/pubsub.py | 4 +-
.../cloud/operators/vertex_ai/generative_model.py | 8 +-
.../providers/google/cloud/sensors/bigquery.py | 7 +-
.../providers/google/cloud/sensors/bigquery_dts.py | 9 +-
.../providers/google/cloud/sensors/bigtable.py | 7 +-
.../google/cloud/sensors/cloud_composer.py | 7 +-
.../sensors/cloud_storage_transfer_service.py | 7 +-
.../providers/google/cloud/sensors/dataflow.py | 11 +-
.../providers/google/cloud/sensors/dataform.py | 7 +-
.../providers/google/cloud/sensors/datafusion.py | 7 +-
.../providers/google/cloud/sensors/dataplex.py | 7 +-
.../providers/google/cloud/sensors/dataprep.py | 7 +-
.../providers/google/cloud/sensors/dataproc.py | 7 +-
.../google/cloud/sensors/dataproc_metastore.py | 7 +-
.../airflow/providers/google/cloud/sensors/gcs.py | 12 +-
.../providers/google/cloud/sensors/looker.py | 7 +-
.../providers/google/cloud/sensors/pubsub.py | 11 +-
.../providers/google/cloud/sensors/tasks.py | 7 +-
.../cloud/sensors/vertex_ai/feature_store.py | 7 +-
.../providers/google/cloud/sensors/workflows.py | 7 +-
.../google/cloud/transfers/cassandra_to_gcs.py | 6 +-
.../google/cloud/transfers/mssql_to_gcs.py | 2 +-
.../google/cloud/utils/field_validator.py | 3 +-
.../google/common/auth_backend/google_openid.py | 3 +-
.../airflow/providers/google/common/deprecated.py | 3 +-
.../providers/google/common/hooks/base_google.py | 6 +-
.../marketing_platform/sensors/campaign_manager.py | 7 +-
.../marketing_platform/sensors/display_video.py | 7 +-
.../providers/google/suite/sensors/drive.py | 7 +-
.../google/suite/transfers/sql_to_sheets.py | 2 +-
.../example_dataflow_native_python_async.py | 2 +-
.../example_dataflow_sensors_deferrable.py | 2 +-
.../operators/test_campaign_manager.py | 47 +-
.../operators/test_display_video.py | 43 +-
providers/grpc/pyproject.toml | 3 +-
.../grpc/src/airflow/providers/grpc/hooks/grpc.py | 4 +-
.../src/airflow/providers/grpc/operators/grpc.py | 4 +-
providers/hashicorp/pyproject.toml | 3 +-
providers/http/pyproject.toml | 3 +-
.../http/src/airflow/providers/http/hooks/http.py | 3 +-
.../src/airflow/providers/http/operators/http.py | 4 +-
.../src/airflow/providers/http/sensors/http.py | 17 +-
.../src/airflow/providers/http/triggers/http.py | 2 +-
.../src/airflow/providers/http}/version_compat.py | 0
providers/imap/pyproject.toml | 3 +-
.../providers/imap/sensors/imap_attachment.py | 7 +-
.../src/airflow/providers/imap}/version_compat.py | 0
providers/influxdb/pyproject.toml | 3 +-
providers/jdbc/pyproject.toml | 3 +-
providers/jenkins/pyproject.toml | 3 +-
.../jenkins/operators/jenkins_job_trigger.py | 7 +-
.../airflow/providers/jenkins/sensors/jenkins.py | 7 +-
.../airflow/providers/jenkins}/version_compat.py | 0
providers/keycloak/pyproject.toml | 3 +-
providers/microsoft/azure/pyproject.toml | 3 +-
.../airflow/providers/microsoft/azure/hooks/asb.py | 3 +-
.../providers/microsoft/azure/hooks/cosmos.py | 4 +-
.../microsoft/azure/hooks/data_factory.py | 7 +-
.../providers/microsoft/azure/hooks/data_lake.py | 4 +-
.../providers/microsoft/azure/hooks/synapse.py | 4 +-
.../providers/microsoft/azure/hooks/wasb.py | 4 +-
.../providers/microsoft/azure/operators/asb.py | 4 +-
.../providers/microsoft/azure/operators/msgraph.py | 3 +-
.../providers/microsoft/azure/sensors/cosmos.py | 7 +-
.../providers/microsoft/azure/sensors/msgraph.py | 11 +-
.../providers/microsoft/azure/sensors/wasb.py | 7 +-
providers/microsoft/mssql/pyproject.toml | 14 +-
providers/microsoft/psrp/pyproject.toml | 3 +-
.../airflow/providers/microsoft/psrp/hooks/psrp.py | 4 +-
providers/microsoft/winrm/pyproject.toml | 3 +-
providers/mongo/pyproject.toml | 3 +-
.../src/airflow/providers/mongo/hooks/mongo.py | 2 +-
.../src/airflow/providers/mongo/sensors/mongo.py | 7 +-
.../src/airflow/providers/mongo}/version_compat.py | 0
providers/mysql/pyproject.toml | 3 +-
providers/neo4j/pyproject.toml | 3 +-
providers/odbc/pyproject.toml | 3 +-
providers/openai/pyproject.toml | 3 +-
.../airflow/providers/openai/operators/openai.py | 2 +-
providers/openfaas/pyproject.toml | 3 +-
providers/openlineage/pyproject.toml | 3 +-
.../providers/openlineage/extractors/base.py | 4 +-
.../providers/openlineage/extractors/python.py | 2 +-
.../providers/openlineage/plugins/listener.py | 38 +-
.../src/airflow/providers/openlineage/sqlparser.py | 3 +-
.../src/airflow/providers/openlineage/utils/sql.py | 4 +-
.../airflow/providers/openlineage/utils/utils.py | 20 +-
.../example_openlineage_base_complex_dag.py | 5 +-
.../tests/unit/openlineage/extractors/test_base.py | 8 +-
.../unit/openlineage/plugins/test_listener.py | 147 +++---
.../tests/unit/openlineage/utils/test_utils.py | 5 +-
providers/opensearch/pyproject.toml | 3 +-
.../providers/opensearch/log/os_response.py | 2 +-
.../providers/opensearch/log/os_task_handler.py | 7 +-
providers/opsgenie/pyproject.toml | 3 +-
providers/oracle/pyproject.toml | 3 +-
.../src/airflow/providers/oracle/hooks/oracle.py | 4 +-
providers/pagerduty/pyproject.toml | 3 +-
.../airflow/providers/pagerduty/hooks/pagerduty.py | 2 +-
.../providers/pagerduty/hooks/pagerduty_events.py | 2 +-
providers/papermill/pyproject.toml | 3 +-
providers/pgvector/pyproject.toml | 3 +-
providers/pinecone/pyproject.toml | 3 +-
providers/postgres/pyproject.toml | 3 +-
.../airflow/providers/postgres/hooks/postgres.py | 6 +-
providers/presto/pyproject.toml | 3 +-
providers/qdrant/pyproject.toml | 3 +-
providers/redis/pyproject.toml | 3 +-
.../airflow/providers/redis/sensors/redis_key.py | 7 +-
.../providers/redis/sensors/redis_pub_sub.py | 7 +-
providers/salesforce/pyproject.toml | 3 +-
.../airflow/providers/salesforce/operators/bulk.py | 3 +-
providers/samba/pyproject.toml | 3 +-
providers/segment/pyproject.toml | 3 +-
providers/sendgrid/pyproject.toml | 3 +-
.../airflow/providers/sendgrid/utils/emailer.py | 3 +-
providers/sftp/pyproject.toml | 3 +-
.../providers/sftp/decorators/sensors/sftp.py | 3 +-
.../sftp/src/airflow/providers/sftp/hooks/sftp.py | 4 +-
.../src/airflow/providers/sftp/sensors/sftp.py | 11 +-
providers/singularity/pyproject.toml | 3 +-
providers/slack/pyproject.toml | 3 +-
.../airflow/providers/slack/hooks/slack_webhook.py | 3 +-
.../src/airflow/providers/slack/operators/slack.py | 4 +-
.../providers/slack/transfers/sql_to_slack.py | 4 +-
providers/smtp/pyproject.toml | 3 +-
providers/snowflake/pyproject.toml | 3 +-
.../providers/snowflake/decorators/snowpark.py | 4 +-
.../airflow/providers/snowflake/hooks/snowflake.py | 6 +-
.../providers/snowflake/hooks/snowflake_sql_api.py | 81 +++-
.../providers/snowflake/operators/snowpark.py | 4 +-
.../airflow/providers/snowflake/utils/snowpark.py | 3 +-
.../unit/snowflake/decorators/test_snowpark.py | 22 +-
.../unit/snowflake/hooks/test_snowflake_sql_api.py | 331 ++++++++++---
.../unit/snowflake/operators/test_snowpark.py | 18 +-
.../transfers/test_copy_into_snowflake.py | 2 +-
providers/sqlite/pyproject.toml | 3 +-
providers/ssh/pyproject.toml | 3 +-
providers/standard/pyproject.toml | 3 +-
.../airflow/providers/standard/decorators/bash.py | 4 +-
.../standard/decorators/branch_external_python.py | 3 +-
.../providers/standard/decorators/branch_python.py | 3 +-
.../standard/decorators/branch_virtualenv.py | 3 +-
.../standard/decorators/external_python.py | 3 +-
.../providers/standard/decorators/python.py | 4 +-
.../standard/decorators/python_virtualenv.py | 3 +-
.../providers/standard/decorators/sensor.py | 4 +-
.../providers/standard/decorators/short_circuit.py | 3 +-
.../airflow/providers/standard/operators/bash.py | 12 +-
.../airflow/providers/standard/operators/branch.py | 8 +-
.../airflow/providers/standard/operators/empty.py | 7 +-
.../airflow/providers/standard/operators/python.py | 12 +-
.../airflow/providers/standard/operators/smooth.py | 7 +-
.../providers/standard/operators/trigger_dagrun.py | 2 +-
.../providers/standard/sensors/external_task.py | 11 +-
.../airflow/providers/standard/sensors/python.py | 4 +-
.../airflow/providers/standard/utils/skipmixin.py | 19 +-
.../airflow/providers/standard/version_compat.py | 1 +
.../decorators/test_branch_external_python.py | 14 +-
.../unit/standard/decorators/test_branch_python.py | 14 +-
.../standard/decorators/test_branch_virtualenv.py | 14 +-
.../standard/decorators/test_external_python.py | 72 +--
.../tests/unit/standard/decorators/test_python.py | 118 ++---
.../standard/decorators/test_python_virtualenv.py | 100 ++--
.../unit/standard/decorators/test_short_circuit.py | 12 +-
.../tests/unit/standard/operators/test_bash.py | 12 +-
.../standard/operators/test_branch_operator.py | 41 +-
.../tests/unit/standard/operators/test_datetime.py | 29 +-
.../operators/test_latest_only_operator.py | 25 +-
.../tests/unit/standard/operators/test_python.py | 134 +++---
.../tests/unit/standard/operators/test_weekday.py | 14 +-
.../standard/sensors/test_external_task_sensor.py | 7 +-
providers/tableau/pyproject.toml | 3 +-
.../airflow/providers/tableau/sensors/tableau.py | 7 +-
.../airflow/providers/tableau}/version_compat.py | 0
providers/telegram/pyproject.toml | 3 +-
providers/teradata/pyproject.toml | 3 +-
.../src/airflow/providers/teradata/hooks/bteq.py | 4 +-
providers/trino/pyproject.toml | 3 +-
providers/vertica/pyproject.toml | 3 +-
.../src/airflow/providers/vertica/hooks/vertica.py | 4 +-
providers/weaviate/pyproject.toml | 3 +-
.../airflow/providers/weaviate/hooks/weaviate.py | 3 +-
providers/yandex/pyproject.toml | 3 +-
providers/ydb/pyproject.toml | 3 +-
providers/zendesk/pyproject.toml | 3 +-
pyproject.toml | 7 +-
scripts/ci/pre_commit/chart_schema.py | 2 +-
scripts/ci/pre_commit/check_deprecations.py | 4 +-
scripts/ci/pre_commit/common_precommit_utils.py | 6 +-
scripts/ci/pre_commit/mypy.py | 2 +-
scripts/ci/pre_commit/mypy_folder.py | 2 +-
scripts/ci/testing/summarize_captured_warnings.py | 4 +-
.../in_container/install_airflow_and_providers.py | 2 +-
scripts/in_container/run_generate_constraints.py | 2 +-
scripts/in_container/run_migration_reference.py | 2 +-
.../in_container/run_provider_yaml_files_check.py | 4 +-
task-sdk/src/airflow/sdk/api/client.py | 2 +-
task-sdk/src/airflow/sdk/bases/decorator.py | 5 +-
task-sdk/src/airflow/sdk/definitions/dag.py | 2 +-
task-sdk/tests/task_sdk/api/test_client.py | 47 ++
645 files changed, 4263 insertions(+), 3416 deletions(-)
delete mode 100644
airflow-core/src/airflow/serialization/serializers/pydantic.py
delete mode 100644 airflow-core/src/airflow/serialization/typing.py
copy providers/{alibaba/src/airflow/providers/alibaba =>
airbyte/src/airflow/providers/airbyte}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
apache/cassandra/src/airflow/providers/apache/cassandra}/version_compat.py
(100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
apache/flink/src/airflow/providers/apache/flink}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
apache/hdfs/src/airflow/providers/apache/hdfs}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
apache/hive/src/airflow/providers/apache/hive}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
apache/livy/src/airflow/providers/apache/livy}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
arangodb/src/airflow/providers/arangodb}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
atlassian/jira/src/airflow/providers/atlassian/jira}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
common/sql/src/airflow/providers/common/sql}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
datadog/src/airflow/providers/datadog}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
ftp/src/airflow/providers/ftp}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
github/src/airflow/providers/github}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
http/src/airflow/providers/http}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
imap/src/airflow/providers/imap}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
jenkins/src/airflow/providers/jenkins}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
mongo/src/airflow/providers/mongo}/version_compat.py (100%)
copy providers/{alibaba/src/airflow/providers/alibaba =>
tableau/src/airflow/providers/tableau}/version_compat.py (100%)
