trend

alg_recsys_recall_4h_region_trend.py

@@ -31,6 +31,7 @@ def check_data(project, table, partition) -> int:
     )
     try:
         t = odps.get_table(name=table)
+        log_.info(f"检查分区是否存在-【 dt={partition} 】")
         check_res = t.exist_partition(partition_spec=f'dt={partition}')
         if check_res:
             sql = f'select * from {project}.{table} where dt = {partition}'