diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts index 04005101da..4959a33eef 100644 --- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts +++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts @@ -370,7 +370,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase { const eventParams: EventParams = { topic: CATALOG_CONFLICTS_TOPIC, eventPayload: { - entity, + unprocessedEntity: entity, entityRef, newLocationKey: locationKey, existingLocationKey: conflictingKey,