This is an automated email from the ASF dual-hosted git repository. jedcunningham pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push: new 2c05187b07 Faster `airflow_version` imports (#39552) 2c05187b07 is described below commit 2c05187b07baf7c41a32b18fabdbb3833acc08eb Author: Jed Cunningham <66968678+jedcunning...@users.noreply.github.com> AuthorDate: Fri May 10 16:54:54 2024 -0600 Faster `airflow_version` imports (#39552) Turns out `importlib.metadata.version` is much slower than a simple import, so let's switch back. It's not "slow", but might as well be faster :) --- airflow/providers/airbyte/__init__.py | 6 ++---- airflow/providers/alibaba/__init__.py | 6 ++---- airflow/providers/amazon/__init__.py | 6 ++---- airflow/providers/apache/beam/__init__.py | 6 ++---- airflow/providers/apache/cassandra/__init__.py | 6 ++---- airflow/providers/apache/drill/__init__.py | 6 ++---- airflow/providers/apache/druid/__init__.py | 6 ++---- airflow/providers/apache/flink/__init__.py | 6 ++---- airflow/providers/apache/hdfs/__init__.py | 6 ++---- airflow/providers/apache/hive/__init__.py | 6 ++---- airflow/providers/apache/impala/__init__.py | 6 ++---- airflow/providers/apache/kafka/__init__.py | 6 ++---- airflow/providers/apache/kylin/__init__.py | 6 ++---- airflow/providers/apache/livy/__init__.py | 6 ++---- airflow/providers/apache/pig/__init__.py | 6 ++---- airflow/providers/apache/pinot/__init__.py | 6 ++---- airflow/providers/apache/spark/__init__.py | 6 ++---- airflow/providers/apprise/__init__.py | 6 ++---- airflow/providers/arangodb/__init__.py | 6 ++---- airflow/providers/asana/__init__.py | 6 ++---- airflow/providers/atlassian/jira/__init__.py | 6 ++---- airflow/providers/celery/__init__.py | 6 ++---- airflow/providers/celery/executors/__init__.py | 4 +--- airflow/providers/celery/executors/celery_executor.py | 10 +++------- airflow/providers/cloudant/__init__.py | 6 ++---- airflow/providers/cncf/kubernetes/__init__.py | 6 ++---- .../providers/cncf/kubernetes/executors/kubernetes_executor.py | 4 +--- airflow/providers/cohere/__init__.py | 6 ++---- airflow/providers/common/io/__init__.py | 6 ++---- airflow/providers/common/io/xcom/__init__.py | 5 +---- airflow/providers/common/sql/__init__.py | 6 ++---- airflow/providers/databricks/__init__.py | 6 ++---- airflow/providers/datadog/__init__.py | 6 ++---- airflow/providers/dbt/cloud/__init__.py | 6 ++---- airflow/providers/dingding/__init__.py | 6 ++---- airflow/providers/discord/__init__.py | 6 ++---- airflow/providers/docker/__init__.py | 6 ++---- airflow/providers/elasticsearch/__init__.py | 6 ++---- airflow/providers/exasol/__init__.py | 6 ++---- airflow/providers/fab/__init__.py | 6 ++---- airflow/providers/facebook/__init__.py | 6 ++---- airflow/providers/ftp/__init__.py | 6 ++---- airflow/providers/github/__init__.py | 6 ++---- airflow/providers/google/__init__.py | 6 ++---- airflow/providers/grpc/__init__.py | 6 ++---- airflow/providers/hashicorp/__init__.py | 6 ++---- airflow/providers/http/__init__.py | 6 ++---- airflow/providers/imap/__init__.py | 6 ++---- airflow/providers/influxdb/__init__.py | 6 ++---- airflow/providers/jdbc/__init__.py | 6 ++---- airflow/providers/jenkins/__init__.py | 6 ++---- airflow/providers/microsoft/azure/__init__.py | 6 ++---- airflow/providers/microsoft/mssql/__init__.py | 6 ++---- airflow/providers/microsoft/psrp/__init__.py | 6 ++---- airflow/providers/microsoft/winrm/__init__.py | 6 ++---- airflow/providers/mongo/__init__.py | 6 ++---- airflow/providers/mysql/__init__.py | 6 ++---- airflow/providers/neo4j/__init__.py | 6 ++---- airflow/providers/odbc/__init__.py | 6 ++---- airflow/providers/openai/__init__.py | 6 ++---- airflow/providers/openfaas/__init__.py | 6 ++---- airflow/providers/openlineage/__init__.py | 6 ++---- airflow/providers/opensearch/__init__.py | 6 ++---- airflow/providers/opsgenie/__init__.py | 6 ++---- airflow/providers/oracle/__init__.py | 6 ++---- airflow/providers/pagerduty/__init__.py | 6 ++---- airflow/providers/papermill/__init__.py | 6 ++---- airflow/providers/pgvector/__init__.py | 6 ++---- airflow/providers/pinecone/__init__.py | 6 ++---- airflow/providers/postgres/__init__.py | 6 ++---- airflow/providers/presto/__init__.py | 6 ++---- airflow/providers/qdrant/__init__.py | 6 ++---- airflow/providers/redis/__init__.py | 6 ++---- airflow/providers/salesforce/__init__.py | 6 ++---- airflow/providers/samba/__init__.py | 6 ++---- airflow/providers/segment/__init__.py | 6 ++---- airflow/providers/sendgrid/__init__.py | 6 ++---- airflow/providers/sftp/__init__.py | 6 ++---- airflow/providers/singularity/__init__.py | 6 ++---- airflow/providers/slack/__init__.py | 6 ++---- airflow/providers/smtp/__init__.py | 6 ++---- airflow/providers/snowflake/__init__.py | 6 ++---- airflow/providers/sqlite/__init__.py | 6 ++---- airflow/providers/ssh/__init__.py | 6 ++---- airflow/providers/tableau/__init__.py | 6 ++---- airflow/providers/telegram/__init__.py | 6 ++---- airflow/providers/teradata/__init__.py | 6 ++---- airflow/providers/trino/__init__.py | 6 ++---- airflow/providers/vertica/__init__.py | 6 ++---- airflow/providers/weaviate/__init__.py | 6 ++---- airflow/providers/yandex/__init__.py | 6 ++---- airflow/providers/zendesk/__init__.py | 6 ++---- .../templates/PROVIDER__INIT__PY_TEMPLATE.py.jinja2 | 6 ++---- 93 files changed, 184 insertions(+), 373 deletions(-) diff --git a/airflow/providers/airbyte/__init__.py b/airflow/providers/airbyte/__init__.py index 0e0d1b3059..a07973c02b 100644 --- a/airflow/providers/airbyte/__init__.py +++ b/airflow/providers/airbyte/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.8.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/alibaba/__init__.py b/airflow/providers/alibaba/__init__.py index 214d1fb451..25807468c0 100644 --- a/airflow/providers/alibaba/__init__.py +++ b/airflow/providers/alibaba/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.8.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/amazon/__init__.py b/airflow/providers/amazon/__init__.py index 5148fc4998..80cbe4e94a 100644 --- a/airflow/providers/amazon/__init__.py +++ b/airflow/providers/amazon/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "8.21.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/beam/__init__.py b/airflow/providers/apache/beam/__init__.py index 0293d1675c..b7eb22ca4a 100644 --- a/airflow/providers/apache/beam/__init__.py +++ b/airflow/providers/apache/beam/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/cassandra/__init__.py b/airflow/providers/apache/cassandra/__init__.py index 87b6b0c5f3..3655657013 100644 --- a/airflow/providers/apache/cassandra/__init__.py +++ b/airflow/providers/apache/cassandra/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/drill/__init__.py b/airflow/providers/apache/drill/__init__.py index df1c996ab5..84a1da053d 100644 --- a/airflow/providers/apache/drill/__init__.py +++ b/airflow/providers/apache/drill/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/druid/__init__.py b/airflow/providers/apache/druid/__init__.py index 333e1f62ea..7efd26ce30 100644 --- a/airflow/providers/apache/druid/__init__.py +++ b/airflow/providers/apache/druid/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.10.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/flink/__init__.py b/airflow/providers/apache/flink/__init__.py index df0e681653..3fec0e9e99 100644 --- a/airflow/providers/apache/flink/__init__.py +++ b/airflow/providers/apache/flink/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/hdfs/__init__.py b/airflow/providers/apache/hdfs/__init__.py index 2e0a6853d1..5bf10680ff 100644 --- a/airflow/providers/apache/hdfs/__init__.py +++ b/airflow/providers/apache/hdfs/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/hive/__init__.py b/airflow/providers/apache/hive/__init__.py index bad3dbe105..c055456a87 100644 --- a/airflow/providers/apache/hive/__init__.py +++ b/airflow/providers/apache/hive/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "8.1.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/impala/__init__.py b/airflow/providers/apache/impala/__init__.py index 286df46a63..bfaf05a3a2 100644 --- a/airflow/providers/apache/impala/__init__.py +++ b/airflow/providers/apache/impala/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/kafka/__init__.py b/airflow/providers/apache/kafka/__init__.py index be1be77227..dd599886c5 100644 --- a/airflow/providers/apache/kafka/__init__.py +++ b/airflow/providers/apache/kafka/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/kylin/__init__.py b/airflow/providers/apache/kylin/__init__.py index 0fb935ecb7..4e57b9e0e2 100644 --- a/airflow/providers/apache/kylin/__init__.py +++ b/airflow/providers/apache/kylin/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/livy/__init__.py b/airflow/providers/apache/livy/__init__.py index af449a4db6..12a06df025 100644 --- a/airflow/providers/apache/livy/__init__.py +++ b/airflow/providers/apache/livy/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.8.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/pig/__init__.py b/airflow/providers/apache/pig/__init__.py index 0a870a3012..be5d281a6a 100644 --- a/airflow/providers/apache/pig/__init__.py +++ b/airflow/providers/apache/pig/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/pinot/__init__.py b/airflow/providers/apache/pinot/__init__.py index 8f9db5c7d4..d060b9626c 100644 --- a/airflow/providers/apache/pinot/__init__.py +++ b/airflow/providers/apache/pinot/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apache/spark/__init__.py b/airflow/providers/apache/spark/__init__.py index 2a28692654..2259b4c575 100644 --- a/airflow/providers/apache/spark/__init__.py +++ b/airflow/providers/apache/spark/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.8.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/apprise/__init__.py b/airflow/providers/apprise/__init__.py index 440c1308df..9416af150f 100644 --- a/airflow/providers/apprise/__init__.py +++ b/airflow/providers/apprise/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.3.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/arangodb/__init__.py b/airflow/providers/arangodb/__init__.py index e87e109dce..90f124c19c 100644 --- a/airflow/providers/arangodb/__init__.py +++ b/airflow/providers/arangodb/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/asana/__init__.py b/airflow/providers/asana/__init__.py index a6db494b73..d1311b1add 100644 --- a/airflow/providers/asana/__init__.py +++ b/airflow/providers/asana/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/atlassian/jira/__init__.py b/airflow/providers/atlassian/jira/__init__.py index 4cc0d04037..c26f65c3e0 100644 --- a/airflow/providers/atlassian/jira/__init__.py +++ b/airflow/providers/atlassian/jira/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/celery/__init__.py b/airflow/providers/celery/__init__.py index f3a794ee59..23fddbde98 100644 --- a/airflow/providers/celery/__init__.py +++ b/airflow/providers/celery/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/celery/executors/__init__.py b/airflow/providers/celery/executors/__init__.py index 8d14611dea..2503cb7e14 100644 --- a/airflow/providers/celery/executors/__init__.py +++ b/airflow/providers/celery/executors/__init__.py @@ -16,13 +16,11 @@ # under the License. from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version from airflow.exceptions import AirflowOptionalProviderFeatureException -airflow_version = importlib.metadata.version("apache-airflow") base_version = packaging.version.parse(airflow_version).base_version if packaging.version.parse(base_version) < packaging.version.parse("2.7.0"): diff --git a/airflow/providers/celery/executors/celery_executor.py b/airflow/providers/celery/executors/celery_executor.py index 4bd0a9f2b9..d81e57a222 100644 --- a/airflow/providers/celery/executors/celery_executor.py +++ b/airflow/providers/celery/executors/celery_executor.py @@ -30,13 +30,14 @@ import operator import time from collections import Counter from concurrent.futures import ProcessPoolExecutor -from importlib.metadata import version as importlib_version from multiprocessing import cpu_count from typing import TYPE_CHECKING, Any, Optional, Sequence, Tuple from celery import states as celery_states from packaging.version import Version +from airflow import __version__ as airflow_version + try: from airflow.cli.cli_config import ( ARG_DAEMON, @@ -52,13 +53,10 @@ try: lazy_load_command, ) except ImportError: - import importlib.metadata - import packaging.version from airflow.exceptions import AirflowOptionalProviderFeatureException - airflow_version = importlib.metadata.version("apache-airflow") base_version = packaging.version.parse(airflow_version).base_version if packaging.version.parse(base_version) < packaging.version.parse("2.7.0"): @@ -178,11 +176,9 @@ ARG_WITHOUT_GOSSIP = Arg( action="store_true", ) -AIRFLOW_VERSION = Version(importlib_version("apache-airflow")) - CELERY_CLI_COMMAND_PATH = ( "airflow.providers.celery.cli.celery_command" - if AIRFLOW_VERSION >= Version("2.8.0") + if Version(airflow_version) >= Version("2.8.0") else "airflow.cli.commands.celery_command" ) diff --git a/airflow/providers/cloudant/__init__.py b/airflow/providers/cloudant/__init__.py index ec0dded9cf..b74bac99b0 100644 --- a/airflow/providers/cloudant/__init__.py +++ b/airflow/providers/cloudant/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/cncf/kubernetes/__init__.py b/airflow/providers/cncf/kubernetes/__init__.py index bad8b413cd..9be2787742 100644 --- a/airflow/providers/cncf/kubernetes/__init__.py +++ b/airflow/providers/cncf/kubernetes/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "8.2.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py index cac2b8507b..f62f021fd2 100644 --- a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py +++ b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py @@ -55,13 +55,11 @@ try: positive_int, ) except ImportError: - import importlib.metadata - import packaging.version + from airflow import __version__ as airflow_version from airflow.exceptions import AirflowOptionalProviderFeatureException - airflow_version = importlib.metadata.version("apache-airflow") base_version = packaging.version.parse(airflow_version).base_version if packaging.version.parse(base_version) < packaging.version.parse("2.7.0"): diff --git a/airflow/providers/cohere/__init__.py b/airflow/providers/cohere/__init__.py index c3d9b6b4e6..db9ea0412b 100644 --- a/airflow/providers/cohere/__init__.py +++ b/airflow/providers/cohere/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.2.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/common/io/__init__.py b/airflow/providers/common/io/__init__.py index fe4ebf08cb..b2fad5afca 100644 --- a/airflow/providers/common/io/__init__.py +++ b/airflow/providers/common/io/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.3.1" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.8.0" ): diff --git a/airflow/providers/common/io/xcom/__init__.py b/airflow/providers/common/io/xcom/__init__.py index fb8148bb88..b245035ddb 100644 --- a/airflow/providers/common/io/xcom/__init__.py +++ b/airflow/providers/common/io/xcom/__init__.py @@ -16,14 +16,11 @@ # under the License. from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version from airflow.exceptions import AirflowOptionalProviderFeatureException -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.9.0" ): diff --git a/airflow/providers/common/sql/__init__.py b/airflow/providers/common/sql/__init__.py index 7163046af3..14fc628017 100644 --- a/airflow/providers/common/sql/__init__.py +++ b/airflow/providers/common/sql/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.13.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/databricks/__init__.py b/airflow/providers/databricks/__init__.py index e7c61a3583..0cfa8ae33b 100644 --- a/airflow/providers/databricks/__init__.py +++ b/airflow/providers/databricks/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "6.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/datadog/__init__.py b/airflow/providers/datadog/__init__.py index eeeb8cb5cb..41faf96ba3 100644 --- a/airflow/providers/datadog/__init__.py +++ b/airflow/providers/datadog/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/dbt/cloud/__init__.py b/airflow/providers/dbt/cloud/__init__.py index 740d82bb88..b826a24292 100644 --- a/airflow/providers/dbt/cloud/__init__.py +++ b/airflow/providers/dbt/cloud/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.8.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/dingding/__init__.py b/airflow/providers/dingding/__init__.py index d1d2250adf..53246c6aca 100644 --- a/airflow/providers/dingding/__init__.py +++ b/airflow/providers/dingding/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/discord/__init__.py b/airflow/providers/discord/__init__.py index f3ecad8de5..0cc87949a4 100644 --- a/airflow/providers/discord/__init__.py +++ b/airflow/providers/discord/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/docker/__init__.py b/airflow/providers/docker/__init__.py index 2f9089e031..33f852b118 100644 --- a/airflow/providers/docker/__init__.py +++ b/airflow/providers/docker/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.11.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/elasticsearch/__init__.py b/airflow/providers/elasticsearch/__init__.py index 16cefb31cf..c81c8644ff 100644 --- a/airflow/providers/elasticsearch/__init__.py +++ b/airflow/providers/elasticsearch/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/exasol/__init__.py b/airflow/providers/exasol/__init__.py index cc52085927..20dc46710e 100644 --- a/airflow/providers/exasol/__init__.py +++ b/airflow/providers/exasol/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/fab/__init__.py b/airflow/providers/fab/__init__.py index 420f49d188..193d230c56 100644 --- a/airflow/providers/fab/__init__.py +++ b/airflow/providers/fab/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.1.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.9.0" ): diff --git a/airflow/providers/facebook/__init__.py b/airflow/providers/facebook/__init__.py index 9e1d29e6a7..a1491034ad 100644 --- a/airflow/providers/facebook/__init__.py +++ b/airflow/providers/facebook/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/ftp/__init__.py b/airflow/providers/ftp/__init__.py index 33c8d16657..6d6494669c 100644 --- a/airflow/providers/ftp/__init__.py +++ b/airflow/providers/ftp/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.9.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/github/__init__.py b/airflow/providers/github/__init__.py index deaf9e1ff2..f2990b662c 100644 --- a/airflow/providers/github/__init__.py +++ b/airflow/providers/github/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/google/__init__.py b/airflow/providers/google/__init__.py index 1b815c1d5b..d364b8d9d3 100644 --- a/airflow/providers/google/__init__.py +++ b/airflow/providers/google/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "10.18.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/grpc/__init__.py b/airflow/providers/grpc/__init__.py index ea0e3a5847..20b8716f3b 100644 --- a/airflow/providers/grpc/__init__.py +++ b/airflow/providers/grpc/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/hashicorp/__init__.py b/airflow/providers/hashicorp/__init__.py index 42b9b57b0e..cebefa52bc 100644 --- a/airflow/providers/hashicorp/__init__.py +++ b/airflow/providers/hashicorp/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/http/__init__.py b/airflow/providers/http/__init__.py index 66ccde62db..2800120db6 100644 --- a/airflow/providers/http/__init__.py +++ b/airflow/providers/http/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.11.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/imap/__init__.py b/airflow/providers/imap/__init__.py index d33ec6f2c9..03780a1e82 100644 --- a/airflow/providers/imap/__init__.py +++ b/airflow/providers/imap/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/influxdb/__init__.py b/airflow/providers/influxdb/__init__.py index 028687307e..06287bc90a 100644 --- a/airflow/providers/influxdb/__init__.py +++ b/airflow/providers/influxdb/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/jdbc/__init__.py b/airflow/providers/jdbc/__init__.py index 1917b3e9b8..50a3bdc4c2 100644 --- a/airflow/providers/jdbc/__init__.py +++ b/airflow/providers/jdbc/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.3.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/jenkins/__init__.py b/airflow/providers/jenkins/__init__.py index 142fec51f7..d79d94784c 100644 --- a/airflow/providers/jenkins/__init__.py +++ b/airflow/providers/jenkins/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/microsoft/azure/__init__.py b/airflow/providers/microsoft/azure/__init__.py index 1e2f790ffa..23a7811f3f 100644 --- a/airflow/providers/microsoft/azure/__init__.py +++ b/airflow/providers/microsoft/azure/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "10.1.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/microsoft/mssql/__init__.py b/airflow/providers/microsoft/mssql/__init__.py index d053ea756f..60680a857e 100644 --- a/airflow/providers/microsoft/mssql/__init__.py +++ b/airflow/providers/microsoft/mssql/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/microsoft/psrp/__init__.py b/airflow/providers/microsoft/psrp/__init__.py index 921c4a5e63..8de9b1b8d2 100644 --- a/airflow/providers/microsoft/psrp/__init__.py +++ b/airflow/providers/microsoft/psrp/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/microsoft/winrm/__init__.py b/airflow/providers/microsoft/winrm/__init__.py index 0b0e3eadc7..fdc12f1f52 100644 --- a/airflow/providers/microsoft/winrm/__init__.py +++ b/airflow/providers/microsoft/winrm/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/mongo/__init__.py b/airflow/providers/mongo/__init__.py index d7619888a2..eb399ee95e 100644 --- a/airflow/providers/mongo/__init__.py +++ b/airflow/providers/mongo/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.1.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/mysql/__init__.py b/airflow/providers/mysql/__init__.py index cb6f3ad8ca..ca8f004145 100644 --- a/airflow/providers/mysql/__init__.py +++ b/airflow/providers/mysql/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/neo4j/__init__.py b/airflow/providers/neo4j/__init__.py index b2689bc8a7..28fce12d8a 100644 --- a/airflow/providers/neo4j/__init__.py +++ b/airflow/providers/neo4j/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/odbc/__init__.py b/airflow/providers/odbc/__init__.py index 665d0213d7..05ff08bb76 100644 --- a/airflow/providers/odbc/__init__.py +++ b/airflow/providers/odbc/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/openai/__init__.py b/airflow/providers/openai/__init__.py index 819546e6ca..97099b637e 100644 --- a/airflow/providers/openai/__init__.py +++ b/airflow/providers/openai/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.2.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/openfaas/__init__.py b/airflow/providers/openfaas/__init__.py index d62150dd48..5e2a80386d 100644 --- a/airflow/providers/openfaas/__init__.py +++ b/airflow/providers/openfaas/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/openlineage/__init__.py b/airflow/providers/openlineage/__init__.py index 7b1fc1e8aa..e63e112c4d 100644 --- a/airflow/providers/openlineage/__init__.py +++ b/airflow/providers/openlineage/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.7.1" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/opensearch/__init__.py b/airflow/providers/opensearch/__init__.py index 980e3d561b..1693916df3 100644 --- a/airflow/providers/opensearch/__init__.py +++ b/airflow/providers/opensearch/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.2.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/opsgenie/__init__.py b/airflow/providers/opsgenie/__init__.py index 458f676a22..8e33e36c07 100644 --- a/airflow/providers/opsgenie/__init__.py +++ b/airflow/providers/opsgenie/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.6.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/oracle/__init__.py b/airflow/providers/oracle/__init__.py index d17413ae37..fa425800b8 100644 --- a/airflow/providers/oracle/__init__.py +++ b/airflow/providers/oracle/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.10.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/pagerduty/__init__.py b/airflow/providers/pagerduty/__init__.py index 97d6072d5f..7e06144428 100644 --- a/airflow/providers/pagerduty/__init__.py +++ b/airflow/providers/pagerduty/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/papermill/__init__.py b/airflow/providers/papermill/__init__.py index 0a2cee74f9..d3ad606f29 100644 --- a/airflow/providers/papermill/__init__.py +++ b/airflow/providers/papermill/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/pgvector/__init__.py b/airflow/providers/pgvector/__init__.py index 6d8e4ae745..be7d58a9f5 100644 --- a/airflow/providers/pgvector/__init__.py +++ b/airflow/providers/pgvector/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.2.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/pinecone/__init__.py b/airflow/providers/pinecone/__init__.py index c68d4e6326..697ee57360 100644 --- a/airflow/providers/pinecone/__init__.py +++ b/airflow/providers/pinecone/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.0.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/postgres/__init__.py b/airflow/providers/postgres/__init__.py index ec9e4c1d62..3a9b4fc9f5 100644 --- a/airflow/providers/postgres/__init__.py +++ b/airflow/providers/postgres/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.11.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/presto/__init__.py b/airflow/providers/presto/__init__.py index 8510ebf276..01b54b4535 100644 --- a/airflow/providers/presto/__init__.py +++ b/airflow/providers/presto/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/qdrant/__init__.py b/airflow/providers/qdrant/__init__.py index 1c5ed55b8a..7fe71b9fb6 100644 --- a/airflow/providers/qdrant/__init__.py +++ b/airflow/providers/qdrant/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.1.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/redis/__init__.py b/airflow/providers/redis/__init__.py index 2836130ad0..e87e22c6e4 100644 --- a/airflow/providers/redis/__init__.py +++ b/airflow/providers/redis/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/salesforce/__init__.py b/airflow/providers/salesforce/__init__.py index 5de51bd593..c714cc7de7 100644 --- a/airflow/providers/salesforce/__init__.py +++ b/airflow/providers/salesforce/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/samba/__init__.py b/airflow/providers/samba/__init__.py index 219223dd02..c44dc8bfb9 100644 --- a/airflow/providers/samba/__init__.py +++ b/airflow/providers/samba/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/segment/__init__.py b/airflow/providers/segment/__init__.py index b36d880d21..5f42ef2059 100644 --- a/airflow/providers/segment/__init__.py +++ b/airflow/providers/segment/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/sendgrid/__init__.py b/airflow/providers/sendgrid/__init__.py index 90ad88640c..3dd3c12c60 100644 --- a/airflow/providers/sendgrid/__init__.py +++ b/airflow/providers/sendgrid/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/sftp/__init__.py b/airflow/providers/sftp/__init__.py index a5e7266c0d..ae7986d56d 100644 --- a/airflow/providers/sftp/__init__.py +++ b/airflow/providers/sftp/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.10.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/singularity/__init__.py b/airflow/providers/singularity/__init__.py index 9367b42e84..13f8234a7b 100644 --- a/airflow/providers/singularity/__init__.py +++ b/airflow/providers/singularity/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/slack/__init__.py b/airflow/providers/slack/__init__.py index 8f4730f3f1..ed52fe6fe3 100644 --- a/airflow/providers/slack/__init__.py +++ b/airflow/providers/slack/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "8.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/smtp/__init__.py b/airflow/providers/smtp/__init__.py index 22da6a16e6..5aedc6ae13 100644 --- a/airflow/providers/smtp/__init__.py +++ b/airflow/providers/smtp/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/snowflake/__init__.py b/airflow/providers/snowflake/__init__.py index 50cbf403a2..78271c7f24 100644 --- a/airflow/providers/snowflake/__init__.py +++ b/airflow/providers/snowflake/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/sqlite/__init__.py b/airflow/providers/sqlite/__init__.py index b128455146..7fa30a6214 100644 --- a/airflow/providers/sqlite/__init__.py +++ b/airflow/providers/sqlite/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.8.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/ssh/__init__.py b/airflow/providers/ssh/__init__.py index 405804da09..cb49b1282d 100644 --- a/airflow/providers/ssh/__init__.py +++ b/airflow/providers/ssh/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.11.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/tableau/__init__.py b/airflow/providers/tableau/__init__.py index 5ef56c3508..6263e46342 100644 --- a/airflow/providers/tableau/__init__.py +++ b/airflow/providers/tableau/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/telegram/__init__.py b/airflow/providers/telegram/__init__.py index 0f111313bf..e2e9bf3678 100644 --- a/airflow/providers/telegram/__init__.py +++ b/airflow/providers/telegram/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.5.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/teradata/__init__.py b/airflow/providers/teradata/__init__.py index 3786b36cc0..aa247076e1 100644 --- a/airflow/providers/teradata/__init__.py +++ b/airflow/providers/teradata/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "2.1.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/trino/__init__.py b/airflow/providers/trino/__init__.py index 68c7dc9981..edda72aca5 100644 --- a/airflow/providers/trino/__init__.py +++ b/airflow/providers/trino/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "5.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/vertica/__init__.py b/airflow/providers/vertica/__init__.py index 747a044dbd..41692946b1 100644 --- a/airflow/providers/vertica/__init__.py +++ b/airflow/providers/vertica/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.8.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/weaviate/__init__.py b/airflow/providers/weaviate/__init__.py index bb919cb6f9..0cd629cb2c 100644 --- a/airflow/providers/weaviate/__init__.py +++ b/airflow/providers/weaviate/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "1.4.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/yandex/__init__.py b/airflow/providers/yandex/__init__.py index c530acf884..3dc0222db3 100644 --- a/airflow/providers/yandex/__init__.py +++ b/airflow/providers/yandex/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "3.11.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/airflow/providers/zendesk/__init__.py b/airflow/providers/zendesk/__init__.py index f98ac814bb..1399120e46 100644 --- a/airflow/providers/zendesk/__init__.py +++ b/airflow/providers/zendesk/__init__.py @@ -23,16 +23,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "4.7.0" -airflow_version = importlib.metadata.version("apache-airflow") - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "2.7.0" ): diff --git a/dev/breeze/src/airflow_breeze/templates/PROVIDER__INIT__PY_TEMPLATE.py.jinja2 b/dev/breeze/src/airflow_breeze/templates/PROVIDER__INIT__PY_TEMPLATE.py.jinja2 index 7117b283c2..870ce1eee2 100644 --- a/dev/breeze/src/airflow_breeze/templates/PROVIDER__INIT__PY_TEMPLATE.py.jinja2 +++ b/dev/breeze/src/airflow_breeze/templates/PROVIDER__INIT__PY_TEMPLATE.py.jinja2 @@ -42,16 +42,14 @@ # from __future__ import annotations -import importlib.metadata - import packaging.version +from airflow import __version__ as airflow_version + __all__ = ["__version__"] __version__ = "{{ RELEASE }}{{ VERSION_SUFFIX }}" -airflow_version = importlib.metadata.version('apache-airflow') - if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse( "{{ MIN_AIRFLOW_VERSION }}" ):