chore fix

Signed-off-by: blam <ben@blam.sh>
2024-11-21 17:46:49 +01:00
parent 6fbc3b359d
commit e327ec4859
1 changed files with 4 additions and 2 deletions
@@ -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),
        });
      }