Skip to content

Commit b9fe92a

Browse files
feat: add stream_interval support to record transformation
Co-Authored-By: [email protected] <[email protected]>
1 parent 71f8db2 commit b9fe92a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

airbyte_cdk/sources/declarative/transformations/transformation.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ def transform(
2222
config: Optional[Config] = None,
2323
stream_state: Optional[StreamState] = None,
2424
stream_slice: Optional[StreamSlice] = None,
25+
stream_interval: Optional[Dict[str, Any]] = None,
2526
) -> None:
2627
"""
2728
Transform a record by adding, deleting, or mutating fields directly from the record reference passed in argument.
@@ -30,6 +31,7 @@ def transform(
3031
:param config: The user-provided configuration as specified by the source's spec
3132
:param stream_state: The stream state
3233
:param stream_slice: The stream slice
34+
:param stream_interval: The stream interval for incremental sync values
3335
:return: The transformed record
3436
"""
3537

0 commit comments

Comments
 (0)