Fix Automator Search (#17942)

* Fix Automator Search * Add only to index
open-metadata · Sep 20, 2024 · f852465 · f852465
1 parent 4cccaae
commit f852465
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/...openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java b/...openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java
@@ -939,6 +939,7 @@ public IngestionPipeline deletePipelineStatus(
  private IngestionPipeline getIngestionPipeline(CreateIngestionPipeline create, String user) {
  OpenMetadataConnection openMetadataServerConnection =
  new OpenMetadataConnectionBuilder(openMetadataApplicationConfig).build();
+
  return repository
  .copy(new IngestionPipeline(), create, user)
  .withPipelineType(create.getPipelineType())

diff --git a/...service/src/main/java/org/openmetadata/service/search/indexes/IngestionPipelineIndex.java b/...service/src/main/java/org/openmetadata/service/search/indexes/IngestionPipelineIndex.java
@@ -6,11 +6,13 @@
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
+import org.json.JSONObject;
 import org.openmetadata.schema.entity.services.ingestionPipelines.AirflowConfig;
 import org.openmetadata.schema.entity.services.ingestionPipelines.IngestionPipeline;
 import org.openmetadata.service.Entity;
 import org.openmetadata.service.search.ParseTags;
 import org.openmetadata.service.search.models.SearchSuggest;
+import org.openmetadata.service.util.JsonUtils;
 
 public class IngestionPipelineIndex implements SearchIndex {
  final IngestionPipeline ingestionPipeline;
@@ -73,7 +75,11 @@ public Map<String, Object> buildSearchIndexDocInternal(Map<String, Object> doc)
  airflowConfigMap.put("scheduleInterval", scheduleInterval);
  doc.put("airflowConfig", airflowConfigMap);
  });
-
+ JSONObject sourceConfigJson =
+ new JSONObject(JsonUtils.pojoToJson(ingestionPipeline.getSourceConfig().getConfig()));
+ Optional.ofNullable(sourceConfigJson.optJSONObject("appConfig"))
+ .map(appConfig -> appConfig.optString("type", null))
+ .ifPresent(c -> doc.put("applicationType", c));
  return doc;
  }