4RjlkddlmZddlZddlZddlmZmZddlmZm Z m Z m Z m Z m Z mZmZmZmZmZddlmZmZddlmZmZddlZddlmZmZmZmZdd lm Z m!Z!dd l"m#Z#m$Z$dd l%m&Z&d d l'm(Z(m)Z)d dl*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3m4Z4d dl5m6Z6m7Z7m8Z8ddl9m:Z:m;Z;ddlZ>m?Z?ddl@mAZAddlBmCZCerddlDmEZEmFZFe de e,e e.e e0e1fZGe dZHejeJZKGddedZLGdde eGe=fZMGd d!eMe-e=fe eHe=feZNGd"d#eNe>e=e=fZOGd$d%eNe:e=e=fZPGd&d'eMe/e=fe eHe=feZQGd(d)eQe>e=e=fZRGd*d+eQe;e=e=fZSy),) 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 RunnerItemTc6eZdZUded<ded<ded<ded<y ) RequestOptionszHeaders | None extra_headersz Query | None extra_queryz Body | None extra_bodyz'float | httpx.Timeout | None | NotGiventimeoutN)__name__ __module__ __qualname____annotations__h/var/www/html/meridian/meridian-ai/venv/lib/python3.12/site-packages/anthropic/lib/tools/_beta_runner.pyr<r<<s!! 44rFr<F)totalcReZdZddd ddZ ddZd dZd dZy) BaseToolRunnerNmax_iterationscompaction_controlcxt||_i|d|dDcgc]}|c}i|_t|jj |j d}|r't ||j dxsi}i|d|i}||_d|_d|_ ||_ d|_ ||_ ycc}w)Nmessages)toolsrOr=Fr) r _tools_by_name_paramsr+valuesgetr_options_messages_modified_cached_tool_call_response_max_iterations_iteration_count_compaction_control) selfparamsoptionsrPrLrMmessager*merged_headerss rG__init__zBaseToolRunner.__init__Ds,E2G G z0BCWCG  0%%,,.ZZ +  *='++o:V:\Z\]NBB/>BG "'CG'- !#5 Ds B7cLt|r||j}||_y)a  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)callablerR)r[r\s rGset_messages_paramsz"BaseToolRunner.set_messages_params`s! F DLL)F rFc|Dcgc]-}t|tr|j|jdn|/c}d|_|j fdd|_ycc}w)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"i|dg|diS)NrOrE)r\message_paramss rGz0BaseToolRunner.append_messages..zs&0n60n:GmPZI[Gm^lGm0nrFN) isinstancerrfrgrVrcrW)r[rOr^ris @rGappend_messageszBaseToolRunner.append_messagesosb$2 CMWVaBbW\\goo >ho o2 #'   !no*.' 2 s2AcP|j|j|jk\ryy)NTF)rXrYr[s rG _should_stopzBaseToolRunner._should_stop}s'    +0E0EI]I]0]rF) r\-ParseMessageCreateParamsBase[ResponseFormatT]r]r<rPzIterable[AnyFunctionToolT]rL int | NonerMCompactionControl | NonereturnNone)r\zParseMessageCreateParamsBase[ResponseFormatT] | Callable[[ParseMessageCreateParamsBase[ResponseFormatT]], ParseMessageCreateParamsBase[ResponseFormatT]]rsrt)rOz5BetaMessageParam | ParsedBetaMessage[ResponseFormatT]rsrtrsbool)rArBrCr`rcrlrorErFrGrJrJCso&*7;6>6 6 * 6 # 656 68 s    /rFrJceZdZddd dfdZddZddZeeddZddZ ddZ dd Z dd Z dd Z dd Zdd ZddZxZS)BaseSyncToolRunnerNrKct||||||||_|-|jdrt j dt d|j|_d|_ yN)r\r]rPrLrMenableda!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 superr`_clientrTwarningswarnDeprecationWarning__run__ _iterator _last_messager[r\r]rPclientrLrM __class__s rGr`zBaseSyncToolRunner.__init__sy )1    ).@.D.DY.O MM}#    rFc6|jjSN)r__next__rns rGrzBaseSyncToolRunner.__next__s~~&&((rFc#6K|jD]}|ywrrr[items rG__iter__zBaseSyncToolRunner.__iter__sNN DJ sc#KtwrNotImplementedErrorrns rG_handle_requestz"BaseSyncToolRunner._handle_request"## c |j|jdsy|j}d}|e|jj|jjxsdz|jj xsdz}||jj z}|jjdt}||krytjd|d|d|jjd|jd}t|jd }|d d d k(rT|d d Dcgc](}t|tr|jddk7r|*}}|r ||d d <n|jg|t!d|jjdt"}|j$j&j(j+|||jdt-d} tjd| jj t| j.d j0dk7r t3d|j5 fdycc}w) Check token usage and compact messages if threshold exceeded. Returns True if compaction was performed, False otherwise. r{Frcontext_token_threshold Token usage  has exceeded the threshold of . Performing compaction.modelrOrf assistantrgtypetool_useusersummary_promptre max_tokens compactionrrOrr=&Compaction complete. New token usage: text1Compaction response content is not of type 'text'c8i|dddjdgdgiSNrOrr)rrrerr\ first_contents rGrjz7BaseSyncToolRunner._check_and_compact..?   &)/(5(:(:$  rFTrZ_get_last_messageusage input_tokenscache_creation_input_tokenscache_read_input_tokens output_tokensrTr,loginforRlistrkdictpoprr-rbetarOcreater*rgr ValueErrorrc r[r^ tokens_usedtotal_input_tokens thresholdrrOblocknon_tool_blocksresponsers @rG_check_and_compactz%BaseSyncToolRunner._check_and_compacts^  # # +43K3KI3V((*   **==<<AC==88=A?  -w}}/J/JJK,,001JL]^  " < },KI;Vnop((,,Wdll76KL Z01 B< ; . &b\)4eT*uyy/@J/NO *9 Y'   00445EG]^  <<$$--44||L1' 5 5  9(..:V:V9WXYX--.q1    'PQ Q     cs/-I$c#K|js#|j5}||j}|J|j}|/|j#|jj |j d<ddd|xjdz c_jdk(rtjdy|jsF|j}|tjdy|js|j||d|_ d|_|js"yy#1swYxYwwN containerrrefusalz9Turn ended with a refusal, exiting from tool runner loop.z;Tool call was not requested, exiting from tool runner loop.Frorr_get_last_assistant_messageridrRrY stop_reasonrdebugrgenerate_tool_call_responserVrlrWr[rr^last_assistant_messagers rGrzBaseSyncToolRunner.__run__s3##%%%' T4 002****.)I)I)K&)5:P:Z:Z:f0F0P0P0S0SDLL- T  ! !Q & ! ""i/ UV**,;;=#II[\..(((;&+D #.2D +?##%% T Ts$"EAD8>B6E6E8E=EcDt||j}|J|S) 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 rG until_donezBaseSyncToolRunner.until_done(s, d#--/ '''rFc|j!tjd|jS|j}||_|S)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.rWrr_generate_tool_call_responser[rs rGrz.BaseSyncToolRunner.generate_tool_call_response2sD  * * 6 II< =22 2446*2'rFc |j}|sy|Dcgc]}|jdk(s|}}|syg}|D]}|jj|j}|}t j d|jdt|jjdtd|jd|jd|jd d d  |j|j}|jd|j|d d|dScc}w#t$r4}|jd|jt|d d Yd}~&d}~wt $rX}t"j%d |j||jd|jt|d d Yd}~d}~wwxYw)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_idrgis_errorrrrg#Error occurred while calling tool: exc_inforre#_get_last_assistant_message_contentrrQrTnamerrrkeys UserWarningappendrcallinputr"r! Exceptionr exception r[rgrtool_use_blocksresultsrtoolresultexcs rGrz/BaseSyncToolRunner._generate_tool_call_response@s::<.5RUz9Q5RR24'* H&&**8==9D| X]]O,((,T-@-@-E-E-G(H'IJmn   -'/{{%28==/#M$(  8>>2 hkk^def/* X733eS<  -'/{{#5c#:$(   CDII;OZ] ^ -'/{{#5c#:$(  s/D#D#":D(( G1)E  G,A F??Gcdt|jr|jS|jSrrbrrns rGrz$BaseSyncToolRunner._get_last_messageys+ D&& '%%' '!!!rFcb|j}||jdk7s |jsy|SNrrrfrgrs rGrz.BaseSyncToolRunner._get_last_assistant_message~s4--/  <#4#4 #C  *   #5 B)Rh 3D 74r" .rFrxc(eZdZeeddZy)BetaToolRunnerc#K|jjjjdi|j|j }||_|ywNrErrrOparserRrUrr[r^s rGrzBetaToolRunner._handle_requestsG3$,,##,,22ST\\ST]]S$ sAAN)rsz,Iterator[ParsedBetaMessage[ResponseFormatT]]rArBrCrrrrErFrGr r s rFr c(eZdZeeddZy)BetaStreamingToolRunnerc#K|jjjjdi|j|j 5}|j |_|dddy#1swYyxYwwrrrrOstreamrRrUget_final_messagerr[rs rGrz'BetaStreamingToolRunner._handle_requestsb/T\\   ' ' . . O O O SY!'!9!9D L   sAA4 A( A4(A1-A4N)rsz,Iterator[BetaMessageStream[ResponseFormatT]]rrErFrGrrs rFrceZdZddd dfdZddZddZeeddZddZ ddZ dd Z dd Z dd Z dd Zdd ZddZxZS)BaseAsyncToolRunnerNrKct||||||||_|-|jdrt j dt d|j|_d|_ yrzr~rs rGr`zBaseAsyncToolRunner.__init__sy )1    ).@.D.DY.O MM}#    rFcRK|jjd{S7wr)r __anext__rns rGrzBaseAsyncToolRunner.__anext__s^^--////s '%'cHK|j23d{}|7 6ywrrrs rG __aiter__zBaseAsyncToolRunner.__aiter__s&..  $J .s "  " "cKtwrrrns rGrz#BaseAsyncToolRunner._handle_requestrrc K|j|jdsy|jd{}d}|e|jj|jjxsdz|jj xsdz}||jj z}|jjdt}||krytjd|d|d|jjd |jd }t|jd }|d d d k(rT|d dDcgc](}t|tr|jddk7r|*}}|r ||d d<n|jg|t!d|jjdt"}|j$j&j(j+|||jdt-dd{} tjd| jj t| j.d j0dk7r t3d|j5 fdy7Ccc}w7w)rNr{FrrrrrrrOrrfrrgrrrrrerrrrrrc8i|dddjdgdgiSrrrs rGrjz8BaseAsyncToolRunner._check_and_compact..rrFTrrs @rGrz&BaseAsyncToolRunner._check_and_compactst  # # +43K3KI3V..00   **==<<AC==88=A?  -w}}/J/JJK,,001JL]^  " < },KI;Vnop((,,Wdll76KL Z01 B< ; . &b\)4eT*uyy/@J/NO *9 Y'   00445EG]^  **33::||L1' 5 ;   9(..:V:V9WXYX--.q1    'PQ Q     U12& s00JI6DJ9-I9&BJ>I>?A8J9JcK|jsT|j4d{}||jd{}|J|jd{}|/|j#|jj |j d<dddd{|xjdz c_jdk(rtjdy|jd{sN|jd{}|tjdy|js|j||d|_ d|_|jsSyy7A7'77#1d{7swYxYw77~wrrrs rGrzBaseAsyncToolRunner.__run__&sw##%++- T T $ 6 6 88***04/O/O/Q)Q&)5:P:Z:Z:f0F0P0P0S0SDLL- T T  ! !Q & ! ""i/ UV00222!%!A!A!CC#II[\..(((;&+D #.2D +?##%% T8*R  T T T T(3Cs&F E)F E4E,E4!E/"5E4 F "E2#AF 4F 5F  F  AF 'F ,E4/E42F 4F:E= ;FF  F ctKt|d{|jd{}|J|S7"7 w)rN)rrrs rGrzBaseAsyncToolRunner.until_doneHsB %T***!3355 ''' +5s8486 88cK|j!tjd|jS|jd{}||_|S7 w)rNrrrs rGrz/BaseAsyncToolRunner.generate_tool_call_responseRsP  * * 6 II< =22 2::<<*2'=sAAAAcKt|jr|jd{S|jS7wrrrns rGrz%BaseAsyncToolRunner._get_last_messageas7 D&& '++-- -!!!.s )><>c~K|jd{}||jdk7s |jsy|S7$wrrrs rGrz/BaseAsyncToolRunner._get_last_assistant_messagefs@!3355  <#4#4 #C! ! / !  !#!5! !F0Rh 3D " .74rFrc(eZdZeeddZy)BetaAsyncToolRunnercK|jjjjdi|j|j d{}||_|y7wrrrs rGrz#BetaAsyncToolRunner._handle_requestsP9 ))2288Y4<<Y4==YY$ ZsA A  A A N)rsz1AsyncIterator[ParsedBetaMessage[ResponseFormatT]]rArBrCrrrrErFrGr,r,s rFr,c(eZdZeeddZy)BetaAsyncStreamingToolRunnerc(K|jjjjdi|j|j 4d{}|j |_|dddd{y7+7#1d{7swYyxYwwrrrs rGrz,BetaAsyncStreamingToolRunner._handle_requests}54<<$$--44Ut||Ut}}U  Y_!'!9!9D L       sHA B A9BA=( B3A;4B;B=BB B BN)rsz6AsyncIterator[BetaAsyncMessageStream[ResponseFormatT]]r.rErFrGr0r0s rFr0)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: getLoggerrArr<rJrxr rrr,r0rErFrGrFs"#    ;1 44C7)=HbbPhhLO4 4S9;RTpp  m$ g!5Ye5=W->?=@G.(8/(IJGT_apTpLqsvG.T'(9/(JO([\01B?1SUd1deL4(/9:GKQ`D`