amechama/sharkey
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(backend): ジョブキュー再試行時のタイミングずれによるエラーを抑制 (#11035)

Browse Source 
* fix(backend): ジョブキュー再試行時のタイミングずれによるエラーを抑制

* fix lint
This commit is contained in:
CyberRex 2023-07-08 08:57:23 +09:00 committed by GitHub
parent 4f876c9e8d
commit 8ec96ad1e0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
packages/backend/src/server/api/endpoints/admin/queue/promote.ts
View File

@ -33,7 +33,17 @@ export default class extends Endpoint<typeof meta, typeof paramDef> {
delayedQueues = await this.queueService.deliverQueue.getDelayed(); delayedQueues = await this.queueService.deliverQueue.getDelayed();
for (let queueIndex = 0; queueIndex < delayedQueues.length; queueIndex++) { for (let queueIndex = 0; queueIndex < delayedQueues.length; queueIndex++) {
const queue = delayedQueues[queueIndex]; const queue = delayedQueues[queueIndex];
await queue.promote(); try {
await queue.promote();
} catch (e) {
if (e instanceof Error) {
if (e.message.indexOf('not in a delayed state') !== -1) {
throw e;
}
} else {
throw e;
}
}
} }
break; break;
@ -41,7 +51,17 @@ export default class extends Endpoint<typeof meta, typeof paramDef> {
delayedQueues = await this.queueService.inboxQueue.getDelayed(); delayedQueues = await this.queueService.inboxQueue.getDelayed();
for (let queueIndex = 0; queueIndex < delayedQueues.length; queueIndex++) { for (let queueIndex = 0; queueIndex < delayedQueues.length; queueIndex++) {
const queue = delayedQueues[queueIndex]; const queue = delayedQueues[queueIndex];
await queue.promote(); try {
await queue.promote();
} catch (e) {
if (e instanceof Error) {
if (e.message.indexOf('not in a delayed state') !== -1) {
throw e;
}
} else {
throw e;
}
}
} }
break; break;
} }