apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-05-23 14:25:12 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix logging startup problems (#446)

Browse source
This commit is contained in:
cybermaggedon 2025-07-31 00:01:08 +01:00 • committed by GitHub
parent 444d205251
commit 069bae7e77
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
trustgraph-base/trustgraph/base/pubsub.py
View file

@ -21,7 +21,7 @@ class PulsarClient:
"pulsar_api_key", "pulsar_api_key",
self.default_pulsar_api_key self.default_pulsar_api_key
) )
log_level = params.get("log_level", LogLevel.INFO) # Hard-code Pulsar logging to ERROR level to minimize noise
self.pulsar_host = pulsar_host self.pulsar_host = pulsar_host
self.pulsar_api_key = pulsar_api_key self.pulsar_api_key = pulsar_api_key
@ -31,13 +31,13 @@ class PulsarClient:
self.client = pulsar.Client( self.client = pulsar.Client(
pulsar_host, pulsar_host,
authentication=auth, authentication=auth,
logger=pulsar.ConsoleLogger(log_level.to_pulsar()) logger=pulsar.ConsoleLogger(_pulsar.LoggerLevel.Error)
) )
else: else:
self.client = pulsar.Client( self.client = pulsar.Client(
pulsar_host, pulsar_host,
listener_name=pulsar_listener, listener_name=pulsar_listener,
logger=pulsar.ConsoleLogger(log_level.to_pulsar()) logger=pulsar.ConsoleLogger(_pulsar.LoggerLevel.Error)
) )
self.pulsar_listener = pulsar_listener self.pulsar_listener = pulsar_listener