From 878d71553b4f490b4a27a30fda30cc456a1491f4 Mon Sep 17 00:00:00 2001 From: kf_wuhao <15392746632@qq.com> Date: Wed, 13 Jan 2021 19:34:11 +0800 Subject: [PATCH] update --- task/summary3.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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):