pepperplus/pepperplus-cb
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: wait for req socket send to make sure we dont stay stuck - if there's no... #23

Merged
9828273 merged 19 commits from feat/cb2ui-robot-connections into dev 2025-11-18 12:24:15 +00:00
Conversation 83 Commits 19 Files Changed 9 +3 -3
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 2eefcc4553 - Show all commits

6
src/control_backend/agents/ri_communication_agent.py
View File

@@ -77,7 +77,7 @@ class RICommunicationAgent(BaseAgent):
topic = b"ping" topic = b"ping"
data = json.dumps(False).encode() data = json.dumps(False).encode()
if self.agent.pub_socket is None: if self.agent.pub_socket is None:
self.agent.logger.error( self.agent.logger.warning(
"Communication agent pub socket not correctly initialized." "Communication agent pub socket not correctly initialized."
) )
else: else:
@@ -227,7 +227,7 @@ class RICommunicationAgent(BaseAgent):
break break
else: else:
self.logger.error("Failed to set up %s after %d retries", self.name, max_retries) self.logger.warning("Failed to set up %s after %d retries", self.name, max_retries)
return return
# Set up ping behaviour # Set up ping behaviour
@@ -238,7 +238,7 @@ class RICommunicationAgent(BaseAgent):
topic = b"ping" topic = b"ping"
data = json.dumps(True).encode() data = json.dumps(True).encode()
if self.pub_socket is None: if self.pub_socket is None:
self.logger.error("Communication agent pub socket not correctly initialized.") self.logger.warning("Communication agent pub socket not correctly initialized.")
else: else:
try: try:
await asyncio.wait_for(self.pub_socket.send_multipart([topic, data]), 5) await asyncio.wait_for(self.pub_socket.send_multipart([topic, data]), 5)