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

Fix DataInsights Test (#20239)

Browse Source
This commit is contained in:
IceS2 2025-03-13 09:19:34 -03:00 committed by GitHub
parent c5c724887e
commit 2411a1040e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
openmetadata-service/src/test/java/org/openmetadata/service/resources/apps/AppsResourceTest.java
View File

@ -6,6 +6,7 @@ import static javax.ws.rs.core.Response.Status.NOT_FOUND;
import static javax.ws.rs.core.Response.Status.OK; import static javax.ws.rs.core.Response.Status.OK;
import static org.openmetadata.common.utils.CommonUtil.listOf; import static org.openmetadata.common.utils.CommonUtil.listOf;
import static org.openmetadata.schema.type.ColumnDataType.INT; import static org.openmetadata.schema.type.ColumnDataType.INT;
import static org.openmetadata.service.Entity.getSearchRepository;
import static org.openmetadata.service.util.TestUtils.ADMIN_AUTH_HEADERS; import static org.openmetadata.service.util.TestUtils.ADMIN_AUTH_HEADERS;
import static org.openmetadata.service.util.TestUtils.assertEventually; import static org.openmetadata.service.util.TestUtils.assertEventually;
import static org.openmetadata.service.util.TestUtils.assertResponseContains; import static org.openmetadata.service.util.TestUtils.assertResponseContains;
@ -316,7 +317,13 @@ public class AppsResourceTest extends EntityResourceTest<App, CreateApp> {
// ------------------------------------------------- // -------------------------------------------------
RestClient searchClient = getSearchClient(); RestClient searchClient = getSearchClient();
es.org.elasticsearch.client.Response response; es.org.elasticsearch.client.Response response;
Request request = new Request("GET", "di-data-assets-*/_search"); String clusterAlias = getSearchRepository().getClusterAlias();
String endpointSuffix = "di-data-assets-*";
String endpoint =
!(clusterAlias == null || clusterAlias.isEmpty())
? String.format("%s-%s", clusterAlias, endpointSuffix)
: endpointSuffix;
Request request = new Request("GET", String.format("%s/_search", endpoint));
String payload = String payload =
String.format( String.format(
"{\"query\":{\"bool\":{\"must\":{\"term\":{\"fullyQualifiedName\":\"%s\"}}}}}", "{\"query\":{\"bool\":{\"must\":{\"term\":{\"fullyQualifiedName\":\"%s\"}}}}}",