kenmirrors/ente
1
0
Fork 0
mirror of https://github.com/ente-io/ente.git synced 2025-08-08 07:28:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

[server] Slow down crons

Browse Source
This commit is contained in:
Neeraj Gupta 2024-09-19 11:49:48 +05:30
parent a7cc96d994
commit a8c7dd52ba
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/cmd/museum/main.go
View File

@ -893,14 +893,14 @@ func setupAndStartCrons(userAuthRepo *repo.UserAuthRepository, publicCollectionR
}
})
schedule(c, "@every 2m", func() {
schedule(c, "@every 10m", func() {
fileController.CleanupDeletedFiles()
})
schedule(c, "@every 101s", func() {
embeddingCtrl.CleanupDeletedEmbeddings()
})
schedule(c, "@every 10m", func() {
schedule(c, "@every 17m", func() {
trashController.DropFileMetadataCron()
})
@ -926,7 +926,7 @@ func setupAndStartCrons(userAuthRepo *repo.UserAuthRepository, publicCollectionR
trashController.ProcessEmptyTrashRequests()
})
schedule(c, "@every 30m", func() {
schedule(c, "@every 45m", func() {
// delete unclaimed codes older than 60 minutes
_ = castDb.DeleteUnclaimedCodes(context.Background(), timeUtil.MicrosecondsBeforeMinutes(60))
dataCleanupCtrl.DeleteDataCron()

2
server/pkg/controller/file.go
View File

@ -689,7 +689,7 @@ func (c *FileController) CleanupDeletedFiles() {
defer func() {
c.LockController.ReleaseLock(DeletedObjectQueueLock)
}()
items, err := c.QueueRepo.GetItemsReadyForDeletion(repo.DeleteObjectQueue, 2000)
items, err := c.QueueRepo.GetItemsReadyForDeletion(repo.DeleteObjectQueue, 1000)
if err != nil {
log.WithError(err).Error("Failed to fetch items from queue")
return