@@ -1876,7 +1876,7 @@ private static Tuple<ClusterState, List<SnapshotDeletionsInProgress.Entry>> read
18761876 && entry .state () == SnapshotDeletionsInProgress .State .WAITING
18771877 && snapshotsInProgress .forRepo (projectRepo )
18781878 .stream ()
1879- .noneMatch (SnapshotsService ::isWritingToRepositoryOrQueueWithGeneration )) {
1879+ .noneMatch (SnapshotsService ::isWritingToRepositoryOrAssignedQueued )) {
18801880 changed = true ;
18811881 final SnapshotDeletionsInProgress .Entry newEntry = entry .started ();
18821882 readyDeletions .add (newEntry );
@@ -2370,7 +2370,7 @@ public ClusterState execute(ClusterState currentState) {
23702370 repositoryData .getGenId (),
23712371 updatedSnapshots .forRepo (projectId , repositoryName )
23722372 .stream ()
2373- .noneMatch (SnapshotsService ::isWritingToRepositoryOrQueueWithGeneration )
2373+ .noneMatch (SnapshotsService ::isWritingToRepositoryOrAssignedQueued )
23742374 && deletionsInProgress .hasExecutingDeletion (projectId , repositoryName ) == false
23752375 ? SnapshotDeletionsInProgress .State .STARTED
23762376 : SnapshotDeletionsInProgress .State .WAITING
@@ -2452,7 +2452,7 @@ public String toString() {
24522452 * @param entry snapshot entry
24532453 * @return true if entry is currently writing to the repository
24542454 */
2455- private static boolean isWritingToRepositoryOrQueueWithGeneration (SnapshotsInProgress .Entry entry ) {
2455+ private static boolean isWritingToRepositoryOrAssignedQueued (SnapshotsInProgress .Entry entry ) {
24562456 if (entry .state ().completed ()) {
24572457 // Entry is writing to the repo because it's finalizing on master
24582458 return true ;
0 commit comments