diff --git a/openmetadata-service/src/test/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java b/openmetadata-service/src/test/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java index 602f08a262e..ce190a2ea84 100644 --- a/openmetadata-service/src/test/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java +++ b/openmetadata-service/src/test/java/org/openmetadata/service/resources/services/ingestionpipelines/IngestionPipelineResourceTest.java @@ -15,6 +15,7 @@ package org.openmetadata.service.resources.services.ingestionpipelines; import static javax.ws.rs.core.Response.Status.BAD_REQUEST; import static javax.ws.rs.core.Response.Status.OK; +import static org.junit.Assert.assertNotNull; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNull; import static org.junit.jupiter.api.Assertions.assertTrue; @@ -137,13 +138,15 @@ public class IngestionPipelineResourceTest extends EntityResourceTest authHeaders) { + IngestionPipeline ingestion, CreateIngestionPipeline createRequest, Map authHeaders) + throws HttpResponseException { assertEquals(createRequest.getAirflowConfig().getConcurrency(), ingestion.getAirflowConfig().getConcurrency()); validateSourceConfig(createRequest.getSourceConfig(), ingestion.getSourceConfig(), ingestion); } @Override - public void compareEntities(IngestionPipeline expected, IngestionPipeline updated, Map authHeaders) { + public void compareEntities(IngestionPipeline expected, IngestionPipeline updated, Map authHeaders) + throws HttpResponseException { assertEquals(expected.getDisplayName(), updated.getDisplayName()); assertReference(expected.getService(), updated.getService()); assertEquals(expected.getSourceConfig(), updated.getSourceConfig()); @@ -177,6 +180,7 @@ public class IngestionPipelineResourceTest extends EntityResourceTest { // put again user with same bot name CreateUser createDifferentBotUser = creatBotUserRequest("test-bot-user-ok", true).withBotName(botName); updateEntity(createDifferentBotUser, OK, ADMIN_AUTH_HEADERS); + assertNotNull(createDifferentBotUser); } private DecodedJWT decodedJWT(String token) {