diff --git a/src/pipecat/runner/utils.py b/src/pipecat/runner/utils.py
index 2334f6da6..2ba5ec31f 100644
--- a/src/pipecat/runner/utils.py
+++ b/src/pipecat/runner/utils.py
@@ -561,7 +561,7 @@ async def create_transport(
                 audio_out_enabled=True,
                 # add_wav_header and serializer will be set automatically
             ),
-            "vonage": lambda: VonageVideoConnectorParams(
+            "vonage": lambda: VonageVideoConnectorTransportParams(
                 audio_in_enabled=True,
                 audio_out_enabled=True,
                 vad_analyzer=SileroVADAnalyzer(),
diff --git a/src/pipecat/transports/vonage/client.py b/src/pipecat/transports/vonage/client.py
index c6b703793..ecdfd24bc 100644
--- a/src/pipecat/transports/vonage/client.py
+++ b/src/pipecat/transports/vonage/client.py
@@ -864,7 +864,7 @@ class VonageClient:
                 except Exception as exc:
                     logger.error(f"Exception in SDK callback task: {exc}")
                 finally:
-                    active_tasks.discard(task)
+                    active_tasks.discard(asyncio.current_task())
                     queue.task_done()
 
             try:
diff --git a/tests/test_vonage_video_connector.py b/tests/test_vonage_video_connector.py
index 39ca716ed..d13575f36 100644
--- a/tests/test_vonage_video_connector.py
+++ b/tests/test_vonage_video_connector.py
@@ -1539,8 +1539,10 @@ class TestVonageVideoConnectorTransport:
 
         # Wait for async processing
         await self._wait_for_condition(
-            lambda: on_stream_received_mock1.await_count > 0
-            and on_stream_received_mock2.await_count > 0
+            lambda: (
+                on_stream_received_mock1.await_count > 0
+                and on_stream_received_mock2.await_count > 0
+            )
         )
 
         # Verify both listeners were called