mirror of https://github.com/citusdata/citus.git
Adjust arbitrary configs metadata sync (#5956)
As of Citus 11, we already sync metadata by default. It is useful to keep one schedule without metadata sync.pull/5938/head^2
parent
757ecba968
commit
431311732a
|
@ -214,10 +214,10 @@ def save_regression_diff(name, output_dir):
|
|||
shutil.move(path, new_file_path)
|
||||
|
||||
|
||||
def sync_metadata_to_workers(pg_path, worker_ports, coordinator_port):
|
||||
def stop_metadata_to_workers(pg_path, worker_ports, coordinator_port):
|
||||
for port in worker_ports:
|
||||
command = (
|
||||
"SELECT * from start_metadata_sync_to_node('localhost', {port});".format(
|
||||
"SELECT * from stop_metadata_sync_to_node('localhost', {port});".format(
|
||||
port=port
|
||||
)
|
||||
)
|
||||
|
@ -286,8 +286,8 @@ def initialize_citus_cluster(bindir, datadir, settings, config):
|
|||
start_databases(bindir, datadir, config.node_name_to_ports, config.name, config.env_variables)
|
||||
create_citus_extension(bindir, config.node_name_to_ports.values())
|
||||
add_workers(bindir, config.worker_ports, config.coordinator_port())
|
||||
if config.is_mx:
|
||||
sync_metadata_to_workers(bindir, config.worker_ports, config.coordinator_port())
|
||||
if not config.is_mx:
|
||||
stop_metadata_to_workers(bindir, config.worker_ports, config.coordinator_port())
|
||||
if config.add_coordinator_to_metadata:
|
||||
add_coordinator_to_metadata(bindir, config.coordinator_port())
|
||||
config.setup_steps()
|
||||
|
|
|
@ -176,7 +176,6 @@ class CitusUpgradeConfig(CitusBaseClusterConfig):
|
|||
self.user = SUPER_USER_NAME
|
||||
self.mixed_mode = arguments["--mixed"]
|
||||
self.fixed_port = 57635
|
||||
self.is_mx = False
|
||||
|
||||
|
||||
class PostgresConfig(CitusDefaultClusterConfig):
|
||||
|
@ -341,6 +340,9 @@ class CitusNonMxClusterConfig(CitusDefaultClusterConfig):
|
|||
def __init__(self, arguments):
|
||||
super().__init__(arguments)
|
||||
self.is_mx = False
|
||||
# citus does not support distributed functions
|
||||
# when metadata is not synced
|
||||
self.skip_tests = ["function_create", "functions"]
|
||||
|
||||
|
||||
class PGUpgradeConfig(CitusBaseClusterConfig):
|
||||
|
|
Loading…
Reference in New Issue