g3fi-#dZddlmZddlmZmZmZmZddlm Z ddl m Z ddl m Z mZddlmZmZmZmZerddlmZGd d eZ dd ZGd d eZGddeeefZy)z$Call tracking middleware for agents.) annotations) TYPE_CHECKING AnnotatedAnyLiteral) AIMessage)UntrackedValue) NotRequiredoverride)AgentMiddleware AgentStatePrivateStateAttr hook_config)Runtimec&eZdZUdZded<ded<y)ModelCallLimitStatezlState schema for `ModelCallLimitMiddleware`. Extends `AgentState` with model call tracking fields. z-NotRequired[Annotated[int, PrivateStateAttr]]thread_model_call_countz=NotRequired[Annotated[int, UntrackedValue, PrivateStateAttr]]run_model_call_countN)__name__ __module__ __qualname____doc____annotations__j/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/langchain/agents/middleware/model_call_limit.pyrrs KJWWrrcg}|||k\r|jd|d|d|||k\r|jd|d|dddj|S)aiBuild a message indicating which limits were exceeded. Args: thread_count: Current thread model call count. run_count: Current run model call count. thread_limit: Thread model call limit (if set). run_limit: Run model call limit (if set). Returns: A formatted message describing which limits were exceeded. zthread limit (/)z run limit (zModel call limits exceeded: z, )appendjoin) thread_count run_count thread_limit run_limitexceeded_limitss r_build_limit_exceeded_messager' st"OLL$@ ~Q|nANOi!7YKq 1EF )$))O*D)E FFrc8eZdZdZ dfd ZxZS)ModelCallLimitExceededErrorzException raised when model call limits are exceeded. This exception is raised when the configured exit behavior is `'error'` and either the thread or run model call limit has been exceeded. cx||_||_||_||_t ||||}t ||y)a/Initialize the exception with call count information. Args: thread_count: Current thread model call count. run_count: Current run model call count. thread_limit: Thread model call limit (if set). run_limit: Run model call limit (if set). N)r"r#r$r%r'super__init__)selfr"r#r$r%msg __class__s rr,z$ModelCallLimitExceededError.__init__AsA)"("+L)\S\] r) r"intr#r0r$ int | Noner%r1returnNone)rrrrr, __classcell__r/s@rr)r):sB !     rr)ceZdZdZeZdddd d fdZedged dZ edg d dZ ed d Z d d Z xZ S) ModelCallLimitMiddlewarea^Tracks model call counts and enforces limits. This middleware monitors the number of model calls made during agent execution and can terminate the agent when specified limits are reached. It supports both thread-level and run-level call counting with configurable exit behaviors. Thread-level: The middleware tracks the number of model calls and persists call count across multiple runs (invocations) of the agent. Run-level: The middleware tracks the number of model calls made during a single run (invocation) of the agent. Example: ```python from langchain.agents.middleware.call_tracking import ModelCallLimitMiddleware from langchain.agents import create_agent # Create middleware with limits call_tracker = ModelCallLimitMiddleware(thread_limit=10, run_limit=5, exit_behavior="end") agent = create_agent("openai:gpt-4o", middleware=[call_tracker]) # Agent will automatically jump to end when limits are exceeded result = await agent.invoke({"messages": [HumanMessage("Help me with a task")]}) ``` Nend)r$r% exit_behaviorct||| d}t||dvrd|d}t|||_||_||_y)aInitialize the call tracking middleware. Args: thread_limit: Maximum number of model calls allowed per thread. `None` means no limit. run_limit: Maximum number of model calls allowed per run. `None` means no limit. exit_behavior: What to do when limits are exceeded. - `'end'`: Jump to the end of the agent execution and inject an artificial AI message indicating that the limit was exceeded. - `'error'`: Raise a `ModelCallLimitExceededError` Raises: ValueError: If both limits are `None` or if `exit_behavior` is invalid. Nz@At least one limit must be specified (thread_limit or run_limit)>r8errorzInvalid exit_behavior: z. Must be 'end' or 'error')r+r, ValueErrorr$r%r9)r-r$r%r9r.r/s rr,z!ModelCallLimitMiddleware.__init__wsc4   I$5TCS/ !  0 0+M?:TUCS/ !("*r) can_jump_toc|jdd}|jdd}|jduxr||jk\}|jduxr||jk\}|s|ru|jdk(r#t |||j|j|jdk(r4t |||j|j}t |}d|gd Sy) aCheck model call limits before making a model call. Args: state: The current agent state containing call counts. runtime: The langgraph runtime. Returns: If limits are exceeded and exit_behavior is `'end'`, returns a `Command` to jump to the end with a limit exceeded message. Otherwise returns `None`. Raises: ModelCallLimitExceededError: If limits are exceeded and `exit_behavior` is `'error'`. rrrNr;)r"r#r$r%r8)content)jump_tomessages)getr$r%r9r)r'r) r-stateruntimer"r#thread_limit_exceededrun_limit_exceeded limit_messagelimit_ai_messages r before_modelz%ModelCallLimitMiddleware.before_models$yy!:A> II4a8 !% 1 1 = c,RVRcRcBc!^^47WI->! $-]#C #(7G6HIIrc.K|j||Sw)aAsync check model call limits before making a model call. Args: state: The current agent state containing call counts. runtime: The langgraph runtime. Returns: If limits are exceeded and exit_behavior is `'end'`, returns a `Command` to jump to the end with a limit exceeded message. Otherwise returns `None`. Raises: ModelCallLimitExceededError: If limits are exceeded and `exit_behavior` is `'error'`. )rIr-rCrDs r abefore_modelz&ModelCallLimitMiddleware.abefore_models*  00cX|jdddz|jdddzdS)zIncrement model call counts after a model call. Args: state: The current agent state. runtime: The langgraph runtime. Returns: State updates with incremented call counts. rrr)rr)rBrKs r after_modelz$ModelCallLimitMiddleware.after_models7(-yy1JA'NQR'R$)II.Da$H1$L  rc.K|j||Sw)zAsync increment model call counts after a model call. Args: state: The current agent state. runtime: The langgraph runtime. Returns: State updates with incremented call counts. )rPrKs r aafter_modelz%ModelCallLimitMiddleware.aafter_modelsw//rM)r$r1r%r1r9zLiteral['end', 'error']r2r3)rCrrDrr2zdict[str, Any] | None)rrrrr state_schemar,rr rIrLrPrRr4r5s@rr7r7Ys6'L $( $16 &+!&+ &+ / &+  &+PeW% (&(TeW%1"11  1&1,    0"00  0rr7N) r"r0r#r0r$r1r%r1r2str)r __future__rtypingrrrrlangchain_core.messagesr"langgraph.channels.untracked_valuer typing_extensionsr r !langchain.agents.middleware.typesr r rrlanggraph.runtimerrr' Exceptionr)r7rrrr]s*"99-=3)X*XGGGG G  G4)>g0/BC/GHg0r