̺iicSSKJr 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$ S S K%J&r&J'r'J(r(J)r)J*r*J+r+J,r, S SK-J.r. S SK/J0r0J1r1J2r2 S SK3J4r4J5r5 SSK6J7r7J8r8J9r9 SSK:J;r; SSKJ?r?J@r@ \ "S\ \'\ \)\ \+\,4S9rA\ "S5rB\R"\D5rE"SS\SS9rF"SS\ \A\745rG"SS\G\(\74\ \B\74\5rH"S S!\H\8\7\745rI"S"S#\H\4\7\745rJ"S$S%\G\*\74\ \B\74\5rK"S&S'\K\8\7\745rL"S(S)\K\5\7\745rMg)*) annotationsN)ABCabstractmethod) TYPE_CHECKINGAnyListUnionGenericTypeVarCallableIterableIterator Coroutine AsyncIterator)contextmanagerasynccontextmanager) TypedDictoverride)BodyQueryHeadersNotGiven)consume_sync_iteratorconsume_async_iterator) BetaMessageBetaMessageParam) ToolErrorBetaFunctionToolBetaRunnableToolBetaAsyncFunctionToolBetaAsyncRunnableToolBetaBuiltinFunctionToolBetaAsyncBuiltinFunctionTool)stainless_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__r>_/var/www/piano.thomer.com/venv/lib/python3.13/site-packages/anthropic/lib/tools/_beta_runner.pyr8r8:s!! 44rEr8F)totalcd\rSrSrSSS.S SjjrS SjrS SjrS SjrSrg) BaseToolRunnerANmax_iterationscompaction_controlcUVs0sHofRU_M snUl0UESUSVs/sHowPM sn0EUl[URR 5UR S5S9nU(a&0UEUR S5=(d 0En 0UESU 0EnX lSUlSUlX@l SUl XPl gs snfs snf)Nmessages)toolsrOr:Fr) name_tools_by_name_paramsr'valuesget_options_messages_modified_cached_tool_call_response_max_iterations_iteration_count_compaction_control) selfparamsoptionsrPrLrMtoolmessage helper_headermerged_headerss rF__init__BaseToolRunner.__init__BsBG "'CG'- !#5 #BDs C  CcT[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)callablerS)r\r]s rFset_messages_params"BaseToolRunner.set_messages_params^s" F  DLL)F rEc^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$)NrOr>)r]message_paramss rF0BaseToolRunner.append_messages..ys"YfYj2XF:4F2X2XYrEN) isinstancerrkrlrWrgrX)r\rOr`rns @rFappend_messagesBaseToolRunner.append_messagesmsn$2 #CMWVaBbBbW\\goo >ho o#2 #'   Y +/'2 s:A'cTURbURUR:agg)NTF)rYrZr\s rF _should_stopBaseToolRunner._should_stop}s'    +0E0EI]I]0]rE)rXr[rZrYrWrVrSrR) r]-ParseMessageCreateParamsBase[ResponseFormatT]r^r8rPzIterable[AnyFunctionToolT]rL int | NonerMCompactionControl | NonereturnNone)r]zParseMessageCreateParamsBase[ResponseFormatT] | Callable[[ParseMessageCreateParamsBase[ResponseFormatT]], ParseMessageCreateParamsBase[ResponseFormatT]]r{r|)rOz5BetaMessageParam | ParsedBetaMessage[ResponseFormatT]r{r|r{bool) r?r@rArBrcrgrrrvrDr>rErFrIrIAso&*7;6>6 6 * 6 # 656 68 s   / rErIc^\rSrSrSSS.SU4SjjjrSSjrSSjr\\SSj55r SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSrU=r$)BaseSyncToolRunnerNrKcl>[TU]UUUUUS9 X@lUR5UlSUlgN)r]r^rPrLrMsuperrc_client__run__ _iterator _last_messager\r]r^rPclientrLrM __class__s rFrcBaseSyncToolRunner.__init__sG )1     rEc6URR5$N)r__next__rus rFrBaseSyncToolRunner.__next__s~~&&((rEc#:# URHnUv M g7frrr\items rF__iter__BaseSyncToolRunner.__iter__sNNDJ#sc## [5e7frNotImplementedErrorrus rF_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+UUURSSS0S9n [RSU RR 35 [U R,5Sm T R.S:wa [1S5eUR3U 4Sj5 gs snf)z Check token usage and compact messages if threshold exceeded. Returns True if compaction was performed, False otherwise. enabledFrcontext_token_threshold Token usage  has exceeded the threshold of . Performing compaction.modelrOrk assistantrltypetool_useusersummary_promptrj max_tokensX-Stainless-Helper compactionrrOrr:&Compaction complete. New token usage: text1Compaction response content is not of type 'text'c8>0UESSSTRS./S./0E$NrOrr)rrrjrr] first_contents rFro7BaseSyncToolRunner._check_and_compact..=   &)/(5(:(:$  rETr[_get_last_messageusage input_tokenscache_creation_input_tokenscache_read_input_tokens output_tokensrUr(loginforSlistrqdictpoprr)rbetarOcreaterlr ValueErrorrg r\r` tokens_usedtotal_input_tokens thresholdrrOblocknon_tool_blocksresponsers @rF_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  9(..:V:V9WXYX--.q1    'PQ Q     csI;I;4I;c#~# UR5(GdUR5nUv UR5nUceUR5nUb0URb#URR UR S'SSS5 U=RS- slUR5(dLUR5nUc[RS5 gUR(dURWU5 SUl SUlUR5(dGMgg!,(df  N=f7fN containerrz;Tool call was not requested, exiting from tool runner loop.Frvrr_get_last_assistant_messageridrSrZrgenerate_tool_call_responserdebugrWrrrXr\rr`last_assistant_messagers rFrBaseSyncToolRunner.__run__s ##%%%%'4 002****.)I)I)K&)5:P:Z:Z:f0F0P0P0S0SDLL-(  ! !Q & !**,,;;=#II[\..(((;&+D #.2D +1##%%''s$'D=AD,B!D=*D=, D:6D=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 rF until_doneBaseSyncToolRunner.until_dones, d#--/ '''rEcURb![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.rXrr_generate_tool_call_responser\rs rFr.BaseSyncToolRunner.generate_tool_call_response"sB  * * 6 II< =22 2446*2'rEc UR5nU(dgUVs/sHo"RS:XdMUPM nnU(dg/nUHnURRUR5nUc|[ R "SURS[URR55S3[SS9 URSURSURS 3S S .5 MURUR5nURSURUS .5 M SUS.$s snf![a6nURSURURS 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.r stacklevel tool_result Error: Tool ' ' not foundTr tool_use_idrlis_errorrrrl#Error occurred while calling tool: exc_inforrj#_get_last_assistant_message_contentrrRrUrQwarningswarnrkeys UserWarningappendrcallinputrrl Exceptionr exceptionrepr r\rlrtool_use_blocksresultsrr_resultexcs rFr/BaseSyncToolRunner._generate_tool_call_response0s::<.5RgUz9Q5gR24'H&&**8==9D| X]]O,((,T-@-@-E-E-G(H'IJmn   -'/{{%28==/#M$(  8>>2 hkk^def/(X733eS<  -'/{{#&;;$(   CDII;OZ] ^ -'/{{#'9$(  s/D3D30:D88 G*E33 GA GGcn[UR5(aUR5$UR$rrfrrus rFr$BaseSyncToolRunner._get_last_messageis. D&& ' '%%' '!!!rEcpUR5nUb!URS:wdUR(dgU$Nrrrkrlrs rFr.BaseSyncToolRunner._get_last_assistant_messagens4--/  <#4#4 #C  *   #5 0)Rh36 74r" ..rErc2\rSrSr\\SSj55rSrg)BetaToolRunneri}c## URRRR"S0URDUR D6nXlUv g7fNr>rrrOparserSrVrr\r`s rFrBetaToolRunner._handle_request~sB,,##,,22ST\\ST]]S$ sAArN)r{z,Iterator[ParsedBetaMessage[ResponseFormatT]]r?r@rArBrrrrDr>rErFr r }s rEr c2\rSrSr\\SSj55rSrg)BetaStreamingToolRunneric## URRRR"S0URDUR D6nUR UlUv SSS5 g!,(df  g=f7fr"rrrOstreamrSrVget_final_messagerr\r-s rFr'BetaStreamingToolRunner._handle_requestsW\\   ' ' . . O O OSY!'!9!9D LP O OsAA9 A( A9( A62A9r'N)r{z,Iterator[BetaMessageStream[ResponseFormatT]]r(r>rErFr*r*s rEr*c^\rSrSrSSS.SU4SjjjrSSjrSSjr\\SSj55r SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSrU=r$)BaseAsyncToolRunneriNrKcl>[TU]UUUUUS9 X@lUR5UlSUlgrrrs rFrcBaseAsyncToolRunner.__init__sG )1     rEcR# URR5IShvN $N7fr)r __anext__rus rFr6BaseAsyncToolRunner.__anext__s^^--////s '%'cJ# URShvN nU7v MN g7frrrs rF __aiter__BaseAsyncToolRunner.__aiter__s.. $J .s #!!#!#c# [5e7frrrus rFr#BaseAsyncToolRunner._handle_requestrrc2^ # 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+UUURSSS0S9IShvN n [RSU RR 35 [U R,5Sm T R.S:wa [1S5eUR3U 4Sj5 gGNTs snfN7f)rNrFrrrrrrrOrrkrrlrrrrrjrrrrrrrc8>0UESSSTRS./S./0E$rrrs rFro8BaseAsyncToolRunner._check_and_compact..rrETrrs @rFr&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/> ;   9(..:V:V9WXYX--.q1    'PQ Q     U12& s<6JJ DJ J'J>JBJJA:JJc# UR5(GdCUR5IShvN nU7v UR5IShvN nUceUR5IShvN nUb0URb#URR UR S'SSS5IShvN U=RS- slUR5IShvN (dTUR5IShvN nUc[RS5 gUR(dURWU5 SUl SUlUR5(dGMBggGN0GNNN!,IShvN (df  N=fNN7frrrs rFrBaseAsyncToolRunner.__run__ s:##%%++-- $ 6 6 88***04/O/O/Q)Q&)5:P:Z:Z:f0F0P0P0S0SDLL-.-  ! !Q & !00222!%!A!A!CC#II[\..(((;&+D #.2D +1##%%-8*R .---3Cs+FEFE' E  E''E#(7E' F*E%+,FFF4F5A#FF E'#E'%F'E>-E0 . E>:FFcv# [U5IShvN UR5IShvN nUceU$N#N 7f)rN)rrrs rFrBaseAsyncToolRunner.until_done(s@ %T***!3355 ''' +5s9597 99c# URb![RS5 UR$UR5IShvN nXlU$N 7f)rNrrrs rFr/BaseAsyncToolRunner.generate_tool_call_response2sM  * * 6 II< =22 2::<<*2'=sAAA Ac# [UR5(aUR5IShvN $UR$N7frr rus rFr%BaseAsyncToolRunner._get_last_messageAs9 D&& ' '++-- -!!!.s.AAAc# UR5IShvN nUb!URS:wdUR(dgU$N+7frrrs rFr/BaseAsyncToolRunner._get_last_assistant_messageFs?!3355  <#4#4 #C  /   #5 40Rh36 " .7474rEr2c2\rSrSr\\SSj55rSrg)BetaAsyncToolRunneric# URRRR"S0URDUR D6IShvN nXlU7v gN7fr"r#r%s rFr#BetaAsyncToolRunner._handle_requestsK ))2288Y4<<Y4==YY$ ZsA A A Ar'N)r{z1AsyncIterator[ParsedBetaMessage[ResponseFormatT]]r?r@rArBrrrrDr>rErFrPrPs rErPc2\rSrSr\\SSj55rSrg)BetaAsyncStreamingToolRunneric2# URRRR"S0URDUR D6IShvN nUR UlU7v SSS5IShvN gN+N!,IShvN (df  g=f7fr"r,r/s rFr,BetaAsyncStreamingToolRunner._handle_requestsc<<$$--44Ut||Ut}}UUY_!'!9!9D LVUUUUUsHA B A9BA=( B3A;4B;B=BB  BBr'N)r{z6AsyncIterator[BetaAsyncMessageStream[ResponseFormatT]]rSr>rErFrUrUs rErU)N __future__rloggingrabcrrtypingrrrr r r r r rrr contextlibrrtyping_extensionsrrhttpx_typesrrrr_utilsrr types.betarr_beta_functionsrr r!r"r#r$r%_stainless_helpersr'_beta_compaction_controlr(r)r*streaming._beta_messagesr+r,types.beta.parsed_beta_messager-r.r/ types.beta.message_create_paramsr0'types.beta.beta_tool_result_block_paramr1rr2r3r4r6 getLoggerr?rr8rIrr r*r2rPrUr>rErFrjs"#    ;1 44C79bbPhhLO4 4S9;RTpp  m$  !5Ye5?W->??Dw.(8/(IJGT_apTpLqsvw.t'(9/(JO([\01B?1SUd1de|4(/9:GKQ`D`