update

bottom_task.sh

@@ -1,4 +1,4 @@
-source env.conf
+source ./env.conf
 env=$ENV
 if [ $env == 'test' ]; then
     cd /data2/rov-offline && /root/anaconda3/bin/python /data2/rov-offline/bottom_videos.py

flow_pool_task.sh

@@ -1,4 +1,4 @@
-source env.conf
+source ./env.conf
 env=$ENV
 if [ $env == 'test' ]; then
     cd /data2/rov-offline && /root/anaconda3/bin/python /data2/rov-offline/pool_predict.py

rov_data_check.py

@@ -15,7 +15,7 @@ log_ = Log()
 
 def rov_train_recall_pool_update():
     # 训练数据和预测数据都准备好时，更新模型，预测
-    os.system('sh {}/rov_train_recall_pool_update.sh'.format(config_.PROJECT_PATH))
+    os.system('cd {} && sh {}/rov_train_recall_pool_update.sh'.format(config_.PROJECT_PATH, config_.PROJECT_PATH))
     # # 将日志上传到oss
     # log_cmd = "ossutil cp -r -f {} oss://{}/{}".format(log_.logname, config_.BUCKET_NAME,
     #                                                    config_.OSS_FOLDER_LOGS + 'rov_recall_pool/')

rov_pool_task.sh

@@ -1,4 +1,4 @@
-source env.conf
+source ./env.conf
 env=$ENV
 if [ $env == 'test' ]; then
     cd /data2/rov-offline && /root/anaconda3/bin/python /data2/rov-offline/rov_data_check.py

rov_train_recall_pool_update.sh

@@ -1,4 +1,4 @@
-source env.conf
+source ./env.conf
 env=$ENV
 if [ $env == 'test' ]; then
     /root/anaconda3/bin/python /data2/rov-offline/get_data.py && /root/anaconda3/bin/python /data2/rov-offline/rov_train.py

top_video_task.sh

@@ -1,4 +1,4 @@
-source env.conf
+source ./env.conf
 env=$ENV
 if [ $env == 'test' ]; then
     cd /data2/rov-offline && /root/anaconda3/bin/python /data2/rov-offline/top_video_list.py

videos_filter_task.sh

@@ -1,4 +1,4 @@
-source env.conf
+source ./env.conf
 env=$ENV
 if [ $env == 'test' ]; then
     cd /data2/rov-offline && /root/anaconda3/bin/python /data2/rov-offline/videos_filter.py