File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -290,8 +290,7 @@ def test_client_side_record_filter_decorator_no_parent_stream(
290
290
config = {},
291
291
condition = record_filter_expression ,
292
292
parameters = {},
293
- date_time_based_cursor = date_time_based_cursor ,
294
- substream_cursor = None ,
293
+ cursor = date_time_based_cursor ,
295
294
)
296
295
297
296
filtered_records = list (
@@ -429,8 +428,7 @@ def date_time_based_cursor_factory() -> DatetimeBasedCursor:
429
428
record_filter_decorator = ClientSideIncrementalRecordFilterDecorator (
430
429
config = {},
431
430
parameters = {},
432
- date_time_based_cursor = date_time_based_cursor ,
433
- substream_cursor = substream_cursor ,
431
+ cursor = substream_cursor or date_time_based_cursor ,
434
432
)
435
433
436
434
# The partition we're testing
You can’t perform that action at this time.
0 commit comments