AvatarSession.aclose() doesn't unbind the audio output start() installed, so a failed avatar start silently mutes the agent

import asyncio
from livekit import rtc
from livekit.agents.voice import AgentSession
from livekit.agents.voice.avatar import AvatarSession, DataStreamAudioOutput


class FakeAvatarSession(AvatarSession):
    """Mimics what an avatar plugin's start() does."""

    @property
    def avatar_identity(self) -> str:
        return "avatar-worker"

    async def start(self, agent_session, room):
        await super().start(agent_session, room)
        agent_session.output.replace_audio_tail(
            DataStreamAudioOutput(room=room, destination_identity=self.avatar_identity)
        )


async def main():
    session = AgentSession()
    room = rtc.Room()
    print("before start:       ", session.output.audio)

    avatar = FakeAvatarSession()
    await avatar.start(session, room=room)
    print("after plugin start: ", type(session.output.audio).__name__)

    # the avatar never joins: wait_for_join(timeout=...) raises, the app gives up
    await avatar.aclose()
    print("after aclose:       ", type(session.output.audio).__name__)


asyncio.run(main())


Output:


before start:        None
after plugin start:  DataStreamAudioOutput
after aclose:        DataStreamAudioOutput

livekit-agents==1.8.0