This commit is contained in:
kf_wuhao 2021-01-08 20:29:53 +08:00
parent 7af0a749e3
commit ed26603406

View File

@ -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()