更改状态码捕获

write_redis/alg_recsys_feature_02_vidhasreturnrov_redis.py

@@ -196,6 +196,14 @@ if __name__ == '__main__':
         print("脚本执行时间超过1小时，执行失败，经过了{}秒。".format(timeout))
         process.terminate()  # 终止子进程
         sys.exit(1)  # 直接退出主进程并返回状态码999
+    else:
+        # 检查子进程的返回值
+        exit_code = process.exitcode
+        if exit_code != 0:
+            print(f"子进程以状态码 {exit_code} 退出，执行失败。")
+            sys.exit(exit_code)  # 将子进程的状态码返回到主进程
+        else:
+            print("子进程正常结束。")
     log_.info("完成执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
 
 

write_redis/alg_recsys_feature_06_vovhour4rank_redis.py

@@ -175,7 +175,15 @@ if __name__ == '__main__':
         print("脚本执行时间超过1小时，执行失败，经过了{}秒。".format(timeout))
         process.terminate()  # 终止子进程
         sys.exit(1)  # 直接退出主进程并返回状态码999
-    log_.info("完成执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
+    else:
+        # 检查子进程的返回值
+        exit_code = process.exitcode
+        if exit_code != 0:
+            print(f"子进程以状态码 {exit_code} 退出，执行失败。")
+            sys.exit(exit_code)  # 将子进程的状态码返回到主进程
+        else:
+            print("子进程正常结束。")
+    # log_.info("完成执行:" + datetime.now().strftime("%Y-%m-%d %H:%M:%S"))
 
 
 

write_redis/alg_recsys_feature_07_vidh24pred_redis_task.sh

@@ -14,8 +14,7 @@ if [[ $ROV_OFFLINE_ENV == 'test' ]]; then
   /root/anaconda3/bin/python alg_recsys_feature_07_vidh24pred_redis.py $cur_time $cur_h
 elif [[ $ROV_OFFLINE_ENV == 'pro' ]]; then
   echo "pro环境"
-  #/root/anaconda3/bin/python alg_recsys_feature_07_vidh24pred_redis.py $cur_time $cur_h
-  /root/anaconda3/bin/python alg_recsys_feature_07_vidh24pred_redis.py $cur_time 20
+  /root/anaconda3/bin/python alg_recsys_feature_07_vidh24pred_redis.py $cur_time $cur_h
   if [ $? -ne 0 ]; then
     msg="写redis的任务，预测视频vovh24使用的特征，alg_recsys_feature_07_vidh24pred_redis.py:${cur_time}-${cur_h}-something-is-wrong."
     echo msg