|
@@ -667,13 +667,13 @@ class Worker:
|
|
|
logger.exception("TTS failed")
|
|
logger.exception("TTS failed")
|
|
|
|
|
|
|
|
|
|
|
|
|
-def _drain_queue(q: "asyncio.Queue") -> None:
|
|
|
|
|
- """Discard any queued-but-not-yet-played TTS audio."""
|
|
|
|
|
- while not q.empty():
|
|
|
|
|
- try:
|
|
|
|
|
- q.get_nowait()
|
|
|
|
|
- except Exception:
|
|
|
|
|
- break
|
|
|
|
|
|
|
+ def _drain_queue(q: "asyncio.Queue") -> None:
|
|
|
|
|
+ """Discard any queued-but-not-yet-played TTS audio."""
|
|
|
|
|
+ while not q.empty():
|
|
|
|
|
+ try:
|
|
|
|
|
+ q.get_nowait()
|
|
|
|
|
+ except Exception:
|
|
|
|
|
+ break
|
|
|
|
|
|
|
|
async def _send(self, msg: dict):
|
|
async def _send(self, msg: dict):
|
|
|
try:
|
|
try:
|