Fixes 18349: proper version comparison (#18352)

* fix version check

* make checks happy

---------

Co-authored-by: Sriharsha Chintalapani <harshach@users.noreply.github.com>
This commit is contained in:
imishchuk-tsgs 2024-12-07 19:04:41 +02:00 committed by GitHub
parent 4d7bfdb9df
commit cd2408b56f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -22,6 +22,7 @@ from airflow.models import DagBag
from airflow.version import version as airflow_version
from flask import request
from openmetadata_managed_apis.utils.logger import api_logger
from packaging import version
logger = api_logger()
@ -110,7 +111,7 @@ def get_dagbag():
class ScanDagsTask(Process):
def run(self):
if airflow_version >= "2.6":
if version.parse(airflow_version) >= version.parse("2.6"):
scheduler_job = self._run_new_scheduler_job()
else:
scheduler_job = self._run_old_scheduler_job()