wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

transport(tavus): fix on_joined callback

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-03-02 21:06:49 -08:00
parent c79a739c85
commit 252f17e1ca
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/transports/tavus/transport.py
View File

@@ -134,12 +134,12 @@ class TavusCallbacks(BaseModel):
"""Callback handlers for Tavus events. """Callback handlers for Tavus events.
Parameters: Parameters:
on_connected: Called when the bot connects to the room. on_joined: Called when the bot joins the Daily room.
on_participant_joined: Called when a participant joins the conversation. on_participant_joined: Called when a participant joins the conversation.
on_participant_left: Called when a participant leaves the conversation. on_participant_left: Called when a participant leaves the conversation.
""" """
on_connected: Callable[[Mapping[str, Any]], Awaitable[None]] on_joined: Callable[[Mapping[str, Any]], Awaitable[None]]
on_participant_joined: Callable[[Mapping[str, Any]], Awaitable[None]] on_participant_joined: Callable[[Mapping[str, Any]], Awaitable[None]]
on_participant_left: Callable[[Mapping[str, Any], str], Awaitable[None]] on_participant_left: Callable[[Mapping[str, Any], str], Awaitable[None]]
@@ -274,7 +274,7 @@ class TavusTransportClient:
async def _on_joined(self, data): async def _on_joined(self, data):
"""Handle joined event.""" """Handle joined event."""
logger.debug("TavusTransportClient joined!") logger.debug("TavusTransportClient joined!")
await self._callbacks.on_connected(data) await self._callbacks.on_joined(data)
async def _on_left(self): async def _on_left(self):
"""Handle left event.""" """Handle left event."""
@@ -708,7 +708,7 @@ class TavusTransport(BaseTransport):
self._params = params self._params = params
callbacks = TavusCallbacks( callbacks = TavusCallbacks(
on_connected=self._on_joined, on_joined=self._on_joined,
on_participant_joined=self._on_participant_joined, on_participant_joined=self._on_participant_joined,
on_participant_left=self._on_participant_left, on_participant_left=self._on_participant_left,
) )