From 4eb3d609a1df4b94021eca6572c69ae76d318a85 Mon Sep 17 00:00:00 2001
From: Grail Finder <wohilas@gmail.com>
Date: Sat, 22 Nov 2025 15:31:46 +0300
Subject: Enha: new tables

---
 rag/rag.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'rag/rag.go')

diff --git a/rag/rag.go b/rag/rag.go
index c560f33..7fbbe98 100644
--- a/rag/rag.go
+++ b/rag/rag.go
@@ -163,9 +163,9 @@ func (r *RAG) writeVectors(vectorCh chan []models.VectorRow) error {
 		for batch := range vectorCh {
 			for _, vector := range batch {
 				if err := r.storage.WriteVector(&vector); err != nil {
-					r.logger.Error("failed to write vector", "error", err, "slug", vector.Slug)
+					r.logger.Error("failed to write vector to DB", "error", err, "slug", vector.Slug)
 					LongJobStatusCh <- ErrRAGStatus
-					continue // a duplicate is not critical
+					return err // Stop the entire RAG operation on DB error
 				}
 			}
 			r.logger.Debug("wrote batch to db", "size", len(batch), "vector_chan_len", len(vectorCh))
-- 
cgit v1.2.3