From bffb84ef3563e9d66b2aff3cd2e713b043199487 Mon Sep 17 00:00:00 2001
From: Ajay Raj <ajay.n.raj@gmail.com>
Date: Fri, 5 Jul 2024 13:57:35 -0700
Subject: [PATCH] remove phantom parameter

---
 vocode/streaming/synthesizer/base_synthesizer.py | 2 +-
 vocode/streaming/utils/create_task.py            | 1 -
 vocode/streaming/utils/worker.py                 | 1 -
 3 files changed, 1 insertion(+), 3 deletions(-)

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: