Grafana Agent Observability

Grafana Agent Observability for Flyte agents.

One call wires an agent built with the Flyte agents plugin into Grafana’s Agent Observability: generations, tool calls, and cost land in Grafana, nested inside the Flyte task span, and grouped by Flyte run.

import flyte
from flyteplugins.agento11y import init
from flyteplugins.agents.openai import run_agent

# Module scope, not inside a task.
init(service_name="my-agent")

env = flyte.TaskEnvironment(name="agent_env")

@env.task
async def agent(question: str) -> str:
    return await run_agent(question, tools=[...], model="gpt-4.1")

Nothing else changes in the agent code. The adapter offers its framework’s run payload to an instrumentor on the way past, which is how a handler reaches a call the adapter owns rather than you.

Supported frameworks: langchain, langgraph, openai, claude, google, pydantic-ai. crewai and mistral have Flyte adapters but no agento11y integration yet, so their runs are still traced but their generations are not captured.

Directory

Classes

Methods

Variables

Methods

get_client()

def get_client()

The client init built, for recording generations by hand.

init()

def init(
    service_name: str | None = None,
    endpoint: str | None = None,
    client: Client | None = None,
    client_options: typing.Mapping[str, typing.Any] | None = None,
    bind_conversation: bool = True,
    bind_agent_name: bool = True,
    trace: bool = True,
    **otel_kwargs: typing.Any,
) -> Client

Send Flyte agent runs to Grafana Agent Observability.

Call this at module scope, not inside a task. Task spans open before the task body runs, so initializing from within the body means that task’s span, and the identity binding that rides on it, have already been missed.

Three things get wired up. An agento11y client, sharing the tracer from flyteplugins-otel so generation spans nest inside the Flyte task span rather than floating off as their own traces. A binding that hands Flyte’s run, task, and version to agento11y as conversation id, agent name, and agent version. And an instrumentor for each agent framework whose integration package is installed, which is what lets the agents plugin attach handlers to calls it owns.

Returns: The agento11y client, for creating generations directly.

instrumented_frameworks()

def instrumented_frameworks()

Frameworks that got an instrumentor, that is, whose integration package is installed.

shutdown()

def shutdown()

Unbind, unregister, and flush a client we created.