Method cacheEntrySet

core/schema/engine.go:95–131

(ctx context.Context, parent dagql.ObjectResult[*core.EngineCache], args struct {
	Key string `default:""`
})

}

func (s *engineSchema) cacheEntrySet(ctx context.Context, parent dagql.ObjectResult[*core.EngineCache], args struct {
	Key string `default:""`
}) (inst dagql.Result[*core.EngineCacheEntrySet], _ error) {
	query, err := core.CurrentQuery(ctx)
	if err != nil {
		return inst, err
	}
	if err := query.RequireMainClient(ctx); err != nil {
		return inst, err
	}
	srv, err := query.Server.Server(ctx)
	if err != nil {
		return inst, fmt.Errorf("failed to get server: %w", err)
	}

	if args.Key == "" {
		err := srv.Select(ctx, parent, &inst,
			dagql.Selector{
				Field: "entrySet",
				Args: []dagql.NamedInput{
					{
						Name:  "key",
						Value: dagql.NewString(identity.NewID()),
					},
				},
			},
		)
		return inst, err
	}

	entrySet, err := query.EngineLocalCacheEntries(ctx)
	if err != nil {
		return inst, fmt.Errorf("failed to load cache entries: %w", err)
	}

	return dagql.NewResultForCurrentCall(ctx, entrySet)
}

func (s *engineSchema) cachePrune(ctx context.Context, parent *core.EngineCache, args struct {
	UseDefaultPolicy bool   `default:"false"`