airbyte_cdk.sources.declarative.incremental.declarative_cursor
1# Copyright (c) 2024 Airbyte, Inc., all rights reserved. 2 3from abc import ABC 4 5from airbyte_cdk.sources.declarative.stream_slicers.stream_slicer import StreamSlicer 6from airbyte_cdk.sources.streams.checkpoint.cursor import Cursor 7 8 9class DeclarativeCursor(Cursor, StreamSlicer, ABC): 10 """ 11 DeclarativeCursors are components that allow for checkpointing syncs. In addition to managing the fetching and updating of 12 state, declarative cursors also manage stream slicing and injecting slice values into outbound requests. 13 """
class
DeclarativeCursor(airbyte_cdk.sources.streams.checkpoint.cursor.Cursor, airbyte_cdk.sources.declarative.stream_slicers.stream_slicer.StreamSlicer, abc.ABC):
10class DeclarativeCursor(Cursor, StreamSlicer, ABC): 11 """ 12 DeclarativeCursors are components that allow for checkpointing syncs. In addition to managing the fetching and updating of 13 state, declarative cursors also manage stream slicing and injecting slice values into outbound requests. 14 """
DeclarativeCursors are components that allow for checkpointing syncs. In addition to managing the fetching and updating of state, declarative cursors also manage stream slicing and injecting slice values into outbound requests.