Skip to content

Commit 6498528

Browse files
committed
Fix format
1 parent 667700f commit 6498528

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airbyte_cdk/sources/declarative/incremental/concurrent_partition_cursor.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -150,8 +150,8 @@ def close_partition(self, partition: Partition) -> None:
150150
self._cursor_per_partition[partition_key].close_partition(partition=partition)
151151
cursor = self._cursor_per_partition[partition_key]
152152
if (
153-
partition_key in self._finished_partitions
154-
and self._semaphore_per_partition[partition_key]._value == 0
153+
partition_key in self._finished_partitions
154+
and self._semaphore_per_partition[partition_key]._value == 0
155155
):
156156
self._update_global_cursor(cursor.state[self.cursor_field.cursor_field_key])
157157
self._emit_state_message()

0 commit comments

Comments
 (0)