chore: Add tags to queue processor traces
This commit is contained in:
@@ -1,5 +1,5 @@
|
|||||||
import Logger from "@server/logging/Logger";
|
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 { traceFunction } from "@server/logging/tracing";
|
||||||
import HealthMonitor from "@server/queues/HealthMonitor";
|
import HealthMonitor from "@server/queues/HealthMonitor";
|
||||||
import { initI18n } from "@server/utils/i18n";
|
import { initI18n } from "@server/utils/i18n";
|
||||||
@@ -88,6 +88,7 @@ export default function init() {
|
|||||||
const ProcessorClass = processors[name];
|
const ProcessorClass = processors[name];
|
||||||
|
|
||||||
setResource(`Processor.${name}`);
|
setResource(`Processor.${name}`);
|
||||||
|
addTags({ event });
|
||||||
|
|
||||||
if (!ProcessorClass) {
|
if (!ProcessorClass) {
|
||||||
throw new Error(
|
throw new Error(
|
||||||
@@ -131,6 +132,7 @@ export default function init() {
|
|||||||
const TaskClass = tasks[name];
|
const TaskClass = tasks[name];
|
||||||
|
|
||||||
setResource(`Task.${name}`);
|
setResource(`Task.${name}`);
|
||||||
|
addTags({ props });
|
||||||
|
|
||||||
if (!TaskClass) {
|
if (!TaskClass) {
|
||||||
throw new Error(
|
throw new Error(
|
||||||
|
|||||||
Reference in New Issue
Block a user