From 0e75b7254b88e2f8b6fe29fe7dbfb38f1b71a265 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Emel=20=C5=9Eim=C5=9Fek?= Date: Fri, 7 Apr 2023 00:03:19 +0300 Subject: [PATCH] Fix upgrade tests --- src/test/regress/citus_tests/common.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/test/regress/citus_tests/common.py b/src/test/regress/citus_tests/common.py index cba2677d3..389f4942f 100644 --- a/src/test/regress/citus_tests/common.py +++ b/src/test/regress/citus_tests/common.py @@ -337,6 +337,10 @@ def get_actual_citus_version(pg_path, port): return get_version_number(citus_version) +def versiontuple(v): + return tuple(map(int, (v.split(".")))) + + def initialize_citus_cluster(bindir, datadir, settings, config): # In case there was a leftover from previous runs, stop the databases stop_databases( @@ -352,7 +356,7 @@ def initialize_citus_cluster(bindir, datadir, settings, config): actual_citus_version = get_actual_citus_version(bindir, config.coordinator_port()) - if actual_citus_version == "11.3": + if versiontuple(actual_citus_version) >= versiontuple("11"): add_coordinator_to_metadata(bindir, config.coordinator_port()) add_workers(bindir, config.worker_ports, config.coordinator_port())