spotless

Author: samxbr

x-pack/plugin/slm/src/internalClusterTest/java/org/elasticsearch/xpack/slm/SLMSnapshotBlockingIntegTests.java

@@ -423,29 +423,29 @@ public void testSLMWithMasterFailover() throws Exception {
             assertEquals(0, policy.getPolicyStats().getSnapshotFailedCount());
             assertEquals(2, policy.getPolicyStats().getSnapshotTakenCount());
         });
-//
-//        final String snapshotName = executePolicy(policyName);
-//        assertBusy(() -> {
-//            final SnapshotInfo snapshotInfo;
-//            try {
-//                GetSnapshotsResponse snapshotsStatusResponse = clusterAdmin().prepareGetSnapshots(TEST_REQUEST_TIMEOUT, REPO)
-//                    .setSnapshots(snapshotName)
-//                    .get();
-//                snapshotInfo = snapshotsStatusResponse.getSnapshots().get(0);
-//            } catch (SnapshotMissingException sme) {
-//                throw new AssertionError(sme);
-//            }
-//            assertEquals(SnapshotState.SUCCESS, snapshotInfo.state());
-//        }, 30L, TimeUnit.SECONDS);
-//
-//        assertBusy(() -> {
-//            SnapshotLifecyclePolicyItem policy = client().execute(
-//                GetSnapshotLifecycleAction.INSTANCE,
-//                new GetSnapshotLifecycleAction.Request(TEST_REQUEST_TIMEOUT, TEST_REQUEST_TIMEOUT, policyName)
-//            ).get().getPolicies().getFirst();
-//            assertNotNull(policy.getLastSuccess());
-//            assertNull(policy.getLastFailure());
-//        }, 30L, TimeUnit.SECONDS);
+        //
+        // final String snapshotName = executePolicy(policyName);
+        // assertBusy(() -> {
+        // final SnapshotInfo snapshotInfo;
+        // try {
+        // GetSnapshotsResponse snapshotsStatusResponse = clusterAdmin().prepareGetSnapshots(TEST_REQUEST_TIMEOUT, REPO)
+        // .setSnapshots(snapshotName)
+        // .get();
+        // snapshotInfo = snapshotsStatusResponse.getSnapshots().get(0);
+        // } catch (SnapshotMissingException sme) {
+        // throw new AssertionError(sme);
+        // }
+        // assertEquals(SnapshotState.SUCCESS, snapshotInfo.state());
+        // }, 30L, TimeUnit.SECONDS);
+        //
+        // assertBusy(() -> {
+        // SnapshotLifecyclePolicyItem policy = client().execute(
+        // GetSnapshotLifecycleAction.INSTANCE,
+        // new GetSnapshotLifecycleAction.Request(TEST_REQUEST_TIMEOUT, TEST_REQUEST_TIMEOUT, policyName)
+        // ).get().getPolicies().getFirst();
+        // assertNotNull(policy.getLastSuccess());
+        // assertNull(policy.getLastFailure());
+        // }, 30L, TimeUnit.SECONDS);
 
     }
 

x-pack/plugin/slm/src/main/java/org/elasticsearch/xpack/slm/SnapshotLifecycleTask.java

@@ -553,9 +553,11 @@ public ClusterState execute(ClusterState currentState) throws Exception {
                                     snapshotInfo.snapshotId().getName(),
                                     snapshotInfo.startTime(),
                                     snapshotInfo.endTime(),
-                                    String.format(Locale.ROOT,
+                                    String.format(
+                                        Locale.ROOT,
                                         "found non-successful registered snapshot [%s] which is no longer running",
-                                        snapshotInfo.snapshotId().getName())
+                                        snapshotInfo.snapshotId().getName()
+                                    )
                                 )
                             );
                             newPolicyMetadata.incrementInvocationsSinceLastSuccess();