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

Fixing incomplete porting

Browse source
This commit is contained in:
Cyber MacGeddon 2025-12-17 16:02:33 +00:00
parent fd749466b6
commit 43de1d811b
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
trustgraph-base/trustgraph/base/consumer_spec.py
View file

@ -19,7 +19,7 @@ class ConsumerSpec(Spec):
consumer = Consumer(
taskgroup = processor.taskgroup,
flow = flow,
backend = processor.pubsub, # Changed from pulsar_client to pubsub
backend = processor.pubsub,
topic = definition[self.name],
subscriber = processor.id + "--" + flow.name + "--" + self.name,
schema = self.schema,

2
trustgraph-base/trustgraph/base/producer_spec.py
View file

@ -15,7 +15,7 @@ class ProducerSpec(Spec):
)
producer = Producer(
backend = processor.pubsub, # Changed from pulsar_client to pubsub
backend = processor.pubsub,
topic = definition[self.name],
schema = self.schema,
metrics = producer_metrics,