Observability and Tracing for Mastra in TypeScript

import { openai } from '@ai-sdk/openai';
import { Agent } from '@mastra/core/agent';
import { Mastra } from '@mastra/core/mastra';
import { createTool } from '@mastra/core/tools';
import { Observability } from '@mastra/observability';
import { Laminar, MastraExporter, observe } from '@lmnr-ai/lmnr';
import { z } from 'zod';

Laminar.initialize();

const lookupFlights = createTool({
  id: 'lookup_flights',
  description: 'Return candidate flights between two cities on a date.',
  inputSchema: z.object({ from: z.string(), to: z.string(), date: z.string() }),
  execute: async (inputData) => {
    const { from, to, date } = inputData.context;
    return {
      flights: [
        { carrier: 'Delta', number: 'DL123', priceUsd: 342 },
        { carrier: 'United', number: 'UA456', priceUsd: 298 },
      ],
      route: `${from} -> ${to}`,
      date,
    };
  },
});

const flightAgent = new Agent({
  id: 'flight-agent',
  name: 'flight-agent',
  instructions:
    'You are a flight specialist. Call lookup_flights and recommend one option.',
  model: openai('gpt-5-mini'),
  tools: { lookupFlights },
});

const bookFlight = createTool({
  id: 'book_flight',
  description: 'Delegate to the flight specialist.',
  inputSchema: z.object({ from: z.string(), to: z.string(), date: z.string() }),
  execute: async (inputData) => {
    const { from, to, date } = inputData.context;
    const res = await flightAgent.generate(
      `Find a flight from ${from} to ${to} on ${date}. Recommend one option.`,
    );
    return { recommendation: res.text };
  },
});

const conciergeAgent = new Agent({
  id: 'concierge',
  name: 'concierge',
  instructions:
    'You are a travel concierge. Use book_flight to delegate, then summarize the plan.',
  model: openai('gpt-5'),
  tools: { bookFlight },
});

new Mastra({
  agents: { conciergeAgent, flightAgent },
  observability: new Observability({
    default: { enabled: false },
    configs: {
      laminar: {
        serviceName: 'trip-planner',
        exporters: [new MastraExporter()],
      },
    },
  }),
});

await observe({ name: 'plan-trip' }, async () => {
  const { text } = await conciergeAgent.generate(
    'Plan a flight from San Francisco to New York on 2026-06-15.',
    { stopWhen: ({ steps }) => (steps?.length ?? 0) >= 6 },
  );
  console.log(text);
});