diff --git a/server/cmd/museum/main.go b/server/cmd/museum/main.go index e1a3622011..9ddb958596 100644 --- a/server/cmd/museum/main.go +++ b/server/cmd/museum/main.go @@ -943,7 +943,7 @@ func setupAndStartCrons(userAuthRepo *repo.UserAuthRepository, publicCollectionR } }) - schedule(c, "@every 10m", func() { + schedule(c, "@every 8m", func() { fileController.CleanupDeletedFiles() }) schedule(c, "@every 101s", func() { diff --git a/server/pkg/controller/file.go b/server/pkg/controller/file.go index 0b2568ff5c..be9a553756 100644 --- a/server/pkg/controller/file.go +++ b/server/pkg/controller/file.go @@ -697,7 +697,7 @@ func (c *FileController) CleanupDeletedFiles() { defer func() { c.LockController.ReleaseLock(DeletedObjectQueueLock) }() - items, err := c.QueueRepo.GetItemsReadyForDeletion(repo.DeleteObjectQueue, 2500) + items, err := c.QueueRepo.GetItemsReadyForDeletion(repo.DeleteObjectQueue, 5000) if err != nil { log.WithError(err).Error("Failed to fetch items from queue") return