Method DecodePersistedObject

core/generators.go:348–383

(
	ctx context.Context,
	dag *dagql.Server,
	_ uint64,
	_ *dagql.ResultCall,
	payload json.RawMessage,
)

}

func (*GeneratorGroup) DecodePersistedObject(
	ctx context.Context,
	dag *dagql.Server,
	_ uint64,
	_ *dagql.ResultCall,
	payload json.RawMessage,
) (dagql.Typed, error) {
	var persisted persistedGeneratorGroupPayload
	if err := json.Unmarshal(payload, &persisted); err != nil {
		return nil, fmt.Errorf("decode persisted generator group payload: %w", err)
	}
	nodes, err := decodePersistedModTree(ctx, dag, persisted.Tree)
	if err != nil {
		return nil, err
	}
	var node *ModTreeNode
	if persisted.NodeID != 0 {
		var ok bool
		node, ok = nodes[persisted.NodeID]
		if !ok {
			return nil, fmt.Errorf("decode persisted generator group: unknown node ID %d", persisted.NodeID)
		}
	}
	generators := make([]*Generator, 0, len(persisted.Generators))
	for _, generatorPayload := range persisted.Generators {
		generator, err := decodePersistedGeneratorPayload(ctx, dag, nodes, generatorPayload)
		if err != nil {
			return nil, err
		}
		generators = append(generators, generator)
	}
	return &GeneratorGroup{
		Node:       node,
		Generators: generators,
	}, nil
}

func (gg *GeneratorGroup) AttachDependencyResults(
	ctx context.Context,