feat(worker): mark submission as running on evaluation start

Author: HuanCheng65

apps/worker/cmd/labkit-worker/dev_fake_handler.go

@@ -37,6 +37,9 @@ func (h *devFakeHandler) Handle(ctx context.Context, job *sqlc.EvaluationJobs) e
 	if err != nil {
 		return err
 	}
+	if err := h.persister.MarkRunning(ctx, submission.ID, startedAt); err != nil {
+		return err
+	}
 	labRow, err := h.queries.GetLab(ctx, submission.LabID)
 	if err != nil {
 		return err

apps/worker/cmd/labkit-worker/runtime_handler.go

@@ -36,6 +36,7 @@ type jobAcknowledger interface {
 }
 
 type resultPersister interface {
+	MarkRunning(context.Context, uuid.UUID, time.Time) error
 	Persist(context.Context, evaluation.PersistInput) error
 }
 
@@ -72,6 +73,9 @@ func (h *runtimeHandler) Handle(ctx context.Context, job *sqlc.EvaluationJobs) e
 	if err != nil {
 		return err
 	}
+	if err := h.persister.MarkRunning(ctx, submission.ID, startedAt); err != nil {
+		return err
+	}
 
 	imageDigest, _ := h.resolveImageDigest(ctx, parsed.Eval.Image)
 	result, err := h.evaluate(ctx, submission, parsed)

apps/worker/cmd/labkit-worker/runtime_handler_test.go

@@ -87,6 +87,15 @@ func TestRuntimeHandlerPersistsScoredResultAndAcknowledgesDone(t *testing.T) {
 		t.Fatalf("Handle() error = %v", err)
 	}
 
+	if persister.markRunningCalls != 1 {
+		t.Fatalf("markRunningCalls = %d, want 1", persister.markRunningCalls)
+	}
+	if persister.runningSubmissionID != submissionID {
+		t.Fatalf("running submission id = %v, want %v", persister.runningSubmissionID, submissionID)
+	}
+	if got := persister.runningStartedAt; !got.Equal(time.Date(2026, 4, 1, 12, 0, 0, 0, time.UTC)) {
+		t.Fatalf("running started_at = %v, want fixed test time", got)
+	}
 	if queue.status != jobs.StatusDone {
 		t.Fatalf("ack status = %q, want %q", queue.status, jobs.StatusDone)
 	}
@@ -251,7 +260,17 @@ func (q *fakeRuntimeQueue) Acknowledge(_ context.Context, _ uuid.UUID, _ string,
 }
 
 type fakeRuntimePersister struct {
-	input evaluation.PersistInput
+	input               evaluation.PersistInput
+	markRunningCalls    int
+	runningSubmissionID uuid.UUID
+	runningStartedAt    time.Time
+}
+
+func (p *fakeRuntimePersister) MarkRunning(_ context.Context, submissionID uuid.UUID, startedAt time.Time) error {
+	p.markRunningCalls++
+	p.runningSubmissionID = submissionID
+	p.runningStartedAt = startedAt
+	return nil
 }
 
 func (p *fakeRuntimePersister) Persist(_ context.Context, input evaluation.PersistInput) error {

apps/worker/internal/service/evaluation/repo.go

@@ -25,6 +25,10 @@ func (r *repo) BeginTx(ctx context.Context) (Tx, error) {
 	return &storeTx{tx: tx, queries: sqlc.New(tx)}, nil
 }
 
+func (r *repo) UpdateSubmissionRunning(ctx context.Context, arg sqlc.UpdateSubmissionRunningParams) error {
+	return sqlc.New(r.pool).UpdateSubmissionRunning(ctx, arg)
+}
+
 type storeTx struct {
 	tx      pgx.Tx
 	queries *sqlc.Queries

apps/worker/internal/service/evaluation/service.go

@@ -16,12 +16,14 @@ import (
 )
 
 const (
-	submissionStatusDone  = string(labkit.SubmissionStatusDone)
-	submissionStatusError = string(labkit.SubmissionStatusError)
+	submissionStatusRunning = string(labkit.SubmissionStatusRunning)
+	submissionStatusDone    = string(labkit.SubmissionStatusDone)
+	submissionStatusError   = string(labkit.SubmissionStatusError)
 )
 
 type Repository interface {
 	BeginTx(context.Context) (Tx, error)
+	UpdateSubmissionRunning(context.Context, sqlc.UpdateSubmissionRunningParams) error
 }
 
 type Tx interface {
@@ -53,6 +55,17 @@ func NewService(repo Repository) *Service {
 	}
 }
 
+func (s *Service) MarkRunning(ctx context.Context, submissionID uuid.UUID, startedAt time.Time) error {
+	if s == nil || s.repo == nil {
+		return fmt.Errorf("evaluation service: repository is required")
+	}
+	return s.repo.UpdateSubmissionRunning(ctx, sqlc.UpdateSubmissionRunningParams{
+		ID:        submissionID,
+		Status:    submissionStatusRunning,
+		StartedAt: timestamptzValue(startedAt),
+	})
+}
+
 func (s *Service) Persist(ctx context.Context, in PersistInput) (err error) {
 	if s == nil || s.repo == nil {
 		return fmt.Errorf("evaluation service: repository is required")

apps/worker/internal/service/evaluation/service_test.go

@@ -195,6 +195,27 @@ func TestPersistLatestScoredSubmissionReplacesLeaderboardPointer(t *testing.T) {
 	}
 }
 
+func TestMarkRunningUpdatesSubmissionStatusAndStartedAt(t *testing.T) {
+	repo := newFakeRepository()
+	svc := newTestService(repo)
+	submission := seededSubmission("66666666-6666-7666-8666-666666666666", 7, "sorting")
+	submission.Status = "queued"
+	repo.submissions[submission.ID] = submission
+	startedAt := time.Date(2026, 3, 31, 13, 30, 0, 0, time.UTC)
+
+	if err := svc.MarkRunning(context.Background(), submission.ID, startedAt); err != nil {
+		t.Fatalf("MarkRunning() error = %v", err)
+	}
+
+	stored := repo.submissions[submission.ID]
+	if stored.Status != "running" {
+		t.Fatalf("submission status = %q, want %q", stored.Status, "running")
+	}
+	if !stored.StartedAt.Valid || !stored.StartedAt.Time.Equal(startedAt) {
+		t.Fatalf("submission started_at = %v, want %v", stored.StartedAt, startedAt)
+	}
+}
+
 func newTestService(repo *fakeRepository) *Service {
 	svc := NewService(repo)
 	svc.now = func() time.Time { return repo.now }
@@ -279,6 +300,14 @@ func (r *fakeRepository) BeginTx(context.Context) (Tx, error) {
 	return tx, nil
 }
 
+func (r *fakeRepository) UpdateSubmissionRunning(_ context.Context, arg sqlc.UpdateSubmissionRunningParams) error {
+	row := r.submissions[arg.ID]
+	row.Status = arg.Status
+	row.StartedAt = arg.StartedAt
+	r.submissions[arg.ID] = row
+	return nil
+}
+
 type fakeTx struct {
 	repo             *fakeRepository
 	updateCalls      int
@@ -356,4 +385,5 @@ var _ interface {
 
 var _ interface {
 	BeginTx(context.Context) (Tx, error)
+	UpdateSubmissionRunning(context.Context, sqlc.UpdateSubmissionRunningParams) error
 } = (*fakeRepository)(nil)

db/queries/submissions.sql

@@ -41,6 +41,12 @@ SET status = $2,
     finished_at = $8
 WHERE id = $1;
 
+-- name: UpdateSubmissionRunning :exec
+UPDATE submissions
+SET status = $2,
+    started_at = $3
+WHERE id = $1;
+
 -- name: CreateScore :exec
 INSERT INTO scores (submission_id, metric_id, value)
 VALUES ($1, $2, $3)