Pass target and composition type back to composition scheduler (#8276)

Author: jdolle

deployment/grafana-dashboards/Schema-Service.json

@@ -745,9 +745,9 @@
             "uid": "PROM_DATASOURCE_UID"
           },
           "editorMode": "code",
-          "expr": "sum(composition_worker_memory_used_bytes) by (instance)",
+          "expr": "max(composition_worker_memory_used_bytes) by (target, type)",
           "instant": false,
-          "legendFormat": "{{instance}}",
+          "legendFormat": "{{target}} - {{type}}",
           "range": true,
           "refId": "A"
         }

packages/services/schema/src/composition-scheduler.ts

@@ -145,7 +145,7 @@ export class CompositionScheduler {
       if (data.event === 'metric') {
         if (data.type === 'heapUsed') {
           compositionWorkerMemoryUsedBytes.set(
-            { target: workerState?.args.targetId, type: workerState?.args.data.type },
+            { target: data.target, type: data.type },
             data.value,
           );
         }

packages/services/schema/src/composition-worker.ts

@@ -17,6 +17,8 @@ export type ErrorResultEvent = {
 
 export type TrackMetricEvent = {
   event: 'metric';
+  target: string | undefined;
+  compositionType: CompositionEvent['data']['type'];
 } & {
   type: 'heapUsed';
   value: number;
@@ -45,6 +47,7 @@ export function createCompositionWorker(args: {
       messageId: message.id,
       event: message.event,
     });
+
     logger.debug('processing message');
     const postResult = (result: CompositionResultEvent | ErrorResultEvent) => {
       args.port.postMessage(result);
@@ -55,6 +58,8 @@ export function createCompositionWorker(args: {
           event: 'metric',
           type: 'heapUsed',
           value: process.memoryUsage().heapUsed,
+          target: message.targetId,
+          compositionType: message.data.type,
         } satisfies TrackMetricEvent);
       }
     };