We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eb612f9 commit eeff98cCopy full SHA for eeff98c
airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py
@@ -281,7 +281,10 @@ def _generate_slices_from_partition(
281
self._number_of_partitions += 1
282
self._cursor_per_partition[partition_key] = cursor
283
284
- if not self._IS_PARTITION_DUPLICATION_LOGGED and partition_key in self._semaphore_per_partition:
+ if (
285
+ not self._IS_PARTITION_DUPLICATION_LOGGED
286
+ and partition_key in self._semaphore_per_partition
287
+ ):
288
logger.warning(f"Partition duplication detected for stream {self._stream_name}")
289
self._IS_PARTITION_DUPLICATION_LOGGED = True
290
else:
0 commit comments