Function TestManagerStartRunExecutionProfile

internal/task/manager_test.go:8152–8224

(t *testing.T)

}

func TestManagerStartRunExecutionProfile(t *testing.T) {
	t.Parallel()

	t.Run(
		"Should pass the persisted execution profile to the session executor",
		func(t *testing.T) {
			t.Parallel()

			store := newInMemoryManagerStore()
			executor := &recordingSessionExecutor{
				startRef: &SessionRef{SessionID: "sess-profiled-worker"},
			}
			manager := newTaskManagerForTestWithOptions(t, store, WithSessionExecutor(executor))
			actor := validActorContext()

			taskRecord, err := manager.CreateTask(context.Background(), CreateTask{
				Scope: ScopeGlobal,
				Title: "Profiled start run",
			}, actor)
			if err != nil {
				t.Fatalf("CreateTask() error = %v", err)
			}
			_, err = manager.SetExecutionProfile(
				context.Background(),
				taskRecord.ID,
				&ExecutionProfile{
					Worker: WorkerProfile{
						Mode:      WorkerModeSelect,
						AgentName: "builder",
						Provider:  "codex",
						Model:     "gpt-5.4",
					},
				},
				actor,
			)
			if err != nil {
				t.Fatalf("SetExecutionProfile() error = %v", err)
			}
			run, err := manager.EnqueueRun(
				context.Background(),
				EnqueueRun{TaskID: taskRecord.ID},
				actor,
			)
			if err != nil {
				t.Fatalf("EnqueueRun() error = %v", err)
			}
			run, err = manager.ClaimRun(context.Background(), run.ID, ClaimRun{}, actor)
			if err != nil {
				t.Fatalf("ClaimRun() error = %v", err)
			}

			if _, err := manager.StartRun(context.Background(), run.ID, StartRun{}, actor); err != nil {
				t.Fatalf("StartRun() error = %v", err)
			}
			if got, want := len(executor.startCalls), 1; got != want {
				t.Fatalf("len(startCalls) = %d, want %d", got, want)
			}
			profile := executor.startCalls[0].ExecutionProfile