apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-20 18:51:03 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Resolve merge conflicts

Browse source
This commit is contained in:
Tyler O 2025-02-12 09:54:37 +00:00 • committed by Cyber MacGeddon
parent 1b4d6feb04
commit 69ec869515
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
trustgraph-base/trustgraph/clients/base.py
View file

@ -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(

2
trustgraph-flow/trustgraph/embeddings/document_embeddings/embeddings.py
View file

@ -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",