diff options
| author | renovate[bot] <29139614+renovate[bot]@users.noreply.github.com> | 2025-09-08 17:11:18 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-09-08 17:11:18 +0900 |
| commit | 2ea784f345bd8bd947573ca9ecca40fba169c621 (patch) | |
| tree | 65ffb23923297054971c797c39078100df584f88 /packages/backend/src/core/QueueService.ts | |
| parent | chore(deps): update [misskey-js] update dependencies (#16489) (diff) | |
| download | misskey-2ea784f345bd8bd947573ca9ecca40fba169c621.tar.gz misskey-2ea784f345bd8bd947573ca9ecca40fba169c621.tar.bz2 misskey-2ea784f345bd8bd947573ca9ecca40fba169c621.zip | |
fix(deps): update [backend] update dependencies (#16491)
* fix(deps): update [backend] update dependencies
* fix type error
* run pnpm dedupe
---------
Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>
Co-authored-by: kakkokari-gtyih <67428053+kakkokari-gtyih@users.noreply.github.com>
Diffstat (limited to 'packages/backend/src/core/QueueService.ts')
| -rw-r--r-- | packages/backend/src/core/QueueService.ts | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts index 0f225a8242..2d0e7b5d83 100644 --- a/packages/backend/src/core/QueueService.ts +++ b/packages/backend/src/core/QueueService.ts @@ -756,8 +756,8 @@ export class QueueService { @bindThis public async queueRetryJob(queueType: typeof QUEUE_TYPES[number], jobId: string) { const queue = this.getQueue(queueType); - const job: Bull.Job | null = await queue.getJob(jobId); - if (job) { + const job = await queue.getJob(jobId); + if (job != null) { if (job.finishedOn != null) { await job.retry(); } else { @@ -769,8 +769,8 @@ export class QueueService { @bindThis public async queueRemoveJob(queueType: typeof QUEUE_TYPES[number], jobId: string) { const queue = this.getQueue(queueType); - const job: Bull.Job | null = await queue.getJob(jobId); - if (job) { + const job = await queue.getJob(jobId); + if (job != null) { await job.remove(); } } @@ -803,8 +803,8 @@ export class QueueService { @bindThis public async queueGetJob(queueType: typeof QUEUE_TYPES[number], jobId: string) { const queue = this.getQueue(queueType); - const job: Bull.Job | null = await queue.getJob(jobId); - if (job) { + const job = await queue.getJob(jobId); + if (job != null) { return this.packJobData(job); } else { throw new Error(`Job not found: ${jobId}`); |