diff --git a/task/summary3.py b/task/summary3.py index cea71b8..3ea182f 100644 --- a/task/summary3.py +++ b/task/summary3.py @@ -138,10 +138,11 @@ class Summary3(Task): def get_cursor(self): if not self.cursor_st: self.cursor_st = self.task_info.get('cursor_et') - if not self.cursor_st: - self.cursor_st = int(time.time()) - 86400 - elif self.cursor_st >= int(pd.Timestamp(time.time(), unit='s', tz=self.timezone).normalize().timestamp()): - self.cursor_st = int(time.time()) - 86400 + if self.cursor_st and self.cursor_st >= int( + pd.Timestamp(time.time(), 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() def generate_cursor_time(self):