fix: next level concurrency

erezrokah · erezrokah · commit 823d9d743a89 · 2023-08-24T08:45:48.000+02:00
diff --git a/lib/src/main/java/io/cloudquery/scheduler/Scheduler.java b/lib/src/main/java/io/cloudquery/scheduler/Scheduler.java
@@ -30,7 +30,7 @@ private void resolveTables(List<Table> tables, Resource parent, int concurrency)
     if (tables == null || tables.isEmpty()) {
       return;
     }
-    ExecutorService executor = Executors.newFixedThreadPool(Math.min(tables.size(), concurrency));
+    ExecutorService executor = Executors.newFixedThreadPool(Math.max(tables.size(), concurrency));
     for (Table table : tables) {
       final int nextLevelConcurrency = Math.max(1, concurrency / 2);
       executor.submit(

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@ private void resolveTables(List<Table> tables, Resource parent, int concurrency)`
`30`	`30`	`if (tables == null \|\| tables.isEmpty()) {`
`31`	`31`	`return;`
`32`	`32`	`}`
`33`		`- ExecutorService executor = Executors.newFixedThreadPool(Math.min(tables.size(), concurrency));`
	`33`	`+ ExecutorService executor = Executors.newFixedThreadPool(Math.max(tables.size(), concurrency));`
`34`	`34`	`for (Table table : tables) {`
`35`	`35`	`final int nextLevelConcurrency = Math.max(1, concurrency / 2);`
`36`	`36`	`executor.submit(`