diff options
| author | misskey-release-bot[bot] <157398866+misskey-release-bot[bot]@users.noreply.github.com> | 2025-07-18 00:28:01 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-07-18 00:28:01 +0000 |
| commit | e86e9b46b3c30391296f04842529f9f8411dcbba (patch) | |
| tree | bbe0f31106c393c1a742183aedd1c39ccdfa39a2 /packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts | |
| parent | Merge pull request #16197 from misskey-dev/develop (diff) | |
| parent | Release: 2025.7.0 (diff) | |
| download | misskey-e86e9b46b3c30391296f04842529f9f8411dcbba.tar.gz misskey-e86e9b46b3c30391296f04842529f9f8411dcbba.tar.bz2 misskey-e86e9b46b3c30391296f04842529f9f8411dcbba.zip | |
Merge pull request #16244 from misskey-dev/develop
Release: 2025.7.0
Diffstat (limited to 'packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts')
| -rw-r--r-- | packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts b/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts index 728fc9e72b..782b74f0cd 100644 --- a/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts +++ b/packages/backend/src/queue/processors/CleanRemoteFilesProcessorService.ts @@ -34,6 +34,11 @@ export class CleanRemoteFilesProcessorService { let deletedCount = 0; let cursor: MiDriveFile['id'] | null = null; + const total = await this.driveFilesRepository.countBy({ + userHost: Not(IsNull()), + isLink: false, + }); + while (true) { const files = await this.driveFilesRepository.find({ where: { @@ -58,12 +63,7 @@ export class CleanRemoteFilesProcessorService { deletedCount += 8; - const total = await this.driveFilesRepository.countBy({ - userHost: Not(IsNull()), - isLink: false, - }); - - job.updateProgress(100 / total * deletedCount); + job.updateProgress(deletedCount * total / 100); } this.logger.succ('All cached remote files has been deleted.'); |