This commit is contained in:
Josh Hawkins 2024-09-23 17:09:11 -05:00
parent 164f1b8545
commit df96c04c38
2 changed files with 0 additions and 3 deletions

View File

@ -37,11 +37,9 @@ class EventMetadataSubscriber(Subscriber):
def check_for_update( def check_for_update(
self, timeout: float = None self, timeout: float = None
) -> Optional[tuple[EventMetadataTypeEnum, any]]: ) -> Optional[tuple[EventMetadataTypeEnum, any]]:
print(f"checking for update, timeout {timeout}")
return super().check_for_update(timeout) return super().check_for_update(timeout)
def _return_object(self, topic: str, payload: any) -> any: def _return_object(self, topic: str, payload: any) -> any:
print(topic, payload)
if payload is None: if payload is None:
return (None, None) return (None, None)
return (EventMetadataTypeEnum[topic[len(self.topic_base) :]], payload) return (EventMetadataTypeEnum[topic[len(self.topic_base) :]], payload)

View File

@ -56,7 +56,6 @@ class EmbeddingMaintainer(threading.Thread):
def run(self) -> None: def run(self) -> None:
"""Maintain a Chroma vector database for semantic search.""" """Maintain a Chroma vector database for semantic search."""
logger.info("in maintainer run()")
while not self.stop_event.is_set(): while not self.stop_event.is_set():
self._process_updates() self._process_updates()
self._process_finalized() self._process_finalized()