summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors/InboxProcessorService.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/backend/src/queue/processors/InboxProcessorService.ts')
-rw-r--r--packages/backend/src/queue/processors/InboxProcessorService.ts9
1 files changed, 4 insertions, 5 deletions
diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts
index 1257467cfe..93d0a08003 100644
--- a/packages/backend/src/queue/processors/InboxProcessorService.ts
+++ b/packages/backend/src/queue/processors/InboxProcessorService.ts
@@ -146,12 +146,11 @@ export class InboxProcessorService implements OnApplicationShutdown {
authUser = await this.apDbResolverService.getAuthUserFromApId(actorId);
} catch (err) {
// 対象が4xxならスキップ
- if (err instanceof StatusError) {
- if (!err.isRetryable) {
- throw new Bull.UnrecoverableError(`skip: Ignored deleted actors on both ends ${actorId} - ${err.statusCode}`);
- }
- throw new Error(`Error in actor ${actorId} - ${err.statusCode}`);
+ if (!isRetryableError(err)) {
+ throw new Bull.UnrecoverableError(`skip: Ignored deleted actors on both ends ${actorId}`);
}
+
+ throw err;
}
}