yjdndZddlmZddlmZddlmZGddeZGddeZddgZ d S) z Dream events for Honcho telemetry. Dream tasks handle memory consolidation through specialist agents (deduction, induction). Events track both the overall dream run and individual specialist executions, with run_id correlation for analytics queries. )ClassVar)Field) BaseEventcneZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z eed <e dd Zedzed<e dd Zeed<e dd Zeed<e dd Zeeed<e dd Zeed<e dd Zeed<e ddZeed<e dd Ze ed!<e dd" Ze ed#<e dd$ Ze ed%<e dd& Ze ed'<e dd( Zeed)<e dd*Zedzed+<e dd,Ze ed-<e dd.Zedzed/<e dd0Z edzed1<e dd2Z!e dzed3<e dd4Z"e dzed5<d6efd7Z#dS)8 DreamRunEventaEmitted when a full dream orchestration completes. This is the top-level event for a dream run, providing aggregate metrics across all specialists. Individual specialist details are captured in DreamSpecialistEvent with the same run_id for correlation. z dream.run _event_type_schema_versiondream _category.Nanoid for run correlation descriptionrun_idWorkspace nameworkspace_nameNzSession name if specified session_nameObserver peer nameobserverObserved peer nameobservedz7Specialists executed (e.g., ['deduction', 'induction'])specialists_runz&Whether deduction specialist succeededdeduction_successz&Whether induction specialist succeededinduction_successFz&Whether surprisal sampling was enableddefaultrsurprisal_enabledrz High-surprisal conclusions foundsurprisal_conclusion_countz+Total LLM iterations across all specialiststotal_iterationsz)Total input tokens across all specialiststotal_input_tokensz*Total output tokens across all specialiststotal_output_tokenszTotal processing timetotal_duration_mszBDreamType slug (currently 'omni'; future: 'deductive'/'inductive') dream_typeualen(settings.DREAM.ENABLED_TYPES) at run start — how many dream types this deploy was producingenabled_types_countzWhat tripped the schedule: 'document_threshold' | 'manual' | 'surprisal'. Captured at schedule time and threaded through the queue payload.trigger_reasonzWhat governed when this dream actually fired: 'idle_timeout' | 'immediate' | 'min_hours_gate'. Disambiguates from trigger_reason to preserve the two-gate scheduler semantics in analytics. delay_reasonuDocument count at the moment check_and_schedule_dream made the decision. Named _at_schedule because the live count changes between schedule and fire (idle delay) — this is the snapshot, not the current value.&documents_since_last_dream_at_schedulez;settings.DREAM.DOCUMENT_THRESHOLD snapshot at schedule timedocument_thresholdreturnc|jS)z)Resource ID is the run_id for uniqueness.)rselfs B/DATA/AppData/hermes/projects/honcho/src/telemetry/events/dream.pyget_resource_idzDreamRunEvent.get_resource_idms {)$__name__ __module__ __qualname____doc__rrstr__annotations__r intr rrrrrrrlistrboolrrrrr r!r"floatr#r$r%r&r'r(r.r/r-rrs"-K#,,,%&OXc]&&&&Ix}&&&%)EFFFFCFFF %1ABBBNCBBB %uT7RSSSL#*SSSE#+?@@@Hc@@@E#+?@@@Hc@@@"' R"""OT#Y$e At$e At $e#Kt',eA''' "E Fc$e D %u E    %uS6MNNNuNNN#UXJd  %uw   "' P"""NC$J %u I   L#*:? L:::*C$J&+UQ&&&d  r/rceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z eed <e dd Z eed <e dd Zeed<e dd Zeed<e dd Zeed<e dd Ze ed<e dd Ze ed<e dd Ze ed<e dd Ze ed<e dd Zeed<e dd Zeed<e d d!"Ze ed#<e d d$"Ze ed%<e ed&'Zeee fed(<e ed)'Zeee fed*<e d+d,"Zeed-<e d d."Ze ed/<e d0d1"Z ed0zed2<d3efd4Z!d0S)5DreamSpecialistEventzEmitted when an individual dream specialist completes. Each specialist (deduction, induction) emits its own event with the same run_id as the parent DreamRunEvent for correlation. zdream.specialistrr r r r .r rrz+Specialist type: 'deduction' or 'induction'specialist_typerrrrrrzNumber of LLM iterations iterationszTotal tool calls madetool_calls_countzInput tokens used input_tokenszOutput tokens generated output_tokenszProcessing time duration_msz Whether the specialist succeededsuccessrziActual observations created across all create_observations calls (from ToolResult.metadata.created_count)rcreated_observation_countziActual observations deleted across all delete_observations calls (from ToolResult.metadata.deleted_count)deleted_observation_countuCounts of created observations per level (explicit / deductive / inductive / contradiction), aggregated across all create_observations tool calls in this specialist run. Levels with zero count may be omitted; queries should treat missing keys as 0. Dict-of-counts rather than list[str] because dream specialists can produce 10-20+ observations per run — a flat list becomes noisy at that scale.)default_factoryrcreated_counts_by_levelzvCounts of deleted observations per level, aggregated across all delete_observations tool calls in this specialist run.deleted_counts_by_levelFz;True when at least one update_peer_card tool call succeededpeer_card_updatedzPNumber of search_memory / search_messages / search_messages_temporal invocationssearch_tool_calls_countNz9Exception class name when success=False; None on success. error_classr)c$|jd|jS)z?Resource ID includes run_id and specialist type for uniqueness.:)rr=r+s r-r.z$DreamSpecialistEvent.get_resource_ids+66 4666r/)"r0r1r2r3rrr4r5r r6r rrr=rrrr>r?r@rArBr9rCr8rDrEdictrGrHrIrJrKr.r:r/r-r<r<rsY "4K#333%&OXc]&&&&Ix}&&&%)EFFFFCFFF!5 FOS  %1ABBBNCBBBE#+?@@@Hc@@@E#+?@@@Hc@@@eC-GHHHJHHH!E#3JKKKcKKKc/BCCCL#CCCs0IJJJM3JJJs0ABBBKBBBE#+MNNNGTNNN&+U&&&s&+U&&&s/4e 0 / / /T#s(^   /4e E///T#s(^$eQt$)5f$$$S$eOKt 7777777r/r<N) r3typingrpydanticrsrc.telemetry.events.baserrr<__all__r:r/r-rSs//////_____I___DR7R7R7R7R79R7R7R7l r/