File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
unit_tests/sources/declarative/incremental Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -3453,7 +3453,9 @@ def test_semaphore_cleanup():
34533453
34543454def test_given_global_state_when_read_then_state_is_not_per_partition () -> None :
34553455 manifest = deepcopy (SUBSTREAM_MANIFEST )
3456- manifest ["definitions" ]["post_comments_stream" ]["incremental_sync" ]["global_substream_cursor" ] = True
3456+ manifest ["definitions" ]["post_comments_stream" ]["incremental_sync" ][
3457+ "global_substream_cursor"
3458+ ] = True
34573459 record = {
34583460 "id" : 9 ,
34593461 "post_id" : 1 ,
@@ -3486,6 +3488,6 @@ def test_given_global_state_when_read_then_state_is_not_per_partition() -> None:
34863488 {
34873489 "lookback_window" : 1 ,
34883490 "parent_state" : {"posts" : {"updated_at" : "2024-01-30T00:00:00Z" }},
3489- "state" : {"updated_at" : "2024-01-25T00:00:00Z" }
3491+ "state" : {"updated_at" : "2024-01-25T00:00:00Z" },
34903492 }, # this state does have per partition which would be under `states`
34913493 )
You can’t perform that action at this time.
0 commit comments