|
58 | 58 | import org.elasticsearch.xpack.inference.services.elastic.authorization.ElasticInferenceServiceAuthorizationRequestHandler; |
59 | 59 | import org.elasticsearch.xpack.inference.services.elastic.completion.ElasticInferenceServiceCompletionModel; |
60 | 60 | import org.elasticsearch.xpack.inference.services.elastic.completion.ElasticInferenceServiceCompletionServiceSettings; |
61 | | -import org.elasticsearch.xpack.inference.services.elastic.densetextembeddings.ElasticInferenceServiceDenseTextEmbeddingsModel; |
62 | 61 | import org.elasticsearch.xpack.inference.services.elastic.densetextembeddings.ElasticInferenceServiceDenseTextEmbeddingsModelTests; |
63 | 62 | import org.elasticsearch.xpack.inference.services.elastic.rerank.ElasticInferenceServiceRerankModel; |
64 | 63 | import org.elasticsearch.xpack.inference.services.elastic.rerank.ElasticInferenceServiceRerankModelTests; |
|
89 | 88 | import static org.elasticsearch.xpack.inference.Utils.getRequestConfigMap; |
90 | 89 | import static org.elasticsearch.xpack.inference.Utils.inferenceUtilityPool; |
91 | 90 | import static org.elasticsearch.xpack.inference.Utils.mockClusterServiceEmpty; |
92 | | -import static org.elasticsearch.xpack.inference.chunking.ChunkingSettingsTests.createRandomChunkingSettings; |
93 | 91 | import static org.elasticsearch.xpack.inference.external.http.Utils.entityAsMap; |
94 | 92 | import static org.elasticsearch.xpack.inference.external.http.Utils.getUrl; |
95 | 93 | import static org.elasticsearch.xpack.inference.services.ServiceComponentsTests.createWithEmptySettings; |
@@ -748,7 +746,7 @@ public void testChunkedInfer_PropagatesProductUseCaseHeader() throws IOException |
748 | 746 | } |
749 | 747 | """; |
750 | 748 | webServer.enqueue(new MockResponse().setResponseCode(200).setBody(responseJson)); |
751 | | - var model = ElasticInferenceServiceDenseTextEmbeddingsModelTests.createModel(getUrl(webServer), "my-dense-model-id", null); |
| 749 | + var model = ElasticInferenceServiceDenseTextEmbeddingsModelTests.createModel(getUrl(webServer), "my-dense-model-id"); |
752 | 750 |
|
753 | 751 | String productUseCase = "test-product-use-case"; |
754 | 752 | threadPool.getThreadContext().putHeader(InferencePlugin.X_ELASTIC_PRODUCT_USE_CASE_HTTP_HEADER, productUseCase); |
@@ -788,22 +786,8 @@ public void testChunkedInfer_PropagatesProductUseCaseHeader() throws IOException |
788 | 786 | } |
789 | 787 |
|
790 | 788 | public void testChunkedInfer_BatchesCallsChunkingSettingsSet() throws IOException { |
791 | | - var model = ElasticInferenceServiceDenseTextEmbeddingsModelTests.createModel( |
792 | | - getUrl(webServer), |
793 | | - "my-dense-model-id", |
794 | | - createRandomChunkingSettings() |
795 | | - ); |
796 | | - |
797 | | - testChunkedInfer_BatchesCalls(model); |
798 | | - } |
| 789 | + var model = ElasticInferenceServiceDenseTextEmbeddingsModelTests.createModel(getUrl(webServer), "my-dense-model-id"); |
799 | 790 |
|
800 | | - public void testChunkedInfer_ChunkingSettingsNotSet() throws IOException { |
801 | | - var model = ElasticInferenceServiceDenseTextEmbeddingsModelTests.createModel(getUrl(webServer), "my-dense-model-id", null); |
802 | | - |
803 | | - testChunkedInfer_BatchesCalls(model); |
804 | | - } |
805 | | - |
806 | | - private void testChunkedInfer_BatchesCalls(ElasticInferenceServiceDenseTextEmbeddingsModel model) throws IOException { |
807 | 791 | var senderFactory = HttpRequestSenderTests.createSenderFactory(threadPool, clientManager); |
808 | 792 |
|
809 | 793 | try (var service = createService(senderFactory, getUrl(webServer))) { |
@@ -871,12 +855,9 @@ private void testChunkedInfer_BatchesCalls(ElasticInferenceServiceDenseTextEmbed |
871 | 855 | assertArrayEquals(new float[] { 0.987f, -0.654f, 0.321f }, embedding.values(), 0.0f); |
872 | 856 | } |
873 | 857 |
|
874 | | - MatcherAssert.assertThat(webServer.requests(), hasSize(1)); |
| 858 | + assertThat(webServer.requests(), hasSize(1)); |
875 | 859 | assertNull(webServer.requests().getFirst().getUri().getQuery()); |
876 | | - MatcherAssert.assertThat( |
877 | | - webServer.requests().getFirst().getHeader(HttpHeaders.CONTENT_TYPE), |
878 | | - equalTo(XContentType.JSON.mediaType()) |
879 | | - ); |
| 860 | + assertThat(webServer.requests().getFirst().getHeader(HttpHeaders.CONTENT_TYPE), equalTo(XContentType.JSON.mediaType())); |
880 | 861 |
|
881 | 862 | var requestMap = entityAsMap(webServer.requests().getFirst().getBody()); |
882 | 863 | MatcherAssert.assertThat( |
|
0 commit comments