summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors
diff options
context:
space:
mode:
authorHazelnoot <acomputerdog@gmail.com>2024-11-03 10:47:27 -0500
committerHazelnoot <acomputerdog@gmail.com>2024-11-26 08:59:08 -0500
commit3f5ea11a1fbb426d55e9f6df4ce8b4b7b642e270 (patch)
treea4ca05506f73cb8b7565b3e664dbc2c2ca937df0 /packages/backend/src/queue/processors
parentdon't retry jobs when processing returns a non-retryable error (diff)
downloadsharkey-3f5ea11a1fbb426d55e9f6df4ce8b4b7b642e270.tar.gz
sharkey-3f5ea11a1fbb426d55e9f6df4ce8b4b7b642e270.tar.bz2
sharkey-3f5ea11a1fbb426d55e9f6df4ce8b4b7b642e270.zip
clarify logging when an inbox job is skipped or fails
Diffstat (limited to 'packages/backend/src/queue/processors')
-rw-r--r--packages/backend/src/queue/processors/InboxProcessorService.ts6
1 files changed, 5 insertions, 1 deletions
diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts
index 260ebe0d40..0318f621e3 100644
--- a/packages/backend/src/queue/processors/InboxProcessorService.ts
+++ b/packages/backend/src/queue/processors/InboxProcessorService.ts
@@ -218,7 +218,11 @@ export class InboxProcessorService implements OnApplicationShutdown {
try {
const result = await this.apInboxService.performActivity(authUser.user, activity);
if (result && !result.startsWith('ok')) {
- this.logger.warn(`inbox activity ignored (maybe): id=${activity.id} reason=${result}`);
+ if (result.startsWith('skip:')) {
+ this.logger.info(`inbox activity ignored: id=${activity.id} reason=${result}`);
+ } else {
+ this.logger.warn(`inbox activity failed: id=${activity.id} reason=${result}`);
+ }
return result;
}
} catch (e) {