From 0ca8f4c3abc5306053ef93021c2a84b280ad46da Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=96=8C?= <259278618@qq.com>
Date: Thu, 27 Aug 2026 09:31:41 +0800
Subject: [PATCH] 1

---
 server/common/training_runner.go |   3 ++-
 server/data/observer.db          | Bin 249856 -> 249856 bytes
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/server/common/training_runner.go b/server/common/training_runner.go
index 26380e2..2790328 100644
--- a/server/common/training_runner.go
+++ b/server/common/training_runner.go
@@ -281,7 +281,8 @@ func (r *sshRunner) runCmd(ctx context.Context, job *TrainingJob, cmd string) (s
 
 func (r *sshRunner) Start(ctx context.Context, job *TrainingJob) (int, error) {
 	taskJson := filepath.Join(job.Workdir, "tasks", fmt.Sprintf("%d.json", job.TaskId))
-	cmd := fmt.Sprintf("cd %s && nohup %s train_server.py --task-json %s > logs/%d.stdout 2>&1 & echo $!",
+	// logs/ 由 bash 重定向所需，须先建（train_server.py 只建 jsonl/结果/产物的父目录）
+	cmd := fmt.Sprintf("cd %s && mkdir -p logs && nohup %s train_server.py --task-json %s > logs/%d.stdout 2>&1 & echo $!",
 		job.Workdir, job.Python, taskJson, job.TaskId)
 	out, err := r.runCmd(ctx, job, cmd)
 	if err != nil {
diff --git a/server/data/observer.db b/server/data/observer.db
index 5acbd9082ef11050a7b226db594957006c4c408e..2b182a43c73743663de48483db8927944c31a522 100644
GIT binary patch
delta 501
zcmZozz~8Wde}XjQm5DOWj8`@$*sf>f+B|Q4T7VEc*9r!HYrZnxjXZC-pK&X5t=KFm
zFo{dJl1qreUYe1KiIJa!gO`_s*Oy@$FQZg)QE6UYW?p(4(*cHQ0tQ9~MrOJO7P>~}
z3I>)|MwV8_CVHkOre<cw+6ER@1_b3B9XNs3NFuCB^!D|h&dAFcmt<saWo)cxY+`6`
zhSe-{D-$C<Q)3eoGhFhh+MAd;gi)+&oc@=GQLFyxg!NCmR=ilZ_WADSr%N`z*s|10
zAvoAW0V4iv&Z-ytr#ziKPoW?)#Y!P5u{gs@Aty60RlyKQ=cgCzTj&*+q~w>DSSk4B
zD-@R|XDFm)=A<g*7b&D<7NsVa<QG+PnHyOen{%NBmWh?Ig`Tmuk)^r05mq0XS{YdC
enHU)xSsG%MhZumQzx@plBM>uff5XEpau@)>=!H@M

delta 58
zcmZozz~8Wde}XjQxrs8)jOR8c*sf<}-#l-9S^y6V&l?7QYrZnxjXZBQ3kuxfX@A4R
O2*ga=-|#St90mY#XcZ*@