diff --git a/object/user.go b/object/user.go index 5bcdfa6e..c4e9d6fd 100644 --- a/object/user.go +++ b/object/user.go @@ -345,7 +345,7 @@ func AddUsers(users []*User) bool { return affected != 0 } -func AddUsersSafe(users []*User) bool { +func AddUsersInBatch(users []*User) bool { batchSize := 1000 if len(users) == 0 { diff --git a/original/sync.go b/original/sync.go index e1ba9c9f..6e2ab515 100644 --- a/original/sync.go +++ b/original/sync.go @@ -141,7 +141,7 @@ func syncUsers() { } } } - object.AddUsersSafe(newUsers) + object.AddUsersInBatch(newUsers) for _, user := range users { id := user.Id