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-13 18:27:40 +08:00
parent aaad6d6230
commit 2545fb6003
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
task/summary3.py
View File

@ -138,10 +138,10 @@ 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(time.time(), unit='s', tz=self.timezone).normalize().timestamp()): if not self.cursor_st:
self.cursor_st -= 86400 self.cursor_st = int(time.time()) - 86400
if not self.cursor_st: elif self.cursor_st >= int(pd.Timestamp(time.time(), unit='s', tz=self.timezone).normalize().timestamp()):
self.cursor_st = int(time.time()) - 86400 self.cursor_st = int(time.time()) - 86400
super().get_cursor() super().get_cursor()
def generate_cursor_time(self): def generate_cursor_time(self):