Function TestManagerGetTaskAndFailRunGuardrails

internal/task/manager_test.go:8783–8815

(t *testing.T)

}

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

	manager := newTaskManagerForTest(t, newInMemoryManagerStore())
	actor := validActorContext()

	if _, err := manager.GetTask(context.Background(), "", actor); !errors.Is(err, ErrValidation) {
		t.Fatalf("GetTask(empty id) error = %v, want %v", err, ErrValidation)
	}
	if _, err := manager.GetTask(context.Background(), "missing-task", actor); !errors.Is(
		err,
		ErrTaskNotFound,
	) {
		t.Fatalf("GetTask(missing) error = %v, want %v", err, ErrTaskNotFound)
	}

	taskRecord, err := manager.CreateTask(context.Background(), CreateTask{
		Scope: ScopeGlobal,
		Title: "Queued fail guard",
	}, actor)
	if err != nil {
		t.Fatalf("CreateTask() error = %v", err)
	}
	run, err := manager.EnqueueRun(context.Background(), EnqueueRun{TaskID: taskRecord.ID}, actor)
	if err != nil {
		t.Fatalf("EnqueueRun() error = %v", err)
	}
	if _, err := manager.FailRun(context.Background(), run.ID, RunFailure{
		Error: "cannot fail queued run",
	}, actor); !errors.Is(err, ErrInvalidStatusTransition) {
		t.Fatalf("FailRun(queued) error = %v, want %v", err, ErrInvalidStatusTransition)
	}
}

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