LangGraph Observability & Runtime Monitoring

import { ObservyzeClient } from "@observyze/sdk";
import OpenAI from "openai";

const observyze = new ObservyzeClient({
  apiKey: process.env.OBSERVYZE_API_KEY!,
  projectId: process.env.OBSERVYZE_PROJECT_ID!,
});

// Instrument model client used in LangGraph nodes
const openai = observyze.wrapOpenAI(new OpenAI());

// In a LangGraph node function:
async function reasonerNode(state: AgentState) {
  const trace = observyze.startTrace("langgraph.reasoner", {
    sessionId: state.sessionId,
  });

  const response = await openai.chat.completions.create({
    model: "gpt-4o",
    messages: state.messages,
  });

  await trace.end();
  return { messages: [...state.messages, response.choices[0].message] };
}