Repository navigation

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

Merged

Anatolii Yatsuk (tolik0) merged 7 commits into

mainfrom

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

May 19, 2026

Merged

fix(concurrent-cdk): enforce runtime cap on concurrent partition generators to prevent deadlock#1015
Anatolii Yatsuk (tolik0) merged 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
  3012695
- Auto-fix lint and format issues
  octavia-squidington-iii
  committed
  3ce4738
- fixup: validate max_concurrent_partition_generators and add debug log on cap guard
  
  Anatolii Yatsuk (tolik0)
  and
  Claude (claude)
  committed
  5a1ba16
- Auto-fix lint and format issues
  octavia-squidington-iii
  committed
  e8fa436
- fixup: clarify max_concurrent_partition_generators docstring for single-threaded mode
  
  Anatolii Yatsuk (tolik0)
  and
  Claude (claude)
  committed
  ab17e2c
- fixup: validate initial_number_of_partitions_to_generate >= 1 in ConcurrentSource.create()
  
  Anatolii Yatsuk (tolik0)
  and
  Claude (claude)
  committed
  4c69e54
- test: cover ValueError for invalid max_concurrent_partition_generators values
  
  Anatolii Yatsuk (tolik0)
  and
  Claude (claude)
  committed
  5990d45