Fix queue name invocation, use correct names, not defaults

This commit is contained in:
Cyber MacGeddon 2024-09-29 20:37:06 +01:00
parent 90127dfecb
commit 5fb88f78bc
2 changed files with 4 additions and 4 deletions

View file

@ -73,8 +73,8 @@ class DocumentRag:
self.lang = PromptClient(
pulsar_host=pulsar_host,
input_queue=prompt_request_queue,
output_queue=prompt_response_queue,
input_queue=pr_request_queue,
output_queue=pr_response_queue,
subscriber=module + "-de-prompt",
)

View file

@ -96,8 +96,8 @@ class GraphRag:
self.lang = PromptClient(
pulsar_host=pulsar_host,
input_queue=prompt_request_queue,
output_queue=prompt_response_queue,
input_queue=pr_request_queue,
output_queue=pr_response_queue,
subscriber=module + "-prompt",
)