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