diff --git a/docs/tech-specs/structured-data.md b/docs/tech-specs/structured-data.md
index 2feaa8e6..0c9142ab 100644
--- a/docs/tech-specs/structured-data.md
+++ b/docs/tech-specs/structured-data.md
@@ -114,7 +114,7 @@ The structured data integration requires the following technical components:
 
    Module: trustgraph-flow/trustgraph/storage/objects/cassandra
 
-5. **Structured Query Service**
+5. **Structured Query Service** ✅ **[COMPLETE]**
    - Accepts structured queries in defined formats
    - Executes queries against the structured store
    - Returns objects matching query criteria
diff --git a/trustgraph-flow/trustgraph/query/objects/cassandra/service.py b/trustgraph-flow/trustgraph/query/objects/cassandra/service.py
index 2d357ff7..8e446339 100644
--- a/trustgraph-flow/trustgraph/query/objects/cassandra/service.py
+++ b/trustgraph-flow/trustgraph/query/objects/cassandra/service.py
@@ -411,7 +411,6 @@ class Processor(FlowProcessor):
             def make_resolver(s_name, r_schema, g_type, f_type, sort_enum):
                 async def resolver(
                     info: Info,
-                    collection: str,
                     where: Optional[f_type] = None,
                     order_by: Optional[str] = None,
                     direction: Optional[sort_enum] = None,
@@ -420,6 +419,7 @@ class Processor(FlowProcessor):
                     # Get the processor instance from context
                     processor = info.context["processor"]
                     user = info.context["user"]
+                    collection = info.context["collection"]
                     
                     # Parse the idiomatic where clause
                     filters = processor.parse_idiomatic_where_clause(where)