Function encodePersistedObjectRef

core/persisted_object.go:47–63

(cache dagql.PersistedObjectCache, ref any, label string)

}

func encodePersistedObjectRef(cache dagql.PersistedObjectCache, ref any, label string) (uint64, error) {
	if cache == nil {
		return 0, fmt.Errorf("encode persisted %s cache: nil cache", label)
	}
	switch x := ref.(type) {
	case nil:
		return 0, fmt.Errorf("encode persisted %s ref: nil value", label)
	case dagql.AnyResult:
		resultID, err := cache.PersistedResultID(x)
		if err != nil {
			return 0, fmt.Errorf("encode persisted %s ref: %w", label, err)
		}
		return resultID, nil
	default:
		return 0, fmt.Errorf("encode persisted %s ref: unsupported value %T", label, ref)
	}
}

func decodePersistedCallID(raw string) (*call.ID, error) {
	if raw == "" {