Function TestManagerStickyTaskBlockNeverAutoClears

internal/task/manager_test.go:5376–5413

(t *testing.T)

}

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

	store := newInMemoryManagerStore()
	manager := newTaskManagerForTest(t, store)
	actor := validActorContext()
	taskRecord, err := manager.CreateTask(context.Background(), CreateTask{
		Scope:       ScopeWorkspace,
		WorkspaceID: "ws-sticky-block",
		Title:       "Sticky block",
	}, actor)
	if err != nil {
		t.Fatalf("CreateTask() error = %v", err)
	}

	block, err := manager.BlockTask(context.Background(), BlockRequest{
		TaskID: taskRecord.ID,
		Kind:   BlockKindNeedsInput,
		Reason: "waiting for creator",
	}, actor)
	if err != nil {
		t.Fatalf("BlockTask() error = %v", err)
	}
	reconciled, err := manager.reconcileTaskCascade(context.Background(), taskRecord.ID)
	if err != nil {
		t.Fatalf("reconcileTaskCascade() error = %v", err)
	}
	if got, want := reconciled.Status, TaskStatusBlocked; got != want {
		t.Fatalf("reconciled.Status = %q, want %q", got, want)
	}
	openBlocks, err := manager.ListTaskBlocks(context.Background(), taskRecord.ID, false, actor)
	if err != nil {
		t.Fatalf("ListTaskBlocks() error = %v", err)
	}
	if len(openBlocks) != 1 || openBlocks[0].ID != block.ID || !openBlocks[0].ClearedAt.IsZero() {
		t.Fatalf("openBlocks = %#v, want sticky block %q still open", openBlocks, block.ID)
	}
}

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