trend

alg_recsys_recall_4h_region_trend.py

@@ -34,6 +34,7 @@ def check_data(project, table, partition) -> int:
         check_res = t.exist_partition(partition_spec=f'dt={partition}')
         if check_res:
             sql = f'select * from {project}.{table} where dt = {partition}'
+            print(sql)
             with odps.execute_sql(sql=sql).open_reader() as reader:
                 data_count = reader.count
         else: