From e327ec4859df64ae5da97f60718fc480be4676a7 Mon Sep 17 00:00:00 2001
From: blam <ben@blam.sh>
Date: Thu, 21 Nov 2024 17:46:49 +0100
Subject: [PATCH] chore fix Signed-off-by: blam <ben@blam.sh>

---
 .../src/module/WrapperProviders.ts                          | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts b/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts
index 0c0f1361cf..738d5733d0 100644
--- a/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts
+++ b/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts
@@ -136,11 +136,13 @@ export class WrapperProviders {
       const topics = engine.supportsEventTopics();
       if (topics.length > 0) {
         logger.info(
-          `Provider ${provider.getProviderName()} subscribing to events for topics: ${topics.join()}`,
+          `Provider ${provider.getProviderName()} subscribing to events for topics: ${topics.join(
+            ',',
+          )}`,
         );
         await this.options.events.subscribe({
           topics,
-          id: provider.getProviderName(),
+          id: `catalog-backend-module-incremental-ingestion:${provider.getProviderName()}`,
           onEvent: evt => engine.onEvent(evt),
         });
       }