Skip to content

Commit a4b6051

Browse files
feat: log concurrency configuration at startup for debugging
Co-Authored-By: unknown <>
1 parent 7f41401 commit a4b6051

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -233,6 +233,13 @@ def __init__(
233233
concurrency_level = self._LOWEST_SAFE_CONCURRENCY_LEVEL
234234
initial_number_of_partitions_to_generate = self._LOWEST_SAFE_CONCURRENCY_LEVEL // 2
235235

236+
self.logger.info(
237+
"Concurrency configuration: concurrency_level=%d, initial_number_of_partitions_to_generate=%d, concurrency_level_from_manifest=%s",
238+
concurrency_level,
239+
initial_number_of_partitions_to_generate,
240+
"defined" if concurrency_level_from_manifest else "not_defined",
241+
)
242+
236243
self._concurrent_source = ConcurrentSource.create(
237244
num_workers=concurrency_level,
238245
initial_number_of_partitions_to_generate=initial_number_of_partitions_to_generate,

0 commit comments

Comments
 (0)