Reformat

Signed-off-by: Tomoyuki Morita <[email protected]>
opensearch-project · Nov 14, 2024 · f30e767 · f30e767
1 parent 278a9c2
commit f30e767
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/async-query/src/test/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManagerTest.java b/async-query/src/test/java/org/opensearch/sql/spark/leasemanager/DefaultLeaseManagerTest.java
@@ -31,12 +31,15 @@ public void leaseManagerRejectsJobs() {
     DefaultLeaseManager defaultLeaseManager = new DefaultLeaseManager(settings, stateStore);
 
     defaultLeaseManager.borrow(getLeaseRequest(JobType.BATCH));
-    assertThrows(ConcurrencyLimitExceededException.class, () ->
-    defaultLeaseManager.borrow(getLeaseRequest(JobType.INTERACTIVE)));
-    assertThrows(ConcurrencyLimitExceededException.class, () ->
-    defaultLeaseManager.borrow(getLeaseRequest(JobType.STREAMING)));
-    assertThrows(ConcurrencyLimitExceededException.class, () ->
-    defaultLeaseManager.borrow(getLeaseRequest(JobType.REFRESH)));
+    assertThrows(
+        ConcurrencyLimitExceededException.class,
+        () -> defaultLeaseManager.borrow(getLeaseRequest(JobType.INTERACTIVE)));
+    assertThrows(
+        ConcurrencyLimitExceededException.class,
+        () -> defaultLeaseManager.borrow(getLeaseRequest(JobType.STREAMING)));
+    assertThrows(
+        ConcurrencyLimitExceededException.class,
+        () -> defaultLeaseManager.borrow(getLeaseRequest(JobType.REFRESH)));
   }
 
   @Test