Function createRunningRunForTest

internal/task/manager_test.go:6221–6251

(t *testing.T, manager *Service, actor ActorContext)

}

func createRunningRunForTest(t *testing.T, manager *Service, actor ActorContext) *Run {
	t.Helper()

	taskRecord, err := manager.CreateTask(context.Background(), CreateTask{
		Scope: ScopeGlobal,
		Title: "Terminal session cleanup",
	}, actor)
	if err != nil {
		t.Fatalf("CreateTask() error = %v", err)
	}
	queuedRun, err := manager.EnqueueRun(
		context.Background(),
		EnqueueRun{TaskID: taskRecord.ID},
		actor,
	)
	if err != nil {
		t.Fatalf("EnqueueRun() error = %v", err)
	}
	claimedRun, err := manager.ClaimRun(context.Background(), queuedRun.ID, ClaimRun{}, actor)
	if err != nil {
		t.Fatalf("ClaimRun() error = %v", err)
	}
	runningRun, err := manager.StartRun(context.Background(), claimedRun.ID, StartRun{}, actor)
	if err != nil {
		t.Fatalf("StartRun() error = %v", err)
	}
	if strings.TrimSpace(runningRun.SessionID) == "" {
		t.Fatal("StartRun().SessionID is empty")
	}
	return runningRun
}

func assertSessionStopCalls(
	t *testing.T,