From 639635f75c2e1003ff84253aa71229fa48c9749f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Art=C3=BAr=20Po=C3=B3r?= Date: Thu, 2 Jul 2026 14:03:14 +0200 Subject: [PATCH 1/2] Separate write folders for each clouseau instance --- dev/run | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/dev/run b/dev/run index 3b13bb6280..f9cac0757a 100755 --- a/dev/run +++ b/dev/run @@ -631,18 +631,27 @@ config: [ name: clouseau1 domain: 127.0.0.1 } + clouseau: { + dir: dev/lib/node1/indexes + } } { node: { name: clouseau2 domain: 127.0.0.1 } + clouseau: { + dir: dev/lib/node2/indexes + } } { node: { name: clouseau3 domain: 127.0.0.1 } + clouseau: { + dir: dev/lib/node3/indexes + } } ] """ @@ -803,7 +812,7 @@ def boot_clouseau(ctx, idx): if is_ziose: clouseau_jars = glob.glob( - os.path.join(clouseau_dir, "clouseau", "target", "**", "*.jar"), + os.path.join(clouseau_dir, "target", "**", "clouseau", "*.jar"), recursive=True, ) @@ -890,6 +899,7 @@ def boot_clouseau(ctx, idx): + clouseau_cookie + [main_class, config_path] ) + print(f"Starting clouseau as {cmd}") try: return sp.Popen( @@ -1186,6 +1196,7 @@ def boot_node(ctx, node): @log("Running cluster setup") def cluster_setup(ctx): + print("Running setup") lead_port = cluster_port(ctx, ctx["node_number_seed"]) if enable_cluster(ctx["N"], lead_port, *ctx["admin"]): for num in range(1, ctx["N"]): @@ -1260,6 +1271,7 @@ def set_cookie(port, user, pswd): def finish_cluster(port, user, pswd): + print("finishing cluster ", port, " ", user, " ", pswd) status, response = try_request( "127.0.0.1", port, From a009d771f808cb02ff33334308e03e8fe8a8efc1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Art=C3=BAr=20Po=C3=B3r?= Date: Thu, 2 Jul 2026 14:15:56 +0200 Subject: [PATCH 2/2] Revert accidentally added changes --- dev/run | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/dev/run b/dev/run index f9cac0757a..0e6396ea5a 100755 --- a/dev/run +++ b/dev/run @@ -812,7 +812,7 @@ def boot_clouseau(ctx, idx): if is_ziose: clouseau_jars = glob.glob( - os.path.join(clouseau_dir, "target", "**", "clouseau", "*.jar"), + os.path.join(clouseau_dir, "clouseau", "target", "**", "*.jar"), recursive=True, ) @@ -899,7 +899,6 @@ def boot_clouseau(ctx, idx): + clouseau_cookie + [main_class, config_path] ) - print(f"Starting clouseau as {cmd}") try: return sp.Popen( @@ -1196,7 +1195,6 @@ def boot_node(ctx, node): @log("Running cluster setup") def cluster_setup(ctx): - print("Running setup") lead_port = cluster_port(ctx, ctx["node_number_seed"]) if enable_cluster(ctx["N"], lead_port, *ctx["admin"]): for num in range(1, ctx["N"]): @@ -1271,7 +1269,6 @@ def set_cookie(port, user, pswd): def finish_cluster(port, user, pswd): - print("finishing cluster ", port, " ", user, " ", pswd) status, response = try_request( "127.0.0.1", port,