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 19:34:11 +08:00
parent 44f9dec9d3
commit 878d71553b
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
task/summary3.py
View File

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