diff --git a/server/cmd/museum/main.go b/server/cmd/museum/main.go index e1aab19cd9..c4a17cb74f 100644 --- a/server/cmd/museum/main.go +++ b/server/cmd/museum/main.go @@ -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() diff --git a/server/pkg/controller/file.go b/server/pkg/controller/file.go index dc00c5e76c..1774e4cc1c 100644 --- a/server/pkg/controller/file.go +++ b/server/pkg/controller/file.go @@ -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