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

[server] Delete more items in single run (#5010)

Browse Source 
## Description

## Tests
This commit is contained in:
Neeraj 2025-02-10 15:25:36 +05:30 committed by GitHub
commit 10ee5989f2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -943,7 +943,7 @@ func setupAndStartCrons(userAuthRepo *repo.UserAuthRepository, publicCollectionR
} }
}) })
schedule(c, "@every 10m", func() { schedule(c, "@every 8m", func() {
fileController.CleanupDeletedFiles() fileController.CleanupDeletedFiles()
}) })
schedule(c, "@every 101s", func() { schedule(c, "@every 101s", func() {

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

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