From 9706df975de43cfc1da40f1d1dfb9b6adff69512 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Emel=20=C5=9Eim=C5=9Fek?= Date: Thu, 6 Apr 2023 21:25:26 +0300 Subject: [PATCH] Handle upgrade tests older versions --- src/test/regress/citus_tests/common.py | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/src/test/regress/citus_tests/common.py b/src/test/regress/citus_tests/common.py index 489edb6b5..609f13b61 100644 --- a/src/test/regress/citus_tests/common.py +++ b/src/test/regress/citus_tests/common.py @@ -325,6 +325,15 @@ def stop_databases( stop(node_name) +def get_version_number(version): + return re.findall(r"\d+.\d+", version)[0] + + +def get_actual_citus_version(pg_path, port): + citus_version = utils.psql_capture(pg_path, port, CITUS_VERSION_SQL) + citus_version = citus_version.decode("utf-8") + return get_version_number(citus_version) + def initialize_citus_cluster(bindir, datadir, settings, config): # In case there was a leftover from previous runs, stop the databases stop_databases( @@ -338,7 +347,10 @@ def initialize_citus_cluster(bindir, datadir, settings, config): ) create_citus_extension(bindir, config.node_name_to_ports.values()) - add_coordinator_to_metadata(bindir, config.coordinator_port()) + actual_citus_version = get_actual_citus_version(config.bindir, config.coordinator_port()) + + if actual_citus_version == '11.3': + add_coordinator_to_metadata(bindir, config.coordinator_port()) add_workers(bindir, config.worker_ports, config.coordinator_port()) if not config.is_mx: