OpenTelemetry tracing for multi-agent runs

import {
  BasicTracerProvider,
  InMemorySpanExporter,
  SimpleSpanProcessor,
} from '@opentelemetry/sdk-trace-base'
import { OpenMultiAgent, type AgentConfig } from '@open-multi-agent/core'
import { createOtelTraceSink } from '@open-multi-agent/otel'

// npm install @open-multi-agent/core@^1.12.1 @open-multi-agent/otel@^0.1.0
// npm install @opentelemetry/api @opentelemetry/sdk-trace-base
// Set OPENAI_API_KEY in the environment for the demo team.
const exporter = new InMemorySpanExporter()
const provider = new BasicTracerProvider({
  spanProcessors: [new SimpleSpanProcessor(exporter)],
})
const sink = createOtelTraceSink({ tracerProvider: provider })

const agents: AgentConfig[] = [
  { name: 'researcher', systemPrompt: 'Gather the key facts.' },
  { name: 'writer', systemPrompt: 'Write a tight summary.' },
]

const oma = new OpenMultiAgent({
  defaultProvider: 'openai',
  defaultModel: 'gpt-5.4-mini',
  observability: { sinks: [sink] },
})
const team = oma.createTeam('brief', { name: 'brief', agents })

try {
  await oma.runTeam(team, 'Summarize the latest release notes.')
  await sink.forceFlush({ timeoutMs: 1_000 })
  console.log(exporter.getFinishedSpans().length)
} finally {
  await sink.shutdown({ timeoutMs: 1_000 })
  await provider.shutdown()
}