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 a2063dd commit e0e2eedCopy full SHA for e0e2eed
airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -1485,7 +1485,6 @@ def create_concurrent_cursor_from_perpartition_cursor(
1485
)
1486
1487
1488
-
1489
stream_state = self.apply_stream_state_migrations(stream_state_migrations, stream_state)
1490
# Per-partition state doesn't make sense for GroupingPartitionRouter, so force the global state
1491
use_global_cursor = isinstance(
0 commit comments