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 0a444a5 commit 3e37a72Copy full SHA for 3e37a72
unit_tests/sources/declarative/partition_routers/test_substream_partition_router.py
@@ -415,7 +415,7 @@ def test_substream_partition_router_invalid_parent_record_type():
415
# Case 3: Initial state with global `state`, no migration expected
416
(
417
{"state": {"updated": "2023-05-27T00:00:00Z"}},
418
- {},
+ {"parent_stream_cursor": "2023-05-27T00:00:00Z"},
419
),
420
# Case 4: Initial state with per-partition `states`, no migration expected
421
@@ -471,7 +471,7 @@ def test_substream_partition_router_invalid_parent_record_type():
471
"use_global_cursor": True,
472
"state": {"updated": "2023-05-27T00:00:00Z"},
473
},
474
475
476
],
477
ids=[
0 commit comments