diff --git a/.github/workflows/java.yml b/.github/workflows/java.yml index 71edbe18c7..41e0cc9b66 100644 --- a/.github/workflows/java.yml +++ b/.github/workflows/java.yml @@ -201,24 +201,24 @@ jobs: cargo-toml-folder: ./java name: lint java rust - start-self-hosted-runner: - if: github.repository_owner == 'valkey-io' - runs-on: ubuntu-latest - environment: AWS_ACTIONS - steps: - - name: Checkout - uses: actions/checkout@v4 - - - name: Start self hosted EC2 runner - uses: ./.github/workflows/start-self-hosted-runner - with: - role-to-assume: ${{ secrets.ROLE_TO_ASSUME }} - aws-region: ${{ secrets.AWS_REGION }} - ec2-instance-id: ${{ secrets.AWS_EC2_INSTANCE_ID }} +# start-self-hosted-runner: +# if: github.repository_owner == 'valkey-io' +# runs-on: ubuntu-latest +# environment: AWS_ACTIONS +# steps: +# - name: Checkout +# uses: actions/checkout@v4 +# +# - name: Start self hosted EC2 runner +# uses: ./.github/workflows/start-self-hosted-runner +# with: +# role-to-assume: ${{ secrets.ROLE_TO_ASSUME }} +# aws-region: ${{ secrets.AWS_REGION }} +# ec2-instance-id: ${{ secrets.AWS_EC2_INSTANCE_ID }} test-modules: if: github.repository_owner == 'valkey-io' - needs: [start-self-hosted-runner] +# needs: [start-self-hosted-runner] name: Running Module Tests runs-on: [self-hosted, linux, ARM64] timeout-minutes: 15 diff --git a/java/integTest/src/test/java/glide/modules/VectorSearchTests.java b/java/integTest/src/test/java/glide/modules/VectorSearchTests.java index 127bebddb5..6e6749a4fa 100644 --- a/java/integTest/src/test/java/glide/modules/VectorSearchTests.java +++ b/java/integTest/src/test/java/glide/modules/VectorSearchTests.java @@ -15,6 +15,7 @@ import glide.api.BaseClient; import glide.api.GlideClient; import glide.api.GlideClusterClient; +import glide.api.models.commands.FlushMode; import glide.api.models.commands.vss.FTCreateOptions.DistanceMetric; import glide.api.models.commands.vss.FTCreateOptions.FieldInfo; import glide.api.models.commands.vss.FTCreateOptions.IndexType; @@ -54,6 +55,7 @@ public static void init() { var clusterClient = GlideClusterClient.createClient(commonClusterClientConfig().requestTimeout(5000).build()) .get(); + clusterClient.flushall(FlushMode.SYNC, ALL_PRIMARIES).get(); clients = List.of(/*Arguments.of(standaloneClient),*/ Arguments.of(clusterClient)); } @@ -174,7 +176,7 @@ public void ft_create(BaseClient client) { new FieldInfo[0]) .get()); assertInstanceOf(RequestException.class, exception.getCause()); - assertTrue(exception.getMessage().contains("arguments are missing")); + assertTrue(exception.getMessage().contains("wrong number of arguments")); } @SneakyThrows @@ -282,7 +284,7 @@ public void ft_search(BaseClient client) { .ftsearch(UUID.randomUUID().toString(), "*", FTSearchOptions.builder().build()) .get()); assertInstanceOf(RequestException.class, exception.getCause()); - assertTrue(exception.getMessage().contains("no such index")); + assertTrue(exception.getMessage().contains("Index not found")); } @SneakyThrows @@ -338,6 +340,6 @@ public void ft_drop(BaseClient client) { var exception = assertThrows(ExecutionException.class, () -> client.ftdrop(index).get()); assertInstanceOf(RequestException.class, exception.getCause()); - assertTrue(exception.getMessage().contains("Unknown: Index name")); + assertTrue(exception.getMessage().contains("Index does not exist")); } }