@@ -1378,8 +1378,7 @@ protected void doRun() {
13781378 assert repositoryOperations .assertNotQueued (snapshot );
13791379
13801380 final var entry = SnapshotsInProgress .get (clusterService .state ()).snapshot (snapshot );
1381- final String failure = entry .failure ();
1382- logger .trace ("[{}] finalizing snapshot in repository, state: [{}], failure[{}]" , snapshot , entry .state (), failure );
1381+ logger .trace ("[{}] finalizing snapshot in repository, state: [{}], failure[{}]" , snapshot , entry .state (), entry .failure ());
13831382 final ShardGenerations shardGenerations = buildGenerations (entry , metadata );
13841383 final SubscribableListener <List <ActionListener <SnapshotInfo >>> snapshotListeners = new SubscribableListener <>();
13851384
@@ -1410,18 +1409,17 @@ public void onFailure(Exception e) {
14101409 repositoryDataListener -> {
14111410 final List <String > finalIndices = shardGenerations .indices ().stream ().map (IndexId ::getName ).toList ();
14121411 final Set <String > finalIndicesSet = Set .copyOf (finalIndices );
1413- final List <SnapshotShardFailure > shardFailures = getSnapshotShardFailures (entry , finalIndicesSet );
14141412 final Repository repository = repositoriesService .repository (snapshot .getRepository ());
14151413 final Metadata metaForSnapshot = metadataForSnapshot (entry , prepareMetadata (entry , repository ));
14161414 final SnapshotInfo snapshotInfo = new SnapshotInfo (
14171415 snapshot ,
14181416 finalIndices ,
14191417 entry .dataStreams ().stream ().filter (metaForSnapshot .getProject ().dataStreams ()::containsKey ).toList (),
14201418 entry .partial () ? onlySuccessfulFeatureStates (entry , finalIndicesSet ) : entry .featureStates (),
1421- failure ,
1419+ entry . failure () ,
14221420 threadPool .absoluteTimeInMillis (),
14231421 entry .partial () ? shardGenerations .totalShards () : entry .shardSnapshotStatusByRepoShardId ().size (),
1424- shardFailures ,
1422+ getSnapshotShardFailures ( entry , finalIndicesSet ) ,
14251423 entry .includeGlobalState (),
14261424 entry .userMetadata (),
14271425 entry .startTime (),
@@ -1488,7 +1486,7 @@ private static ShardGenerations buildGenerations(SnapshotsInProgress.Entry snaps
14881486 return builder .build ();
14891487 }
14901488
1491- private List <SnapshotShardFailure > getSnapshotShardFailures (SnapshotsInProgress .Entry entry , Set <String > indexNames ) {
1489+ private static List <SnapshotShardFailure > getSnapshotShardFailures (SnapshotsInProgress .Entry entry , Set <String > indexNames ) {
14921490 final var shardFailures = new ArrayList <SnapshotShardFailure >();
14931491 for (Map .Entry <RepositoryShardId , ShardSnapshotStatus > shardStatus : entry .shardSnapshotStatusByRepoShardId ().entrySet ()) {
14941492 RepositoryShardId shardId = shardStatus .getKey ();
0 commit comments