From 2628558fc87bfdde770f1cdb061a163fffb82d3b Mon Sep 17 00:00:00 2001 From: Cyber MacGeddon Date: Fri, 26 Jul 2024 14:30:57 +0100 Subject: [PATCH] Tweak subscriber name --- trustgraph/embeddings/vectorize/vectorize.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/trustgraph/embeddings/vectorize/vectorize.py b/trustgraph/embeddings/vectorize/vectorize.py index 963017b6..bac0e932 100755 --- a/trustgraph/embeddings/vectorize/vectorize.py +++ b/trustgraph/embeddings/vectorize/vectorize.py @@ -36,7 +36,7 @@ class Processor(ConsumerProducer): self.embeddings = EmbeddingsClient( pulsar_host=self.pulsar_host, - subscriber=module + "emb", + subscriber=module + "-emb", ) def emit(self, source, chunk, vectors):