apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-04-29 02:23:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

Collection deletion batch error fixed (#559)

Browse source 
Collection deletion caused a batch error, this reduces batch size on deletion
This commit is contained in:
cybermaggedon 2025-11-13 16:29:40 +00:00 • committed by GitHub
parent db4e842df3
commit 2baf21c5e1
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
trustgraph-flow/trustgraph/direct/cassandra_kg.py
View file

@ -334,13 +334,14 @@ class KnowledgeGraph:
count += 1
# Execute batch every 100 triples to avoid oversized batches
if count % 100 == 0:
# Execute batch every 25 triples to avoid oversized batches
# (Each triple adds ~4 statements, so 25 triples = ~100 statements)
if count % 25 == 0:
self.session.execute(batch)
batch = BatchStatement()
# Execute remaining deletions
if count % 100 != 0:
if count % 25 != 0:
self.session.execute(batch)
# Step 3: Delete collection metadata