Function Syncer

core/schema/util.go:18–52

()

}

func Syncer[T dagql.Typed]() dagql.Field[T] {
	return dagql.NodeFunc("sync", func(ctx context.Context, self dagql.ObjectResult[T], args struct {
		Recipe bool `default:"false" internal:"true"`
	}) (res dagql.Result[dagql.ID[T]], _ error) {
		if _, ok := dagql.UnwrapAs[dagql.HasLazyEvaluation](self); ok {
			cache, err := dagql.EngineCache(ctx)
			if err != nil {
				return res, err
			}
			if err := cache.Evaluate(ctx, self); err != nil {
				return res, err
			}
		} else {
			syncable, ok := dagql.UnwrapAs[core.Syncable](self)
			if !ok {
				return res, fmt.Errorf("internal error: %T does not support sync", self.Self())
			}
			if err := syncable.Sync(ctx); err != nil {
				return res, err
			}
		}
		var selfID *call.ID
		var err error
		if args.Recipe {
			selfID, err = self.RecipeID(ctx)
		} else {
			selfID, err = self.ID()
		}
		if err != nil {
			return res, err
		}
		id := dagql.NewID[T](selfID)
		return dagql.NewResultForCurrentCall(ctx, id)
	}).DoNotCache("sync is an operational boundary and each object already controls its own underlying lazy/cached state")
}

func collectInputsSlice[T dagql.Type](inputs []dagql.InputObject[T]) []T {
	ts := make([]T, len(inputs))