🐛 concurrent-cdk: Do not set the max number of tasks to the number of…

… workers (#32971) Co-authored-by: girarda <girarda@users.noreply.github.com>
airbytehq · Nov 30, 2023 · 6671bce · 6671bce
1 parent a6d463f
commit 6671bce
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airbyte-cdk/python/airbyte_cdk/sources/concurrent_source/concurrent_source.py b/airbyte-cdk/python/airbyte_cdk/sources/concurrent_source/concurrent_source.py
@@ -40,7 +40,8 @@ def create(
         timeout_seconds: int = DEFAULT_TIMEOUT_SECONDS,
     ) -> "ConcurrentSource":
         threadpool = ThreadPoolManager(
-            concurrent.futures.ThreadPoolExecutor(max_workers=num_workers, thread_name_prefix="workerpool"), logger, num_workers
+            concurrent.futures.ThreadPoolExecutor(max_workers=num_workers, thread_name_prefix="workerpool"),
+            logger,
         )
         return ConcurrentSource(
             threadpool, logger, slice_logger, message_repository, initial_number_of_partitions_to_generate, timeout_seconds