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

Resolve merge conflicts

Browse source
This commit is contained in:
Tyler O 2025-02-12 09:54:37 +00:00
parent e3a816f851
commit d12a0cae60
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) auth = pulsar.AuthenticationToken(pulsar_api_key)
self.client = pulsar.Client( self.client = pulsar.Client(
pulsar_host, pulsar_host,
logger=pulsar.ConsoleLogger(log_level),
authentication=auth, authentication=auth,
logger=pulsar.ConsoleLogger(log_level.to_pulsar())
) )
else: else:
self.client = pulsar.Client( self.client = pulsar.Client(
pulsar_host, pulsar_host,
logger=pulsar.ConsoleLogger(log_level.to_pulsar()) logger=pulsar.ConsoleLogger(log_level)
) )
self.producer = self.client.create_producer( 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( self.embeddings = EmbeddingsClient(
pulsar_host=self.pulsar_host, pulsar_host=self.pulsar_host,
pulsar_api_key=self.pulsar_api_key, pulsar_api_key=self.pulsar_api_key,
input_queue=emb_request_queue, input_queue=emb_request_queue,
output_queue=emb_response_queue, output_queue=emb_response_queue,
subscriber=module + "-emb", subscriber=module + "-emb",