fix(cluster): wait for process finish

RedHatInsights · Nov 28, 2024 · 10433ef · 10433ef
1 parent d0680c5
commit 10433ef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cluster/cluster.py b/cluster/cluster.py
@@ -40,7 +40,7 @@ def launch_cluster(table: str, fields: List[str]):
     with process.stdout:
         for line in iter(process.stdout.readline, b""):
             LOGGER.info(line[: len(line) - 1].decode("utf-8"))
-    if process.returncode != 0:
+    if process.wait() != 0:
         LOGGER.error("pg_repack process returned non-zero code: %s. Exiting.", process.returncode)
         sys.exit(2)