spotlessApply

masseyke · Dec 12, 2024 · 0f0eafa · 0f0eafa
1 parent c514089
commit 0f0eafa
Showing 1 changed file with 11 additions and 15 deletions.
diff --git a/...n/java/org/elasticsearch/xpack/migrate/action/CancelReindexDataStreamTransportAction.java b/...n/java/org/elasticsearch/xpack/migrate/action/CancelReindexDataStreamTransportAction.java
@@ -90,23 +90,19 @@ private void cancelTaskOnThisNode(String persistentTaskId, ActionListener<Acknow
             );
         } else {
             // Calling sendRemoveRequest results in the task (and its child tasks) being cancelled
-            persistentTasksService.sendRemoveRequest(
-                persistentTaskId,
-                TimeValue.MAX_VALUE,
-                new ActionListener<>() {
-                    @Override
-                    public void onResponse(PersistentTasksCustomMetadata.PersistentTask<?> persistentTask) {
-                        // Calling unregister removes the task from the /_tasks list
-                        taskManager.unregister(runningTask);
-                        listener.onResponse(AcknowledgedResponse.TRUE);
-                    }
+            persistentTasksService.sendRemoveRequest(persistentTaskId, TimeValue.MAX_VALUE, new ActionListener<>() {
+                @Override
+                public void onResponse(PersistentTasksCustomMetadata.PersistentTask<?> persistentTask) {
+                    // Calling unregister removes the task from the /_tasks list
+                    taskManager.unregister(runningTask);
+                    listener.onResponse(AcknowledgedResponse.TRUE);
+                }
 
-                    @Override
-                    public void onFailure(Exception e) {
-                        listener.onFailure(e);
-                    }
+                @Override
+                public void onFailure(Exception e) {
+                    listener.onFailure(e);
                 }
-            );
+            });
         }
     }