langchain-middleware

Requirements: Checkpointer + thread_id config for all HITL workflows. @tool def send_email(to: str, subject: str, body: str) -> str: """Send an email.""" return f"Email sent to {to}" agent = create_agent( model="gpt-4.1", tools=[send_email], checkpointer=MemorySaver(), # Required for HITL middleware=[ HumanInTheLoopMiddleware( interrupt_on={ "send_email": {"allowed_decisions": ["approve", "edit", "reject"]}, } ) ], ) config = {"configurable": {"thread_id": "session-1"}} result1 = agent.invoke({ "messages": [{"role": "user", "content": "Send email to john@example.com "}] }, config=config) if " interrupt " in result1: print(f"Waiting for approval: {result1[' interrupt ']}") result2 = agent.invoke( Command(resume={"decisions": [{"type": "approve"}]}), config=config ) agent = create_agent( model="gpt-4.1", tools=[send_email], checkpointer=MemorySaver(), # Required middleware=[HumanInTheLoopMiddleware({...})] ) agent.invoke(input, config={"configurable": {"thread_id": "user-123"}}) // CORRECT import { Command } from "@langchain/langgraph"; await agent.invoke(new Command({ resume: { decisions: [{ type: "approve" }] } }), config); - HumanInTheLoopMiddleware / humanInTheLoopMiddleware : Pause before dangerous tool calls for human approval - Custom middleware : Intercept tool calls for error handling, logging, retry logic - Command resume : Continue execution after human decisions...