Skip to content

Commit 7d0c069

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent 3c94fb3 commit 7d0c069

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1439,7 +1439,9 @@ def create_concurrent_cursor_from_perpartition_cursor(
14391439
stream_state = self.apply_stream_state_migrations(stream_state_migrations, stream_state)
14401440

14411441
# Per-partition state doesn't make sense for GroupingPartitionRouter, so force the global state
1442-
use_global_cursor = isinstance(partition_router, GroupingPartitionRouter) or component_definition.get("global_substream_cursor", False)
1442+
use_global_cursor = isinstance(
1443+
partition_router, GroupingPartitionRouter
1444+
) or component_definition.get("global_substream_cursor", False)
14431445

14441446
# Return the concurrent cursor and state converter
14451447
return ConcurrentPerPartitionCursor(

0 commit comments

Comments
 (0)