yj=?dZddlmZddlZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZddlmZmZdd lmZdd lmZdd lmZdd lmZmZdd lmZmZddlmZm Z ddl!m"Z"m#Z#m$Z$m%Z%m&Z&ej'e(Z)e deZ*d`dZ+dadZ,dbd/Z-dcd2Z.ddd5Z/ded9Z0e dfdgdUZ1e dhdidWZ1e djdkd\Z1 dhdld^Z1gd_Z2dS)maSingle-call executor: the inner LLM-call path without tool-loop orchestration. `honcho_llm_call_inner` handles one backend call (complete or stream), building the effective ModelConfig and delegating to request_builder. Result / stream chunk types are bridged to the public Honcho* shapes here. Used by: - src/llm/api.py (the public entrypoint, for both tool-less and tool-enabled paths) - src/llm/tool_loop.py (each iteration of the tool loop calls this) ) annotationsN) AsyncIterator)AnyLiteralTypeVaroverload) BaseModel) ModelConfigModelTransport)CompletionResult) StreamChunk)ToolCallResult)CLIENTSbackend_for_provider)execute_completionexecute_stream) AttemptPlaneffective_config_for_call)HonchoLLMCallResponseHonchoLLMCallStreamChunkLLMTelemetryContextProviderClientReasoningEffortTypeM)bounderrBaseException | Nonereturn(Literal['success', 'error', 'cancelled']cF|dSt|tjrdSdS)uMap a finally-block error into the telemetry outcome literal. CancelledError is a normal control-flow event (client disconnect, server shutdown) — surface it distinctly so it doesn't pollute error-rate alerts. Nsuccess cancellederror) isinstanceasyncioCancelledError)rs 8/DATA/AppData/hermes/projects/honcho/src/llm/executor.py_outcome_from_errorr)+s- {y#w-..{ 7 tool_callrdict[str, Any]cR|j|j|jd}|j |j|d<|S)N)idnameinputthought_signature)r.r/r0r1)r+results r(_tool_call_result_to_dictr3:s;lF ".&/&A"# Mr*planAttemptPlan | None telemetryLLMTelemetryContext | Noneproviderr modelstr max_tokensint duration_msfloat has_toolsbool was_streamoutcomer2BackendCompletionResult | Noner$Nonec   ddlm} m} m} d}|I|jrB | |j}n0#t $r#t d|jYnwxYw||jnd}||j nd}||j nd}| | d"id|r|j ndd|d |r|j ndd |d t|||d |d |d| r| jndd| r| jndd| r| jndd| r| jndd| r| jndd|d||kd| rt'| jndd|d|d|d|d|d| rt+| jndd|d|r|jndd|r|jnddS#t2$r t dd !YdSwxYw)#zBuild and emit an LLMCallCompletedEvent. Best-effort; swallows errors so telemetry failures never bleed into the LLM call path.r) CallPurposeLLMCallCompletedEventemitNz=Unknown LLMTelemetryContext.call_purpose=%r; emitting withoutr Fworkspace_name call_purposeparent_category transportprovider_labelr9effective_max_output_tokensprovider_input_tokensprovider_output_tokenscache_read_tokenscache_creation_tokens finish_reasonrBis_final_attempt error_classattemptretry_attempts was_fallbackr=r?tool_call_countrArun_id iterationz$Failed to emit LLMCallCompletedEventT)exc_info)src.telemetry.eventsrFrGrHrJ ValueErrorloggerdebugrVrW is_fallbackrIrK_infer_provider_label input_tokens output_tokenscache_read_input_tokenscache_creation_input_tokensrStype__name__len tool_callsrZr[ Exception)r4r6r8r9r;r=r?rArBr2r$rFrGrHrJrVrWrXs r(_emit_llm_call_completedrmEs  2LQQQQQQQQQQ,0  Y%;  *{9+ABB     S*  #'"2$,,040@,,a+/+;t''   ! !   Gv334    #*^";";! "6;DT%[[11# $ % & .~' (*\) *(K+ ,$)- .z1completion_result_to_response..s!SSS22266SSSr*) contentrdrergrffinish_reasonstool_calls_madethinking_contentthinking_blocksreasoning_details) rrrdrergrfrSrkrrr)r2s r(completion_result_to_responserst !(*$*$F & >171EM,--2SSARSSS0. 2    r*chunkBackendStreamChunkrcdt|j|j|jr|jgng|jS)N)ris_donerre)rrrrSre)rs r(stream_chunk_to_response_chunkrsA $  050CK+,,)    r*Fpromptresponse_modeltype[M] json_mode temperature float | None stop_seqslist[str] | Nonereasoning_effortr verbosity'Literal['low', 'medium', 'high'] | Nonethinking_budget_tokens int | NonestreamLiteral[False]client_overrideProviderClient | Nonetoolslist[dict[str, Any]] | None tool_choicestr | dict[str, Any] | NonemessagesrvModelConfig | NoneHonchoLLMCallResponse[M]c KdSNr]r8r9rr;rrrrrrrrrrrrrvr4r6s r(honcho_llm_call_innerrs * #sr*HonchoLLMCallResponse[str]c KdSrr]rs r(rrs *"%r*.type[BaseModel] | None Literal[True]'AsyncIterator[HonchoLLMCallStreamChunk]c KdSrr]rs r(rrs */2cr*DHonchoLLMCallResponse[Any] | AsyncIterator[HonchoLLMCallStreamChunk]c" K| ptj}|td|d|dg}t|}t |||| |}|| d}| rt j t||| |||j| d{Vn^#t$rQ}tt jz dzt d t|d| d}~wwxYwd fd }|St j}d}d} t||| |||j| d{V}t|tt j|z dzt dt||| S#t$r}|}d}~wwxYw#tt j|z dzt dt||| wxYw)aOne backend call. No retry, no fallback, no tool loop. The outer src/llm/api.py `honcho_llm_call` handles retry + fallback + tool orchestration on top of this. Emits one LLMCallCompletedEvent per call. On the stream path, setup runs inside the awaited coroutine (so it sits inside any outer retry wrapper) and emits its own event on failure; the wrapping generator emits a second event from its finally block after drain completes or raises. `was_stream` is True for streamed calls. Token counts are zero on the stream path because provider token totals aren't surfaced post-stream at this layer; aggregate envelopes (DialecticCompletedEvent etc.) carry the accurate totals. NzMissing client for user)roler)rvr8r9rrrr)rr)rr;rrresponse_format cache_policy extra_paramsT r4r6r8r9r;r=r?rArBr2r$rrcKd} 23d{V}t|WV6n#t$r}|}d}~wwxYw t tjz dzt dt |d| dS#t tjz dzt dt |d| wxYw)NrTr)r BaseExceptionrmtime perf_counterr@r)) stream_errorrexcr;r9r4r8 stream_iter stream_startr6rs r( _wrap_streamz+honcho_llm_call_inner.._wrap_streamjsT15L #.@@@@@@@%8???????$/;    "  $/ )'%)!%!2!4!4|!Ct K"5kk#/ ==&      ('%)!%!2!4!4|!Ct K"5kk#/ ==&     s)%#%B 727BA CF)rr)rgetr_rrrrrrrrmr@r)rr)r8r9rr;rrrrrrrrrrrrrvr4r6clientbackendeffective_config call_extrasrrstartbackend_resultr$rrs`` ` ` `` @@r(rrsCF 5 H 5 5F ~9x99:::#778"8V44G0'5)1: "R"RK ?(**   . !%' .-:( ! ! !      KK    $#!%!.00<?4Gu+++C00                    .|~~    E59N"&E 1  !#*)6$       -^<< !!*,,u4<5kk'..!   !!*,,u4<5kk'..! s>>#B"" C=,A C88C=/1F,, F>6F99F>>GA H)rrr)rrrr )r+rrr,)r4r5r6r7r8r r9r:r;r<r=r>r?r@rAr@rBr r2rCr$rrrD)rnr r9r:r4r5rro)r2rxrry)rrrr)FNNNNNFNNNNNNN)(r8r r9r:rr:r;r<rrrr@rrrrrrrrrrrrrrrrrrrrrvrr4r5r6r7rr)NFNNNNNFNNNNNNN)(r8r r9r:rr:r;r<rrDrr@rrrrrrrrrrrrrrrrrrrrrvrr4r5r6r7rr)NFNNNNN.NNNNNNN)(r8r r9r:rr:r;r<rrrr@rrrrrrrrrrrrrrrrrrrrrvrr4r5r6r7rr)(r8r r9r:rr:r;r<rrrr@rrrrrrrrrrrr@rrrrrrrrrvrr4r5r6r7rr)3__doc__ __future__rr&loggingrcollections.abcrtypingrrrrpydanticr src.configr r rr rxrrrregistryrrrequest_builderrrruntimerrtypesrrrrr getLoggerrir`rr)r3rmrcrrr__all__r]r*r(rsg  #""""" ))))))22222222222222222222@@@@@@666666######33333333????????;;;;;;;;  8 $ $ GCy!!!    BLBLBLBLJ4"  $"&,09=)-"-1)-/3,0*.#,0'#### #.   $"&,09=)-"-1)-/3,0*.#,0'%%%% %. .2 $"&,09=)--1)-/3,0*.#,0'2222 28.2 $"&,09=)--1)-/3,0*.#,0'[ [ [ [ [ |   r*