b\jlkSSKJr SSKrSSKrSSKJrJr SSKJrJ r J r J r J r J r JrJrJrJrJr SSKJrJr SSKJrJr SSKrSSKJrJrJrJr SS KJ r J!r! SS K"J#r#J$r$ SS K%J&r& S S K'J(r(J)r) S SK*J+r+J,r,J-r-J.r.J/r/J0r0J1r1 SSK2J3r3J4r4 S SK5J6r6J7r7J8r8 SSK9J:r:J;r; SSKr>J?r? SSK@JArA SSKBJCrC \(aSSKDJErEJFrF \ "S\ \,\ \.\ \0\14S9rG\ "S5rH\R"\J5rK"SS\SS9rL"SS\ \G\=45rM"S S!\M\-\=4\ \H\=4\5rN"S"S#\N\>\=\=45rO"S$S%\N\:\=\=45rP"S&S'\M\/\=4\ \H\=4\5rQ"S(S)\Q\>\=\=45rR"S*S+\Q\;\=\=45rSg),) annotationsN)ABCabstractmethod) TYPE_CHECKINGAnyListUnionGenericTypeVarCallableIterableIterator Coroutine AsyncIterator)contextmanagerasynccontextmanager) TypedDictoverride)BodyQueryHeadersNotGiven)consume_sync_iteratorconsume_async_iterator) BetaMessageBetaMessageParam) merge_headers) tool_registrytool_error_content) ToolErrorBetaFunctionToolBetaRunnableToolBetaAsyncFunctionToolBetaAsyncRunnableToolBetaBuiltinFunctionToolBetaAsyncBuiltinFunctionTool) helper_headerstainless_helper_header)DEFAULT_THRESHOLDDEFAULT_SUMMARY_PROMPTCompactionControl)BetaMessageStreamBetaAsyncMessageStream)ResponseFormatTParsedBetaMessageParsedBetaContentBlock)ParseMessageCreateParamsBase)BetaToolResultBlockParam) AnthropicAsyncAnthropicAnyFunctionToolT)bound RunnerItemTc>\rSrSr%S\S'S\S'S\S'S\S 'S rg ) RequestOptions<zHeaders | None extra_headersz Query | None extra_queryz Body | None extra_bodyz'float | httpx.Timeout | None | NotGiventimeoutN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__rBV/var/www/website/venv/lib/python3.13/site-packages/anthropic/lib/tools/_beta_runner.pyr<r<<s!! 44rIr<F)totalcd\rSrSrSSS.S SjjrS SjrS SjrS SjrSrg) BaseToolRunnerCNmax_iterationscompaction_controlc[U5Ul0UESUSVs/sHofPM sn0EUl[URR 5UR S5S9nU(a+[ XrR S5=(d 05n0UESU0EnX lSUlSUl X@l SUl XPl gs snf)Nmessages)toolsrSr>Fr) r _tools_by_name_paramsr+valuesgetr_options_messages_modified_cached_tool_call_response_max_iterations_iteration_count_compaction_control) selfparamsoptionsrTrPrQmessager*merged_headerss rJ__init__BaseToolRunner.__init__Ds,E2G G z0BC0BW0BCG  0%%,,.ZZ +  *=++o:V:\Z\]NBB/>BG "'CG'- !#5 Ds B<cT[U5(aU"UR5nXlg)z Update the parameters for the next API call. This invalidates any cached tool responses. Args: params (ParsedMessageCreateParamsBase[ResponseFormatT] | Callable): Either new parameters or a function to mutate existing parameters N)callablerV)r_r`s rJset_messages_params"BaseToolRunner.set_messages_params`s" F  DLL)F rIc^UVs/sH3n[U[5(aURURS.OUPM5 snmSUlUR U4Sj5 SUlgs snf)zAdd one or more messages to the conversation history. This invalidates the cached tool response, i.e. if tools were already called, then they will be called again on the next loop iteration. rolecontentTc">0UES/USQTQ0E$)NrSrB)r`message_paramss rJ0BaseToolRunner.append_messages..zs$0n60n:GmPZI[Gm^lGm0nrIN) isinstancerrlrmrZrhr[)r_rSrbros @rJappend_messagesBaseToolRunner.append_messagesosj$2 #CMWVaBbBbW\\goo >ho o#2 #'   !no*.' 2 s:A'cTURbURUR:agg)NTF)r\r]r_s rJ _should_stopBaseToolRunner._should_stop}s'    +0E0EI]I]0]rI)r[r^r]r\rZrYrVrU) r`-ParseMessageCreateParamsBase[ResponseFormatT]rar<rTzIterable[AnyFunctionToolT]rP int | NonerQCompactionControl | NonereturnNone)r`zParseMessageCreateParamsBase[ResponseFormatT] | Callable[[ParseMessageCreateParamsBase[ResponseFormatT]], ParseMessageCreateParamsBase[ResponseFormatT]]r|r})rSz5BetaMessageParam | ParsedBetaMessage[ResponseFormatT]r|r}r|bool) rCrDrErFrdrhrsrwrHrBrIrJrMrMCso&*7;6>6 6 * 6 # 656 68 s    /rIrMc^\rSrSrSSS.SU4SjjjrSSjrSSjr\\SSj55r SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSrU=r$)BaseSyncToolRunnerNrOc>[TU]UUUUUS9 X@lUb0URS5(a[R "S[ SS9 UR5UlSUl gN)r`rarTrPrQenableda!The 'compaction_control' parameter is deprecated and will be removed in a future version. Use server-side compaction instead by passing `edits=[{'type': 'compact_20260112'}]` in your the params passed to `tool_runner()`. See https://platform.claude.com/docs/en/build-with-claude/compactionr stacklevel superrd_clientrXwarningswarnDeprecationWarning__run__ _iterator _last_messager_r`rarTclientrPrQ __class__s rJrdBaseSyncToolRunner.__init__sz )1    ).@.D.DY.O.O MM}#    rIc6URR5$N)r__next__rvs rJrBaseSyncToolRunner.__next__s~~&&((rIc#:# URHnUv M g7frrr_items rJ__iter__BaseSyncToolRunner.__iter__sNNDJ#sc## [5e7frNotImplementedErrorrvs rJ_handle_request"BaseSyncToolRunner._handle_request"## c^ URbURS(dgUR5nSnUbnURRURR=(d S-URR =(d S-nX1RR -nURRS[5nX$:ag[RSUSUS35 URRSURS5n[URS 5nUS S S :XaeUS S Vs/sH3n[U[5(dMURS5S:wdM1UPM5 nnU(aXS S 'OUR5 /UQ[!SURRS["5S9PnUR$R&R(R+UUURS[-S5S9n [RSU RR 35 [U R.5Sm T R0S:wa [3S5eUR5U 4Sj5 gs snf)z Check token usage and compact messages if threshold exceeded. Returns True if compaction was performed, False otherwise. rFrcontext_token_threshold Token usage  has exceeded the threshold of . Performing compaction.modelrSrl assistantrmtypetool_useusersummary_promptrk max_tokens compactionrrSrr>&Compaction complete. New token usage: text1Compaction response content is not of type 'text'c8>0UESSSTRS./S./0E$NrSrr)rrrkrr` first_contents rJrp7BaseSyncToolRunner._check_and_compact..=   &)/(5(:(:$  rITr^_get_last_messageusage input_tokenscache_creation_input_tokenscache_read_input_tokens output_tokensrXr,loginforVlistrrdictpoprr-rbetarScreater*rmr ValueErrorrh r_rb tokens_usedtotal_input_tokens thresholdrrSblocknon_tool_blocksresponsers @rJ_check_and_compact%BaseSyncToolRunner._check_and_compactsa  # # +43K3KI3V((*   **==<<AC==88=A?  -}}/J/JJK,,001JL]^  " < },KI;Vnop((,,Wdll76KL Z01 B< ; . &b\)44EeT*/4yy/@J/N4  *9 Y'   00445EG]^  <<$$--44||L1' 5 5  9(..:V:V9WXYX--.q1    'PQ Q     csJJ4Jc## UR5(Gd7UR5nUv UR5nUceUR5nUb0URb#URR UR S'SSS5 U=RS- slWRS:Xa[RS5 gUR5(dKUR5nUc[RS5 gUR(dURX$5 SUl SUlUR5(dGM6gg!,(df  N=f7fN containerrrefusalz9Turn ended with a refusal, exiting from tool runner loop.z;Tool call was not requested, exiting from tool runner loop.Frwrr_get_last_assistant_messageridrVr] stop_reasonrdebugrgenerate_tool_call_responserZrsr[r_rrblast_assistant_messagers rJrBaseSyncToolRunner.__run__s)##%%%%'4 002****.)I)I)K&)5:P:Z:Z:f0F0P0P0S0SDLL-(  ! !Q & ! ""i/ UV**,,;;=#II[\..((;&+D #.2D +?##%%''s$'E"AECE"E" EE"cF[U5 UR5nUceU$) Consumes the tool runner stream and returns the last message if it has not been consumed yet. If it has, it simply returns the last message. )rrr_ last_messages rJ until_doneBaseSyncToolRunner.until_done(s, d#--/ '''rIcURb![RS5 UR$UR5nXlU$)Generate a MessageParam by calling tool functions with any tool use blocks from the last message. Note the tool call response is cached, repeated calls to this method will return the same response. None can be returned if no tool call was applicable. $Returning cached tool call response.r[rr_generate_tool_call_responser_rs rJr.BaseSyncToolRunner.generate_tool_call_response2sB  * * 6 II< =22 2446*2'rIc UR5nU(dgUVs/sHo"RS:XdMUPM nnU(dg/nUHnURRUR5nUc|[ R "SURS[URR55S3[SS9 URSURSURS 3S S .5 MURUR5nURSURUS .5 M SUS.$s snf![a5nURSUR[U5S S .5 SnAGM*SnAf[ aVn["R%S UR3US9 URSUR[U5S S .5 SnAGMSnAff=f)NrTool '-' not found in tool runner. Available tools: z. If using a raw tool definition, handle the tool call manually and use `append_messages()` to add the result. Otherwise, pass the tool using `beta_tool(func)` or a `@beta_tool` decorated function.rr tool_result Error: Tool ' ' not foundTr tool_use_idrmis_errorrrrm#Error occurred while calling tool: exc_inforrk#_get_last_assistant_message_contentrrUrXnamerrrkeys UserWarningappendrcallinputr"r! Exceptionr exception r_rmrtool_use_blocksresultsrtoolresultexcs rJr/BaseSyncToolRunner._generate_tool_call_response@s::<.5RgUz9Q5gR24'H&&**8==9D| X]]O,((,T-@-@-E-E-G(H'IJmn   -'/{{%28==/#M$(  8>>2 hkk^def/(X733eS<  -'/{{#5c#:$(   CDII;OZ] ^ -'/{{#5c#:$(  s/D3D30:D88 G)E22 G?A GGcn[UR5(aUR5$UR$rrgrrvs rJr$BaseSyncToolRunner._get_last_messageys. D&& ' '%%' '!!!rIcpUR5nUb!URS:wdUR(dgU$Nrrrlrmrs rJr.BaseSyncToolRunner._get_last_assistant_message~s4--/  <#4#4 #C  *   #5 B)Rh 3D 74r" ..rIrc2\rSrSr\\SSj55rSrg)BetaToolRunneric## URRRR"S0URDUR D6nXlUv g7fNrBrrrSparserVrYrr_rbs rJrBetaToolRunner._handle_requestsB,,##,,22ST\\ST]]S$ sAArN)r|z,Iterator[ParsedBetaMessage[ResponseFormatT]]rCrDrErFrrrrHrBrIrJr$r$s rIr$c2\rSrSr\\SSj55rSrg)BetaStreamingToolRunneric## URRRR"S0URDUR D6nUR UlUv SSS5 g!,(df  g=f7fr&rrrSstreamrVrYget_final_messagerr_r1s rJr'BetaStreamingToolRunner._handle_requestsW\\   ' ' . . O O OSY!'!9!9D LP O OsAA9 A( A9( A62A9r+N)r|z,Iterator[BetaMessageStream[ResponseFormatT]]r,rBrIrJr.r.s rIr.c^\rSrSrSSS.SU4SjjjrSSjrSSjr\\SSj55r SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSrU=r$)BaseAsyncToolRunneriNrOc>[TU]UUUUUS9 X@lUb0URS5(a[R "S[ SS9 UR5UlSUl grrrs rJrdBaseAsyncToolRunner.__init__sz )1    ).@.D.DY.O.O MM}#    rIcR# URR5IShvN $N7fr)r __anext__rvs rJr:BaseAsyncToolRunner.__anext__s^^--////s '%'cJ# URShvN nU7v MN g7frrrs rJ __aiter__BaseAsyncToolRunner.__aiter__s.. $J .s #!!#!#c# [5e7frrrvs rJr#BaseAsyncToolRunner._handle_requestrrc@^ # URbURS(dgUR5IShvN nSnUbnURRURR=(d S-URR =(d S-nX1RR -nURRS[5nX$:ag[RSUSUS35 URRS URS 5n[URS 5nUS S S :XaeUS SVs/sH3n[U[5(dMURS5S:wdM1UPM5 nnU(aXS S'OUR5 /UQ[!SURRS["5S9PnUR$R&R(R+UUURS[-S5S9IShvN n [RSU RR 35 [U R.5Sm T R0S:wa [3S5eUR5U 4Sj5 gGN[s snfN7f)rNrFrrrrrrrSrrlrrmrrrrrkrrrrrrc8>0UESSSTRS./S./0E$rrrs rJrp8BaseAsyncToolRunner._check_and_compact..rrITrrs @rJr&BaseAsyncToolRunner._check_and_compactsv  # # +43K3KI3V..00   **==<<AC==88=A?  -}}/J/JJK,,001JL]^  " < },KI;Vnop((,,Wdll76KL Z01 B< ; . &b\)44EeT*/4yy/@J/N4  *9 Y'   00445EG]^  **33::||L1' 5 ;   9(..:V:V9WXYX--.q1    'PQ Q     U12& s<6JJDJ J'J>JBJJA:JJcZ# UR5(GdhUR5IShvN nU7v UR5IShvN nUceUR5IShvN nUb0URb#URR UR S'SSS5IShvN U=RS- slWRS:Xa[RS5 gUR5IShvN (dSUR5IShvN nUc[RS5 gUR(dURX$5 SUl SUlUR5(dGMgggGNUGN;GN!N!,IShvN (df  N=fNN7frrrs rJrBaseAsyncToolRunner.__run__&sX##%%++-- $ 6 6 88***04/O/O/Q)Q&)5:P:Z:Z:f0F0P0P0S0SDLL-.-  ! !Q & ! ""i/ UV00222!%!A!A!CC#II[\..((;&+D #.2D +?##%%-8*R .---(3Cs+F+FF+F  F F 'F(7F  F+*F +AF+=F'>F+F)A"F+F+F F  F+ F$F  F$ F+)F+cv# [U5IShvN UR5IShvN nUceU$N#N 7f)rN)rrrs rJrBaseAsyncToolRunner.until_doneHs@ %T***!3355 ''' +5s9597 99c# URb![RS5 UR$UR5IShvN nXlU$N 7f)rNrrrs rJr/BaseAsyncToolRunner.generate_tool_call_responseRsM  * * 6 II< =22 2::<<*2'=sAAA Ac# [UR5(aUR5IShvN $UR$N7frrrvs rJr%BaseAsyncToolRunner._get_last_messageas9 D&& ' '++-- -!!!.s.AAAc# UR5IShvN nUb!URS:wdUR(dgU$N+7frrrs rJr/BaseAsyncToolRunner._get_last_assistant_messagefs?!3355  <#4#4 #C! ! / !  !#!5! !!F0Rh 3D " .7474rIr6c2\rSrSr\\SSj55rSrg)BetaAsyncToolRunneric# URRRR"S0URDUR D6IShvN nXlU7v gN7fr&r'r)s rJr#BetaAsyncToolRunner._handle_requestsK ))2288Y4<<Y4==YY$ ZsA A A Ar+N)r|z1AsyncIterator[ParsedBetaMessage[ResponseFormatT]]rCrDrErFrrrrHrBrIrJrTrTs rIrTc2\rSrSr\\SSj55rSrg)BetaAsyncStreamingToolRunneric2# URRRR"S0URDUR D6IShvN nUR UlU7v SSS5IShvN gN+N!,IShvN (df  g=f7fr&r0r3s rJr,BetaAsyncStreamingToolRunner._handle_requestsc<<$$--44Ut||Ut}}UUY_!'!9!9D LVUUUUUsHA B A9BA=( B3A;4B;B=BB  BBr+N)r|z6AsyncIterator[BetaAsyncMessageStream[ResponseFormatT]]rWrBrIrJrYrYs rIrY)T __future__rloggingrabcrrtypingrrrr r r r r rrr contextlibrrtyping_extensionsrrhttpx_typesrrrr_utilsrr types.betarr _base_clientr_tool_dispatchr r!_beta_functionsr"r#r$r%r&r'r(_stainless_helpersr*r+_beta_compaction_controlr,r-r.streaming._beta_messagesr/r0types.beta.parsed_beta_messager1r2r3 types.beta.message_create_paramsr4'types.beta.beta_tool_result_block_paramr5rr6r7r8r: getLoggerrCrr<rMrr$r.r6rTrYrBrIrJrps"#    ;1 44C7)=HbbPhhLO4 4S9;RTpp  m$  !5Ye5=W->?=@G.(8/(IJGT_apTpLqsvG.T'(9/(JO([\01B?1SUd1deL4(/9:GKQ`D`