diff options
| author | riku6460 <17585784+riku6460@users.noreply.github.com> | 2024-01-06 09:40:08 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-01-06 09:40:08 +0900 |
| commit | 24645e3d3dbcdde5bda02c19d0358353e843734a (patch) | |
| tree | caf3e6aac2bf968982f3c51227eb1dd608252f5e /packages/backend/src/queue/processors/InboxProcessorService.ts | |
| parent | enhance(backend): ActivityPub Deliver queueでBodyを事前処理するよう... (diff) | |
| download | sharkey-24645e3d3dbcdde5bda02c19d0358353e843734a.tar.gz sharkey-24645e3d3dbcdde5bda02c19d0358353e843734a.tar.bz2 sharkey-24645e3d3dbcdde5bda02c19d0358353e843734a.zip | |
enhance(backend): ActivityPub 周りで連合先から HTTP 429 Too Many Requests を受け取った際にジョブをリトライするように (#12917)
* enhance(backend): ActivityPub 周りで HTTP 429 Too Many Requests を受け取った際にリトライするように
* add to changelog
---------
Co-authored-by: syuilo <Syuilotan@yahoo.co.jp>
Diffstat (limited to 'packages/backend/src/queue/processors/InboxProcessorService.ts')
| -rw-r--r-- | packages/backend/src/queue/processors/InboxProcessorService.ts | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts index 89d4ea503e..50e7a1631e 100644 --- a/packages/backend/src/queue/processors/InboxProcessorService.ts +++ b/packages/backend/src/queue/processors/InboxProcessorService.ts @@ -85,7 +85,7 @@ export class InboxProcessorService { } catch (err) { // 対象が4xxならスキップ if (err instanceof StatusError) { - if (err.isClientError) { + if (!err.isRetryable) { throw new Bull.UnrecoverableError(`skip: Ignored deleted actors on both ends ${activity.actor} - ${err.statusCode}`); } throw new Error(`Error in actor ${activity.actor} - ${err.statusCode}`); |