diff --git a/trustgraph-flow/trustgraph/gateway/agent.py b/trustgraph-flow/trustgraph/gateway/agent.py index 40586133..e8fd0e72 100644 --- a/trustgraph-flow/trustgraph/gateway/agent.py +++ b/trustgraph-flow/trustgraph/gateway/agent.py @@ -1,7 +1,7 @@ -from ... schema import AgentRequest, AgentResponse -from ... schema import agent_request_queue -from ... schema import agent_response_queue +from .. schema import AgentRequest, AgentResponse +from .. schema import agent_request_queue +from .. schema import agent_response_queue from . endpoint import MultiResponseServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/dbpedia.py b/trustgraph-flow/trustgraph/gateway/dbpedia.py index 4fa7336b..a61292a6 100644 --- a/trustgraph-flow/trustgraph/gateway/dbpedia.py +++ b/trustgraph-flow/trustgraph/gateway/dbpedia.py @@ -1,7 +1,7 @@ -from ... schema import LookupRequest, LookupResponse -from ... schema import dbpedia_lookup_request_queue -from ... schema import dbpedia_lookup_response_queue +from .. schema import LookupRequest, LookupResponse +from .. schema import dbpedia_lookup_request_queue +from .. schema import dbpedia_lookup_response_queue from . endpoint import ServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/embeddings.py b/trustgraph-flow/trustgraph/gateway/embeddings.py index 7c4b578d..6d3a9fe6 100644 --- a/trustgraph-flow/trustgraph/gateway/embeddings.py +++ b/trustgraph-flow/trustgraph/gateway/embeddings.py @@ -1,7 +1,7 @@ -from ... schema import EmbeddingsRequest, EmbeddingsResponse -from ... schema import embeddings_request_queue -from ... schema import embeddings_response_queue +from .. schema import EmbeddingsRequest, EmbeddingsResponse +from .. schema import embeddings_request_queue +from .. schema import embeddings_response_queue from . endpoint import ServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/encyclopedia.py b/trustgraph-flow/trustgraph/gateway/encyclopedia.py index c6041cb2..32eb5cd1 100644 --- a/trustgraph-flow/trustgraph/gateway/encyclopedia.py +++ b/trustgraph-flow/trustgraph/gateway/encyclopedia.py @@ -1,7 +1,7 @@ -from ... schema import LookupRequest, LookupResponse -from ... schema import encyclopedia_lookup_request_queue -from ... schema import encyclopedia_lookup_response_queue +from .. schema import LookupRequest, LookupResponse +from .. schema import encyclopedia_lookup_request_queue +from .. schema import encyclopedia_lookup_response_queue from . endpoint import ServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/graph_embeddings_load.py b/trustgraph-flow/trustgraph/gateway/graph_embeddings_load.py index 81fb6647..18a2e6fe 100644 --- a/trustgraph-flow/trustgraph/gateway/graph_embeddings_load.py +++ b/trustgraph-flow/trustgraph/gateway/graph_embeddings_load.py @@ -4,9 +4,9 @@ from pulsar.schema import JsonSchema import uuid from aiohttp import WSMsgType -from ... schema import Metadata -from ... schema import GraphEmbeddings -from ... schema import graph_embeddings_store_queue +from .. schema import Metadata +from .. schema import GraphEmbeddings +from .. schema import graph_embeddings_store_queue from . publisher import Publisher from . socket import SocketEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/graph_embeddings_stream.py b/trustgraph-flow/trustgraph/gateway/graph_embeddings_stream.py index 3d4efd45..f0b4dd86 100644 --- a/trustgraph-flow/trustgraph/gateway/graph_embeddings_stream.py +++ b/trustgraph-flow/trustgraph/gateway/graph_embeddings_stream.py @@ -4,8 +4,8 @@ import queue from pulsar.schema import JsonSchema import uuid -from ... schema import GraphEmbeddings -from ... schema import graph_embeddings_store_queue +from .. schema import GraphEmbeddings +from .. schema import graph_embeddings_store_queue from . subscriber import Subscriber from . socket import SocketEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/graph_rag.py b/trustgraph-flow/trustgraph/gateway/graph_rag.py index d33090ca..58679004 100644 --- a/trustgraph-flow/trustgraph/gateway/graph_rag.py +++ b/trustgraph-flow/trustgraph/gateway/graph_rag.py @@ -1,7 +1,7 @@ -from ... schema import GraphRagQuery, GraphRagResponse -from ... schema import graph_rag_request_queue -from ... schema import graph_rag_response_queue +from .. schema import GraphRagQuery, GraphRagResponse +from .. schema import graph_rag_request_queue +from .. schema import graph_rag_response_queue from . endpoint import ServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/internet_search.py b/trustgraph-flow/trustgraph/gateway/internet_search.py index f55a4a3e..5a5dc948 100644 --- a/trustgraph-flow/trustgraph/gateway/internet_search.py +++ b/trustgraph-flow/trustgraph/gateway/internet_search.py @@ -1,7 +1,7 @@ -from ... schema import LookupRequest, LookupResponse -from ... schema import internet_search_request_queue -from ... schema import internet_search_response_queue +from .. schema import LookupRequest, LookupResponse +from .. schema import internet_search_request_queue +from .. schema import internet_search_response_queue from . endpoint import ServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/prompt.py b/trustgraph-flow/trustgraph/gateway/prompt.py index d19005bc..f09a0e0e 100644 --- a/trustgraph-flow/trustgraph/gateway/prompt.py +++ b/trustgraph-flow/trustgraph/gateway/prompt.py @@ -1,9 +1,9 @@ import json -from ... schema import PromptRequest, PromptResponse -from ... schema import prompt_request_queue -from ... schema import prompt_response_queue +from .. schema import PromptRequest, PromptResponse +from .. schema import prompt_request_queue +from .. schema import prompt_response_queue from . endpoint import ServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/serialize.py b/trustgraph-flow/trustgraph/gateway/serialize.py index 2b955645..35932382 100644 --- a/trustgraph-flow/trustgraph/gateway/serialize.py +++ b/trustgraph-flow/trustgraph/gateway/serialize.py @@ -1,4 +1,4 @@ -from ... schema import Value, Triple +from .. schema import Value, Triple def to_value(x): return Value(value=x["v"], is_uri=x["e"]) diff --git a/trustgraph-flow/trustgraph/gateway/service.py b/trustgraph-flow/trustgraph/gateway/service.py index faa250dc..e927ecf6 100755 --- a/trustgraph-flow/trustgraph/gateway/service.py +++ b/trustgraph-flow/trustgraph/gateway/service.py @@ -22,10 +22,10 @@ import pulsar from pulsar.schema import JsonSchema from prometheus_client import start_http_server -from ... log_level import LogLevel +from .. log_level import LogLevel -from ... schema import Metadata, Document, TextDocument -from ... schema import document_ingest_queue, text_ingest_queue +from .. schema import Metadata, Document, TextDocument +from .. schema import document_ingest_queue, text_ingest_queue from . serialize import to_subgraph from . running import Running diff --git a/trustgraph-flow/trustgraph/gateway/text_completion.py b/trustgraph-flow/trustgraph/gateway/text_completion.py index d9f69b7e..d59737f0 100644 --- a/trustgraph-flow/trustgraph/gateway/text_completion.py +++ b/trustgraph-flow/trustgraph/gateway/text_completion.py @@ -1,7 +1,7 @@ -from ... schema import TextCompletionRequest, TextCompletionResponse -from ... schema import text_completion_request_queue -from ... schema import text_completion_response_queue +from .. schema import TextCompletionRequest, TextCompletionResponse +from .. schema import text_completion_request_queue +from .. schema import text_completion_response_queue from . endpoint import ServiceEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/triples_load.py b/trustgraph-flow/trustgraph/gateway/triples_load.py index dbb3e617..2689f3ad 100644 --- a/trustgraph-flow/trustgraph/gateway/triples_load.py +++ b/trustgraph-flow/trustgraph/gateway/triples_load.py @@ -4,9 +4,9 @@ from pulsar.schema import JsonSchema import uuid from aiohttp import WSMsgType -from ... schema import Metadata -from ... schema import Triples -from ... schema import triples_store_queue +from .. schema import Metadata +from .. schema import Triples +from .. schema import triples_store_queue from . publisher import Publisher from . socket import SocketEndpoint diff --git a/trustgraph-flow/trustgraph/gateway/triples_query.py b/trustgraph-flow/trustgraph/gateway/triples_query.py index 9c5939c8..5a0cfff8 100644 --- a/trustgraph-flow/trustgraph/gateway/triples_query.py +++ b/trustgraph-flow/trustgraph/gateway/triples_query.py @@ -1,7 +1,7 @@ -from ... schema import TriplesQueryRequest, TriplesQueryResponse, Triples -from ... schema import triples_request_queue -from ... schema import triples_response_queue +from .. schema import TriplesQueryRequest, TriplesQueryResponse, Triples +from .. schema import triples_request_queue +from .. schema import triples_response_queue from . endpoint import ServiceEndpoint from . serialize import to_value, serialize_subgraph diff --git a/trustgraph-flow/trustgraph/gateway/triples_stream.py b/trustgraph-flow/trustgraph/gateway/triples_stream.py index 4638e08d..92ada132 100644 --- a/trustgraph-flow/trustgraph/gateway/triples_stream.py +++ b/trustgraph-flow/trustgraph/gateway/triples_stream.py @@ -4,8 +4,8 @@ import queue from pulsar.schema import JsonSchema import uuid -from ... schema import Triples -from ... schema import triples_store_queue +from .. schema import Triples +from .. schema import triples_store_queue from . subscriber import Subscriber from . socket import SocketEndpoint