chore: More tracing cleanup

server/queues/processors/BacklinksProcessor.ts

@@ -6,7 +6,9 @@ import parseDocumentIds from "@server/utils/parseDocumentIds";
 import slugify from "@server/utils/slugify";
 import BaseProcessor from "./BaseProcessor";
 
-@APM.trace()
+@APM.trace({
+  spanName: "processor",
+})
 export default class BacklinksProcessor extends BaseProcessor {
   static applicableEvents: Event["name"][] = [
     "documents.publish",

server/queues/processors/DebounceProcessor.ts

@@ -4,7 +4,9 @@ import { Event } from "@server/types";
 import { globalEventQueue } from "..";
 import BaseProcessor from "./BaseProcessor";
 
-@APM.trace()
+@APM.trace({
+  spanName: "processor",
+})
 export default class DebounceProcessor extends BaseProcessor {
   static applicableEvents: Event["name"][] = [
     "documents.update",

server/queues/processors/NotificationsProcessor.ts

@@ -19,7 +19,9 @@ import {
 } from "@server/types";
 import BaseProcessor from "./BaseProcessor";
 
-@APM.trace()
+@APM.trace({
+  spanName: "processor",
+})
 export default class NotificationsProcessor extends BaseProcessor {
   static applicableEvents: Event["name"][] = [
     "documents.publish",

server/queues/processors/RevisionsProcessor.ts

@@ -5,7 +5,9 @@ import { Revision, Document, User } from "@server/models";
 import { DocumentEvent, RevisionEvent, Event } from "@server/types";
 import BaseProcessor from "./BaseProcessor";
 
-@APM.trace()
+@APM.trace({
+  spanName: "processor",
+})
 export default class RevisionsProcessor extends BaseProcessor {
   static applicableEvents: Event["name"][] = ["documents.update.debounced"];
 

server/queues/processors/SlackProcessor.ts

@@ -11,7 +11,9 @@ import {
 } from "@server/types";
 import BaseProcessor from "./BaseProcessor";
 
-@APM.trace()
+@APM.trace({
+  spanName: "processor",
+})
 export default class SlackProcessor extends BaseProcessor {
   static applicableEvents: Event["name"][] = [
     "documents.publish",

server/queues/processors/WebsocketsProcessor.ts

@@ -19,7 +19,9 @@ import {
 } from "@server/presenters";
 import { Event } from "../../types";
 
-@APM.trace()
+@APM.trace({
+  spanName: "processor",
+})
 export default class WebsocketsProcessor {
   async perform(event: Event, socketio: Server) {
     switch (event.name) {

server/queues/tasks/CleanupDeletedDocumentsTask.ts

@@ -10,7 +10,9 @@ type Props = {
   limit: number;
 };
 
-@APM.trace()
+@APM.trace({
+  spanName: "task",
+})
 export default class CleanupDeletedDocumentsTask extends BaseTask<Props> {
   public async perform({ limit }: Props) {
     Logger.info(

server/queues/tasks/CleanupDeletedTeamsTask.ts

@@ -10,7 +10,9 @@ type Props = {
   limit: number;
 };
 
-@APM.trace()
+@APM.trace({
+  spanName: "task",
+})
 export default class CleanupDeletedTeamsTask extends BaseTask<Props> {
   public async perform({ limit }: Props) {
     Logger.info(

server/queues/tasks/CleanupExpiredFileOperationsTask.ts

@@ -9,7 +9,9 @@ type Props = {
   limit: number;
 };
 
-@APM.trace()
+@APM.trace({
+  spanName: "task",
+})
 export default class CleanupExpiredFileOperationsTask extends BaseTask<Props> {
   public async perform({ limit }: Props) {
     Logger.info("task", `Expiring export file operations older than 30 days…`);

server/queues/tasks/EmailTask.ts

@@ -7,7 +7,9 @@ type Props = {
   props: Record<string, any>;
 };
 
-@APM.trace()
+@APM.trace({
+  spanName: "task",
+})
 export default class EmailTask extends BaseTask<Props> {
   public async perform({ templateName, props }: Props) {
     const EmailClass = emails[templateName];