From 1228caadbe5e6585fea25b7909519a72abdf3788 Mon Sep 17 00:00:00 2001 From: tiranux <23462892+tiranux@users.noreply.github.com> Date: Fri, 11 Aug 2023 04:51:04 +0000 Subject: [PATCH] Fix wrong OR condition when evaluating beam version < 2.39.0 --- airflow/providers/apache/beam/hooks/beam.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/providers/apache/beam/hooks/beam.py b/airflow/providers/apache/beam/hooks/beam.py index d92ade2050c9a..ee43d86d73f45 100644 --- a/airflow/providers/apache/beam/hooks/beam.py +++ b/airflow/providers/apache/beam/hooks/beam.py @@ -273,7 +273,7 @@ def start_python_pipeline( self.log.info("Beam version: %s", beam_version) impersonate_service_account = variables.get("impersonate_service_account") if impersonate_service_account: - if Version(beam_version) < Version("2.39.0") or True: + if Version(beam_version) < Version("2.39.0"): raise AirflowException( "The impersonateServiceAccount option requires Apache Beam 2.39.0 or newer." ) @@ -488,7 +488,7 @@ async def start_python_pipeline_async( self.log.info("Beam version: %s", beam_version) impersonate_service_account = variables.get("impersonate_service_account") if impersonate_service_account: - if Version(beam_version) < Version("2.39.0") or True: + if Version(beam_version) < Version("2.39.0"): raise AirflowException( "The impersonateServiceAccount option requires Apache Beam 2.39.0 or newer." )