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

Fixing document loading

Browse source
This commit is contained in:
Cyber MacGeddon 2025-12-17 15:03:23 +00:00
parent 20c75b1c4f
commit 8e92f01c97
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-flow/trustgraph/librarian/service.py
View file

@ -306,7 +306,7 @@ class Processor(AsyncProcessor):
logger.debug(f"Submitting to queue {q}...") logger.debug(f"Submitting to queue {q}...")
pub = Publisher( pub = Publisher(
self.pulsar_client, q, schema=schema self.pubsub, q, schema=schema
) )
await pub.start() await pub.start()