fmt

slackhq · Nov 8, 2024 · ae205cf · ae205cf
1 parent 0cc5822
commit ae205cf
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/astra/src/main/java/com/slack/astra/metadata/core/AstraPartitioningMetadataStore.java b/astra/src/main/java/com/slack/astra/metadata/core/AstraPartitioningMetadataStore.java
@@ -230,7 +230,9 @@ public CompletionStage<T> findAsync(String path) {
    */
   public T findSync(String path) {
     try {
-      return findAsync(path).toCompletableFuture().get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS);
+      return findAsync(path)
+          .toCompletableFuture()
+          .get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS);
     } catch (InterruptedException | ExecutionException | TimeoutException e) {
       throw new InternalMetadataStoreException("Error fetching node at path " + path, e);
     }
@@ -283,7 +285,9 @@ public CompletableFuture<List<T>> listAsync() {
 
   public List<T> listSync() {
     try {
-      return listAsync().toCompletableFuture().get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS);
+      return listAsync()
+          .toCompletableFuture()
+          .get(zkConfig.getZkConnectionTimeoutMs(), TimeUnit.MILLISECONDS);
     } catch (ExecutionException | InterruptedException | TimeoutException e) {
       throw new InternalMetadataStoreException("Error listing nodes", e);
     }