nemo_flow.integrations.langgraph.callbacks

LangGraph callback handler that reuses the LangChain NeMo Flow integration.

Classes

NemoFlowCallbackHandler

Bridge LangChain and LangGraph runs to NeMo Flow using public callback APIs.

Module Contents

class nemo_flow.integrations.langgraph.callbacks.NemoFlowCallbackHandler

Bases: nemo_flow.integrations.langchain.callbacks.NemoFlowCallbackHandler, langgraph.callbacks.GraphCallbackHandler

Bridge LangChain and LangGraph runs to NeMo Flow using public callback APIs.

This handler inherits the existing LangChain callback integration, so normal runnable scopes from LangGraph and LangChain are recorded by the same code path. It also implements LangGraph’s public lifecycle callback hooks for interrupt and resume marks.

on_interrupt(event: langgraph.callbacks.GraphInterruptEvent) → Any

Emit a NeMo Flow mark for a LangGraph interrupt lifecycle event.

on_resume(event: langgraph.callbacks.GraphResumeEvent) → Any

Emit a NeMo Flow mark for a LangGraph resume lifecycle event.