Create an Agent

from zrt import Agent

class MyAgent(Agent):
    def __init__(self, pipeline):
        super().__init__(
            agent_id="assistant",
            instructions="You are a helpful assistant. Keep replies short and friendly.",
            pipeline=pipeline,
        )

async def on_enter(self):
    print("Agent has entered the session.")
    await self.session.say("Hello everyone! I'm here to help.")

async def on_exit(self):
    print("Agent is exiting the session.")
    await self.session.say("It was a pleasure assisting you. Goodbye!")

import zrt
from zrt import Agent, Pipeline
from zrt.plugins import DeepgramSTT, GoogleLLM, CartesiaTTS, TurnDetector
from zrt.inference import AICousticsDenoise

AGENT_ID = "assistant"

pipeline = Pipeline(
    stt=DeepgramSTT(),
    llm=GoogleLLM(),
    tts=CartesiaTTS(),
    turn_detector=TurnDetector(model="echo-large"),
    denoise=AICousticsDenoise(model_id="quail-vf-2.2-l-16khz"),
)

class MyAgent(Agent):
    def __init__(self):
        super().__init__(
            agent_id=AGENT_ID,
            instructions="You are a helpful voice assistant.",
            pipeline=pipeline,
        )

    async def on_enter(self):
        await self.session.say("Hello! How can I help you today?")

    async def on_exit(self):
        await self.session.say("Goodbye!")

if __name__ == "__main__":
    # Pass the class itself (not an instance): serve() builds a fresh MyAgent +
    # pipeline per call, which is required for correct per-call state under concurrent calls.
    zrt.serve(MyAgent, on_ready=lambda: zrt.invoke(AGENT_ID, room=zrt.Room(playground=True)))