From bc5f9dc50259785a104e3d518fa2ce03c1e75dfd Mon Sep 17 00:00:00 2001 From: Gusto Date: Wed, 16 Aug 2023 01:47:01 +0300 Subject: [PATCH] Run all configs without log parsing from simapp --- scripts/run_configs.py | 16 +++------------- 1 file changed, 3 insertions(+), 13 deletions(-) diff --git a/scripts/run_configs.py b/scripts/run_configs.py index 6645615..86db269 100644 --- a/scripts/run_configs.py +++ b/scripts/run_configs.py @@ -4,19 +4,9 @@ import os import time def run_simulation(command): - # TODO: Graceful shutdown in simulation doesn't work yet, remove the ouput filtering once implemented. - search_string = "ALL DONE" - - with subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True, bufsize=1, universal_newlines=True) as process: - for line in iter(process.stdout.readline, ''): - if search_string in line: - # TODO: In simulation, subscriber will drop all remaining unpersisted records when the process - # is terminated, add some delay for filesystem to catch up with writing the output data. - time.sleep(5) - process.terminate() - return - - process.communicate() # wait for the process to finish if it hasn't yet + start_time = time.time() + process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True, bufsize=1, universal_newlines=True) + process.communicate() def run_simulations(configs_path): for filename in os.listdir(configs_path):