LangGraph Step-by-Step Integration & Setup

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!,
  executionBudget: { maxCostUsd: 0.50, maxSteps: 10 },
});

const openai = observyze.wrapOpenAI(new OpenAI());

// LangGraph node with custom span:
export async function agentReasoner(state: { messages: any[]; runId: string }) {
  const trace = observyze.startTrace("langgraph.execution", {
    sessionId: state.runId,
  });

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

  return { messages: [...state.messages, response.choices[0].message] };
}