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 }}"
):
