diff --git a/trustgraph-flow/trustgraph/direct/cassandra_kg.py b/trustgraph-flow/trustgraph/direct/cassandra_kg.py
index a4cf12b4..6c5d9c34 100644
--- a/trustgraph-flow/trustgraph/direct/cassandra_kg.py
+++ b/trustgraph-flow/trustgraph/direct/cassandra_kg.py
@@ -157,7 +157,7 @@ class KnowledgeGraph:
 
         # Query statements for optimized access
         self.get_all_stmt = self.session.prepare(
-            f"SELECT s, p, o FROM {self.subject_table} WHERE collection = ? LIMIT ?"
+            f"SELECT s, p, o FROM {self.subject_table} WHERE collection = ? LIMIT ? ALLOW FILTERING"
         )
 
         self.get_s_stmt = self.session.prepare(