195195}
196196CONFIG_START_TIME = ab_datetime_parse (input_config ["start_time" ])
197197CONFIG_END_TIME = ab_datetime_parse (input_config ["end_time" ])
198+ _NO_STATE = {}
198199
199200
200201def get_factory_with_parameters (
@@ -3467,8 +3468,8 @@ def test_create_concurrent_cursor_from_datetime_based_cursor(
34673468 component_definition = cursor_component_definition ,
34683469 stream_name = stream_name ,
34693470 stream_namespace = None ,
3471+ stream_state = _NO_STATE ,
34703472 config = config ,
3471- stream_state = {},
34723473 )
34733474 else :
34743475 concurrent_cursor = (
@@ -3478,8 +3479,8 @@ def test_create_concurrent_cursor_from_datetime_based_cursor(
34783479 component_definition = cursor_component_definition ,
34793480 stream_name = stream_name ,
34803481 stream_namespace = None ,
3482+ stream_state = _NO_STATE ,
34813483 config = config ,
3482- stream_state = {},
34833484 )
34843485 )
34853486
@@ -3708,8 +3709,8 @@ def test_create_concurrent_cursor_uses_min_max_datetime_format_if_defined():
37083709 component_definition = cursor_component_definition ,
37093710 stream_name = stream_name ,
37103711 stream_namespace = None ,
3712+ stream_state = _NO_STATE ,
37113713 config = config ,
3712- stream_state = {},
37133714 )
37143715 )
37153716
@@ -3808,8 +3809,8 @@ def test_create_concurrent_cursor_from_datetime_based_cursor_with_clamping(
38083809 component_definition = cursor_component_definition ,
38093810 stream_name = stream_name ,
38103811 stream_namespace = None ,
3812+ stream_state = _NO_STATE ,
38113813 config = config ,
3812- stream_state = {},
38133814 )
38143815
38153816 else :
@@ -3820,8 +3821,8 @@ def test_create_concurrent_cursor_from_datetime_based_cursor_with_clamping(
38203821 component_definition = cursor_component_definition ,
38213822 stream_name = stream_name ,
38223823 stream_namespace = None ,
3824+ stream_state = _NO_STATE ,
38233825 config = config ,
3824- stream_state = {},
38253826 )
38263827 )
38273828
0 commit comments