yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-27 18:36:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Automator Search (#17942)

Browse Source 
* Fix Automator Search

* Add only to index
This commit is contained in:
Mohit Yadav 2024-09-20 19:37:16 +05:30 committed by GitHub
parent 4cccaae446
commit f85246583e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
openmetadata-service/src/main/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResource.java
View File

@ -939,6 +939,7 @@ public class IngestionPipelineResource
private IngestionPipeline getIngestionPipeline(CreateIngestionPipeline create, String user) {
OpenMetadataConnection openMetadataServerConnection =
new OpenMetadataConnectionBuilder(openMetadataApplicationConfig).build();
return repository
.copy(new IngestionPipeline(), create, user)
.withPipelineType(create.getPipelineType())

8
openmetadata-service/src/main/java/org/openmetadata/service/search/indexes/IngestionPipelineIndex.java
View File

@ -6,11 +6,13 @@ import java.util.List;
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 class IngestionPipelineIndex implements SearchIndex {
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;
}