From c1743dcffd16e05785c7c68317981280b299de94 Mon Sep 17 00:00:00 2001 From: Mark Backman Date: Mon, 2 Mar 2026 15:22:44 -0500 Subject: [PATCH] Rename Tavus event, on_connected --- src/pipecat/transports/tavus/transport.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/src/pipecat/transports/tavus/transport.py b/src/pipecat/transports/tavus/transport.py index 6db44d431..cb6844250 100644 --- a/src/pipecat/transports/tavus/transport.py +++ b/src/pipecat/transports/tavus/transport.py @@ -134,12 +134,12 @@ class TavusCallbacks(BaseModel): """Callback handlers for Tavus events. Parameters: - on_joined: Called when the bot joins the Daily room. + on_connected: Called when the bot connects to the room. on_participant_joined: Called when a participant joins the conversation. on_participant_left: Called when a participant leaves the conversation. """ - on_joined: Callable[[Mapping[str, Any]], Awaitable[None]] + on_connected: 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]] @@ -274,7 +274,7 @@ class TavusTransportClient: async def _on_joined(self, data): """Handle joined event.""" logger.debug("TavusTransportClient joined!") - await self._callbacks.on_joined(data) + await self._callbacks.on_connected(data) async def _on_left(self): """Handle left event.""" @@ -669,6 +669,7 @@ class TavusTransport(BaseTransport): Event handlers available: + - on_connected(transport, data): Bot connected to the room - on_client_connected(transport, participant): Participant connected to the session - on_client_disconnected(transport, participant): Participant disconnected from the session @@ -707,7 +708,7 @@ class TavusTransport(BaseTransport): self._params = params callbacks = TavusCallbacks( - on_joined=self._on_joined, + on_connected=self._on_joined, on_participant_joined=self._on_participant_joined, on_participant_left=self._on_participant_left, ) @@ -726,13 +727,13 @@ class TavusTransport(BaseTransport): # Register supported handlers. The user will only be able to register # these handlers. - self._register_event_handler("on_joined") + self._register_event_handler("on_connected") self._register_event_handler("on_client_connected") self._register_event_handler("on_client_disconnected") async def _on_joined(self, data): """Handle bot joined room event.""" - await self._call_event_handler("on_joined", data) + await self._call_event_handler("on_connected", data) if self._input: await self._input.push_frame(BotConnectedFrame())