summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts
diff options
context:
space:
mode:
authorkeito <131662659+mst-mkt@users.noreply.github.com>2025-06-25 20:30:17 +0900
committerGitHub <noreply@github.com>2025-06-25 20:30:17 +0900
commitc424554d4a9f49560e4f3d379a93c64bdabab29e (patch)
tree009dd8a88921cd70aeb3374123da3c95dcdbba5c /packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts
parentenhance(frontend): ページネーションの並び順を逆にできるよ... (diff)
downloadmisskey-c424554d4a9f49560e4f3d379a93c64bdabab29e.tar.gz
misskey-c424554d4a9f49560e4f3d379a93c64bdabab29e.tar.bz2
misskey-c424554d4a9f49560e4f3d379a93c64bdabab29e.zip
ジョブキューの`Progress`の値を正しく計算する (#16218)
* fix: ジョブキューのProgressの値の範囲を 0~100 に統一 * fix(backend): ジョブキューのProgressの計算に用いる総数を最初に一度だけ取得する
Diffstat (limited to 'packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts')
-rw-r--r--packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts10
1 files changed, 5 insertions, 5 deletions
diff --git a/packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts b/packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts
index 291fa4a6d8..5a8a8ca940 100644
--- a/packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts
+++ b/packages/backend/src/queue/processors/DeleteDriveFilesProcessorService.ts
@@ -43,6 +43,10 @@ export class DeleteDriveFilesProcessorService {
let deletedCount = 0;
let cursor: MiDriveFile['id'] | null = null;
+ const total = await this.driveFilesRepository.countBy({
+ userId: user.id,
+ });
+
while (true) {
const files = await this.driveFilesRepository.find({
where: {
@@ -67,11 +71,7 @@ export class DeleteDriveFilesProcessorService {
deletedCount++;
}
- const total = await this.driveFilesRepository.countBy({
- userId: user.id,
- });
-
- job.updateProgress(deletedCount / total);
+ job.updateProgress(deletedCount / total * 100);
}
this.logger.succ(`All drive files (${deletedCount}) of ${user.id} has been deleted.`);