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"); } };