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

Query is working

Browse source
This commit is contained in:
Cyber MacGeddon 2025-09-03 21:53:02 +01:00
parent f21fcd2269
commit 5a6a5234b4
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
trustgraph-flow/trustgraph/query/objects/cassandra/service.py
View file

@ -284,8 +284,11 @@ class Processor(FlowProcessor):
Query = type('Query', (), query_dict)
Query = strawberry.type(Query)
# Create the schema
self.graphql_schema = strawberry.Schema(query=Query)
# Create the schema with auto_camel_case disabled to keep snake_case field names
self.graphql_schema = strawberry.Schema(
query=Query,
config=strawberry.schema.config.StrawberryConfig(auto_camel_case=False)
)
logger.info(f"Generated GraphQL schema with {len(self.schemas)} types")
async def query_cassandra(
@ -331,10 +334,13 @@ class Processor(FlowProcessor):
if where_clauses:
query += " WHERE " + " AND ".join(where_clauses)
# Add limit
# Add limit first (must come before ALLOW FILTERING)
if limit:
query += f" LIMIT {limit}"
# Add ALLOW FILTERING for now (should optimize with proper indexes later)
query += " ALLOW FILTERING"
# Execute query
try:
result = self.session.execute(query, params)