Skip to content

Commit

Permalink
Simplify airflow_version imports (apache#39497)
Browse files Browse the repository at this point in the history
Use `importlib.metadata.version` to get `airflow_version`. This is a more standardized approach to getting the version.
  • Loading branch information
jedcunningham authored and RodrigoGanancia committed May 10, 2024
1 parent 958ed4a commit d46fca5
Show file tree
Hide file tree
Showing 94 changed files with 280 additions and 377 deletions.
7 changes: 3 additions & 4 deletions airflow/providers/airbyte/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "3.8.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/alibaba/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "2.8.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/amazon/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "8.21.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/beam/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "5.7.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/cassandra/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "3.5.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/drill/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "2.7.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/druid/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "3.10.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/flink/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "1.4.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/hdfs/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "4.4.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/hive/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "8.1.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/impala/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "1.4.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/kafka/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "1.4.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/kylin/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "3.6.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/livy/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "3.8.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/pig/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "4.4.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/pinot/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "4.4.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apache/spark/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "4.8.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/apprise/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "1.3.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/arangodb/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "2.5.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
7 changes: 3 additions & 4 deletions airflow/providers/asana/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,16 +23,15 @@
#
from __future__ import annotations

import importlib.metadata

import packaging.version

__all__ = ["__version__"]

__version__ = "2.5.0"

try:
from airflow import __version__ as airflow_version
except ImportError:
from airflow.version import version as airflow_version
airflow_version = importlib.metadata.version("apache-airflow")

if packaging.version.parse(packaging.version.parse(airflow_version).base_version) < packaging.version.parse(
"2.7.0"
Expand Down
Loading

0 comments on commit d46fca5

Please sign in to comment.