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

Fix ID not being used for subscribers

Browse source
This commit is contained in:
Cyber MacGeddon 2025-04-21 13:03:54 +01:00
parent 40242015ee
commit 5f9481dfed
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -20,7 +20,7 @@ class ConsumerSpec(Spec):
flow = flow, flow = flow,
client = processor.client, client = processor.client,
topic = definition[self.name], topic = definition[self.name],
subscriber = flow.id + "---" + self.name, subscriber = processor.id + "--" + self.name,
schema = self.schema, schema = self.schema,
handler = self.handler, handler = self.handler,
metrics = consumer_metrics, metrics = consumer_metrics,