fix(concurrent-cdk): enforce runtime cap on concurrent partition generators to prevent deadlock#1015

Open

Anatolii Yatsuk (tolik0) wants to merge 7 commits into

mainfrom

tolik0/concurrent-source/fix-concurrent-generator-starvation-deadlock

Commits on May 7, 2026

fix(concurrent-cdk): enforce runtime cap on concurrent partition generators to prevent thread pool starvation deadlock

Anatolii Yatsuk (tolik0)
and
Claude (claude)
committed
Auto-fix lint and format issues
octavia-squidington-iii
committed
fixup: validate max_concurrent_partition_generators and add debug log on cap guard

Anatolii Yatsuk (tolik0)
and
Claude (claude)
committed
Auto-fix lint and format issues
octavia-squidington-iii
committed
fixup: clarify max_concurrent_partition_generators docstring for single-threaded mode

Anatolii Yatsuk (tolik0)
and
Claude (claude)
committed
fixup: validate initial_number_of_partitions_to_generate >= 1 in ConcurrentSource.create()

Anatolii Yatsuk (tolik0)
and
Claude (claude)
committed
test: cover ValueError for invalid max_concurrent_partition_generators values

Anatolii Yatsuk (tolik0)
and
Claude (claude)
committed