[Feature] Reduce Slightly CPU Usage For Raspberry Pi 4

app/api/api_v1/sockets/web_sockets.py

@@ -35,7 +35,7 @@ async def websocket_endpoint(websocket: WebSocket) -> None:
             # WebSocketDisconnect is not raised unless we poll
             # https://github.com/tiangolo/fastapi/issues/3008
             try:
-                message = await asyncio.wait_for(websocket.receive_text(), 0.1)
+                message = await asyncio.wait_for(websocket.receive_text(), 5.0)
                 await socket_connection_manager.received_message(
                     websocket=websocket, message=message
                 )

app/container_manager/container_manager.py

@@ -138,10 +138,10 @@ async def __container_ready(self, container: Container) -> None:
             raise e
 
     async def __container_started(self, container: Container) -> None:
-        sleep_interval = 0.2
+        sleep_interval = 1.0
 
         while True:
-            # Check if the container is running, then sleep for 0.1 sec
+            # Check if the container is running, then sleep
             if self.is_running(container):
                 return
 

app/log.py

@@ -136,7 +136,6 @@ def __configure_logging(
     logger.add(
         sys.stdout,
         enqueue=True,
-        backtrace=True,
         level=level.upper(),
         format=format,
         colorize=colorize,
@@ -148,7 +147,6 @@ def __configure_logging(
         rotation=rotation,
         retention=retention,
         enqueue=True,
-        backtrace=True,
         level=level.upper(),
         format=format,
     )

app/socket_connection_manager.py

@@ -178,7 +178,7 @@ async def relay_video_frames(self, connection: WebSocketConnection) -> None:
                         try:
                             # WebSocketDisconnect is not raised unless we poll
                             # https://github.com/tiangolo/fastapi/issues/3008
-                            await asyncio.wait_for(websocket.receive_text(), 0.1)
+                            await asyncio.wait_for(websocket.receive_text(), 1.0)
                         except asyncio.TimeoutError:
                             pass
             # Starlette raises websockets.exceptions.ConnectionClosedOK

app/test_engine/test_log_handler.py

@@ -26,7 +26,7 @@
 from app.schemas.test_run_log_entry import TestRunLogEntry
 from app.test_engine.models import TestCase, TestRun, TestStep, TestSuite
 
-LOG_PROCESSING_INTERVAL = 0.5
+LOG_PROCESSING_INTERVAL = 2.0
 
 
 class TestLogHandler:

app/test_engine/test_ui_observer.py

@@ -40,9 +40,11 @@
 
 class TestUIObserver(Observer):
     __test__ = False
-    __async_updates: list[Task] = []
-    __last_seen_run_state: Optional[TestStateEnum] = None
-    __last_seen_run_log_len = 0
+
+    def __init__(self) -> None:
+      self.__async_updates: list[Task] = []
+      self.__last_seen_run_state: Optional[TestStateEnum] = None
+      self.__last_seen_run_log_len = 0
 
     def dispatch(
         self, observable: Union[TestRun, TestSuite, TestCase, TestStep]

test_collections/matter/sdk_tests/support/python_testing/models/python_testing_hooks_proxy.py

@@ -246,3 +246,10 @@ def show_two_way_talk_prompt(self, msg: str) -> None:
 
     def show_push_av_stream_prompt(self, msg: str) -> None:
         self.results.put(SDKPythonTestResultShowPushAVStreamPrompt(msg=msg))
+
+    def get_update(self) -> tuple[SDKPythonTestResultBase | None, bool]:
+        """Returns (update_or_None, is_finished) in a single IPC call."""
+        try:
+            return self.results.get(block=False), False
+        except Empty:
+            return None, SDKPythonTestRunnerHooks.finished

test_collections/matter/sdk_tests/support/python_testing/models/test_case.py

@@ -600,14 +600,14 @@ async def execute(self) -> None:
                 logger.error(f"Failed to initialize test output path: {e}")
                 self.file_output_path = None
 
-            while ((update := test_runner_hooks.update_test()) is not None) or (
-                not test_runner_hooks.is_finished()
-            ):
-                if not update:
-                    await sleep(0.0001)
-                    continue
-
-                await self.__handle_update(update)
+            while True:
+                update, finished = test_runner_hooks.get_update()
+                if update:
+                    await self.__handle_update(update)
+                elif finished:
+                    break
+                else:
+                    await sleep(0.2)
 
             # Step: Show test logs
             if self.current_test_step_index < len(self.test_steps) - 1: