diff --git a/trustgraph-base/trustgraph/clients/base.py b/trustgraph-base/trustgraph/clients/base.py index 42de45a5..ac809123 100644 --- a/trustgraph-base/trustgraph/clients/base.py +++ b/trustgraph-base/trustgraph/clients/base.py @@ -42,13 +42,13 @@ class BaseClient: auth = pulsar.AuthenticationToken(pulsar_api_key) self.client = pulsar.Client( pulsar_host, + logger=pulsar.ConsoleLogger(log_level), authentication=auth, - logger=pulsar.ConsoleLogger(log_level.to_pulsar()) ) else: self.client = pulsar.Client( pulsar_host, - logger=pulsar.ConsoleLogger(log_level.to_pulsar()) + logger=pulsar.ConsoleLogger(log_level) ) self.producer = self.client.create_producer( diff --git a/trustgraph-flow/trustgraph/embeddings/document_embeddings/embeddings.py b/trustgraph-flow/trustgraph/embeddings/document_embeddings/embeddings.py index 48486378..5fe8a23e 100755 --- a/trustgraph-flow/trustgraph/embeddings/document_embeddings/embeddings.py +++ b/trustgraph-flow/trustgraph/embeddings/document_embeddings/embeddings.py @@ -47,7 +47,7 @@ class Processor(ConsumerProducer): self.embeddings = EmbeddingsClient( pulsar_host=self.pulsar_host, - pulsar_api_key=self.pulsar_api_key, + pulsar_api_key=self.pulsar_api_key, input_queue=emb_request_queue, output_queue=emb_response_queue, subscriber=module + "-emb",