|
@@ -86,7 +86,7 @@ def h_timer_check():
|
|
|
#1 判断数据表是否生产完成
|
|
|
project = "loghubods"
|
|
|
table = "alg_recsys_recall_strategy_trend"
|
|
|
- partition = "dt=2023122019"
|
|
|
+ partition = "2023122019"
|
|
|
table_data_cnt = check_data(project, table, partition)
|
|
|
if table_data_cnt == 0:
|
|
|
log_.info("上游数据{}未就绪{},等待...".format(table, partition))
|