@@ -111,6 +111,8 @@ def h_data_check(project, table, now_date):
check_res = check_table_partition_exits(date=dt, project=project, table=table)
if check_res:
sql = f'select * from {project}.{table} where dt = {dt}'
+ print("zhangbo-sql-是否有数据")
+ print(sql)
with odps.execute_sql(sql=sql).open_reader() as reader:
data_count = reader.count
else:
zhangbo