Auto-fix lint and format issues

octavia-squidington-iii · octavia-squidington-iii · commit d7337a635575 · 2025-07-30T17:44:40.000Z
diff --git a/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py b/airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -2209,7 +2209,7 @@ def _build_concurrent_cursor(
             )
         elif model.incremental_sync:
             if type(model.incremental_sync) == IncrementingCountCursorModel:
-                return self.create_concurrent_cursor_from_incrementing_count_cursor(    # type: ignore # This is a known issue that we are creating and returning a ConcurrentCursor which does not technically implement the (low-code) StreamSlicer. However, (low-code) StreamSlicer and ConcurrentCursor both implement StreamSlicer.stream_slices() which is the primary method needed for checkpointing
+                return self.create_concurrent_cursor_from_incrementing_count_cursor(  # type: ignore # This is a known issue that we are creating and returning a ConcurrentCursor which does not technically implement the (low-code) StreamSlicer. However, (low-code) StreamSlicer and ConcurrentCursor both implement StreamSlicer.stream_slices() which is the primary method needed for checkpointing
                     model_type=IncrementingCountCursorModel,
                     component_definition=model.incremental_sync.__dict__,
                     stream_name=model.name or "",

Original file line number	Diff line number	Diff line change
`@@ -2209,7 +2209,7 @@ def _build_concurrent_cursor(`
`2209`	`2209`	`)`
`2210`	`2210`	`elif model.incremental_sync:`
`2211`	`2211`	`if type(model.incremental_sync) == IncrementingCountCursorModel:`
`2212`		`- return self.create_concurrent_cursor_from_incrementing_count_cursor( # type: ignore # This is a known issue that we are creating and returning a ConcurrentCursor which does not technically implement the (low-code) StreamSlicer. However, (low-code) StreamSlicer and ConcurrentCursor both implement StreamSlicer.stream_slices() which is the primary method needed for checkpointing`
	`2212`	`+ return self.create_concurrent_cursor_from_incrementing_count_cursor( # type: ignore # This is a known issue that we are creating and returning a ConcurrentCursor which does not technically implement the (low-code) StreamSlicer. However, (low-code) StreamSlicer and ConcurrentCursor both implement StreamSlicer.stream_slices() which is the primary method needed for checkpointing`
`2213`	`2213`	`model_type=IncrementingCountCursorModel,`
`2214`	`2214`	`component_definition=model.incremental_sync.__dict__,`
`2215`	`2215`	`stream_name=model.name or "",`