From 292d5cb2a103ac4f4c30e6bda0bfcc6f24c25d58 Mon Sep 17 00:00:00 2001 From: Cyber MacGeddon Date: Tue, 30 Sep 2025 21:40:10 +0100 Subject: [PATCH] Address creation/deletion sync problems --- .../trustgraph/librarian/collection_manager.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/trustgraph-flow/trustgraph/librarian/collection_manager.py b/trustgraph-flow/trustgraph/librarian/collection_manager.py index ea67fa3f..1530ed84 100644 --- a/trustgraph-flow/trustgraph/librarian/collection_manager.py +++ b/trustgraph-flow/trustgraph/librarian/collection_manager.py @@ -88,7 +88,7 @@ class CollectionManager: logger.info(f"Broadcasting create-collection for {creation_key}") self.pending_deletions[creation_key] = { - "responses_pending": 3, # vector, object, triples + "responses_pending": 4, # doc-embeddings, graph-embeddings, object, triples "responses_received": [], "all_successful": True, "error_messages": [], @@ -213,7 +213,7 @@ class CollectionManager: logger.info(f"Broadcasting create-collection for {creation_key}") self.pending_deletions[creation_key] = { - "responses_pending": 3, # vector, object, triples + "responses_pending": 4, # doc-embeddings, graph-embeddings, object, triples "responses_received": [], "all_successful": True, "error_messages": [], @@ -328,7 +328,7 @@ class CollectionManager: # Track this deletion request self.pending_deletions[deletion_key] = { - "responses_pending": 3, # vector, object, triples + "responses_pending": 4, # doc-embeddings, graph-embeddings, object, triples "responses_received": [], "all_successful": True, "error_messages": [], @@ -418,9 +418,9 @@ class CollectionManager: if response.error and response.error.message: info["all_successful"] = False info["error_messages"].append(response.error.message) - logger.warning(f"Storage deletion failed for {deletion_key}: {response.error.message}") + logger.warning(f"Storage operation failed for {deletion_key}: {response.error.message}") else: - logger.debug(f"Storage deletion succeeded for {deletion_key}") + logger.debug(f"Storage operation succeeded for {deletion_key}") # If all responses received, signal completion if info["responses_pending"] == 0: