|
|
|
@@ -124,6 +124,7 @@ class Controller:
|
|
|
|
self.worker_parallelism = int(self.env.get("WORKER_PARALLELISM", "3"))
|
|
|
|
self.worker_parallelism = int(self.env.get("WORKER_PARALLELISM", "3"))
|
|
|
|
self.fast_mode = self.env.get("FAST_MODE", "1")
|
|
|
|
self.fast_mode = self.env.get("FAST_MODE", "1")
|
|
|
|
self.skip_rebuild = self.env.get("SKIP_REBUILD", "0") == "1"
|
|
|
|
self.skip_rebuild = self.env.get("SKIP_REBUILD", "0") == "1"
|
|
|
|
|
|
|
|
self.force_reinit = False
|
|
|
|
|
|
|
|
|
|
|
|
def log(self, msg):
|
|
|
|
def log(self, msg):
|
|
|
|
print(f"==> {msg}")
|
|
|
|
print(f"==> {msg}")
|
|
|
|
@@ -299,6 +300,7 @@ class Controller:
|
|
|
|
raise RuntimeError(f"Worker rebuild failures: {failures}")
|
|
|
|
raise RuntimeError(f"Worker rebuild failures: {failures}")
|
|
|
|
|
|
|
|
|
|
|
|
# Rebuild can invalidate prior bootstrap stages; force reconciliation.
|
|
|
|
# Rebuild can invalidate prior bootstrap stages; force reconciliation.
|
|
|
|
|
|
|
|
self.force_reinit = True
|
|
|
|
self.clear_done([
|
|
|
|
self.clear_done([
|
|
|
|
"primary_initialized",
|
|
|
|
"primary_initialized",
|
|
|
|
"cni_installed",
|
|
|
|
"cni_installed",
|
|
|
|
@@ -316,10 +318,10 @@ class Controller:
|
|
|
|
return self.remote(self.primary_ip, cmd, check=False).returncode == 0
|
|
|
|
return self.remote(self.primary_ip, cmd, check=False).returncode == 0
|
|
|
|
|
|
|
|
|
|
|
|
def stage_init_primary(self):
|
|
|
|
def stage_init_primary(self):
|
|
|
|
if self.stage_done("primary_initialized") and self.has_admin_conf() and self.cluster_ready():
|
|
|
|
if (not self.force_reinit) and self.stage_done("primary_initialized") and self.has_admin_conf() and self.cluster_ready():
|
|
|
|
self.log("Primary control plane init already complete")
|
|
|
|
self.log("Primary control plane init already complete")
|
|
|
|
return
|
|
|
|
return
|
|
|
|
if self.has_admin_conf() and self.cluster_ready():
|
|
|
|
if (not self.force_reinit) and self.has_admin_conf() and self.cluster_ready():
|
|
|
|
self.log("Existing cluster detected on primary control plane")
|
|
|
|
self.log("Existing cluster detected on primary control plane")
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
self.log(f"Initializing primary control plane on {self.primary_cp}")
|
|
|
|
self.log(f"Initializing primary control plane on {self.primary_cp}")
|
|
|
|
|