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):