Skip to content

Commit

Permalink
remove cursor_field param
Browse files Browse the repository at this point in the history
  • Loading branch information
nidhilashkari17 committed Jan 2, 2024
1 parent bfe299a commit f10a7fd
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -236,7 +236,7 @@ def shouldFetchFromOriginalResource (self,stream_state = None):
# Fetch data from original stream else fetch data from events
shouldResetState = durationInDaysFromLastSync >= 30
return hasState is False or self.completed is False or shouldResetState
def read_records(self, stream_slice, stream_state = None, cursor_field= None, **kwargs) -> Iterable[Mapping[str, Any]]:
def read_records(self, stream_slice, stream_state = None, **kwargs) -> Iterable[Mapping[str, Any]]:
shouldFetchFromOriginalResource = self.shouldFetchFromOriginalResource(stream_state)
if shouldFetchFromOriginalResource:
self.logger.info("Fetching from original source")
Expand Down

0 comments on commit f10a7fd

Please sign in to comment.