@@ -38,6 +38,7 @@ def check_data(project, table, partition) -> int:
with odps.execute_sql(sql=sql).open_reader() as reader:
data_count = reader.count
else:
+ log_.info("表{}分区{}不存在".format(table, partition))
data_count = 0
except Exception as e:
log_.error("table:{},partition:{} no data. return data_count=0".format(table, partition))