From b9fe92a23244019d865a752b8df8776aaee6966a Mon Sep 17 00:00:00 2001 From: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> Date: Fri, 7 Feb 2025 22:09:07 +0000 Subject: [PATCH] feat: add stream_interval support to record transformation Co-Authored-By: natik@airbyte.io --- .../sources/declarative/transformations/transformation.py | 2 ++ 1 file changed, 2 insertions(+) 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 """