don't retry jobs when processing returns a non-retryable error
This commit is contained in:
@@ -341,7 +341,7 @@ export class ApInboxService {
|
|||||||
// 対象が4xxならスキップ
|
// 対象が4xxならスキップ
|
||||||
if (err instanceof StatusError) {
|
if (err instanceof StatusError) {
|
||||||
if (!err.isRetryable) {
|
if (!err.isRetryable) {
|
||||||
return `Ignored announce target ${target.id} - ${err.statusCode}`;
|
return `skip: ignored announce target ${target.id} - ${err.statusCode}`;
|
||||||
}
|
}
|
||||||
return `Error in announce target ${target.id} - ${err.statusCode}`;
|
return `Error in announce target ${target.id} - ${err.statusCode}`;
|
||||||
}
|
}
|
||||||
@@ -461,7 +461,7 @@ export class ApInboxService {
|
|||||||
return 'ok';
|
return 'ok';
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
if (err instanceof StatusError && !err.isRetryable) {
|
if (err instanceof StatusError && !err.isRetryable) {
|
||||||
return `skip ${err.statusCode}`;
|
return `skip: ${err.statusCode}`;
|
||||||
} else {
|
} else {
|
||||||
throw err;
|
throw err;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user