From 212102c61c485d4dc3a5a0bf1751539e4653e616 Mon Sep 17 00:00:00 2001 From: cybermaggedon Date: Fri, 29 Nov 2024 17:17:20 +0000 Subject: [PATCH] Tweak queue names (#184) --- trustgraph-base/trustgraph/schema/documents.py | 2 +- trustgraph-base/trustgraph/schema/graph.py | 4 ++-- trustgraph-base/trustgraph/schema/models.py | 4 ++-- trustgraph-base/trustgraph/schema/prompt.py | 2 +- trustgraph-base/trustgraph/schema/retrieval.py | 4 ++-- 5 files changed, 8 insertions(+), 8 deletions(-) diff --git a/trustgraph-base/trustgraph/schema/documents.py b/trustgraph-base/trustgraph/schema/documents.py index 59aba287..2a3d3d0c 100644 --- a/trustgraph-base/trustgraph/schema/documents.py +++ b/trustgraph-base/trustgraph/schema/documents.py @@ -60,5 +60,5 @@ document_embeddings_request_queue = topic( 'doc-embeddings', kind='non-persistent', namespace='request' ) document_embeddings_response_queue = topic( - 'doc-embeddings-response', kind='non-persistent', namespace='response', + 'doc-embeddings', kind='non-persistent', namespace='response', ) diff --git a/trustgraph-base/trustgraph/schema/graph.py b/trustgraph-base/trustgraph/schema/graph.py index 2d108a30..78c1a99c 100644 --- a/trustgraph-base/trustgraph/schema/graph.py +++ b/trustgraph-base/trustgraph/schema/graph.py @@ -34,7 +34,7 @@ graph_embeddings_request_queue = topic( 'graph-embeddings', kind='non-persistent', namespace='request' ) graph_embeddings_response_queue = topic( - 'graph-embeddings-response', kind='non-persistent', namespace='response', + 'graph-embeddings', kind='non-persistent', namespace='response' ) ############################################################################ @@ -67,5 +67,5 @@ triples_request_queue = topic( 'triples', kind='non-persistent', namespace='request' ) triples_response_queue = topic( - 'triples-response', kind='non-persistent', namespace='response', + 'triples', kind='non-persistent', namespace='response' ) diff --git a/trustgraph-base/trustgraph/schema/models.py b/trustgraph-base/trustgraph/schema/models.py index 70cb2c8f..a634e1c4 100644 --- a/trustgraph-base/trustgraph/schema/models.py +++ b/trustgraph-base/trustgraph/schema/models.py @@ -23,7 +23,7 @@ text_completion_request_queue = topic( 'text-completion', kind='non-persistent', namespace='request' ) text_completion_response_queue = topic( - 'text-completion-response', kind='non-persistent', namespace='response', + 'text-completion', kind='non-persistent', namespace='response' ) ############################################################################ @@ -41,5 +41,5 @@ embeddings_request_queue = topic( 'embeddings', kind='non-persistent', namespace='request' ) embeddings_response_queue = topic( - 'embeddings-response', kind='non-persistent', namespace='response' + 'embeddings', kind='non-persistent', namespace='response' ) diff --git a/trustgraph-base/trustgraph/schema/prompt.py b/trustgraph-base/trustgraph/schema/prompt.py index 9bcdf117..15eddea8 100644 --- a/trustgraph-base/trustgraph/schema/prompt.py +++ b/trustgraph-base/trustgraph/schema/prompt.py @@ -59,7 +59,7 @@ prompt_request_queue = topic( 'prompt', kind='non-persistent', namespace='request' ) prompt_response_queue = topic( - 'prompt-response', kind='non-persistent', namespace='response' + 'prompt', kind='non-persistent', namespace='response' ) ############################################################################ diff --git a/trustgraph-base/trustgraph/schema/retrieval.py b/trustgraph-base/trustgraph/schema/retrieval.py index ad860c3c..9c4361a1 100644 --- a/trustgraph-base/trustgraph/schema/retrieval.py +++ b/trustgraph-base/trustgraph/schema/retrieval.py @@ -20,7 +20,7 @@ graph_rag_request_queue = topic( 'graph-rag', kind='non-persistent', namespace='request' ) graph_rag_response_queue = topic( - 'graph-rag-response', kind='non-persistent', namespace='response' + 'graph-rag', kind='non-persistent', namespace='response' ) ############################################################################ @@ -40,5 +40,5 @@ document_rag_request_queue = topic( 'doc-rag', kind='non-persistent', namespace='request' ) document_rag_response_queue = topic( - 'doc-rag-response', kind='non-persistent', namespace='response' + 'doc-rag', kind='non-persistent', namespace='response' )