From 4cbed7c2ed5a01a3c0358f102ff99f6a382de9fe Mon Sep 17 00:00:00 2001 From: kolaente Date: Fri, 20 Sep 2024 07:54:23 +0200 Subject: [PATCH] fix(typesense): use emplace instead of upsert to update documents (cherry picked from commit 3f1d0f390bddd05992f7ad1170ddfbda0bb3aec7) --- pkg/models/typesense.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/pkg/models/typesense.go b/pkg/models/typesense.go index 21a166f1a..81668a9e2 100644 --- a/pkg/models/typesense.go +++ b/pkg/models/typesense.go @@ -199,8 +199,6 @@ func CreateTypesenseCollections() error { } func ReindexAllTasks() (err error) { - tasks := make(map[int64]*Task) - s := db.NewSession() defer s.Close() @@ -218,6 +216,7 @@ func ReindexAllTasks() (err error) { return fmt.Errorf("could not update last sync: %s", err.Error()) } + tasks := make(map[int64]*Task) err = s.Find(tasks) if err != nil { return fmt.Errorf("could not get all tasks: %s", err.Error()) @@ -321,7 +320,7 @@ func reindexTasksInTypesense(s *xorm.Session, tasks map[int64]*Task) (err error) _, err = typesenseClient.Collection("tasks"). Documents(). Import(context.Background(), typesenseTasks, &api.ImportDocumentsParams{ - Action: pointer.String("upsert"), + Action: pointer.String("emplace"), BatchSize: pointer.Int(100), }) if err != nil {