wuhao/data_cleaning
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

'update'

Browse Source
This commit is contained in:
kf_wuhao 2021-01-09 10:22:23 +08:00
parent ed26603406
commit 2be81a0511
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
task/summary3.py
View File

@ -137,7 +137,7 @@ class Summary3(Task):
def get_cursor(self): def get_cursor(self):
if not self.cursor_st: if not self.cursor_st:
self.cursor_st = self.task_info.get('cursor_et') 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()): if self.cursor_st >= int(pd.Timestamp(time.time(), unit='s', tz=self.timezone).normalize().timestamp()):
self.cursor_st -= 86400 self.cursor_st -= 86400
if not self.cursor_st: if not self.cursor_st:
self.cursor_st = int(time.time()) - 86400 self.cursor_st = int(time.time()) - 86400