File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
airbyte_cdk/sources/declarative/retrievers Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -78,7 +78,7 @@ def _validate_and_get_stream_slice_jobs(
78
78
"""
79
79
return stream_slice .extra_fields .get ("jobs" , []) if stream_slice else []
80
80
81
- def _get_cursor_slice_info (
81
+ def _get_cursor_slice (
82
82
self ,
83
83
stream_slice : Optional [StreamSlice ] = None ,
84
84
) -> Mapping [str , Any ]:
@@ -106,7 +106,7 @@ def read_records(
106
106
) -> Iterable [StreamData ]:
107
107
# emit the slice_descriptor log message, for connector builder TestRead
108
108
yield self .slice_logger .create_slice_log_message (
109
- self ._get_cursor_slice_info (stream_slice ),
109
+ self ._get_cursor_slice (stream_slice ),
110
110
)
111
111
stream_state : StreamState = self ._get_stream_state ()
112
112
jobs : Iterable [AsyncJob ] = self ._validate_and_get_stream_slice_jobs (stream_slice )
You can’t perform that action at this time.
0 commit comments