Get Shard Generations from source metadata as well

Signed-off-by: Gaurav Bafna <[email protected]>
gbbafna · Oct 16, 2024 · f36691d · f36691d
1 parent e77aefe
commit f36691d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/snapshots/SnapshotsService.java b/server/src/main/java/org/opensearch/snapshots/SnapshotsService.java
@@ -962,8 +962,6 @@ public void clusterStateProcessed(String source, ClusterState oldState, final Cl
                 final Executor executor = threadPool.executor(ThreadPool.Names.SNAPSHOT);
 
                 executor.execute(ActionRunnable.supply(snapshotInfoListener, () -> repository.getSnapshotInfo(sourceSnapshotId)));
-                final ShardGenerations shardGenerations = repositoryData.shardGenerations();
-
                 snapshotInfoListener.whenComplete(snapshotInfo -> {
                     final SnapshotInfo cloneSnapshotInfo = new SnapshotInfo(
                         snapshot.getSnapshotId(),
@@ -1000,6 +998,7 @@ public void clusterStateProcessed(String source, ClusterState oldState, final Cl
                         }
                     );
                     metadataListener.whenComplete(meta -> {
+                        ShardGenerations shardGenerations = buildGenerations(newEntry, meta);
                         repository.finalizeSnapshot(
                             shardGenerations,
                             repositoryData.getGenId(),