Fix CorruptedBlobStoreRepositoryIT tests

Signed-off-by: Ashish Singh <[email protected]>
ashking94 · Sep 4, 2024 · 00da4f3 · 00da4f3
1 parent f67be03
commit 00da4f3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...src/internalClusterTest/java/org/opensearch/snapshots/CorruptedBlobStoreRepositoryIT.java b/...src/internalClusterTest/java/org/opensearch/snapshots/CorruptedBlobStoreRepositoryIT.java
@@ -458,7 +458,7 @@ public void testHandleSnapshotErrorWithBwCFormat() throws IOException, Execution
         // not break subsequent repository operations
         logger.info("--> move shard level metadata to new generation");
         final IndexId indexId = getRepositoryData(repoName).resolveIndexId(indexName);
-        final Path shardPath = repoPath.resolve("indices").resolve(indexId.getId()).resolve("0");
+        final Path shardPath = repoPath.resolve(resolvePath(indexId, "0"));
         final Path initialShardMetaPath = shardPath.resolve(BlobStoreRepository.INDEX_FILE_PREFIX + "0");
         assertFileExists(initialShardMetaPath);
         Files.move(initialShardMetaPath, shardPath.resolve(BlobStoreRepository.INDEX_FILE_PREFIX + "1"));
@@ -487,8 +487,9 @@ public void testRepairBrokenShardGenerations() throws Exception {
 
         logger.info("--> move shard level metadata to new generation and make RepositoryData point at an older generation");
         final IndexId indexId = getRepositoryData(repoName).resolveIndexId(indexName);
-        final Path shardPath = repoPath.resolve("indices").resolve(indexId.getId()).resolve("0");
+        final Path shardPath = repoPath.resolve(resolvePath(indexId, "0"));
         final Path initialShardMetaPath = shardPath.resolve(BlobStoreRepository.INDEX_FILE_PREFIX + "0");
+
         assertFileExists(initialShardMetaPath);
         Files.move(initialShardMetaPath, shardPath.resolve(BlobStoreRepository.INDEX_FILE_PREFIX + randomIntBetween(1, 1000)));