MirrorMirror
/
01
mirror of https://github.com/OpenInterpreter/01.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Better errors, bug fix

This commit is contained in:
killian 2024-02-15 12:42:41 -08:00
parent 3571382a9f
commit 1b68f14a7a
3 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
01OS/01OS/clients/base_device.py
View File

@ -128,8 +128,11 @@ class Device:
play(audio) play(audio)
self.audiosegments.remove(audio) self.audiosegments.remove(audio)
await asyncio.sleep(0.1) await asyncio.sleep(0.1)
except asyncio.exceptions.CancelledError:
# This happens once at the start?
pass
except: except:
logger.debug(f"Non fatal error, retrying: ", traceback.format_exc()) logger.info(traceback.format_exc())
def record_audio(self): def record_audio(self):
@ -282,7 +285,7 @@ class Device:
except: except:
logger.debug(f"Non fatal error, retrying: ", traceback.format_exc()) logger.debug(traceback.format_exc())
logger.info(f"Connecting to `{WS_URL}`...") logger.info(f"Connecting to `{WS_URL}`...")
await asyncio.sleep(2) await asyncio.sleep(2)

2
01OS/01OS/server/server.py
View File

@ -102,7 +102,7 @@ async def websocket_endpoint(websocket: WebSocket):
try: try:
await asyncio.gather(receive_task, send_task) await asyncio.gather(receive_task, send_task)
except Exception as e: except Exception as e:
logger.debug(f"Non fatal error, retrying: ", traceback.format_exc()) logger.debug(traceback.format_exc())
logger.info(f"Connection lost. Error: {e}") logger.info(f"Connection lost. Error: {e}")
async def receive_messages(websocket: WebSocket): async def receive_messages(websocket: WebSocket):

4
01OS/01OS/utils/accumulator.py
View File

@ -17,6 +17,10 @@ class Accumulator:
return None return None
if "content" in chunk: if "content" in chunk:
# Display
print(chunk['content'], end="", flush=True)
if any(self.message[key] != chunk[key] for key in self.message if key != "content"): if any(self.message[key] != chunk[key] for key in self.message if key != "content"):
self.message = chunk self.message = chunk
if "content" not in self.message: if "content" not in self.message: