From 8e92f01c978ce9fee63a8f548e2bfc91d01dcdb5 Mon Sep 17 00:00:00 2001 From: Cyber MacGeddon Date: Wed, 17 Dec 2025 15:03:23 +0000 Subject: [PATCH] Fixing document loading --- trustgraph-flow/trustgraph/librarian/service.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/trustgraph-flow/trustgraph/librarian/service.py b/trustgraph-flow/trustgraph/librarian/service.py index 55f7ec27..48bb0190 100755 --- a/trustgraph-flow/trustgraph/librarian/service.py +++ b/trustgraph-flow/trustgraph/librarian/service.py @@ -306,7 +306,7 @@ class Processor(AsyncProcessor): logger.debug(f"Submitting to queue {q}...") pub = Publisher( - self.pulsar_client, q, schema=schema + self.pubsub, q, schema=schema ) await pub.start()