yj[PdZddlmZddlmZddlmZGddeZdgZdS)z Representation events for Honcho telemetry. Representation tasks extract conclusions from messages to build peer representations. These events track the processing of message batches and the conclusions extracted from them. )ClassVar)Field) BaseEventceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z eed <e dd Zeed<e dd Ze ed<e dd Zeed<e dd Zeed<e dd Ze ed<e dd Ze ed<e dd Zeed<e dd Zeed<e dd Zeed<e dd Ze ed!<e dd" Ze ed#<e dd$ Ze ed%<e d&d'(Ze ed)<e d&d*(Ze ed+<e d&d,(Ze ed-<e d&d.(Ze ed/<e d&d0(Ze ed1<e d&d2(Z e ed3<e d&d4(Z!e ed5<e d&d6(Z"e ed7<e d8d9(Z#e$ed:<e d8d;(Z%e$ed<<e d8d=(Z&e$ed><e d&d?(Z'e ed@<dAefdBZ(dCS)DRepresentationCompletedEventaEmitted when a representation task completes processing a message batch. Representation tasks extract conclusions from messages to build peer representations. This event captures the full context of what was processed and what was extracted. zrepresentation.completed _event_type_schema_versionrepresentation _category.zWorkspace name) descriptionworkspace_namez Session name session_namezObserved peer nameobservedz2Number of QueueItem records dequeued and processedqueue_items_processedzFirst message ID in batchearliest_message_idzLast message ID in batchlatest_message_idzNumber of messages processed message_countz(Number of explicit conclusions extractedexplicit_conclusion_countzTime spent preparing contextcontext_preparation_mszTime spent in LLM call llm_call_mszTotal processing timetotal_duration_msuQueued-message tokens (the ones we're actually reasoning ABOUT). This field is the downstream metering key for representation.completed — DO NOT rename or repurpose without coordinating with downstream consumers. input_tokensz@Total tokens sent to the LLM (queued + extra context + scaffold)total_input_tokenszOutput tokens generated output_tokensrzVNumber of messages in this batch that were the actual queue items being reasoned about)defaultr queued_message_countuDTotal messages in the prompt — queued + extra interleaving contextprompt_message_countz4Sum of token_count across all messages in the promptprompt_message_tokenszTprompt_message_count - queued_message_count: the extra-context messages we pulled inextra_context_message_countzEprompt_message_tokens - input_tokens: token cost of the extra contextextra_context_tokensz>Estimated tokens for the system/scaffold portion of the promptprompt_scaffold_tokensz>settings.DERIVER.REPRESENTATION_BATCH_MAX_TOKENS at fetch timebatch_max_tokensz.settings.DERIVER.MAX_INPUT_TOKENS at call timemax_input_tokensFz5settings.DERIVER.FLUSH_ENABLED snapshot at batch timewas_flush_enabledzETrue when the queue batcher clamped the batch to fit batch_max_tokenshit_batch_token_capzHTrue when the LLM call truncated input messages to fit max_input_tokens.hit_input_token_capz9Number of observers this representation was saved againstobserver_countreturnc4|jd|jd|jS)zKResource ID includes workspace, session, and latest message for uniqueness.:)rrr)selfs K/DATA/AppData/hermes/projects/honcho/src/telemetry/events/representation.pyget_resource_idz,RepresentationCompletedEvent.get_resource_ids'%TT(9TTD>>L#>>>E#+?@@@Hc@@@"' M"""3 %uS6QRRRRRR"U34NOOOsOOOs0NOOOM3OOO&+U C&&&s %*E 7%%%Es0HIIIKIII$uS6MNNNuNNN  6L#$e Vs0IJJJM3JJJ !&l!!!#!&Z!!!#"'J"""3(-uj(((!&[!!!##(%T###C "ETc"EOc$eKt!&[!!!!& V!!! %ONC UUUUUUUr/rN) r3typingrpydanticrsrc.telemetry.events.baserr__all__r9r/r-r>s//////wUwUwUwUwU9wUwUwUt * *r/