diff --git a/vocode/streaming/synthesizer/base_synthesizer.py b/vocode/streaming/synthesizer/base_synthesizer.py index bdbd6d7d5..2263cc0e2 100644 --- a/vocode/streaming/synthesizer/base_synthesizer.py +++ b/vocode/streaming/synthesizer/base_synthesizer.py @@ -428,7 +428,7 @@ async def send_chunks(): miniaudio_worker.consume_nonblocking(None) # sentinel try: - asyncio_create_task(send_chunks(), reraise_cancelled=True) + asyncio_create_task(send_chunks()) # Await the output queue of the MiniaudioWorker and yield the wav chunks in another loop while True: diff --git a/vocode/streaming/utils/create_task.py b/vocode/streaming/utils/create_task.py index 38778d0bf..0680709c5 100644 --- a/vocode/streaming/utils/create_task.py +++ b/vocode/streaming/utils/create_task.py @@ -8,7 +8,6 @@ def asyncio_create_task( *args, - reraise_cancelled: bool = False, **kwargs, ) -> asyncio.Task: task = asyncio.create_task(*args, **kwargs) diff --git a/vocode/streaming/utils/worker.py b/vocode/streaming/utils/worker.py index 16c52a655..d2552fb0d 100644 --- a/vocode/streaming/utils/worker.py +++ b/vocode/streaming/utils/worker.py @@ -226,7 +226,6 @@ async def _run_loop(self): self.interruptible_event = item self.current_task = asyncio_create_task( self.process(item), - reraise_cancelled=True, ) try: