From b37e31ab5cbf9902c4d9159ab958bcf832ddecef Mon Sep 17 00:00:00 2001
From: Cyber MacGeddon <cybermaggedon@gmail.com>
Date: Fri, 20 Jun 2025 16:55:01 +0100
Subject: [PATCH] Fixed dispatch invocation

---
 trustgraph-flow/trustgraph/gateway/dispatch/agent.py          | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/config.py         | 2 +-
 .../trustgraph/gateway/dispatch/document_embeddings_import.py | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/document_load.py  | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/document_rag.py   | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/embeddings.py     | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/flow.py           | 2 +-
 .../trustgraph/gateway/dispatch/graph_embeddings_query.py     | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/graph_rag.py      | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/knowledge.py      | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/librarian.py      | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/prompt.py         | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/serialize.py      | 4 ++--
 .../trustgraph/gateway/dispatch/text_completion.py            | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/text_load.py      | 2 +-
 trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py  | 2 +-
 16 files changed, 17 insertions(+), 17 deletions(-)

diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/agent.py b/trustgraph-flow/trustgraph/gateway/dispatch/agent.py
index c22703f5..1a5e8299 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/agent.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/agent.py
@@ -1,6 +1,6 @@
 
 from ... schema import AgentRequest, AgentResponse
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/config.py b/trustgraph-flow/trustgraph/gateway/dispatch/config.py
index c44e56f9..c4fac5fa 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/config.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/config.py
@@ -2,7 +2,7 @@
 from ... schema import ConfigRequest, ConfigResponse, ConfigKey, ConfigValue
 from ... schema import config_request_queue
 from ... schema import config_response_queue
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/document_embeddings_import.py b/trustgraph-flow/trustgraph/gateway/dispatch/document_embeddings_import.py
index 1c6177bf..dd4fc4e1 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/document_embeddings_import.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/document_embeddings_import.py
@@ -6,7 +6,7 @@ from aiohttp import WSMsgType
 from ... schema import Metadata
 from ... schema import DocumentEmbeddings, ChunkEmbeddings
 from ... base import Publisher
-from .... base.messaging.translators.document_loading import DocumentEmbeddingsTranslator
+from ... messaging.translators.document_loading import DocumentEmbeddingsTranslator
 
 class DocumentEmbeddingsImport:
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/document_load.py b/trustgraph-flow/trustgraph/gateway/dispatch/document_load.py
index 4991de83..101e9b41 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/document_load.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/document_load.py
@@ -2,7 +2,7 @@
 import base64
 
 from ... schema import Document, Metadata
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . sender import ServiceSender
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/document_rag.py b/trustgraph-flow/trustgraph/gateway/dispatch/document_rag.py
index 5bbe5028..a7f3634e 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/document_rag.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/document_rag.py
@@ -1,6 +1,6 @@
 
 from ... schema import DocumentRagQuery, DocumentRagResponse
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/embeddings.py b/trustgraph-flow/trustgraph/gateway/dispatch/embeddings.py
index bac1c285..47146e57 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/embeddings.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/embeddings.py
@@ -1,6 +1,6 @@
 
 from ... schema import EmbeddingsRequest, EmbeddingsResponse
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/flow.py b/trustgraph-flow/trustgraph/gateway/dispatch/flow.py
index c45f5066..30f8d45e 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/flow.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/flow.py
@@ -2,7 +2,7 @@
 from ... schema import FlowRequest, FlowResponse
 from ... schema import flow_request_queue
 from ... schema import flow_response_queue
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/graph_embeddings_query.py b/trustgraph-flow/trustgraph/gateway/dispatch/graph_embeddings_query.py
index 683b10c8..f5be06fb 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/graph_embeddings_query.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/graph_embeddings_query.py
@@ -1,6 +1,6 @@
 
 from ... schema import GraphEmbeddingsRequest, GraphEmbeddingsResponse
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/graph_rag.py b/trustgraph-flow/trustgraph/gateway/dispatch/graph_rag.py
index 2d6a2826..a15a1aee 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/graph_rag.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/graph_rag.py
@@ -1,6 +1,6 @@
 
 from ... schema import GraphRagQuery, GraphRagResponse
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/knowledge.py b/trustgraph-flow/trustgraph/gateway/dispatch/knowledge.py
index 40cfa888..950b3430 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/knowledge.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/knowledge.py
@@ -5,7 +5,7 @@ from ... schema import KnowledgeRequest, KnowledgeResponse, Triples
 from ... schema import GraphEmbeddings, Metadata, EntityEmbeddings
 from ... schema import knowledge_request_queue
 from ... schema import knowledge_response_queue
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py b/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py
index 74d72bac..2155aa5d 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/librarian.py
@@ -4,7 +4,7 @@ import base64
 from ... schema import LibrarianRequest, LibrarianResponse
 from ... schema import librarian_request_queue
 from ... schema import librarian_response_queue
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/prompt.py b/trustgraph-flow/trustgraph/gateway/dispatch/prompt.py
index ab73dad5..5c316cf6 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/prompt.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/prompt.py
@@ -2,7 +2,7 @@
 import json
 
 from ... schema import PromptRequest, PromptResponse
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/serialize.py b/trustgraph-flow/trustgraph/gateway/dispatch/serialize.py
index 1ee0f772..653ecfd9 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/serialize.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/serialize.py
@@ -3,10 +3,10 @@ import base64
 
 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.
 # Examples:
-#   from trustgraph.base.messaging.translators.primitives import ValueTranslator
+#   from trustgraph.... messaging.translators.primitives import ValueTranslator
 #   value_translator = ValueTranslator()
 #   pulsar_value = value_translator.to_pulsar({"v": "example", "e": True})
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/text_completion.py b/trustgraph-flow/trustgraph/gateway/dispatch/text_completion.py
index 8edfb79b..d29d1918 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/text_completion.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/text_completion.py
@@ -1,6 +1,6 @@
 
 from ... schema import TextCompletionRequest, TextCompletionResponse
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/text_load.py b/trustgraph-flow/trustgraph/gateway/dispatch/text_load.py
index 018e1324..8f30c8de 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/text_load.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/text_load.py
@@ -2,7 +2,7 @@
 import base64
 
 from ... schema import TextDocument, Metadata
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . sender import ServiceSender
 
diff --git a/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py b/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py
index 796258a7..d2def9c1 100644
--- a/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py
+++ b/trustgraph-flow/trustgraph/gateway/dispatch/triples_query.py
@@ -1,6 +1,6 @@
 
 from ... schema import TriplesQueryRequest, TriplesQueryResponse, Triples
-from .... base.messaging import TranslatorRegistry
+from ... messaging import TranslatorRegistry
 
 from . requestor import ServiceRequestor