fix: update error message for unsupported Airflow version to include equality check

This commit is contained in:
2025-05-04 09:18:08 +00:00
parent 2031650535
commit 950dc06901

View File

@@ -57,7 +57,7 @@ async def get_airflow_tools(config: AirflowConfig, mode: str = "unsafe") -> list
if airflow_version is None: if airflow_version is None:
raise RuntimeError("Could not determine Airflow version from get_version tool.") raise RuntimeError("Could not determine Airflow version from get_version tool.")
if parse_version(airflow_version) <= parse_version("3.1.0"): if parse_version(airflow_version) <= parse_version("3.1.0"):
raise RuntimeError(f"Airflow version {airflow_version} is not supported. Requires > 3.1.0.") raise RuntimeError(f"Airflow version {airflow_version} is not supported. Requires >= 3.1.0.")
tools = [] tools = []
for operation_id, tool in _tools_cache.items(): for operation_id, tool in _tools_cache.items():