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

Fixed dispatch invocation

Browse source
This commit is contained in:
Cyber MacGeddon 2025-06-20 16:55:01 +01:00
parent 5ba7199895
commit b37e31ab5c
16 changed files with 17 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-flow/trustgraph/gateway/dispatch/agent.py
View file

@ -1,6 +1,6 @@
from ... schema import AgentRequest, AgentResponse from ... schema import AgentRequest, AgentResponse
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/config.py
View file

@ -2,7 +2,7 @@
from ... schema import ConfigRequest, ConfigResponse, ConfigKey, ConfigValue from ... schema import ConfigRequest, ConfigResponse, ConfigKey, ConfigValue
from ... schema import config_request_queue from ... schema import config_request_queue
from ... schema import config_response_queue from ... schema import config_response_queue
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/document_embeddings_import.py
View file

@ -6,7 +6,7 @@ from aiohttp import WSMsgType
from ... schema import Metadata from ... schema import Metadata
from ... schema import DocumentEmbeddings, ChunkEmbeddings from ... schema import DocumentEmbeddings, ChunkEmbeddings
from ... base import Publisher from ... base import Publisher
from .... base.messaging.translators.document_loading import DocumentEmbeddingsTranslator from ... messaging.translators.document_loading import DocumentEmbeddingsTranslator
class DocumentEmbeddingsImport: class DocumentEmbeddingsImport:

2
trustgraph-flow/trustgraph/gateway/dispatch/document_load.py
View file

@ -2,7 +2,7 @@
import base64 import base64
from ... schema import Document, Metadata from ... schema import Document, Metadata
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . sender import ServiceSender from . sender import ServiceSender

2
trustgraph-flow/trustgraph/gateway/dispatch/document_rag.py
View file

@ -1,6 +1,6 @@
from ... schema import DocumentRagQuery, DocumentRagResponse from ... schema import DocumentRagQuery, DocumentRagResponse
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/embeddings.py
View file

@ -1,6 +1,6 @@
from ... schema import EmbeddingsRequest, EmbeddingsResponse from ... schema import EmbeddingsRequest, EmbeddingsResponse
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/flow.py
View file

@ -2,7 +2,7 @@
from ... schema import FlowRequest, FlowResponse from ... schema import FlowRequest, FlowResponse
from ... schema import flow_request_queue from ... schema import flow_request_queue
from ... schema import flow_response_queue from ... schema import flow_response_queue
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/graph_embeddings_query.py
View file

@ -1,6 +1,6 @@
from ... schema import GraphEmbeddingsRequest, GraphEmbeddingsResponse from ... schema import GraphEmbeddingsRequest, GraphEmbeddingsResponse
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/graph_rag.py
View file

@ -1,6 +1,6 @@
from ... schema import GraphRagQuery, GraphRagResponse from ... schema import GraphRagQuery, GraphRagResponse
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/knowledge.py
View file

@ -5,7 +5,7 @@ from ... schema import KnowledgeRequest, KnowledgeResponse, Triples
from ... schema import GraphEmbeddings, Metadata, EntityEmbeddings from ... schema import GraphEmbeddings, Metadata, EntityEmbeddings
from ... schema import knowledge_request_queue from ... schema import knowledge_request_queue
from ... schema import knowledge_response_queue from ... schema import knowledge_response_queue
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/librarian.py
View file

@ -4,7 +4,7 @@ import base64
from ... schema import LibrarianRequest, LibrarianResponse from ... schema import LibrarianRequest, LibrarianResponse
from ... schema import librarian_request_queue from ... schema import librarian_request_queue
from ... schema import librarian_response_queue from ... schema import librarian_response_queue
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/prompt.py
View file

@ -2,7 +2,7 @@
import json import json
from ... schema import PromptRequest, PromptResponse from ... schema import PromptRequest, PromptResponse
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

4
trustgraph-flow/trustgraph/gateway/dispatch/serialize.py
View file

@ -3,10 +3,10 @@ import base64
from ... schema import Value, Triple, DocumentMetadata, ProcessingMetadata from ... schema import Value, Triple, DocumentMetadata, ProcessingMetadata
# DEPRECATED: These functions have been moved to trustgraph.base.messaging.translators # DEPRECATED: These functions have been moved to trustgraph.... messaging.translators
# Use the new messaging translation system instead for consistency and reusability. # Use the new messaging translation system instead for consistency and reusability.
# Examples: # Examples:
# from trustgraph.base.messaging.translators.primitives import ValueTranslator # from trustgraph.... messaging.translators.primitives import ValueTranslator
# value_translator = ValueTranslator() # value_translator = ValueTranslator()
# pulsar_value = value_translator.to_pulsar({"v": "example", "e": True}) # pulsar_value = value_translator.to_pulsar({"v": "example", "e": True})

2
trustgraph-flow/trustgraph/gateway/dispatch/text_completion.py
View file

@ -1,6 +1,6 @@
from ... schema import TextCompletionRequest, TextCompletionResponse from ... schema import TextCompletionRequest, TextCompletionResponse
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor

2
trustgraph-flow/trustgraph/gateway/dispatch/text_load.py
View file

@ -2,7 +2,7 @@
import base64 import base64
from ... schema import TextDocument, Metadata from ... schema import TextDocument, Metadata
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . sender import ServiceSender from . sender import ServiceSender

2
trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py
View file

@ -1,6 +1,6 @@
from ... schema import TriplesQueryRequest, TriplesQueryResponse, Triples from ... schema import TriplesQueryRequest, TriplesQueryResponse, Triples
from .... base.messaging import TranslatorRegistry from ... messaging import TranslatorRegistry
from . requestor import ServiceRequestor from . requestor import ServiceRequestor