fix(typesense): upsert one document at a time
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/push Build is passing
Details
This commit is contained in:
parent
8a15c91a4f
commit
1a492722dd
|
@ -240,7 +240,6 @@ func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
typesenseTasks := []interface{}{}
|
|
||||||
for _, task := range tasks {
|
for _, task := range tasks {
|
||||||
searchTask := convertTaskToTypesenseTask(task)
|
searchTask := convertTaskToTypesenseTask(task)
|
||||||
|
|
||||||
|
@ -250,17 +249,12 @@ func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
typesenseTasks = append(typesenseTasks, searchTask)
|
_, err = typesenseClient.Collection("tasks").
|
||||||
}
|
Documents().
|
||||||
|
Upsert(searchTask)
|
||||||
_, err = typesenseClient.Collection("tasks").
|
if err != nil {
|
||||||
Documents().
|
return err
|
||||||
Import(typesenseTasks, &api.ImportDocumentsParams{
|
}
|
||||||
Action: pointer.String("upsert"),
|
|
||||||
BatchSize: pointer.Int(100),
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|
Loading…
Reference in New Issue