From b25a2992e1e7255556d0683b79e82a8c09b01590 Mon Sep 17 00:00:00 2001 From: alikia2x Date: Mon, 20 Oct 2025 05:36:38 +0800 Subject: [PATCH] update: missing `service` & `codePath` info in some logging --- packages/core/net/delegate.ts | 2 +- packages/crawler/mq/exec/snapshotTick.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/core/net/delegate.ts b/packages/core/net/delegate.ts index 1b784b4..32b3196 100644 --- a/packages/core/net/delegate.ts +++ b/packages/core/net/delegate.ts @@ -132,7 +132,7 @@ class NetworkDelegate { } catch (e) { const error = e as Error; if (e instanceof ReplyError) { - logger.error(error, "redis"); + logger.error(error, "redis", "fn:triggerLimiter"); } else if (e instanceof RateLimiterError) { // Re-throw it to ensure this.request can catch it throw e; diff --git a/packages/crawler/mq/exec/snapshotTick.ts b/packages/crawler/mq/exec/snapshotTick.ts index 2f4b320..4ca99bc 100644 --- a/packages/crawler/mq/exec/snapshotTick.ts +++ b/packages/crawler/mq/exec/snapshotTick.ts @@ -48,7 +48,7 @@ export const bulkSnapshotTickWorker = async (_job: Job) => { } return `OK`; } catch (e) { - logger.error(e as Error); + logger.error(e as Error, "mq", "fn:snapshotTickWorker"); } }; @@ -77,7 +77,7 @@ export const snapshotTickWorker = async (_job: Job) => { } return `OK`; } catch (e) { - logger.error(e as Error); + logger.error(e as Error, "mq", "fn:snapshotTickWorker"); } };