From 5f9481dfed11acc34e10a5a421b7fab31a092025 Mon Sep 17 00:00:00 2001
From: Cyber MacGeddon <cybermaggedon@gmail.com>
Date: Mon, 21 Apr 2025 13:03:54 +0100
Subject: [PATCH] Fix ID not being used for subscribers

---
 trustgraph-base/trustgraph/base/consumer_spec.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/trustgraph-base/trustgraph/base/consumer_spec.py b/trustgraph-base/trustgraph/base/consumer_spec.py
index 1bde250a..aaeca677 100644
--- a/trustgraph-base/trustgraph/base/consumer_spec.py
+++ b/trustgraph-base/trustgraph/base/consumer_spec.py
@@ -20,7 +20,7 @@ class ConsumerSpec(Spec):
             flow = flow,
             client = processor.client,
             topic = definition[self.name],
-            subscriber = flow.id + "---" + self.name,
+            subscriber = processor.id + "--" + self.name,
             schema = self.schema,
             handler = self.handler,
             metrics = consumer_metrics,