OKi8SrSSKJr SSKrSSKrSSKrSSKJrJr SSK J r SSK J r J r JrJrJr SSKJrJrJrJr \(aSSKJrJr SS KJr SS KJr SS KJr "S S \\\\\45rg)z!Tool retry middleware for agents.) annotationsN) TYPE_CHECKINGAny) ToolMessage) OnFailureRetryOncalculate_delayshould_retry_exceptionvalidate_retry_params)AgentMiddleware AgentStateContextT ResponseT) AwaitableCallable)Command)ToolCallRequest)BaseToolc ^\rSrSrSrSS\4SSSSS S .SU4S jjjrSS jr\SS j5r SSjr SSjr SSjr Sr U=r$)ToolRetryMiddlewarea Middleware that automatically retries failed tool calls with configurable backoff. Supports retrying on specific exceptions and exponential backoff. Examples: !!! example "Basic usage with default settings (2 retries, exponential backoff)" ```python from langchain.agents import create_agent from langchain.agents.middleware import ToolRetryMiddleware agent = create_agent(model, tools=[search_tool], middleware=[ToolRetryMiddleware()]) ``` !!! example "Retry specific exceptions only" ```python from requests.exceptions import RequestException, Timeout retry = ToolRetryMiddleware( max_retries=4, retry_on=(RequestException, Timeout), backoff_factor=1.5, ) ``` !!! example "Custom exception filtering" ```python from requests.exceptions import HTTPError def should_retry(exc: Exception) -> bool: # Only retry on 5xx errors if isinstance(exc, HTTPError): return 500 <= exc.status_code < 600 return False retry = ToolRetryMiddleware( max_retries=3, retry_on=should_retry, ) ``` !!! example "Apply to specific tools with custom error handling" ```python def format_error(exc: Exception) -> str: return "Database temporarily unavailable. Please try again later." retry = ToolRetryMiddleware( max_retries=4, tools=["search_database"], on_failure=format_error, ) ``` !!! example "Apply to specific tools using `BaseTool` instances" ```python from langchain_core.tools import tool @tool def search_database(query: str) -> str: '''Search the database.''' return results retry = ToolRetryMiddleware( max_retries=4, tools=[search_database], # Pass BaseTool instance ) ``` !!! example "Constant backoff (no exponential growth)" ```python retry = ToolRetryMiddleware( max_retries=5, backoff_factor=0.0, # No exponential growth initial_delay=2.0, # Always wait 2 seconds ) ``` !!! example "Raise exception on failure" ```python retry = ToolRetryMiddleware( max_retries=2, on_failure="error", # Re-raise exception instead of returning message ) ``` Ncontinueg@g?gN@T) max_retriestoolsretry_on on_failurebackoff_factor initial_delay max_delayjitterc>[T U]5 [XXu5 US:XaSn [R"U [ SS9 SnO$US:XaSn [R"U [ SS9 SnXlU Ub:UV s/sH&n [U [5(d U ROU PM( sn Ul OS Ul /Ul X0l X@l XPlX`lXplXlg s sn f) u~Initialize `ToolRetryMiddleware`. Args: max_retries: Maximum number of retry attempts after the initial call. Must be `>= 0`. tools: Optional list of tools or tool names to apply retry logic to. Can be a list of `BaseTool` instances or tool name strings. If `None`, applies to all tools. retry_on: Either a tuple of exception types to retry on, or a callable that takes an exception and returns `True` if it should be retried. Default is to retry on all exceptions. on_failure: Behavior when all retries are exhausted. Options: - `'continue'`: Return a `ToolMessage` with error details, allowing the LLM to handle the failure and potentially recover. - `'error'`: Re-raise the exception, stopping agent execution. - **Custom callable:** Function that takes the exception and returns a string for the `ToolMessage` content, allowing custom error formatting. **Deprecated values** (for backwards compatibility): - `'return_message'`: Use `'continue'` instead. - `'raise'`: Use `'error'` instead. backoff_factor: Multiplier for exponential backoff. Each retry waits `initial_delay * (backoff_factor ** retry_number)` seconds. Set to `0.0` for constant delay. initial_delay: Initial delay in seconds before first retry. max_delay: Maximum delay in seconds between retries. Caps exponential backoff growth. jitter: Whether to add random jitter (`±25%`) to delay to avoid thundering herd. Raises: ValueError: If `max_retries < 0` or delays are negative. raisezion_failure='raise' is deprecated and will be removed in a future version. Use on_failure='error' instead.r) stacklevelerrorreturn_messagezuon_failure='return_message' is deprecated and will be removed in a future version. Use on_failure='continue' instead.rN)super__init__r warningswarnDeprecationWarningr isinstancestrname _tool_filterrrrrrr r!) selfrrrrrrr r!msgtool __class__s h/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/langchain/agents/middleware/tool_retry.pyr(ToolRetryMiddleware.__init__sr  k)T  2  MM#1a @ J + +J  MM#1a @#J&  ^c d^cVZ*T32G2GT!Q^c dD  $D   $,*" !es4-Cc:URcgXR;$)zCheck if retry logic should apply to this tool. Args: tool_name: Name of the tool being called. Returns: `True` if retry logic should apply, `False` otherwise. T)r/)r0 tool_names r4_should_retry_tool&ToolRetryMiddleware._should_retry_tools"    $----c z[U5Rn[U5nUS:XaSOSnSUSUSUSUSUS 3 $) zFormat the failure message when retries are exhausted. Args: tool_name: Name of the tool that failed. exc: The exception that caused the failure. attempts_made: Number of attempts actually made. Returns: Formatted error message string. attemptattemptszTool 'z' failed after  z with z: z. Please try again.)type__name__r-)r7exc attempts_madeexc_typeexc_msg attempt_words r4_format_failure_message+ToolRetryMiddleware._format_failure_messages[9%%c($1Q$6yJ YK}oQ|nM:Ry(; = r:cURS:XaUe[UR5(aURU5nOURXU5n[UUUSS9$)a~Handle failure when all retries are exhausted. Args: tool_name: Name of the tool that failed. tool_call_id: ID of the tool call (may be `None`). exc: The exception that caused the failure. attempts_made: Number of attempts actually made. Returns: `ToolMessage` with error details. Raises: Exception: If `on_failure` is `'error'`, re-raises the exception. r%)content tool_call_idr.status)rcallablerGr)r0r7rKrBrCrJs r4_handle_failure#ToolRetryMiddleware._handle_failures]" ??g %I DOO $ $ooc*G229=QG%   r:c UR(aURROURSnURU5(dU"U5$URSn[ UR S-5H nU"U5s $ Sn [#U 5e![ anUS-n[X`R5(dURX4Xg5sSnAs $XPR :a][UURURURURS9nUS:a[R "U5 SnAMSnAMURX4Xg5sSnAs $SnAff=f)anIntercept tool execution and retry on failure. Args: request: Tool call request with call dict, `BaseTool`, state, and runtime. handler: Callable to execute the tool (can be called multiple times). Returns: `ToolMessage` or `Command` (the final result). Raises: RuntimeError: If the retry loop completes without returning. This should not happen. r.idr<Nrrr r!r2Unexpected: retry loop completed without returning)r2r. tool_callr8ranger Exceptionr rrNr rrr r!timesleep RuntimeError r0requesthandlerr7rKr=rBrCdelayr1s r4wrap_tool_call"ToolRetryMiddleware.wrap_tool_call sB"*1GLL%%7;L;LV;T &&y117# #((. T--12G ]w''3:C37 ] '! .c==AA// \\---+'+':':&*&8&8"&..#{{ Eqy 5))!  // \\/ ]s1B E%#0E E%A E E E% E%c # UR(aURROURSnURU5(dU"U5IShvN $URSn[ UR S-5HnU"U5IShvN s $ Sn [#U 5eNPN![ anUS-n[X`R5(dURX4Xg5sSnAs $XPR :af[UURURURURS9nUS:a%[R "U5IShvN SnAMSnAMURX4Xg5sSnAs $SnAff=f7f)aIntercept and control async tool execution with retry logic. Args: request: Tool call request with call `dict`, `BaseTool`, state, and runtime. handler: Async callable to execute the tool and returns `ToolMessage` or `Command`. Returns: `ToolMessage` or `Command` (the final result). Raises: RuntimeError: If the retry loop completes without returning. This should not happen. r.NrQr<rRrrS)r2r.rTr8rUrrVr rrNr rrr r!asynciorXrYrZs r4awrap_tool_call#ToolRetryMiddleware.awrap_tool_callZsV$*1GLL%%7;L;LV;T &&y11 )) )((. T--12G ]$W---3:C3G*. ] '! .c==AA// \\---+'+':':&*&8&8"&..#{{ Eqy%mmE222!  // \\/ ]sAFB+.F B/B-B/F-B// F90E?)F*F1A#E?EE? F&E?7F8F?FF) r/rrr!r rrrr)rintrzlist[BaseTool | str] | Nonerrrrrfloatrrer rer!boolreturnNone)r7r-rgrf)r7r-rBrVrCrdrgr-) r7r-rKz str | NonerBrVrCrdrgr)r[rr\z7Callable[[ToolCallRequest], ToolMessage | Command[Any]]rgToolMessage | Command[Any])r[rr\zBCallable[[ToolCallRequest], Awaitable[ToolMessage | Command[Any]]]rgri)rA __module__ __qualname____firstlineno____doc__rVr(r8 staticmethodrGrNr^rb__static_attributes__ __classcell__)r3s@r4rrs'_H-1&L * #"]]+ ]  ]  ]]]]] ]]~ .  &  ,6 =F WZ  @8  8 I8  $ 8 t9  9 T9  $ 9 9 r:r)rm __future__rrarWr)typingrrlangchain_core.messagesr"langchain.agents.middleware._retryrrr r r !langchain.agents.middleware.typesr r rrcollections.abcrrlanggraph.typesrrlangchain.toolsrrr:r4rzs['" %/_^3'A(u /*Y*?9*TUu r: