fix

Signed-off-by: Huamin Chen <[email protected]>

Author: rootfs

candle-binding/src/model_architectures/traditional/deberta_v3_test.rs

@@ -29,7 +29,7 @@ fn test_deberta_v3_invalid_path() {
 #[test]
 fn test_deberta_v3_debug_format() {
     // Test that the Debug trait exists
-    let _type_check: Option<Box<dyn std::fmt::Debug>> = None::<Box<DebertaV3Classifier>>;
+    let _type_check: Option<Box<dyn std::fmt::Debug>> = None;
 }
 
 #[cfg(test)]

config/config.redis.yaml

@@ -9,7 +9,6 @@ semantic_cache:
   similarity_threshold: 0.80  # Global threshold (lowered for better matching)
   ttl_seconds: 3600
   backend_config_path: "config/semantic-cache/redis.yaml"
-  
   # Embedding model for semantic similarity matching
   # Options: "bert" (fast, 384-dim), "qwen3" (high quality, 1024-dim, 32K context), "gemma" (balanced, 768-dim, 8K context)
   # Default: "bert" (fastest, lowest memory)

src/semantic-router/pkg/cache/cache_test.go

@@ -275,7 +275,7 @@ development:
 			Context("with unsupported backend type", func() {
 				It("should return error for unsupported backend type", func() {
 					config := CacheConfig{
-						BackendType:         "redis", // Unsupported
+						BackendType:         "unsupported_type", // Unsupported
 						Enabled:             true,
 						SimilarityThreshold: 0.8,
 						TTLSeconds:          3600,
@@ -492,7 +492,7 @@ development:
 			It("should return information about available backends", func() {
 				backends := GetAvailableCacheBackends()
 
-				Expect(backends).To(HaveLen(2)) // Memory and Milvus
+				Expect(backends).To(HaveLen(3)) // Memory, Milvus, and Redis
 
 				// Check memory backend info
 				memoryBackend := backends[0]
@@ -509,6 +509,14 @@ development:
 				Expect(milvusBackend.Description).To(ContainSubstring("Milvus vector database"))
 				Expect(milvusBackend.Features).To(ContainElement("Highly scalable"))
 				Expect(milvusBackend.Features).To(ContainElement("Persistent storage"))
+
+				// Check Redis backend info
+				redisBackend := backends[2]
+				Expect(redisBackend.Type).To(Equal(RedisCacheType))
+				Expect(redisBackend.Name).To(Equal("Redis Vector Database"))
+				Expect(redisBackend.Description).To(ContainSubstring("Redis with vector search"))
+				Expect(redisBackend.Features).To(ContainElement("Fast in-memory performance"))
+				Expect(redisBackend.Features).To(ContainElement("TTL support"))
 			})
 		})
 	})

src/semantic-router/pkg/cache/redis_cache.go

@@ -419,9 +419,9 @@ func (c *RedisCache) UpdateWithResponse(requestID string, responseBody []byte) e
 	logging.Infof("UpdateWithResponse: found %d result(s) for request_id=%s", results.Total, requestID)
 
 	doc := results.Docs[0]
-	model, _ := doc.Fields["model"]
-	queryStr, _ := doc.Fields["query"]
-	requestBodyStr, _ := doc.Fields["request_body"]
+	model := fmt.Sprint(doc.Fields["model"])
+	queryStr := fmt.Sprint(doc.Fields["query"])
+	requestBodyStr := fmt.Sprint(doc.Fields["request_body"])
 
 	// Extract document ID from the result
 	docID := doc.ID
@@ -639,7 +639,13 @@ func (c *RedisCache) FindSimilarWithThreshold(model string, query string, thresh
 	}
 
 	var distance float64
-	fmt.Sscanf(fmt.Sprint(distanceVal), "%f", &distance)
+	if _, err := fmt.Sscanf(fmt.Sprint(distanceVal), "%f", &distance); err != nil {
+		logging.Infof("RedisCache.FindSimilarWithThreshold: failed to parse distance value: %v", err)
+		atomic.AddInt64(&c.missCount, 1)
+		metrics.RecordCacheOperation("redis", "find_similar", "error", time.Since(start).Seconds())
+		metrics.RecordCacheMiss()
+		return nil, false, nil
+	}
 
 	// Convert distance to similarity score based on metric type
 	var similarity float32