external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix upgrade tests

pull/6843/head
Emel Şimşek 2023-04-07 00:03:19 +03:00
parent 1de21841e4
commit 0e75b7254b
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/regress/citus_tests/common.py
View File

@ -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())