Function TestManagerCancelTaskPropagatesAcrossTree

internal/task/manager_test.go:6487–6606

(t *testing.T)

}

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

	store := newInMemoryManagerStore()
	executor := &recordingSessionExecutor{}
	manager := newTaskManagerForTestWithOptions(
		t,
		store,
		WithSessionExecutor(executor),
		WithCancelGracePeriod(0),
	)
	actor := validActorContext()

	parent, err := manager.CreateTask(context.Background(), CreateTask{
		Scope: ScopeGlobal,
		Title: "Parent task",
	}, actor)
	if err != nil {
		t.Fatalf("CreateTask(parent) error = %v", err)
	}
	queuedChild, err := manager.CreateChildTask(context.Background(), parent.ID, CreateTask{
		Scope: ScopeGlobal,
		Title: "Queued child",
	}, actor)
	if err != nil {
		t.Fatalf("CreateChildTask(queued child) error = %v", err)
	}
	activeChild, err := manager.CreateChildTask(context.Background(), parent.ID, CreateTask{
		Scope: ScopeGlobal,
		Title: "Active child",
	}, actor)
	if err != nil {
		t.Fatalf("CreateChildTask(active child) error = %v", err)
	}

	queuedRun, err := manager.EnqueueRun(
		context.Background(),
		EnqueueRun{TaskID: queuedChild.ID},
		actor,
	)
	if err != nil {
		t.Fatalf("EnqueueRun(queued child) error = %v", err)
	}
	activeRun, err := manager.EnqueueRun(
		context.Background(),
		EnqueueRun{TaskID: activeChild.ID},
		actor,
	)
	if err != nil {
		t.Fatalf("EnqueueRun(active child) error = %v", err)
	}
	activeRun, err = manager.ClaimRun(context.Background(), activeRun.ID, ClaimRun{}, actor)
	if err != nil {
		t.Fatalf("ClaimRun(active child) error = %v", err)
	}
	activeRun, err = manager.StartRun(context.Background(), activeRun.ID, StartRun{}, actor)
	if err != nil {
		t.Fatalf("StartRun(active child) error = %v", err)