调整VJ的运行参数

descending_cabin_task.py

@@ -525,7 +525,7 @@ def _process_one_task(row, runner):
     drop_price_change_upper = float(task.get("drop_price_change_upper"))   # 降价的最小幅度
     drop_price_change_lower = float(task.get("drop_price_change_lower"))
 
-    max_threshold = round(drop_price_change_upper * runner.rate * 0.5)   # 降价阈值要按汇率转人民币（四舍五入到整数）
+    max_threshold = round(drop_price_change_upper * runner.rate * 0.8)   # 降价阈值要按汇率转人民币（四舍五入到整数）
 
     result = results[0]
     # adult_price = result.get("adult_price")

run_vj.sh

@@ -14,7 +14,7 @@ log "=== 脚本开始执行 ==="
 START_TIME=$(date +%s)
 
 # 启动第一个任务（后台执行）
-/home/node04/anaconda3/bin/python main_pe_0.py >> $LOG_DIR/prediction.log 2>&1 &
+/home/node04/anaconda3/bin/python -u main_pe_0.py >> $LOG_DIR/prediction.log 2>&1 &
 PID=$!
 
 log "main_pe_0.py 已启动，PID=$PID"
@@ -41,6 +41,6 @@ fi
 
 log "开始执行 follow_up.py"
 
-/home/node04/anaconda3/bin/python follow_up.py >> $LOG_DIR/keep.log 2>&1
+/home/node04/anaconda3/bin/python -u follow_up.py >> $LOG_DIR/keep.log 2>&1
 
 log "=== 脚本执行结束 ==="