feat: Implement event loop instrumentation (#14956)

sradevski · shahednasser · web-flow · commit 6f0465f76bbc · 2026-04-10T12:15:21.000Z
## Summary

Add Event loop instrumentation support. This should make it easier to detect a common issue - the event loop getting blocked resulting in 503s and restarts.

I still need to do some testing, but code-wise it can be reviewed.

Co-authored-by: Shahed Nasser &lt;27354907+shahednasser@users.noreply.github.com&gt;
diff --git a/.changeset/dry-clowns-write.md b/.changeset/dry-clowns-write.md
@@ -0,0 +1,7 @@
+---
+"@medusajs/framework": patch
+"@medusajs/medusa": patch
+"@medusajs/deps": patch
+---
+
+feat: Implement event loop instrumentation
diff --git a/packages/core/framework/package.json b/packages/core/framework/package.json
@@ -43,6 +43,9 @@
     "./mikro-orm/migrations": "./dist/deps/mikro-orm-migrations.js",
     "./mikro-orm/postgresql": "./dist/deps/mikro-orm-postgresql.js",
     "./opentelemetry/instrumentation-pg": "./dist/deps/opentelemetry-instrumentation-pg.js",
+    "./opentelemetry/exporter-trace-otlp-http": "./dist/deps/opentelemetry-exporter-trace-otlp-http.js",
+    "./opentelemetry/exporter-metrics-otlp-http": "./dist/deps/opentelemetry-exporter-metrics-otlp-http.js",
+    "./opentelemetry/sdk-metrics": "./dist/deps/opentelemetry-sdk-metrics.js",
     "./opentelemetry/sdk-node": "./dist/deps/opentelemetry-sdk-node.js",
     "./opentelemetry/sdk-trace-node": "./dist/deps/opentelemetry-sdk-trace-node.js",
     "./opentelemetry/resources": "./dist/deps/opentelemetry-resources.js",
diff --git a/packages/core/framework/src/deps/opentelemetry-exporter-metrics-otlp-http.ts b/packages/core/framework/src/deps/opentelemetry-exporter-metrics-otlp-http.ts
@@ -0,0 +1 @@
+export * from "@medusajs/deps/opentelemetry/exporter-metrics-otlp-http"
diff --git a/packages/core/framework/src/deps/opentelemetry-exporter-trace-otlp-http.ts b/packages/core/framework/src/deps/opentelemetry-exporter-trace-otlp-http.ts
@@ -0,0 +1 @@
+export * from "@medusajs/deps/opentelemetry/exporter-trace-otlp-http"
diff --git a/packages/core/framework/src/deps/opentelemetry-sdk-metrics.ts b/packages/core/framework/src/deps/opentelemetry-sdk-metrics.ts
@@ -0,0 +1 @@
+export * from "@medusajs/deps/opentelemetry/sdk-metrics"
diff --git a/packages/deps/package.json b/packages/deps/package.json
@@ -20,10 +20,13 @@
   "exports": {
     ".": "./dist/index.js",
     "./opentelemetry/instrumentation-pg": "./dist/opentelemetry-instrumentation-pg.js",
+    "./opentelemetry/sdk-metrics": "./dist/opentelemetry-sdk-metrics.js",
     "./opentelemetry/sdk-node": "./dist/opentelemetry-sdk-node.js",
     "./opentelemetry/sdk-trace-node": "./dist/opentelemetry-sdk-trace-node.js",
     "./opentelemetry/resources": "./dist/opentelemetry-resources.js",
     "./opentelemetry/api": "./dist/opentelemetry-api.js",
+    "./opentelemetry/exporter-trace-otlp-http": "./dist/opentelemetry-exporter-trace-otlp-http.js",
+    "./opentelemetry/exporter-metrics-otlp-http": "./dist/opentelemetry-exporter-metrics-otlp-http.js",
     "./mikro-orm/cli": "./dist/mikro-orm-cli.js",
     "./mikro-orm/core": "./dist/mikro-orm-core.js",
     "./mikro-orm/knex": "./dist/mikro-orm-knex.js",
@@ -44,11 +47,14 @@
     "@mikro-orm/knex": "6.6.12",
     "@mikro-orm/migrations": "6.6.12",
     "@mikro-orm/postgresql": "6.6.12",
-    "@opentelemetry/api": "^1.9.0",
-    "@opentelemetry/instrumentation-pg": "^0.52.0",
-    "@opentelemetry/resources": "^2.0.0",
-    "@opentelemetry/sdk-node": "^0.200.0",
-    "@opentelemetry/sdk-trace-node": "^2.0.0",
+    "@opentelemetry/api": "^1.9.1",
+    "@opentelemetry/exporter-metrics-otlp-http": "^0.214.0",
+    "@opentelemetry/exporter-trace-otlp-http": "^0.214.0",
+    "@opentelemetry/instrumentation-pg": "^0.56.0",
+    "@opentelemetry/resources": "^2.6.1",
+    "@opentelemetry/sdk-metrics": "^2.6.1",
+    "@opentelemetry/sdk-node": "^0.214.0",
+    "@opentelemetry/sdk-trace-node": "^2.6.1",
     "awilix": "^8.0.1",
     "pg": "^8.16.3",
     "zod": "3.25.76"
diff --git a/packages/deps/src/opentelemetry-exporter-metrics-otlp-http.ts b/packages/deps/src/opentelemetry-exporter-metrics-otlp-http.ts
@@ -0,0 +1 @@
+export * from "@opentelemetry/exporter-metrics-otlp-http"
diff --git a/packages/deps/src/opentelemetry-exporter-trace-otlp-http.ts b/packages/deps/src/opentelemetry-exporter-trace-otlp-http.ts
@@ -0,0 +1 @@
+export * from "@opentelemetry/exporter-trace-otlp-http"
diff --git a/packages/deps/src/opentelemetry-sdk-metrics.ts b/packages/deps/src/opentelemetry-sdk-metrics.ts
@@ -0,0 +1 @@
+export * from "@opentelemetry/sdk-metrics"
diff --git a/packages/medusa/src/commands/start.ts b/packages/medusa/src/commands/start.ts
@@ -69,7 +69,6 @@ export async function registerInstrumentation(directory: string) {
     skipDbConnection: true,
   })
   const logger = container.resolve(ContainerRegistrationKeys.LOGGER)
-
   const fileSystem = new FileSystem(directory)
   const exists =
     (await fileSystem.exists(`${INSTRUMENTATION_FILE}.ts`)) ||
diff --git a/packages/medusa/src/instrumentation/cloud.ts b/packages/medusa/src/instrumentation/cloud.ts
@@ -0,0 +1,37 @@
+import { OTLPTraceExporter } from "@medusajs/framework/opentelemetry/exporter-trace-otlp-http"
+import { OTLPMetricExporter } from "@medusajs/framework/opentelemetry/exporter-metrics-otlp-http"
+
+const MEDUSA_CLOUD_EXECUTION_CONTEXT = "medusa-cloud"
+
+export function getCloudExporters() {
+  const isCloud =
+    process.env.EXECUTION_CONTEXT === MEDUSA_CLOUD_EXECUTION_CONTEXT
+  if (!isCloud) {
+    return {
+      exporter: undefined,
+      metricsExporter: undefined,
+    }
+  }
+
+  const tracesUrl = process.env.MEDUSA_CLOUD_OTLP_TRACES_EXPORTER_URL
+  const metricsUrl = process.env.MEDUSA_CLOUD_OTLP_METRICS_EXPORTER_URL
+
+  return {
+    exporter: tracesUrl
+      ? new OTLPTraceExporter({
+          url: process.env.MEDUSA_CLOUD_OTLP_TRACES_EXPORTER_URL,
+          headers: process.env.MEDUSA_CLOUD_OTLP_TRACES_EXPORTER_HEADERS
+            ? JSON.parse(process.env.MEDUSA_CLOUD_OTLP_TRACES_EXPORTER_HEADERS)
+            : {},
+        })
+      : undefined,
+    metricsExporter: metricsUrl
+      ? new OTLPMetricExporter({
+          url: process.env.MEDUSA_CLOUD_OTLP_METRICS_EXPORTER_URL,
+          headers: process.env.MEDUSA_CLOUD_OTLP_METRICS_EXPORTER_HEADERS
+            ? JSON.parse(process.env.MEDUSA_CLOUD_OTLP_METRICS_EXPORTER_HEADERS)
+            : {},
+        })
+      : undefined,
+  }
+}
diff --git a/packages/medusa/src/instrumentation/index.ts b/packages/medusa/src/instrumentation/index.ts
diff --git a/yarn.lock b/yarn.lock

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+export * from "@medusajs/deps/opentelemetry/exporter-metrics-otlp-http"`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+export * from "@opentelemetry/exporter-metrics-otlp-http"`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+export * from "@opentelemetry/sdk-metrics"`