diff --git a/task/summary3.py b/task/summary3.py index 6b70f66..d0c6742 100644 --- a/task/summary3.py +++ b/task/summary3.py @@ -137,6 +137,8 @@ class Summary3(Task): def get_cursor(self): if not self.cursor_st: self.cursor_st = self.task_info.get('cursor_et') + if self.cursor_st >= int(pd.Timestamp(self.cursor_st, unit='s', tz=self.timezone).normalize().timestamp()): + self.cursor_st -= 86400 if not self.cursor_st: self.cursor_st = int(time.time()) - 86400 super().get_cursor()