diff --git a/api/daily/common.go b/api/daily/common.go index f38eb05..df048e2 100644 --- a/api/daily/common.go +++ b/api/daily/common.go @@ -96,8 +96,7 @@ func Init() error { return nil } - S3SaveMigration() - _, err = s3scheduler.AddFunc("@weekly", func() { + _, err = s3scheduler.AddFunc("@hourly", func() { time.Sleep(time.Second) S3SaveMigration() }) diff --git a/db/savedata.go b/db/savedata.go index 5b9e9e1..77dc3f6 100644 --- a/db/savedata.go +++ b/db/savedata.go @@ -270,7 +270,7 @@ func RetrieveSystemSaveFromS3(uuid []byte) error { func RetrieveOldAccounts() [][]byte { var users [][]byte - rows, err := handle.Query("SELECT uuid FROM accounts WHERE isInLocalDb = 1 && lastActivity < DATE_SUB(NOW(), INTERVAL 3 MONTH)") + rows, err := handle.Query("SELECT uuid FROM accounts WHERE isInLocalDb = 1 && lastActivity < DATE_SUB(NOW(), INTERVAL 3 MONTH) LIMIT 3000") if err != nil { return nil }