Skip to content

Commit

Permalink
feat: klaviyo v2
Browse files Browse the repository at this point in the history
- fix flows archive issue
  • Loading branch information
am6010 committed Jun 20, 2024
1 parent 09c4a6d commit 566b729
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,7 @@ def get_updated_state(self, current_stream_state: MutableMapping[str, Any], late
current_stream_cursor_value = current_stream_state.get("archived", {}).get(self.cursor_field, self._start_ts)
latest_record_cursor_value = latest_record[self.cursor_field]
latest_cursor = max(pendulum.parse(latest_record_cursor_value), pendulum.parse(current_stream_cursor_value))
current_stream_state["archived"] = {self.cursor_field: latest_cursor}
current_stream_state["archived"] = {self.cursor_field: str(latest_cursor)}
return current_stream_state
else:
return super().get_updated_state(current_stream_state, latest_record)
Expand Down

0 comments on commit 566b729

Please sign in to comment.