Function persistedDecodeQuery

core/persisted_object.go:25–38

(dag *dagql.Server)

}

func persistedDecodeQuery(dag *dagql.Server) (*Query, error) {
	if dag == nil {
		return nil, fmt.Errorf("persisted decode query: nil dagql server")
	}
	root := dag.Root()
	if root == nil {
		return nil, fmt.Errorf("persisted decode query: nil dagql root")
	}
	query, ok := dagql.UnwrapAs[*Query](root)
	if !ok {
		return nil, fmt.Errorf("persisted decode query: root is %T", root.Unwrap())
	}
	return query, nil
}

func encodePersistedCallID(id *call.ID) (string, error) {
	if id == nil {