From 1adbf4a5b39b229b4771305ee39b75f5af4c9c7b Mon Sep 17 00:00:00 2001 From: stainless-bot Date: Wed, 17 Jul 2024 21:55:01 +0000 Subject: [PATCH] feat(api): update via SDK Studio --- ...kt => InferencePipelineRowUpdateParams.kt} | 50 +++++++++---------- ... => InferencePipelineRowUpdateResponse.kt} | 20 ++++---- .../inferencePipelines/RowServiceAsync.kt | 10 ++-- .../inferencePipelines/RowServiceAsyncImpl.kt | 16 +++--- .../blocking/inferencePipelines/RowService.kt | 10 ++-- .../inferencePipelines/RowServiceImpl.kt | 16 +++--- .../InferencePipelineRowStreamResponseTest.kt | 20 -------- ...> InferencePipelineRowUpdateParamsTest.kt} | 24 ++++----- .../InferencePipelineRowUpdateResponseTest.kt | 20 ++++++++ .../inferencePipelines/RowServiceTest.kt | 14 +++--- 10 files changed, 100 insertions(+), 100 deletions(-) rename openlayer-java-core/src/main/kotlin/com/openlayer/api/models/{InferencePipelineRowStreamParams.kt => InferencePipelineRowUpdateParams.kt} (90%) rename openlayer-java-core/src/main/kotlin/com/openlayer/api/models/{InferencePipelineRowStreamResponse.kt => InferencePipelineRowUpdateResponse.kt} (86%) delete mode 100644 openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowStreamResponseTest.kt rename openlayer-java-core/src/test/kotlin/com/openlayer/api/models/{InferencePipelineRowStreamParamsTest.kt => InferencePipelineRowUpdateParamsTest.kt} (86%) create mode 100644 openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateResponseTest.kt diff --git a/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowStreamParams.kt b/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateParams.kt similarity index 90% rename from openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowStreamParams.kt rename to openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateParams.kt index 64b926d..a8072f9 100644 --- a/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowStreamParams.kt +++ b/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateParams.kt @@ -14,7 +14,7 @@ import com.openlayer.api.models.* import java.util.Objects import java.util.Optional -class InferencePipelineRowStreamParams +class InferencePipelineRowUpdateParams constructor( private val inferencePipelineId: String, private val inferenceId: String, @@ -34,8 +34,8 @@ constructor( fun config(): Optional = Optional.ofNullable(config) @JvmSynthetic - internal fun getBody(): InferencePipelineRowStreamBody { - return InferencePipelineRowStreamBody( + internal fun getBody(): InferencePipelineRowUpdateBody { + return InferencePipelineRowUpdateBody( row, config, additionalBodyProperties, @@ -59,9 +59,9 @@ constructor( } } - @JsonDeserialize(builder = InferencePipelineRowStreamBody.Builder::class) + @JsonDeserialize(builder = InferencePipelineRowUpdateBody.Builder::class) @NoAutoDetect - class InferencePipelineRowStreamBody + class InferencePipelineRowUpdateBody internal constructor( private val row: JsonValue?, private val config: Config?, @@ -85,7 +85,7 @@ constructor( return true } - return other is InferencePipelineRowStreamBody && + return other is InferencePipelineRowUpdateBody && this.row == other.row && this.config == other.config && this.additionalProperties == other.additionalProperties @@ -104,7 +104,7 @@ constructor( } override fun toString() = - "InferencePipelineRowStreamBody{row=$row, config=$config, additionalProperties=$additionalProperties}" + "InferencePipelineRowUpdateBody{row=$row, config=$config, additionalProperties=$additionalProperties}" companion object { @@ -118,11 +118,11 @@ constructor( private var additionalProperties: MutableMap = mutableMapOf() @JvmSynthetic - internal fun from(inferencePipelineRowStreamBody: InferencePipelineRowStreamBody) = + internal fun from(inferencePipelineRowUpdateBody: InferencePipelineRowUpdateBody) = apply { - this.row = inferencePipelineRowStreamBody.row - this.config = inferencePipelineRowStreamBody.config - additionalProperties(inferencePipelineRowStreamBody.additionalProperties) + this.row = inferencePipelineRowUpdateBody.row + this.config = inferencePipelineRowUpdateBody.config + additionalProperties(inferencePipelineRowUpdateBody.additionalProperties) } @JsonProperty("row") fun row(row: JsonValue) = apply { this.row = row } @@ -143,8 +143,8 @@ constructor( this.additionalProperties.putAll(additionalProperties) } - fun build(): InferencePipelineRowStreamBody = - InferencePipelineRowStreamBody( + fun build(): InferencePipelineRowUpdateBody = + InferencePipelineRowUpdateBody( checkNotNull(row) { "`row` is required but was not set" }, config, additionalProperties.toUnmodifiable(), @@ -163,7 +163,7 @@ constructor( return true } - return other is InferencePipelineRowStreamParams && + return other is InferencePipelineRowUpdateParams && this.inferencePipelineId == other.inferencePipelineId && this.row == other.row && this.config == other.config && @@ -186,7 +186,7 @@ constructor( } override fun toString() = - "InferencePipelineRowStreamParams{inferencePipelineId=$inferencePipelineId, row=$row, config=$config, inferenceId=$inferenceId, additionalQueryParams=$additionalQueryParams, additionalHeaders=$additionalHeaders, additionalBodyProperties=$additionalBodyProperties}" + "InferencePipelineRowUpdateParams{inferencePipelineId=$inferencePipelineId, row=$row, config=$config, inferenceId=$inferenceId, additionalQueryParams=$additionalQueryParams, additionalHeaders=$additionalHeaders, additionalBodyProperties=$additionalBodyProperties}" fun toBuilder() = Builder().from(this) @@ -207,15 +207,15 @@ constructor( private var additionalBodyProperties: MutableMap = mutableMapOf() @JvmSynthetic - internal fun from(inferencePipelineRowStreamParams: InferencePipelineRowStreamParams) = + internal fun from(inferencePipelineRowUpdateParams: InferencePipelineRowUpdateParams) = apply { - this.inferencePipelineId = inferencePipelineRowStreamParams.inferencePipelineId - this.inferenceId = inferencePipelineRowStreamParams.inferenceId - this.row = inferencePipelineRowStreamParams.row - this.config = inferencePipelineRowStreamParams.config - additionalQueryParams(inferencePipelineRowStreamParams.additionalQueryParams) - additionalHeaders(inferencePipelineRowStreamParams.additionalHeaders) - additionalBodyProperties(inferencePipelineRowStreamParams.additionalBodyProperties) + this.inferencePipelineId = inferencePipelineRowUpdateParams.inferencePipelineId + this.inferenceId = inferencePipelineRowUpdateParams.inferenceId + this.row = inferencePipelineRowUpdateParams.row + this.config = inferencePipelineRowUpdateParams.config + additionalQueryParams(inferencePipelineRowUpdateParams.additionalQueryParams) + additionalHeaders(inferencePipelineRowUpdateParams.additionalHeaders) + additionalBodyProperties(inferencePipelineRowUpdateParams.additionalBodyProperties) } fun inferencePipelineId(inferencePipelineId: String) = apply { @@ -283,8 +283,8 @@ constructor( this.additionalBodyProperties.putAll(additionalBodyProperties) } - fun build(): InferencePipelineRowStreamParams = - InferencePipelineRowStreamParams( + fun build(): InferencePipelineRowUpdateParams = + InferencePipelineRowUpdateParams( checkNotNull(inferencePipelineId) { "`inferencePipelineId` is required but was not set" }, diff --git a/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowStreamResponse.kt b/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateResponse.kt similarity index 86% rename from openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowStreamResponse.kt rename to openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateResponse.kt index c52d907..35e877e 100644 --- a/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowStreamResponse.kt +++ b/openlayer-java-core/src/main/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateResponse.kt @@ -17,9 +17,9 @@ import com.openlayer.api.core.toUnmodifiable import com.openlayer.api.errors.OpenlayerInvalidDataException import java.util.Objects -@JsonDeserialize(builder = InferencePipelineRowStreamResponse.Builder::class) +@JsonDeserialize(builder = InferencePipelineRowUpdateResponse.Builder::class) @NoAutoDetect -class InferencePipelineRowStreamResponse +class InferencePipelineRowUpdateResponse private constructor( private val success: JsonField, private val additionalProperties: Map, @@ -37,7 +37,7 @@ private constructor( @ExcludeMissing fun _additionalProperties(): Map = additionalProperties - fun validate(): InferencePipelineRowStreamResponse = apply { + fun validate(): InferencePipelineRowUpdateResponse = apply { if (!validated) { success() validated = true @@ -51,7 +51,7 @@ private constructor( return true } - return other is InferencePipelineRowStreamResponse && + return other is InferencePipelineRowUpdateResponse && this.success == other.success && this.additionalProperties == other.additionalProperties } @@ -64,7 +64,7 @@ private constructor( } override fun toString() = - "InferencePipelineRowStreamResponse{success=$success, additionalProperties=$additionalProperties}" + "InferencePipelineRowUpdateResponse{success=$success, additionalProperties=$additionalProperties}" companion object { @@ -77,10 +77,10 @@ private constructor( private var additionalProperties: MutableMap = mutableMapOf() @JvmSynthetic - internal fun from(inferencePipelineRowStreamResponse: InferencePipelineRowStreamResponse) = + internal fun from(inferencePipelineRowUpdateResponse: InferencePipelineRowUpdateResponse) = apply { - this.success = inferencePipelineRowStreamResponse.success - additionalProperties(inferencePipelineRowStreamResponse.additionalProperties) + this.success = inferencePipelineRowUpdateResponse.success + additionalProperties(inferencePipelineRowUpdateResponse.additionalProperties) } fun success(success: Success) = success(JsonField.of(success)) @@ -103,8 +103,8 @@ private constructor( this.additionalProperties.putAll(additionalProperties) } - fun build(): InferencePipelineRowStreamResponse = - InferencePipelineRowStreamResponse(success, additionalProperties.toUnmodifiable()) + fun build(): InferencePipelineRowUpdateResponse = + InferencePipelineRowUpdateResponse(success, additionalProperties.toUnmodifiable()) } class Success diff --git a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsync.kt b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsync.kt index ce9b54b..4522c37 100644 --- a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsync.kt +++ b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsync.kt @@ -5,16 +5,16 @@ package com.openlayer.api.services.async.inferencePipelines import com.openlayer.api.core.RequestOptions -import com.openlayer.api.models.InferencePipelineRowStreamParams -import com.openlayer.api.models.InferencePipelineRowStreamResponse +import com.openlayer.api.models.InferencePipelineRowUpdateParams +import com.openlayer.api.models.InferencePipelineRowUpdateResponse import java.util.concurrent.CompletableFuture interface RowServiceAsync { /** Update an inference data point in an inference pipeline. */ @JvmOverloads - fun stream( - params: InferencePipelineRowStreamParams, + fun update( + params: InferencePipelineRowUpdateParams, requestOptions: RequestOptions = RequestOptions.none() - ): CompletableFuture + ): CompletableFuture } diff --git a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsyncImpl.kt b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsyncImpl.kt index b13033e..9304fa7 100644 --- a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsyncImpl.kt +++ b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/async/inferencePipelines/RowServiceAsyncImpl.kt @@ -8,8 +8,8 @@ import com.openlayer.api.core.http.HttpMethod import com.openlayer.api.core.http.HttpRequest import com.openlayer.api.core.http.HttpResponse.Handler import com.openlayer.api.errors.OpenlayerError -import com.openlayer.api.models.InferencePipelineRowStreamParams -import com.openlayer.api.models.InferencePipelineRowStreamResponse +import com.openlayer.api.models.InferencePipelineRowUpdateParams +import com.openlayer.api.models.InferencePipelineRowUpdateResponse import com.openlayer.api.services.errorHandler import com.openlayer.api.services.json import com.openlayer.api.services.jsonHandler @@ -23,15 +23,15 @@ constructor( private val errorHandler: Handler = errorHandler(clientOptions.jsonMapper) - private val streamHandler: Handler = - jsonHandler(clientOptions.jsonMapper) + private val updateHandler: Handler = + jsonHandler(clientOptions.jsonMapper) .withErrorHandler(errorHandler) /** Update an inference data point in an inference pipeline. */ - override fun stream( - params: InferencePipelineRowStreamParams, + override fun update( + params: InferencePipelineRowUpdateParams, requestOptions: RequestOptions - ): CompletableFuture { + ): CompletableFuture { val request = HttpRequest.builder() .method(HttpMethod.PUT) @@ -45,7 +45,7 @@ constructor( return clientOptions.httpClient.executeAsync(request, requestOptions).thenApply { response -> response - .use { streamHandler.handle(it) } + .use { updateHandler.handle(it) } .apply { if (requestOptions.responseValidation ?: clientOptions.responseValidation) { validate() diff --git a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowService.kt b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowService.kt index 68e608b..3548f85 100644 --- a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowService.kt +++ b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowService.kt @@ -5,15 +5,15 @@ package com.openlayer.api.services.blocking.inferencePipelines import com.openlayer.api.core.RequestOptions -import com.openlayer.api.models.InferencePipelineRowStreamParams -import com.openlayer.api.models.InferencePipelineRowStreamResponse +import com.openlayer.api.models.InferencePipelineRowUpdateParams +import com.openlayer.api.models.InferencePipelineRowUpdateResponse interface RowService { /** Update an inference data point in an inference pipeline. */ @JvmOverloads - fun stream( - params: InferencePipelineRowStreamParams, + fun update( + params: InferencePipelineRowUpdateParams, requestOptions: RequestOptions = RequestOptions.none() - ): InferencePipelineRowStreamResponse + ): InferencePipelineRowUpdateResponse } diff --git a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceImpl.kt b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceImpl.kt index 09c5c4f..d5f73a0 100644 --- a/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceImpl.kt +++ b/openlayer-java-core/src/main/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceImpl.kt @@ -8,8 +8,8 @@ import com.openlayer.api.core.http.HttpMethod import com.openlayer.api.core.http.HttpRequest import com.openlayer.api.core.http.HttpResponse.Handler import com.openlayer.api.errors.OpenlayerError -import com.openlayer.api.models.InferencePipelineRowStreamParams -import com.openlayer.api.models.InferencePipelineRowStreamResponse +import com.openlayer.api.models.InferencePipelineRowUpdateParams +import com.openlayer.api.models.InferencePipelineRowUpdateResponse import com.openlayer.api.services.errorHandler import com.openlayer.api.services.json import com.openlayer.api.services.jsonHandler @@ -22,15 +22,15 @@ constructor( private val errorHandler: Handler = errorHandler(clientOptions.jsonMapper) - private val streamHandler: Handler = - jsonHandler(clientOptions.jsonMapper) + private val updateHandler: Handler = + jsonHandler(clientOptions.jsonMapper) .withErrorHandler(errorHandler) /** Update an inference data point in an inference pipeline. */ - override fun stream( - params: InferencePipelineRowStreamParams, + override fun update( + params: InferencePipelineRowUpdateParams, requestOptions: RequestOptions - ): InferencePipelineRowStreamResponse { + ): InferencePipelineRowUpdateResponse { val request = HttpRequest.builder() .method(HttpMethod.PUT) @@ -43,7 +43,7 @@ constructor( .build() return clientOptions.httpClient.execute(request, requestOptions).let { response -> response - .use { streamHandler.handle(it) } + .use { updateHandler.handle(it) } .apply { if (requestOptions.responseValidation ?: clientOptions.responseValidation) { validate() diff --git a/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowStreamResponseTest.kt b/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowStreamResponseTest.kt deleted file mode 100644 index 2b615a5..0000000 --- a/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowStreamResponseTest.kt +++ /dev/null @@ -1,20 +0,0 @@ -// File generated from our OpenAPI spec by Stainless. - -package com.openlayer.api.models - -import org.assertj.core.api.Assertions.assertThat -import org.junit.jupiter.api.Test - -class InferencePipelineRowStreamResponseTest { - - @Test - fun createInferencePipelineRowStreamResponse() { - val inferencePipelineRowStreamResponse = - InferencePipelineRowStreamResponse.builder() - .success(InferencePipelineRowStreamResponse.Success.TRUE) - .build() - assertThat(inferencePipelineRowStreamResponse).isNotNull - assertThat(inferencePipelineRowStreamResponse.success()) - .isEqualTo(InferencePipelineRowStreamResponse.Success.TRUE) - } -} diff --git a/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowStreamParamsTest.kt b/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateParamsTest.kt similarity index 86% rename from openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowStreamParamsTest.kt rename to openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateParamsTest.kt index 15f8668..f4a70bf 100644 --- a/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowStreamParamsTest.kt +++ b/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateParamsTest.kt @@ -7,15 +7,15 @@ import com.openlayer.api.models.* import org.assertj.core.api.Assertions.assertThat import org.junit.jupiter.api.Test -class InferencePipelineRowStreamParamsTest { +class InferencePipelineRowUpdateParamsTest { @Test - fun createInferencePipelineRowStreamParams() { - InferencePipelineRowStreamParams.builder() + fun createInferencePipelineRowUpdateParams() { + InferencePipelineRowUpdateParams.builder() .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e") .row(JsonValue.from(mapOf())) .config( - InferencePipelineRowStreamParams.Config.builder() + InferencePipelineRowUpdateParams.Config.builder() .groundTruthColumnName("ground_truth") .humanFeedbackColumnName("human_feedback") .inferenceIdColumnName("id") @@ -30,11 +30,11 @@ class InferencePipelineRowStreamParamsTest { @Test fun getQueryParams() { val params = - InferencePipelineRowStreamParams.builder() + InferencePipelineRowUpdateParams.builder() .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e") .row(JsonValue.from(mapOf())) .config( - InferencePipelineRowStreamParams.Config.builder() + InferencePipelineRowUpdateParams.Config.builder() .groundTruthColumnName("ground_truth") .humanFeedbackColumnName("human_feedback") .inferenceIdColumnName("id") @@ -52,7 +52,7 @@ class InferencePipelineRowStreamParamsTest { @Test fun getQueryParamsWithoutOptionalFields() { val params = - InferencePipelineRowStreamParams.builder() + InferencePipelineRowUpdateParams.builder() .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e") .row(JsonValue.from(mapOf())) .inferenceId("inferenceId") @@ -65,11 +65,11 @@ class InferencePipelineRowStreamParamsTest { @Test fun getBody() { val params = - InferencePipelineRowStreamParams.builder() + InferencePipelineRowUpdateParams.builder() .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e") .row(JsonValue.from(mapOf())) .config( - InferencePipelineRowStreamParams.Config.builder() + InferencePipelineRowUpdateParams.Config.builder() .groundTruthColumnName("ground_truth") .humanFeedbackColumnName("human_feedback") .inferenceIdColumnName("id") @@ -84,7 +84,7 @@ class InferencePipelineRowStreamParamsTest { assertThat(body.row()).isEqualTo(JsonValue.from(mapOf())) assertThat(body.config()) .isEqualTo( - InferencePipelineRowStreamParams.Config.builder() + InferencePipelineRowUpdateParams.Config.builder() .groundTruthColumnName("ground_truth") .humanFeedbackColumnName("human_feedback") .inferenceIdColumnName("id") @@ -97,7 +97,7 @@ class InferencePipelineRowStreamParamsTest { @Test fun getBodyWithoutOptionalFields() { val params = - InferencePipelineRowStreamParams.builder() + InferencePipelineRowUpdateParams.builder() .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e") .row(JsonValue.from(mapOf())) .inferenceId("inferenceId") @@ -110,7 +110,7 @@ class InferencePipelineRowStreamParamsTest { @Test fun getPathParam() { val params = - InferencePipelineRowStreamParams.builder() + InferencePipelineRowUpdateParams.builder() .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e") .row(JsonValue.from(mapOf())) .inferenceId("inferenceId") diff --git a/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateResponseTest.kt b/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateResponseTest.kt new file mode 100644 index 0000000..427675b --- /dev/null +++ b/openlayer-java-core/src/test/kotlin/com/openlayer/api/models/InferencePipelineRowUpdateResponseTest.kt @@ -0,0 +1,20 @@ +// File generated from our OpenAPI spec by Stainless. + +package com.openlayer.api.models + +import org.assertj.core.api.Assertions.assertThat +import org.junit.jupiter.api.Test + +class InferencePipelineRowUpdateResponseTest { + + @Test + fun createInferencePipelineRowUpdateResponse() { + val inferencePipelineRowUpdateResponse = + InferencePipelineRowUpdateResponse.builder() + .success(InferencePipelineRowUpdateResponse.Success.TRUE) + .build() + assertThat(inferencePipelineRowUpdateResponse).isNotNull + assertThat(inferencePipelineRowUpdateResponse.success()) + .isEqualTo(InferencePipelineRowUpdateResponse.Success.TRUE) + } +} diff --git a/openlayer-java-core/src/test/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceTest.kt b/openlayer-java-core/src/test/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceTest.kt index bff5a32..8347fd9 100644 --- a/openlayer-java-core/src/test/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceTest.kt +++ b/openlayer-java-core/src/test/kotlin/com/openlayer/api/services/blocking/inferencePipelines/RowServiceTest.kt @@ -13,20 +13,20 @@ import org.junit.jupiter.api.extension.ExtendWith class RowServiceTest { @Test - fun callStream() { + fun callUpdate() { val client = OpenlayerOkHttpClient.builder() .baseUrl(TestServerExtension.BASE_URL) .apiKey("My API Key") .build() val rowService = client.inferencePipelines().rows() - val inferencePipelineRowStreamResponse = - rowService.stream( - InferencePipelineRowStreamParams.builder() + val inferencePipelineRowUpdateResponse = + rowService.update( + InferencePipelineRowUpdateParams.builder() .inferencePipelineId("182bd5e5-6e1a-4fe4-a799-aa6d9a6ab26e") .row(JsonValue.from(mapOf())) .config( - InferencePipelineRowStreamParams.Config.builder() + InferencePipelineRowUpdateParams.Config.builder() .groundTruthColumnName("ground_truth") .humanFeedbackColumnName("human_feedback") .inferenceIdColumnName("id") @@ -37,7 +37,7 @@ class RowServiceTest { .inferenceId("inferenceId") .build() ) - println(inferencePipelineRowStreamResponse) - inferencePipelineRowStreamResponse.validate() + println(inferencePipelineRowUpdateResponse) + inferencePipelineRowUpdateResponse.validate() } }