Skip to content

Commit 644c208

Browse files
committed
Use Sequential Field Fetchers
1 parent 26ca445 commit 644c208

1 file changed

Lines changed: 1 addition & 12 deletions

File tree

openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/EntityRepository.java

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -6908,18 +6908,7 @@ public static void validateColumn(Table table, String columnName, Boolean caseSe
69086908
}
69096909

69106910
protected void fetchAndSetFields(List<T> entities, Fields fields) {
6911-
if (fieldFetchers.size() <= 1) {
6912-
fieldFetchers.values().forEach(fetcher -> fetcher.accept(entities, fields));
6913-
return;
6914-
}
6915-
List<CompletableFuture<Void>> futures =
6916-
fieldFetchers.values().stream()
6917-
.map(
6918-
fetcher ->
6919-
CompletableFuture.runAsync(
6920-
() -> fetcher.accept(entities, fields), FIELD_FETCH_EXECUTOR))
6921-
.toList();
6922-
CompletableFuture.allOf(futures.toArray(CompletableFuture[]::new)).join();
6911+
fieldFetchers.values().forEach(fetcher -> fetcher.accept(entities, fields));
69236912
}
69246913

69256914
private void fetchAndSetOwners(List<T> entities, Fields fields) {

0 commit comments

Comments
 (0)