From 2545fb6003ed3873d0dcbabc49cccd827accd675 Mon Sep 17 00:00:00 2001 From: kf_wuhao <15392746632@qq.com> Date: Wed, 13 Jan 2021 18:27:40 +0800 Subject: [PATCH] update --- task/summary3.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/task/summary3.py b/task/summary3.py index cde9d2d..cea71b8 100644 --- a/task/summary3.py +++ b/task/summary3.py @@ -138,10 +138,10 @@ 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(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 + 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 super().get_cursor() def generate_cursor_time(self):