From f30e767fbde9cb76859d5847b0ebd9e4cec91433 Mon Sep 17 00:00:00 2001 From: Tomoyuki Morita Date: Wed, 13 Nov 2024 16:26:15 -0800 Subject: [PATCH] Reformat Signed-off-by: Tomoyuki Morita --- .../leasemanager/DefaultLeaseManagerTest.java | 15 +++++++++------ 1 file changed, 9 insertions(+), 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 index 2d5f27dd62..a7ea6aa22f 100644 --- 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