Tweak subscriber name

This commit is contained in:
Cyber MacGeddon 2024-07-26 14:30:57 +01:00
parent b8bc2ba109
commit 2628558fc8

View file

@ -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):