apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-24 12:41:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Address creation/deletion sync problems

Browse source
This commit is contained in:
Cyber MacGeddon 2025-09-30 21:40:10 +01:00
parent b7bf7388aa
commit 292d5cb2a1
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
trustgraph-flow/trustgraph/librarian/collection_manager.py
View file

@ -88,7 +88,7 @@ class CollectionManager:
logger.info(f"Broadcasting create-collection for {creation_key}") logger.info(f"Broadcasting create-collection for {creation_key}")
self.pending_deletions[creation_key] = { self.pending_deletions[creation_key] = {
"responses_pending": 3, # vector, object, triples "responses_pending": 4, # doc-embeddings, graph-embeddings, object, triples
"responses_received": [], "responses_received": [],
"all_successful": True, "all_successful": True,
"error_messages": [], "error_messages": [],
@ -213,7 +213,7 @@ class CollectionManager:
logger.info(f"Broadcasting create-collection for {creation_key}") logger.info(f"Broadcasting create-collection for {creation_key}")
self.pending_deletions[creation_key] = { self.pending_deletions[creation_key] = {
"responses_pending": 3, # vector, object, triples "responses_pending": 4, # doc-embeddings, graph-embeddings, object, triples
"responses_received": [], "responses_received": [],
"all_successful": True, "all_successful": True,
"error_messages": [], "error_messages": [],
@ -328,7 +328,7 @@ class CollectionManager:
# Track this deletion request # Track this deletion request
self.pending_deletions[deletion_key] = { self.pending_deletions[deletion_key] = {
"responses_pending": 3, # vector, object, triples "responses_pending": 4, # doc-embeddings, graph-embeddings, object, triples
"responses_received": [], "responses_received": [],
"all_successful": True, "all_successful": True,
"error_messages": [], "error_messages": [],
@ -418,9 +418,9 @@ class CollectionManager:
if response.error and response.error.message: if response.error and response.error.message:
info["all_successful"] = False info["all_successful"] = False
info["error_messages"].append(response.error.message) 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: 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 all responses received, signal completion
if info["responses_pending"] == 0: if info["responses_pending"] == 0: