Moved multiprocessing test fixture, and skipped tests if on win32 sys.

Author: A-Artemis

backend/tests/unit/conftest.py

@@ -8,13 +8,6 @@
 
 from app.services import ActivePipelineService, MetricsService
 
-# @pytest.fixture(scope="session", autouse=True)
-# def set_multiprocessing_start_method():
-#     # Set multiprocessing start method to 'fork' to ensure mocked objects and patches
-#     # from the parent process are inherited by child processes. The default 'spawn'
-#     # method creates isolated child processes that don't inherit mocked state.
-#     mp.set_start_method("fork", force=True)
-
 
 @pytest.fixture
 def fxt_active_pipeline_service() -> MagicMock:

backend/tests/unit/services/test_metrics_service.py

@@ -95,7 +95,7 @@ def test_time_window_measurements(self):
         collector.record_inference_end(model_id=model_id, start_time=start_time)
 
         # Then add an "old" measurement by mocking datetime
-        with patch("app.services.metrics_collector.datetime") as mock_datetime:
+        with patch("app.services.metrics_service.datetime") as mock_datetime:
             mock_datetime.now.return_value = datetime.now(UTC) - timedelta(seconds=90)
             collector.record_inference_end(model_id, start_time)
 
@@ -115,7 +115,7 @@ def test_latency_measurement_timestamp(self):
         model_id = uuid4()
         start_time = collector.record_inference_start()
 
-        with patch("app.services.metrics_collector.datetime") as mock_datetime:
+        with patch("app.services.metrics_service.datetime") as mock_datetime:
             mock_datetime.now.return_value = fixed_time
             collector.record_inference_end(model_id, start_time)
 

backend/tests/unit/workers/test_stream_loading.py

@@ -3,6 +3,7 @@
 
 import multiprocessing as mp
 import queue
+import sys
 import time
 from unittest.mock import Mock, patch
 
@@ -93,9 +94,17 @@ def mock_services(mock_config, mock_video_stream):
         }
 
 
+@pytest.mark.skipif(sys.platform == "win32", reason="Multiprocessing 'fork' start method not available on Windows")
 class TestFrameAcquisition:
     """Unit tests for the frame acquisition routine"""
 
+    @pytest.fixture(scope="session", autouse=True)
+    def set_multiprocessing_start_method(self):
+        # Set multiprocessing start method to 'fork' to ensure mocked objects and patches
+        # from the parent process are inherited by child processes. The default 'spawn'
+        # method creates isolated child processes that don't inherit mocked state.
+        mp.set_start_method("fork", force=True)
+
     def test_queue_full(self, frame_queue, mock_stream_data, stop_event, config_changed_condition, mock_services):
         """Test that stream frames are not acquired when queue is full"""