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

Handle messages properly

Browse source
This commit is contained in:
Cyber MacGeddon 2025-09-29 23:31:26 +01:00
parent 34a65ee408
commit 1180f49fa9
1 changed files with 2 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

10
trustgraph-flow/trustgraph/storage/triples/cassandra/write.py
View file

@ -176,15 +176,9 @@ class Processor(TriplesStoreService):
self.table = request.user
# Delete all triples for this collection from the unified table
# In the unified table schema, collection is the partition key
delete_cql = """
DELETE FROM triples
WHERE collection = ?
"""
# Delete all triples for this collection using the built-in method
try:
self.tg.session.execute(delete_cql, (request.collection,))
self.tg.delete_collection(request.collection)
logger.info(f"Deleted all triples for collection {request.collection} from keyspace {request.user}")
except Exception as e:
logger.error(f"Failed to delete collection data: {e}")