fix(backend): removed wrong defer in db.Saver

2023-02-21 15:29:24 +01:00 · 2023-02-21 15:29:24 +01:00 · 4bdc095c76
commit 4bdc095c76
parent bc227dc450
1 changed files with 0 additions and 1 deletions
--- a/ee/backend/internal/db/datasaver/saver.go
+++ b/ee/backend/internal/db/datasaver/saver.go
@ -19,7 +19,6 @@ func New(pg *cache.PGCache, cfg *db.Config) *Saver {
 	var producer types.Producer = nil
 	if cfg.UseQuickwit {
 		producer = queue.NewProducer(cfg.MessageSizeLimit, true)
-		defer producer.Close(15000)
 	}
 	return &Saver{pg: pg, producer: producer, topic: cfg.QuickwitTopic}
 }