apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-24 20:51:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Structure query processor to be runnable

Browse source
This commit is contained in:
Cyber MacGeddon 2025-09-03 21:29:42 +01:00
parent 818dcb31f4
commit c9c8d50871
4 changed files with 9 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-flow/pyproject.toml
View file

@ -88,12 +88,12 @@ librarian = "trustgraph.librarian:run"
mcp-tool = "trustgraph.agent.mcp_tool:run" mcp-tool = "trustgraph.agent.mcp_tool:run"
metering = "trustgraph.metering:run" metering = "trustgraph.metering:run"
objects-write-cassandra = "trustgraph.storage.objects.cassandra:run" objects-write-cassandra = "trustgraph.storage.objects.cassandra:run"
objects-query-cassandra = "trustgraph.query.objects.cassandra:run"
oe-write-milvus = "trustgraph.storage.object_embeddings.milvus:run" oe-write-milvus = "trustgraph.storage.object_embeddings.milvus:run"
pdf-decoder = "trustgraph.decoding.pdf:run" pdf-decoder = "trustgraph.decoding.pdf:run"
pdf-ocr-mistral = "trustgraph.decoding.mistral_ocr:run" pdf-ocr-mistral = "trustgraph.decoding.mistral_ocr:run"
prompt-template = "trustgraph.prompt.template:run" prompt-template = "trustgraph.prompt.template:run"
rev-gateway = "trustgraph.rev_gateway:run" rev-gateway = "trustgraph.rev_gateway:run"
rows-write-cassandra = "trustgraph.storage.rows.cassandra:run"
run-processing = "trustgraph.processing:run" run-processing = "trustgraph.processing:run"
text-completion-azure = "trustgraph.model.text_completion.azure:run" text-completion-azure = "trustgraph.model.text_completion.azure:run"
text-completion-azure-openai = "trustgraph.model.text_completion.azure_openai:run" text-completion-azure-openai = "trustgraph.model.text_completion.azure_openai:run"

2
trustgraph-flow/trustgraph/query/objects/cassandra/__init__.py
View file

@ -0,0 +1,2 @@
from . service import *

1
trustgraph-flow/trustgraph/query/objects/cassandra/__main__.py
View file

@ -3,3 +3,4 @@
from . service import run from . service import run
run() run()

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

@ -243,11 +243,11 @@ class Processor(FlowProcessor):
# Create resolver function for this schema # Create resolver function for this schema
def make_resolver(schema_name, row_schema, graphql_type): def make_resolver(schema_name, row_schema, graphql_type):
async def resolver( async def resolver(
self_query, self_query: Any,
info: Info, info: Info,
collection: str, collection: str,
limit: Optional[int] = 100, limit: Optional[int] = 100,
**filters **filters: Any
) -> List[Any]: ) -> List[Any]:
# Get the processor instance from context # Get the processor instance from context
processor = info.context["processor"] processor = info.context["processor"]
@ -508,3 +508,4 @@ class Processor(FlowProcessor):
def run(): def run():
"""Entry point for objects-query-graphql-cassandra command""" """Entry point for objects-query-graphql-cassandra command"""
Processor.launch(default_ident, __doc__) Processor.launch(default_ident, __doc__)