From 1a492722dd8102d553260a709c0d84e476d7fd09 Mon Sep 17 00:00:00 2001 From: kolaente Date: Sun, 3 Sep 2023 22:51:43 +0200 Subject: [PATCH] fix(typesense): upsert one document at a time --- pkg/models/typesense.go | 18 ++++++------------ 1 file changed, 6 insertions(+), 12 deletions(-) diff --git a/pkg/models/typesense.go b/pkg/models/typesense.go index 559dc93dd..d633fc9a9 100644 --- a/pkg/models/typesense.go +++ b/pkg/models/typesense.go @@ -240,7 +240,6 @@ func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) { return err } - typesenseTasks := []interface{}{} for _, task := range tasks { searchTask := convertTaskToTypesenseTask(task) @@ -250,17 +249,12 @@ func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) { return err } - typesenseTasks = append(typesenseTasks, searchTask) - } - - _, err = typesenseClient.Collection("tasks"). - Documents(). - Import(typesenseTasks, &api.ImportDocumentsParams{ - Action: pointer.String("upsert"), - BatchSize: pointer.Int(100), - }) - if err != nil { - return err + _, err = typesenseClient.Collection("tasks"). + Documents(). + Upsert(searchTask) + if err != nil { + return err + } } return nil