remove phantom parameter (#612)

vocodedev · Jul 5, 2024 · be5f78e · be5f78e
1 parent c580d13
commit be5f78e
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 3 deletions.
diff --git 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
@@ -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
@@ -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: