delete only existing ids in event cleanup

This commit is contained in:
Josh Hawkins 2024-09-22 11:13:36 -05:00
parent e98b402cdf
commit cbc98c5b46

View File

@ -230,7 +230,12 @@ class EventCleanup(threading.Thread):
Event.delete().where(Event.id << chunk).execute()
if self.config.semantic_search.enabled:
self.embeddings.thumbnail.delete(ids=chunk)
self.embeddings.description.delete(ids=chunk)
for collection in [
self.embeddings.thumbnail,
self.embeddings.description,
]:
existing_ids = collection.get(ids=chunk, include=[])["ids"]
if existing_ids:
collection.delete(ids=existing_ids)
logger.info("Exiting event cleanup...")