Skip to content

Commit 7630382

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent 47af0fa commit 7630382

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -364,7 +364,8 @@ def _group_streams(
364364
== DatetimeBasedCursorModel.__name__
365365
and hasattr(declarative_stream.retriever, "stream_slicer")
366366
and isinstance(
367-
declarative_stream.retriever.stream_slicer, (GlobalSubstreamCursor, PerPartitionWithGlobalCursor)
367+
declarative_stream.retriever.stream_slicer,
368+
(GlobalSubstreamCursor, PerPartitionWithGlobalCursor),
368369
)
369370
):
370371
stream_state = self._connector_state_manager.get_stream_state(

unit_tests/sources/declarative/incremental/test_concurrent_perpartitioncursor.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3479,7 +3479,7 @@ def test_given_global_state_when_read_then_state_is_not_per_partition() -> None:
34793479
},
34803480
),
34813481
]
3482-
3482+
34833483
run_mocked_test(
34843484
mock_requests,
34853485
manifest,
@@ -3491,6 +3491,6 @@ def test_given_global_state_when_read_then_state_is_not_per_partition() -> None:
34913491
"lookback_window": 1,
34923492
"parent_state": {"posts": {"updated_at": "2024-01-30T00:00:00Z"}},
34933493
"state": {"updated_at": "2024-01-25T00:00:00Z"},
3494-
"use_global_cursor": True # ensures that it is running the Concurrent CDK version as this is not populated in the declarative implementation
3494+
"use_global_cursor": True, # ensures that it is running the Concurrent CDK version as this is not populated in the declarative implementation
34953495
}, # this state does have per partition which would be under `states`
34963496
)

0 commit comments

Comments
 (0)