yj5dZddlmZddlmZddlmZGddeZGddeZGd d eZ Gd d eZ Gd deZ GddeZ gdZ dS)af Agent events for Honcho telemetry. Agent events track per-iteration metrics and state-changing tool executions within agentic loops (dream specialists, dialectic agents). These events correlate with parent events via run_id for detailed analytics. Events in this module: - AgentIterationEvent: Per-LLM-call metrics within an agent run - AgentToolConclusionsCreatedEvent: Conclusions created by agent tool - AgentToolConclusionsDeletedEvent: Conclusions deleted by agent tool - AgentToolPeerCardUpdatedEvent: Peer card updated by agent tool - AgentToolSummaryCreatedEvent: Summary created by agent tool (future) )ClassVar)Field) BaseEventczeZdZUdZdZeeed<dZee ed<dZ eeed<dZ eeed <e d d Z eed <e d d Zeed<e d d Zeed<e d d Zeed<e ddZedzed<e ddZedzed<e ddZedzed<e d d Ze ed<e edZeeed <e d d! Ze ed"<e d d# Ze ed$<e d%d&Ze ed'<e d%d(Ze ed)<d*efd+ZdS),AgentIterationEventzEmitted after each LLM call within an agentic loop. Tracks per-iteration token usage and tool calls for detailed cost analysis. Correlates with parent events (dream.run, dream.specialist, dialectic.completed) via run_id. zagent.iteration _event_type_schema_versionagent _category high_volume _volume_class.Nanoid for run correlation descriptionrun_id'Parent category: 'dream' or 'dialectic'parent_category4Agent type: 'deduction', 'induction', or 'dialectic' agent_typeWorkspace nameworkspace_nameNObserver peer namedefaultrobserverObserved peer nameobservedzPeer name being queried peer_nameIteration number (1-indexed) iterationz>Tool names called in this iteration (can be empty or multiple)default_factoryr tool_callszInput tokens for this iteration input_tokensz Output tokens for this iteration output_tokensrzTokens read from prompt cachecache_read_tokenszTokens written to prompt cachecache_creation_tokensreturnc$|jd|jS)9Resource ID includes run_id and iteration for uniqueness.:rr!selfs B/DATA/AppData/hermes/projects/honcho/src/telemetry/events/agent.pyget_resource_idz#AgentIterationEvent.get_resource_idJs+00000)__name__ __module__ __qualname____doc__rrstr__annotations__r intr rrrrrrrrrr!listr$r%r&r'r(r1r2r0rrs"3K#222%&OXc]&&&&Ix}&&�M8C=000%)EFFFFCFFF!5 BOSe OJ %1ABBBNCBBB!5;OPPPHcDjPPP 5;OPPPHcDjPPP"E$s"'?"""31111111r2rceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z e ed <e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Ze ed<e edZeeed<defdZdS) AgentToolConclusionsCreatedEventz~Emitted when the create_conclusions tool is executed. Tracks conclusion creation with level breakdown for analytics. zagent.tool.conclusions.createdrr r r r .rrr#Iteration number when this occurredr!rrrrrrrrrrzNumber of conclusions createdconclusion_countzGLevel of each conclusion (e.g., ['explicit', 'deductive', 'deductive'])r"levelsr)c&|jd|jdS)r+r,z:conclusions_createdr-r.s r0r1z0AgentToolConclusionsCreatedEvent.get_resource_idq+DDDDDDr2Nr3r4r5r6rrr7r8r r9r rrr!rrrrrr?r:r@r1r;r2r0r=r=Os "BK#AAA%&OXc]&&&&Ix}&&&%)EFFFFCFFFU3,QRRRIsRRR!5 BOSe OJ %1ABBBNCBBBE#+?@@@Hc@@@E#+?@@@Hc@@@"E#3RSSScSSS]FDI EEEEEEEr2r=ceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z e ed <e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Ze ed<e edZeeed<defdZdS) AgentToolConclusionsDeletedEventz~Emitted when the delete_conclusions tool is executed. Tracks conclusion deletion for memory consolidation analytics. zagent.tool.conclusions.deletedrr r r .rrrr>r!#Parent category (typically 'dream')rz0Agent type (typically 'deduction' for deletions)rrrrrrrzNumber of conclusions deletedr?zOLevel of each deleted conclusion (e.g., ['explicit', 'deductive', 'deductive'])r"r@r)c&|jd|jdS)r+r,z:conclusions_deletedr-r.s r0r1z0AgentToolConclusionsDeletedEvent.get_resource_idrBr2NrCr;r2r0rErEvs "BK#AAA%&OXc]&&&&Ix}&&&%)EFFFFCFFFU3,QRRRIsRRR!52WXXXOSXXXe KJ %1ABBBNCBBBE#+?@@@Hc@@@E#+?@@@Hc@@@"E#3RSSScSSSeFDI EEEEEEEr2rEceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z e ed <e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Ze ed<defdZdS)AgentToolPeerCardUpdatedEventzrEmitted when the update_peer_card tool is executed. Tracks peer card updates during dream consolidation. zagent.tool.peer_card.updatedrr r r r .rrrr>r!rGrz&Agent type: 'deduction' or 'induction'rrrrrrrz Number of facts in the peer card facts_countr)c&|jd|jdS)r+r,z:peer_card_updatedr-r.s r0r1z-AgentToolPeerCardUpdatedEvent.get_resource_ids+BBBBBBr2N)r3r4r5r6rrr7r8r r9r rrr!rrrrrrKr1r;r2r0rJrJs "@K#???%&OXc]&&&&Ix}&&&%)EFFFFCFFFU3,QRRRIsRRR!52WXXXOSXXXeC-UVVVJVVV%1ABBBNCBBBE#+?@@@Hc@@@E#+?@@@Hc@@@uS.PQQQKQQQCCCCCCCr2rJceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z e ed <e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Ze ed<e dd Ze ed<e dd Zeed<e dd Ze ed<e dd Ze ed!<e d"d#$Ze ed%<e d"d&$Ze ed'<e d"d($Ze ed)<d*efd+Zd,S)-AgentToolSummaryCreatedEventzEmitted when a summary is created. Tracks summary creation with full context about what was summarized and the resources consumed. zagent.tool.summary.createdrr r r r .rrrr>r!zParent categoryrz Agent typerrrz Session name session_namez#Message ID the summary covers up to message_idz&Number of messages included in summary message_countz.Sequence number of the base message in sessionmessage_seq_in_sessionzSummary type: 'short' or 'long' summary_typeuProvider-side input tokens for the summary LLM call (equivalent to HonchoLLMCallResponse.input_tokens). keeps this field unchanged — adding a duplicate `provider_input_tokens` would only churn analytics queries.r%z#Output tokens (summary token count)r&rzrToken count of the previous summary text fed back in as context. 0 when this is the first summary for the session.rprevious_summary_tokenszkSum of `Message.token_count` across the messages being summarized (excludes scaffold and previous_summary).message_tokenszpEstimated tokens for the static scaffold portion of the prompt (from estimate_short/long_summary_prompt_tokens).prompt_scaffold_tokensr)c&|jd|jdS)r+r,z:summary_createdr-r.s r0r1z,AgentToolSummaryCreatedEvent.get_resource_ids+@@@@@@r2N)r3r4r5r6rrr7r8r r9r rrr!rrrrOrPrQrRrSr%r&rTrUrVr1r;r2r0rNrNs ">K#===%&OXc]&&&&Ix}&&&%)EFFFFCFFFU3,QRRRIsRRR!52CDDDOSDDDeC\:::J:::%1ABBBNCBBBc~>>>L#>>>eC-RSSSJSSS AM3#(% I###C c/PQQQL#QQQ  JL#s0UVVVM3VVV$)5 @$$$S % CNC#(% @###CAAAAAAAr2rNcXeZdZUdZdZeeed<dZee ed<dZ eeed<dZ eeed <e d d Z eed <e d d Ze ed<e d d Ze ed<e ddZedzed<e d d Zeed<e d d Zeed<e d d Zeed<e d d Zeed<e d d Zeed<e d d!Zeed"<e d d# Ze ed$<e dd%Ze dzed&<e d'd(Ze ed)<e d d*Zeed+<e dd,Ze dzed-<e dd.Ze dzed/<e dd0Ze dzed1<e dd2Z edzed3<e d'd4Z!e ed5<d6efd7Z"dS)8AgentToolCallCompletedEventugeneric tool-call event: fires once per tool invocation. Complements the four state-changer events (conclusions_created/deleted, peer_card_updated, summary_created), which carry semantic information about specific tools, with a lightweight per-call telemetry record that covers every tool — including read-only tools (`search_memory`, `get_recent_history`, etc.) that have no dedicated event today. Resource id includes `tool_call_seq` so the model can legitimately call the same tool twice in one iteration (it does) without colliding event ids — without seq, both calls would deterministically hash to the same id and dedupe would drop one. zagent.tool.call.completedrr r r r r.zRun id for correlationrrr r!zp0-indexed position within the iteration's tool batch. Disambiguates two calls to the same tool in one iteration. tool_call_seqNzvProvider-supplied tool call id (e.g. Anthropic's toolu_*) when available; lets analytics cross-reference provider logsrprovider_tool_call_idrrrrrrzTool name as invoked tool_namez"Wall-clock duration of the handler duration_msFzTrue if the handler raisedis_errorz/Length of the result string returned to the LLM result_charszyOriginal result size when the handler truncated; None when no truncation occurred. Pair with was_truncated for the delta.result_chars_before_truncationrz>tiktoken-based size proxy for the result string; estimate onlyresult_tokens_estimatez=True when the handler clamped the result to fit a size budget was_truncatedz*tiktoken estimate of the search query text query_tokensz$Caller-supplied top_k for the searchtop_kz(Number of results returned by the search results_countzCTrue when the search ran a vector lookup (vs. metadata-only filter)used_embeddingzBNumber of embedding API calls the handler made for this invocationembedding_query_countr)c4|jd|jd|jS)z}{run_id}:{iteration}:{tool_call_seq} so duplicate tool calls within one iteration produce distinct deterministic ids.r,)rr!r[r.s r0r1z+AgentToolCallCompletedEvent.get_resource_id\s'+EEEE1CEEEr2)#r3r4r5r6rrr7r8r r9r rrrr!r[r\rrrr]r^floatr_boolr`rarbrcrdrerfrgrhr1r;r2r0rYrY s  "=K#<<<%&OXc]&&&&Ix}&&�M8C=000%)ABBBFCBBBU3,JKKKIsKKK GM3).M)))3: !5 BOSe OJ %1ABBBNCBBBU3,BCCCIsCCCs0TUUUKUUUU56RSSSHdSSS JL#27P222"C$J#(%T###C %SM4 %u"N   L#*"HE3:!&"L!!!M3:#(%Y###ND4K"'X"""3 FFFFFFFr2rY)rrYr=rErJrNN)r6typingrpydanticrsrc.telemetry.events.baserrr=rErJrNrY__all__r;r2r0rps  //////5151515151)515151p$E$E$E$E$Ey$E$E$EN"E"E"E"E"Ey"E"E"EJCCCCCICCC>LALALALALA9LALALA^VFVFVFVFVF)VFVFVFr   r2