diff --git a/server/services/worker.ts b/server/services/worker.ts index e7d835bd6..003f74aa8 100644 --- a/server/services/worker.ts +++ b/server/services/worker.ts @@ -1,5 +1,5 @@ import Logger from "@server/logging/Logger"; -import { setResource } from "@server/logging/tracer"; +import { setResource, addTags } from "@server/logging/tracer"; import { traceFunction } from "@server/logging/tracing"; import HealthMonitor from "@server/queues/HealthMonitor"; import { initI18n } from "@server/utils/i18n"; @@ -88,6 +88,7 @@ export default function init() { const ProcessorClass = processors[name]; setResource(`Processor.${name}`); + addTags({ event }); if (!ProcessorClass) { throw new Error( @@ -131,6 +132,7 @@ export default function init() { const TaskClass = tasks[name]; setResource(`Task.${name}`); + addTags({ props }); if (!TaskClass) { throw new Error(