Reduced test timing to 112 seconds. Also, added fix for lint

Author: franporcel

modules/01-operating-room/tests/test_dds_communication.py

@@ -233,7 +233,7 @@ def test_arm_receives_motor_control(self, proc_manager, dds_participant):
         from Types import SurgicalRobot, SurgicalRobot_MotorControl
 
         proc = proc_manager.start_app("Arm", extra_env=self.QT_ENV)
-        wait_for_process_ready(proc, timeout_sec=10)
+        wait_for_process_ready(proc, timeout_sec=3)
         assert proc.poll() is None, f"Arm exited early with code {proc.returncode}"
 
         writer = create_writer(

modules/01-operating-room/tests/test_demo_flow.py

@@ -310,7 +310,9 @@ def test_secure_launch(self, proc_manager_secure, dds_env_secure):
         # Wait for security handshake and DDS initialization (parallel).
         # Apps that fail the handshake crash within the first 1-2 s; 3 s is
         # enough to catch startup failures while keeping the test fast.
-        threads = [threading.Thread(target=wait_for_process_ready, args=(p, 3)) for p in apps.values()]
+        threads = [
+            threading.Thread(target=wait_for_process_ready, args=(p, 3)) for p in apps.values()
+        ]
         for t in threads:
             t.start()
         for t in threads:

modules/01-operating-room/tests/test_launch.py

@@ -84,7 +84,7 @@ class TestPatientMonitor:
 
     def test_starts_and_stays_alive(self, proc_manager):
         proc = proc_manager.start_app("PatientMonitor", extra_env=self.QT_ENV)
-        wait_for_process_ready(proc, timeout_sec=10)
+        wait_for_process_ready(proc, timeout_sec=3)
         assert proc.poll() is None, f"PatientMonitor exited early with code {proc.returncode}"
 
 
@@ -96,7 +96,7 @@ class TestArm:
 
     def test_starts_and_stays_alive(self, proc_manager):
         proc = proc_manager.start_app("Arm", extra_env=self.QT_ENV)
-        wait_for_process_ready(proc, timeout_sec=10)
+        wait_for_process_ready(proc, timeout_sec=3)
         assert proc.poll() is None, f"Arm exited early with code {proc.returncode}"
 
 

modules/02-record-playback/tests/test_recording.py

@@ -36,7 +36,7 @@ def test_recording_creates_database(self, proc_manager, clean_recording_dir):
         """Recording Service should create or_recording_database.dat."""
         # Start PatientSensor to produce t/Vitals data
         ps = proc_manager.start_app("PatientSensor")
-        wait_for_process_ready(ps, timeout_sec=10)
+        wait_for_process_ready(ps, timeout_sec=5)
         assert ps.poll() is None, f"PatientSensor exited early with code {ps.returncode}"
 
         # Start Recording Service
@@ -61,10 +61,10 @@ def test_recording_creates_database(self, proc_manager, clean_recording_dir):
         # Stop recording service gracefully
         rec_proc.terminate()
         try:
-            rec_proc.wait(timeout=10)
+            rec_proc.wait(timeout=5)
         except Exception:
             rec_proc.kill()
-            rec_proc.wait(timeout=5)
+            rec_proc.wait(timeout=3)
 
         # Verify the database file was created
         db_file = RECORDING_DIR / "or_recording_database.dat"

modules/02-record-playback/tests/test_replay.py

@@ -44,7 +44,7 @@ def test_replay_produces_vitals(self, proc_manager, dds_env_dict, clean_recordin
         """Replay Service should publish t/Vitals from a recording."""
         # ── Phase 1: Record some data ─────────────────────────────────
         ps = proc_manager.start_app("PatientSensor")
-        wait_for_process_ready(ps, timeout_sec=10)
+        wait_for_process_ready(ps, timeout_sec=5)
         assert ps.poll() is None, f"PatientSensor exited early with code {ps.returncode}"
 
         rec_proc = proc_manager.start(
@@ -61,25 +61,25 @@ def test_replay_produces_vitals(self, proc_manager, dds_env_dict, clean_recordin
 
         rec_proc.terminate()
         try:
-            rec_proc.wait(timeout=10)
+            rec_proc.wait(timeout=5)
         except Exception:
             rec_proc.kill()
-            rec_proc.wait(timeout=5)
+            rec_proc.wait(timeout=3)
 
         db_file = RECORDING_DIR / "or_recording_database.dat"
         assert db_file.is_file(), "Recording phase failed — no database"
 
         # Kill PatientSensor so the only source of data is the replay
         proc_manager.shutdown_all()
-        time.sleep(1)
+        time.sleep(0.5)
 
         # ── Phase 2: Replay and verify data arrives ───────────────────
         # Start Replay Service
         replay_proc = proc_manager.start(
             [REPLAY_SERVICE, "-cfgFile", self.REPLAY_CONFIG, "-cfgName", "RepServCfg"],
             cwd=MODULE_DIR,
         )
-        wait_for_process_ready(replay_proc, timeout_sec=10)
+        wait_for_process_ready(replay_proc, timeout_sec=5)
 
         # Run a short subscriber in a subprocess to capture replayed data
         subscriber_script = f"""\
@@ -100,7 +100,7 @@ def test_replay_produces_vitals(self, proc_manager, dds_env_dict, clean_recordin
 reader = dds.DataReader(subscriber, topic, dr_qos)
 
 collected = []
-deadline = time.monotonic() + 15
+deadline = time.monotonic() + 8
 while time.monotonic() < deadline and len(collected) < 3:
     for s in reader.take():
         if s.info.valid:
@@ -117,7 +117,7 @@ def test_replay_produces_vitals(self, proc_manager, dds_env_dict, clean_recordin
             cwd=MODULE_01_DIR,
             capture_output=True,
             text=True,
-            timeout=30,
+            timeout=20,
             check=False,
         )
         assert result.returncode == 0, (