ij1tSrSSKJrJrJr SSKJrJrJr SSK J r SSK J r SSK JrJr SSKJrJr "SS \5r"S S \5r\S r"S S\5r"SS\5r"SS\5r"SS\5r"SS\5r\\-\-r"SS\5r"SS\5r"SS\5r"SS\5rg) Human in the loop middleware.)AnyLiteralProtocol) AIMessageToolCall ToolMessage)Runtime) interrupt) NotRequired TypedDict)AgentMiddleware AgentStatec:\rSrSr%Sr\\S'\\\4\S'Sr g)Action z*Represents an action with a name and args.nameargsN) __name__ __module__ __qualname____firstlineno____doc__str__annotations__dictr__static_attributes__rg/home/james-whalen/.local/lib/python3.13/site-packages/langchain/agents/middleware/human_in_the_loop.pyrr s4 IK sCx.QrrcL\rSrSr%Sr\\S'\\\4\S'\ \\S'Sr g) ActionRequestz@Represents an action request with a name, args, and description.rr descriptionrN) rrrrrrrrrr rrrr r"r"s,J I1 sCx.QS!!7rr"approveeditrejectcR\rSrSr%Sr\\S'\\\S'\ \ \\ 4\S'Sr g) ReviewConfig'z$Policy for reviewing a HITL request. action_nameallowed_decisions args_schemarN) rrrrrrrlist DecisionTyper rrrrrr r*r*'s2.GL)):T#s(^,,Trr*c<\rSrSr%Sr\\\S'\\\S'Sr g) HITLRequest4zIRequest for human feedback on a sequence of actions requested by a model.action_requestsreview_configsrN) rrrrrr/r"rr*rrrr r2r24s!S-((3&&8rr2c*\rSrSr%Sr\S\S'Srg)ApproveDecision>z*Response when a human approves the action.r&typerN)rrrrrrrrrrr r7r7>s4 ) @rr7c6\rSrSr%Sr\S\S'\\S'Srg) EditDecisionEz'Response when a human edits the action.r'r9 edited_actionrN) rrrrrrrrrrrr r;r;Es1 &/=rr;c<\rSrSr%Sr\S\S'\\\S'Sr g)RejectDecisionRz)Response when a human rejects the action.r(r9messagerN) rrrrrrrr rrrrr r?r?Rs!3 ( ?  Orr?c*\rSrSr%Sr\\\S'Srg) HITLResponse_z#Response payload for a HITLRequest. decisionsrN) rrrrrr/Decisionrrrrr rCrC_s-H~*rrCc2\rSrSrSrS\S\S\S\4Sjr Sr g ) _DescriptionFactoryfz6Callable that generates a description for a tool call. tool_callstateruntimereturncg)z'Generate a description for a tool call.Nr)selfrJrKrLs r __call___DescriptionFactory.__call__is rrN) rrrrrrrr rrPrrrr rHrHfs'@ ( :  TW rrHc^\rSrSr%Sr\\\S'\\ \ -\S'\\ \ \ 4\S'Sr g)InterruptOnConfignzConfiguration for an action requiring human in the loop. This is the configuration format used in the `HumanInTheLoopMiddleware.__init__` method. r-r$r.rN)rrrrrr/r0rr rrHrrrrrr rSrSnsF L))9S#6677!DT#s(^,,TrrSc ^\rSrSrSrSS.S\\\\-4S\SS4U4S jjjr S \ S \S \ S \ S\ \\44 SjrS\S \ S \S\ \ S-\S-44SjrS \ S \ S\\\4S-4SjrSrU=r$)HumanInTheLoopMiddlewarerz Tool execution requires approval)description_prefix interrupt_onrXrMNc>[TU]5 0nUR5HLupE[U[5(aUSLa[ /SQS9X4'M.M0UR S5(dMHXSU'MN X0lX lg)a=Initialize the human in the loop middleware. Args: interrupt_on: Mapping of tool name to allowed actions. If a tool doesn't have an entry, it's auto-approved by default. * `True` indicates all decisions are allowed: approve, edit, and reject. * `False` indicates that the tool is auto-approved. * `InterruptOnConfig` indicates the specific decisions allowed for this tool. The InterruptOnConfig can include a `description` field (`str` or `Callable`) for custom formatting of the interrupt description. description_prefix: The prefix to use when constructing action requests. This is used to provide context about the tool call and the action being requested. Not used if a tool has a `description` in its `InterruptOnConfig`. Tr%)r-r-N) super__init__items isinstanceboolrSgetrYrX)rOrYrXresolved_configs tool_name tool_config __class__s r r\!HumanInTheLoopMiddleware.__init__s. 9;&2&8&8&: "I+t,,$&2C*G3$/'!455.9+';-"4rrJconfigrKrLcUSnUSnURS5n[U5(a U"XU5nOUbUnOURSUSU3n[UUUS9n [ UUSS9n X4$) z9Create an ActionRequest and ReviewConfig for a tool call.rrr$z Tool: z Args: )rrr$r-)r,r-)r`callablerXr"r*) rOrJrfrKrLrb tool_argsdescription_valuer$action_request review_configs r _create_action_and_config2HumanInTheLoopMiddleware._create_action_and_configsf% f% #JJ}5 % & &+IgFK  *+K!445Z {(S\R]^K'# %!$%89 ,,rdecisionc tUSnUSS:Xa SU;aUS4$USS:Xa"SU;aUSn[SUSUS US S 9S4$USS :XaAS U;a;URS 5=(d SUSSUS 3n[UUSUS SS9nX'4$SUSURS5SUSSUS3 n[U5e)zUProcess a single decision and return the revised tool call and optional tool message.r-r9r&Nr'r=rJrrid)r9rrrqr(rAz!User rejected the tool call for `z ` with id error)contentr tool_call_idstatuszUnexpected human decision: z. Decision type 'z' is not allowed for tool 'z'. Expected one of z# based on the tool's configuration.)rr`r ValueError) rOrorJrfr-r=rs tool_messagemsgs r _process_decision*HumanInTheLoopMiddleware._process_decisionsF##67 F y (Y:K-Kd? " F v %&4E*E$_5M$&v.&v.     F x 'H8I,Ill9-3If4E3FjQZ[_Q`Pab 'v&&t_ L * *)(4&ll6234((1&(9':;011T V orcUSnU(dg[S[U55S5nU(aUR(dg/n/nURH:nUSUR;aUR U5 M)UR U5 M< U(dgUR 5n/n /n /n UHKnURUSn UR X|X5upU R U 5 U R U5 MM [U U S9n[U5nUSn[U5=n[U5=n:waSUSUS 3n[U5e[U5HdunnUUnURUSn URUX|5unnU(aUR U5 U(dMSU R U5 Mf XlSU/U Q0$) zETrigger interrupt flows for relevant tool calls after an `AIMessage`.messagesNc3T# UHn[U[5(dMUv M g7f)N)r^r).0rxs r 7HumanInTheLoopMiddleware.after_model..s\+=CCQZA[CC+=s( (r)r4r5rEzNumber of human decisions (z/) does not match number of hanging tool calls (z).) nextreversed tool_callsrYappendcopyrmr2r lenrv enumeratery)rOrKrLr| last_ai_msginterrupt_tool_callsauto_approved_tool_callsrJrevised_tool_callsartificial_tool_messagesr4r5rfrkrl hitl_request hitl_responserE decisions_leninterrupt_tool_calls_lenrxirorevised_tool_callrws r after_model$HumanInTheLoopMiddleware.after_models$\8H+=\^bc +"8"802#% $//I6?7""7# ' ' 2(@(G(G (R0 $.F-J-J-L68 02-/-I&&y'89F-1,J,J5- )N  " "> 2  ! !- 0.#+) '0 &= !+. !^ +M(+,@(A A $ .m_=11I0J"N S/ !%Y/KAx,Q/I&&y'89F.2.D.DXy.a + | "))*;<|(// =0"4[D+CDEEr)rXrY)rrrrrrrr_rSr\rrr tupler"r*rmrFr ryrrr __classcell__)rds@r rVrVs' #E "53'8 889"5 "5  "5"5H"-"-""- "-  "- }l* + "-H(((" ( x$ d 22 3 (TKFKFgKF$sCx.SWBWKFKFrrVN) rtypingrrrlangchain_core.messagesrrr langgraph.runtimer langgraph.typesr typing_extensionsr r !langchain.agents.middleware.typesrrrr"r0r*r2r7r;r?rFrCrHrSrVrrr rs#))DD%%4IRYR 8I 823  U9 U9)9AiA 9 PYP \ )N :+9+ ( .U .Ub@F@Fr