all

alg_recsys_recall_undertake.py

@@ -65,7 +65,7 @@ def process_and_store(row):
 def main():
     log_.info("开始执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
     #1 读取当前时间及上一时间
-    now_date = datetime.today()
+    now_date = datetime.today() - timedelta(hours=1)
     hour = datetime.strftime(now_date, '%H').lstrip('0')
     date = datetime.strftime(now_date, '%Y%m%d')
     if hour == "":