File tree Expand file tree Collapse file tree 2 files changed +2
-5
lines changed
airbyte_cdk/sources/declarative/partition_routers
unit_tests/sources/declarative/partition_routers Expand file tree Collapse file tree 2 files changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -149,7 +149,7 @@ def stream_slices(self) -> Iterable[StreamSlice]:
149149 for stream_slice_tuple in product :
150150 partition = dict (ChainMap (* [s .partition for s in stream_slice_tuple ])) # type: ignore # ChainMap expects a MutableMapping[Never, Never] for reasons
151151 cursor_slices = [s .cursor_slice for s in stream_slice_tuple if s .cursor_slice ]
152- extra_fields = dict (ChainMap (* [s .extra_fields for s in stream_slice_tuple ]))
152+ extra_fields = dict (ChainMap (* [s .extra_fields for s in stream_slice_tuple ])) # type: ignore # ChainMap expects a MutableMapping[Never, Never] for reasons
153153 if len (cursor_slices ) > 1 :
154154 raise ValueError (
155155 f"There should only be a single cursor slice. Found { cursor_slices } "
Original file line number Diff line number Diff line change 66
77from airbyte_cdk .models import SyncMode
88from airbyte_cdk .sources .declarative .declarative_stream import DeclarativeStream
9- from airbyte_cdk .sources .declarative .incremental .per_partition_cursor import (
10- StreamSlice ,
11- )
129from airbyte_cdk .sources .declarative .interpolation import InterpolatedString
1310from airbyte_cdk .sources .streams .checkpoint import Cursor
14- from airbyte_cdk .sources .types import Record
11+ from airbyte_cdk .sources .types import Record , StreamSlice
1512
1613
1714class MockStream (DeclarativeStream ):
You can’t perform that action at this time.
0 commit comments