diff --git a/airbyte_cdk/sources/declarative/transformations/transformation.py b/airbyte_cdk/sources/declarative/transformations/transformation.py index f5b226429..d76a0e61b 100644 --- a/airbyte_cdk/sources/declarative/transformations/transformation.py +++ b/airbyte_cdk/sources/declarative/transformations/transformation.py @@ -22,6 +22,7 @@ def transform( config: Optional[Config] = None, stream_state: Optional[StreamState] = None, stream_slice: Optional[StreamSlice] = None, + stream_interval: Optional[Dict[str, Any]] = None, ) -> None: """ Transform a record by adding, deleting, or mutating fields directly from the record reference passed in argument. @@ -30,6 +31,7 @@ def transform( :param config: The user-provided configuration as specified by the source's spec :param stream_state: The stream state :param stream_slice: The stream slice + :param stream_interval: The stream interval for incremental sync values :return: The transformed record """