yj ndZddlmZddlmZddlmZGddeZGddeZddgZ d S) a Reconciliation events for Honcho telemetry. Reconciliation tasks handle maintenance operations: - Sync vectors: Synchronize documents and message embeddings to external vector stores - Cleanup stale items: Clean up soft-deleted records and expired queue items )ClassVar)Field) BaseEventcFeZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z e ed <e dd Z e ed <e dd Ze ed<e dd Ze ed<e dd Ze ed<e ddZeed<defdZdS)SyncVectorsCompletedEventaEmitted when a vector sync cycle completes. Vector sync tasks synchronize documents and message embeddings to external vector stores. These run periodically and operate across all workspaces. Note: This event has no workspace context as it operates globally. z%reconciliation.sync_vectors.completed _event_type_schema_versionreconciliation _categoryrz-Documents successfully synced to vector storedefault descriptiondocuments_syncedzDocuments that failed to syncdocuments_failedz-Soft-deleted documents cleaned up during syncdocuments_cleanedz&Message embeddings successfully syncedmessage_embeddings_syncedz&Message embeddings that failed to syncmessage_embeddings_failed.Total processing timertotal_duration_msreturncdS)/Resource ID is fixed for this global operation. sync_vectorsselfs K/DATA/AppData/hermes/projects/honcho/src/telemetry/events/reconciliation.pyget_resource_idz)SyncVectorsCompletedEvent.get_resource_id3s~N)__name__ __module__ __qualname____doc__rrstr__annotations__r intr rrrrrrrfloatr rr!rrrs"IK#HHH%&OXc]&&&/Ix}///"ENc"E>c#UNs &+UG&&&s&+UG&&&s %uS6MNNNuNNNr!rceZdZUdZdZeeed<dZee ed<dZ eeed<e dd Z e ed <e dd Z e ed <e ddZeed<defdZdS)CleanupStaleItemsCompletedEventaEmitted when a stale items cleanup cycle completes. Cleanup tasks remove soft-deleted documents and expired queue items. These run periodically and operate across all workspaces. Note: This event has no workspace context as it operates globally. z,reconciliation.cleanup_stale_items.completedrr r r r rz!Soft-deleted documents cleaned upr rzExpired queue items cleaned upqueue_items_cleaned.rrrrcdS)rcleanup_stale_itemsrrs rr z/CleanupStaleItemsCompletedEvent.get_resource_idPs$$r!N)r"r#r$r%rrr&r'r r(r rrr,rr)r rr!rr+r+8s"PK#OOO%&OXc]&&&/Ix}///#UBs %u?    %uS6MNNNuNNN%%%%%%%r!r+N) r%typingrpydanticrsrc.telemetry.events.baserrr+__all__rr!rr3s//////%%%%% %%%P%%%%%i%%%< % r!