File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -1718,6 +1718,7 @@ def _build_incremental_cursor(
1718
1718
config = config or {},
1719
1719
)
1720
1720
return self ._create_component_from_model (model = model .incremental_sync , config = config )
1721
+ return None
1721
1722
1722
1723
def _build_resumable_cursor (
1723
1724
self ,
@@ -1748,14 +1749,12 @@ def _merge_stream_slicers(
1748
1749
# support or unordered slices (for example, when we trigger reports for January and February, the report
1749
1750
# in February can be completed first). Once we have support for custom concurrent cursor or have a new
1750
1751
# implementation available in the CDK, we can enable more cursors here.
1751
- raise ValueError (
1752
- "AsyncRetriever with cursor other than DatetimeBasedCursor is not supported yet"
1753
- )
1752
+ raise ValueError ("AsyncRetriever with cursor other than DatetimeBasedCursor is not supported yet." )
1754
1753
1755
1754
if model .retriever .type == "AsyncRetriever" and model .retriever .partition_router :
1756
1755
# Note that this development is also done in parallel to the per partition development which once merged
1757
1756
# we could support here by calling `create_concurrent_cursor_from_perpartition_cursor`
1758
- raise ValueError ("Per partition state is not supported yet for AsyncRetriever" )
1757
+ raise ValueError ("Per partition state is not supported yet for AsyncRetriever. " )
1759
1758
1760
1759
stream_slicer = self ._build_stream_slicer_from_partition_router (model .retriever , config )
1761
1760
You can’t perform that action at this time.
0 commit comments