Skip to content
Open
Changes from all commits
Commits
Show all changes
22 commits
Select commit Hold shift + click to select a range
20eccfa
feat: Attempt to sync all streams instead of crashing on the first error
edgarrmondragon Mar 6, 2026
5dc0393
refactor: Annotate `Context` parameter type as a mutable mapping
edgarrmondragon Mar 6, 2026
4cbc377
chore: Update types in parent-child test
edgarrmondragon Mar 6, 2026
f80df50
refactor: Reraise stream errors as sync abortions
edgarrmondragon Mar 6, 2026
addb3cc
test: Add snapshot test
edgarrmondragon Mar 6, 2026
c436f33
fix: Child failure means partial parent success
edgarrmondragon Mar 6, 2026
4de1384
refactor: Reorganize code
edgarrmondragon Mar 6, 2026
417cd73
refactor: Remove superfluous exception catches
edgarrmondragon Mar 6, 2026
58b31d9
Revert "refactor: Annotate `Context` parameter type as a mutable mapp…
edgarrmondragon Mar 6, 2026
f23d3e1
refactor: Simplify a bit
edgarrmondragon Mar 6, 2026
351ce2b
test: Remove redundant tests
edgarrmondragon Mar 6, 2026
b683354
refactor: Remove redundant log
edgarrmondragon Mar 6, 2026
90c8ce9
test: Simplify tests
edgarrmondragon Mar 6, 2026
7651893
refactor: Make `combine` an instance method
edgarrmondragon Mar 6, 2026
f4aeaaf
refactor: Mention error
edgarrmondragon Mar 6, 2026
c5240e6
fix: Handle exit codes
edgarrmondragon Mar 6, 2026
127a7e0
Merge branch 'feat/safely-ignore-errors' into feature/continue-errors
edgarrmondragon Mar 11, 2026
7836109
refactor: Return `SyncResult`
edgarrmondragon Mar 14, 2026
2704bb7
Merge branch 'feat/safely-ignore-errors' into feature/continue-errors
edgarrmondragon Mar 20, 2026
010c703
Merge branch 'feat/safely-ignore-errors' into feature/continue-errors
edgarrmondragon Mar 24, 2026
5395658
Merge branch 'feat/safely-ignore-errors' into feature/continue-errors
edgarrmondragon Mar 30, 2026
3406325
Merge branch 'feat/safely-ignore-errors' into feature/continue-errors
edgarrmondragon Apr 24, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions singer_sdk/streams/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -156,6 +156,14 @@ def __init__(
self.child_streams: list[Stream] = []
self.sync_result: SyncResult | None = None

# Initialize state manager
self._state_manager = StreamStateManager(
tap_name=tap.name,
stream_name=self.name,
tap_state=self._tap_state,
state_partitioning_keys=self._state_partitioning_keys,
)

if schema:
if isinstance(schema, (PathLike, str)):
if not Path(schema).is_file(): # ty: ignore[invalid-argument-type]
Expand Down
Loading