Function resolverForSharedResultObject

dagql/cache.go:1610–1633

resolverForSharedResultObject returns a resolver that can instantiate the cached object's concrete type, rebuilding a dependency-aware schema from the result's call graph if the current resolver does not have the type. This is the fallback path for object reconstruction; the common path reuses the

(ctx context.Context, resolver TypeResolver, res *sharedResult, typeName string)

// Persisted-envelope decoding still uses this directly because there is no
// in-memory value to derive a class from at decode time.
func resolverForSharedResultObject(ctx context.Context, resolver TypeResolver, res *sharedResult, typeName string) (TypeResolver, error) {
	if resolver == nil || res == nil || typeName == "" {
		return resolver, nil
	}
	if _, ok := resolver.ObjectType(typeName); ok {
		return resolver, nil
	}
	srv, ok := resolver.(*Server)
	if !ok || srv.resultServerForCall == nil {
		return resolver, nil
	}
	resultCall := res.loadResultCall()
	if resultCall == nil {
		return resolver, nil
	}
	resolved, err := srv.resultServerForCall(ctx, resultCall)
	if err != nil {
		return nil, fmt.Errorf("resolve schema for result %d type %q: %w", res.id, typeName, err)
	}
	if resolved == nil {
		return resolver, nil
	}
	return resolved, nil
}

func wrapSharedResultWithResolver(ctx context.Context, res *sharedResult, hitCache bool, resolver TypeResolver) (AnyResult, error) {
	ret := Result[Typed]{