Function decodePersistedGeneratorPayload

core/generators.go:229–254

(
	ctx context.Context,
	dag *dagql.Server,
	nodes map[int]*ModTreeNode,
	payload persistedGeneratorPayload,
)

}

func decodePersistedGeneratorPayload(
	ctx context.Context,
	dag *dagql.Server,
	nodes map[int]*ModTreeNode,
	payload persistedGeneratorPayload,
) (*Generator, error) {
	if payload.NodeID == 0 {
		return nil, fmt.Errorf("decode persisted generator: missing node ID")
	}
	node, ok := nodes[payload.NodeID]
	if !ok {
		return nil, fmt.Errorf("decode persisted generator: unknown node ID %d", payload.NodeID)
	}
	g := &Generator{
		Node:      node,
		Completed: payload.Completed,
	}
	if payload.ChangesResultID != 0 {
		changes, err := loadPersistedObjectResultByResultID[*Changeset](ctx, dag, payload.ChangesResultID, "generator changes")
		if err != nil {
			return nil, err
		}
		g.Changes = changes
	}
	return g, nil
}

func (g *Generator) EncodePersistedObject(ctx context.Context, cache dagql.PersistedObjectCache) (dagql.PersistedObjectEncoding, error) {
	_ = ctx