Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions tap_chargebee/streams/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -145,6 +145,9 @@ def sync_data(self):
params = {"updated_at[after]": bookmark_date_posix}
bookmark_key = 'updated_at'

# Add sort_by[asc] by REPLICATION_KEY to prevent data overwrite by oldest deleted records
params['sort_by[asc]'] = self.REPLICATION_KEY

LOGGER.info("Querying {} starting at {}".format(table, bookmark_date))

while not done:
Expand Down