diff --git a/src/control_backend/agents/ri_communication_agent.py b/src/control_backend/agents/ri_communication_agent.py index 8d72c8a..960a4b8 100644 --- a/src/control_backend/agents/ri_communication_agent.py +++ b/src/control_backend/agents/ri_communication_agent.py @@ -56,11 +56,8 @@ class RICommunicationAgent(BaseAgent): "we probably dont have any receivers... but let's check!" ) - # Wait up to three seconds for a reply:) + # Wait up to {seconds_to_wait_total/2} seconds for a reply:) try: - self.agent.logger.debug( - f"waiting for message for{seconds_to_wait_total / 2} seconds." - ) message = await asyncio.wait_for( self.agent._req_socket.recv_json(), timeout=seconds_to_wait_total / 2 ) @@ -96,7 +93,7 @@ class RICommunicationAgent(BaseAgent): # Try to reboot. await self.agent.setup() - self.agent.logger.debug('Received message "%s"', message) + self.agent.logger.debug(f'Received message "{message}" from RI.') if "endpoint" not in message: self.agent.logger.error("No received endpoint in message, excepted ping endpoint.") return diff --git a/src/control_backend/api/v1/endpoints/robot.py b/src/control_backend/api/v1/endpoints/robot.py index dfa7332..ccc6bd6 100644 --- a/src/control_backend/api/v1/endpoints/robot.py +++ b/src/control_backend/api/v1/endpoints/robot.py @@ -39,7 +39,6 @@ async def ping_stream(request: Request): async def event_stream(): # Set up internal socket to receive ping updates - logger.debug("Ping stream router event stream entered.") sub_socket = Context.instance().socket(zmq.SUB) sub_socket.connect(settings.zmq_settings.internal_sub_address) @@ -52,12 +51,10 @@ async def ping_stream(request: Request): # So, True - False - True - False for connectivity. # Let's still check:) while True: - logger.debug("Ping stream entered listening ") try: topic, body = await asyncio.wait_for( sub_socket.recv_multipart(), timeout=ping_frequency ) - logger.debug(f"got ping change in ping_stream router: {body}") connected = json.loads(body) except TimeoutError: logger.debug("got timeout error in ping loop in ping router")