|
|
@@ -46,7 +46,6 @@ while true; do
|
|
|
# shellcheck disable=SC2039
|
|
|
if (( current_hour > max_hour || (current_hour == max_hour && current_minute >= max_minute) )); then
|
|
|
echo "最长等待时间已到，失败:${current_hour}-${current_minute}"
|
|
|
- /root/anaconda3/bin/python monitor_util.py --level error --msg "荐模型数据更新 \n【任务名称】:step0校验是否生产完数据\n【是否成功】:error\n【信息】:最长等待时间已到，失败:${current_hour}-${current_minute}"
|
|
|
exit 1
|
|
|
fi
|
|
|
done
|
|
|
@@ -84,7 +83,6 @@ table:${table} &
|
|
|
wait
|
|
|
if [ $? -ne 0 ]; then
|
|
|
echo "Spark原始样本生产任务执行失败"
|
|
|
- /root/anaconda3/bin/python monitor_util.py --level error --msg "荐模型数据更新 \n【任务名称】:step1根据${table}生产原始数据\n【是否成功】:error\n【信息】:Spark原始样本生产任务执行失败"
|
|
|
exit 1
|
|
|
else
|
|
|
echo "spark原始样本生产执行成功"
|
|
|
@@ -104,7 +102,6 @@ fileName:20240609_bucket_314.txt \
|
|
|
whatLabel:is_return whatApps:0,4,21,17
|
|
|
if [ $? -ne 0 ]; then
|
|
|
echo "Spark特征分桶处理任务执行失败"
|
|
|
- /root/anaconda3/bin/python monitor_util.py --level error --msg "荐模型数据更新 \n【任务名称】:step3训练数据产出\n【是否成功】:error\n【信息】:Spark特征分桶处理任务执行失败"
|
|
|
exit 1
|
|
|
else
|
|
|
echo "spark特征分桶处理执行成功"
|
