From fa5a4a040cbe31a206dde754af9b70728e517b6f Mon Sep 17 00:00:00 2001 From: etiennedi Date: Tue, 6 Jan 2026 09:56:18 +0100 Subject: [PATCH] fix schema update with named vectors --- benchmarker/cmd/ann_benchmark.go | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/benchmarker/cmd/ann_benchmark.go b/benchmarker/cmd/ann_benchmark.go index 162c46f..a6804a7 100644 --- a/benchmarker/cmd/ann_benchmark.go +++ b/benchmarker/cmd/ann_benchmark.go @@ -613,7 +613,12 @@ func enableCompression(cfg *Config, client *weaviate.Client, dimensions uint, co if cfg.MultiVectorDimensions > 0 { vectorIndexConfig = classConfig.VectorConfig["multivector"].VectorIndexConfig.(map[string]interface{}) } else { - vectorIndexConfig = classConfig.VectorIndexConfig.(map[string]interface{}) + if cfg.NamedVector == "" { + vectorIndexConfig = classConfig.VectorIndexConfig.(map[string]interface{}) + } else { + vectorIndexConfig = classConfig.VectorConfig[cfg.NamedVector].VectorIndexConfig.(map[string]interface{}) + classConfig.Vectorizer = "" + } } switch compressionType { @@ -661,7 +666,13 @@ func enableCompression(cfg *Config, client *weaviate.Client, dimensions uint, co vectorConfig.VectorIndexConfig = vectorIndexConfig classConfig.VectorConfig["multivector"] = vectorConfig } else { - classConfig.VectorIndexConfig = vectorIndexConfig + if cfg.NamedVector == "" { + classConfig.VectorIndexConfig = vectorIndexConfig + } else { + vectorConfig := classConfig.VectorConfig[cfg.NamedVector] + vectorConfig.VectorIndexConfig = vectorIndexConfig + classConfig.VectorConfig[cfg.NamedVector] = vectorConfig + } } err = client.Schema().ClassUpdater().WithClass(classConfig).Do(context.Background())