From c34b612df30b1aca4ba31a0efec3775b60e30582 Mon Sep 17 00:00:00 2001 From: IceS2 Date: Fri, 7 Feb 2025 13:47:48 +0100 Subject: [PATCH] Fix followers for Data Insights index (#19693) --- .../processors/DataInsightsEntityEnricherProcessor.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/insights/workflows/dataAssets/processors/DataInsightsEntityEnricherProcessor.java b/openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/insights/workflows/dataAssets/processors/DataInsightsEntityEnricherProcessor.java index 840b7694fc5..210aaf38bdb 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/insights/workflows/dataAssets/processors/DataInsightsEntityEnricherProcessor.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/insights/workflows/dataAssets/processors/DataInsightsEntityEnricherProcessor.java @@ -4,6 +4,7 @@ import static org.openmetadata.schema.EntityInterface.ENTITY_TYPE_TO_CLASS_MAP; import static org.openmetadata.service.apps.bundles.insights.utils.TimestampUtils.END_TIMESTAMP_KEY; import static org.openmetadata.service.apps.bundles.insights.utils.TimestampUtils.START_TIMESTAMP_KEY; import static org.openmetadata.service.apps.bundles.insights.workflows.dataAssets.DataAssetsWorkflow.ENTITY_TYPE_FIELDS_KEY; +import static org.openmetadata.service.search.SearchIndexUtils.parseFollowers; import static org.openmetadata.service.workflows.searchIndex.ReindexingUtil.ENTITY_TYPE_KEY; import static org.openmetadata.service.workflows.searchIndex.ReindexingUtil.TIMESTAMP_KEY; import static org.openmetadata.service.workflows.searchIndex.ReindexingUtil.getUpdatedStats; @@ -231,10 +232,8 @@ public class DataInsightsEntityEnricherProcessor oCustomProperties.ifPresent( o -> entityMap.put(String.format("%sCustomProperty", entityType), o)); - // Remove 'changeDescription' field - entityMap.remove("changeDescription"); - // Remove 'sampleData' - entityMap.remove("sampleData"); + // Parse Followers: + entityMap.put("followers", parseFollowers(entity.getFollowers())); return entityMap; }