From e1b11de472769ed2a455d974fcbaaec5aa377cd7 Mon Sep 17 00:00:00 2001 From: Tomasz Szuba Date: Fri, 3 Jan 2025 14:46:42 +0000 Subject: [PATCH] Code lint --- .../declarative/incremental/global_substream_cursor.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py b/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py index 856774e01..e67f1f9e1 100644 --- a/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py +++ b/airbyte_cdk/sources/declarative/incremental/global_substream_cursor.py @@ -112,7 +112,9 @@ def stream_slices(self) -> Iterable[StreamSlice]: * Yield the last slice. At that point, once there are as many slices yielded as closes, the global slice will be closed too """ slice_generator = ( - StreamSlice(partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields) + StreamSlice( + partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields + ) for partition in self._partition_router.stream_slices() for cursor_slice in self._stream_cursor.stream_slices() ) @@ -128,7 +130,9 @@ def stream_slices(self) -> Iterable[StreamSlice]: def generate_slices_from_partition(self, partition: StreamSlice) -> Iterable[StreamSlice]: slice_generator = ( - StreamSlice(partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields) + StreamSlice( + partition=partition, cursor_slice=cursor_slice, extra_fields=partition.extra_fields + ) for cursor_slice in self._stream_cursor.stream_slices() )