File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -2069,7 +2069,9 @@ def create_declarative_stream(
20692069 # We specifically exclude Connector Builder stuff for now as Brian is working on this anyway
20702070
20712071 stream_name = model .name or ""
2072- stream_slicer : ConcurrentStreamSlicer = concurrent_cursor if concurrent_cursor else SinglePartitionRouter ()
2072+ stream_slicer : ConcurrentStreamSlicer = (
2073+ concurrent_cursor if concurrent_cursor else SinglePartitionRouter (parameters = {})
2074+ )
20732075 cursor : Cursor = FinalStateCursor (stream_name , None , self ._message_repository )
20742076 if isinstance (retriever , AsyncRetriever ):
20752077 # The AsyncRetriever only ever worked with a cursor from the concurrent package. Hence, the method
You can’t perform that action at this time.
0 commit comments