Method cacheVolumeCacheKey

core/schema/cache.go:45–67

(
	ctx context.Context,
	parent dagql.ObjectResult[*core.Query],
	args cacheArgs,
	req *dagql.CallRequest,
)

}

func (s *cacheSchema) cacheVolumeCacheKey(
	ctx context.Context,
	parent dagql.ObjectResult[*core.Query],
	args cacheArgs,
	req *dagql.CallRequest,
) error {
	if args.Namespace == "" {
		m, err := parent.Self().CurrentModule(ctx)
		if err != nil && !errors.Is(err, core.ErrNoCurrentModule) {
			return err
		}
		namespaceKey, err := namespaceFromModule(ctx, m.Self())
		if err != nil {
			return err
		}
		args.Namespace = namespaceKey
		if err := req.SetArgInput(ctx, "namespace", dagql.NewString(namespaceKey), false); err != nil {
			return err
		}
	}

	return nil
}

func (s *cacheSchema) cacheVolume(ctx context.Context, parent dagql.ObjectResult[*core.Query], args cacheArgs) (dagql.Result[*core.CacheVolume], error) {
	source := dagql.Nullable[dagql.ObjectResult[*core.Directory]]{}