Skip to content

Commit ea7a757

Browse files
fix: ruff format long lines in create_state_delegating_stream
Co-Authored-By: alfredo.garcia@airbyte.io <freddy.garcia7.fg@gmail.com>
1 parent 8faa0ae commit ea7a757

1 file changed

Lines changed: 9 additions & 3 deletions

File tree

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3578,12 +3578,18 @@ def create_state_delegating_stream(
35783578
has_parent = False if has_parent_state is None else has_parent_state
35793579

35803580
if not stream_state and not has_parent:
3581-
return self._create_component_from_model(model.full_refresh_stream, config=config, **kwargs) # type: ignore[no-any-return]
3581+
return self._create_component_from_model(
3582+
model.full_refresh_stream, config=config, **kwargs
3583+
) # type: ignore[no-any-return]
35823584

3583-
incremental_stream: DefaultStream = self._create_component_from_model(model.incremental_stream, config=config, **kwargs) # type: ignore[assignment]
3585+
incremental_stream: DefaultStream = self._create_component_from_model(
3586+
model.incremental_stream, config=config, **kwargs
3587+
) # type: ignore[assignment]
35843588

35853589
if model.api_retention_period and stream_state:
3586-
full_refresh_stream: DefaultStream = self._create_component_from_model(model.full_refresh_stream, config=config, **kwargs) # type: ignore[assignment]
3590+
full_refresh_stream: DefaultStream = self._create_component_from_model(
3591+
model.full_refresh_stream, config=config, **kwargs
3592+
) # type: ignore[assignment]
35873593
cursors = [full_refresh_stream.cursor, incremental_stream.cursor]
35883594
if self._is_cursor_older_than_retention_period(
35893595
stream_state, cursors, model.api_retention_period, model.name

0 commit comments

Comments
 (0)