Repository navigation

feat: Add block_simultaneous_read with stream_groups + fix default HTTP timeout - #940

Closed

Alfredo Garcia (agarctfi) wants to merge 31 commits into

mainfrom

devin/1772836274-block-simultaneous-read-with-timeout

Closed

feat: Add block_simultaneous_read with stream_groups + fix default HTTP timeout#940
Alfredo Garcia (agarctfi) wants to merge 31 commits into
mainfrom
devin/1772836274-block-simultaneous-read-with-timeout

Commits on Mar 6, 2026
- Add block_simultaneous_read to DefaultStream
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  52900d1
- Change `block_simultaneous_read` to string
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  0b8561e
- Fix StreamFacade
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  c6e89c1
- Fix NoneType error when all streams are blocked
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  4868f26
- Fix unit tests
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  6b614b3
- Auto-fix lint and format issues
  
  octavia-squidington-iii
  authored and
  devin-ai-integration[bot]
  committed
  46e7c19
- Add retry deferred streams on stream completion
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  b82dfbc
- Fix unit tests
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  0c0f4ef
- More fixes for unit tests
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  cc1d47c
- refactor: replace per-stream block_simultaneous_read with top-level stream_groups
  devin-ai-integration[bot]
  committed
  6f5b4ea
- refactor: move stream_name_to_group into ModelToComponentFactory
  devin-ai-integration[bot]
  committed
  d5ff69e
- refactor: use stream_groups manifest in factory test instead of hardcoded dict
  devin-ai-integration[bot]
  committed
  5ed978f
- fix: only include parent stream in stream_groups to avoid deadlock
  devin-ai-integration[bot]
  committed
  b41a4b3
- style: fix ruff format for long line
  devin-ai-integration[bot]
  committed
  a231e8c
- refactor: move _build_stream_name_to_group into ModelToComponentFactory
  devin-ai-integration[bot]
  committed
  d3c8067
- refactor: resolve stream_groups from actual stream instances instead of factory
  devin-ai-integration[bot]
  committed
  3a3cf8b
- Fix stream format in schema
  
  Anatolii Yatsuk (tolik0)
  authored and
  devin-ai-integration[bot]
  committed
  7ccf6cf
- refactor: add get_partition_router() helper to DefaultStream
  devin-ai-integration[bot]
  committed
  8d3b1f2
- feat: validate no parent-child streams share a group to prevent deadlock
  devin-ai-integration[bot]
  committed
  77b25c5
- feat: assert partition generation queue is empty when all streams are done
  devin-ai-integration[bot]
  committed
  3014458
- refactor: move inline imports to module level in default_stream.py and concurrent_declarative_source.py
  devin-ai-integration[bot]
  committed
  48711d3
- fix: unwrap GroupingPartitionRouter in get_partition_router() to detect parent streams
  devin-ai-integration[bot]
  committed
  5e4ed38
- fix: handle GroupingPartitionRouter at call sites instead of in get_partition_router()
  devin-ai-integration[bot]
  committed
  0e710d2
- feat: check active_groups is empty in is_done() safety check
  devin-ai-integration[bot]
  committed
  a0fbd89
- test: add missing unit tests for GroupingPartitionRouter, active_groups check, and get_partition_router
  devin-ai-integration[bot]
  committed
  d8ef4fa
- fix: make deadlock validation check all ancestors, not just direct parents
  devin-ai-integration[bot]
  committed
  f000313
- style: alphabetize StreamGroup and BlockSimultaneousSyncsAction in schema definitions
  devin-ai-integration[bot]
  committed
  68850ec
- style: move BlockSimultaneousSyncsAction next to StreamGroup for easier reading
  devin-ai-integration[bot]
  committed
  b183f80
- fix: add default HTTP request timeout to prevent indefinite hangs
  
  devin-ai-integration[bot]
  and
  Alfredo Garcia (agarctfi)
  committed
  e1bd626
- fix: match test assertions against AirbyteTracedException message field
  
  devin-ai-integration[bot]
  and
  Alfredo Garcia (agarctfi)
  committed
  29951b2
- style: fix ruff format in test_concurrent_read_processor.py
  
  devin-ai-integration[bot]
  and
  Alfredo Garcia (agarctfi)
  committed
  b0537da

Commits

Commits on Mar 6, 2026