Add 1s timeout to metadata subscriber in embeddings maintainer

This commit is contained in:
Josh Hawkins 2024-09-24 17:24:09 -05:00
parent 8c540d7210
commit d5e0f0de2e

View File

@ -151,7 +151,7 @@ class EmbeddingMaintainer(threading.Thread):
def _process_event_metadata(self): def _process_event_metadata(self):
# Check for regenerate description requests # Check for regenerate description requests
(topic, event_id) = self.event_metadata_subscriber.check_for_update() (topic, event_id) = self.event_metadata_subscriber.check_for_update(timeout=1)
if topic is None: if topic is None:
return return