chore: add debug statements for OTel

biothings · Oct 3, 2024 · aa83d8c · aa83d8c
1 parent 555e7ee
commit aa83d8c
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/src/controllers/opentelemetry.ts b/src/controllers/opentelemetry.ts
@@ -18,5 +18,6 @@ const sdk = new NodeSDK({
     [ATTR_SERVICE_NAME]: "biothings-explorer",
   }),
 });
+debug(`OTel URL ${process.env.JAEGER_HOST ?? 'jaeger-otel-collector'}:${process.env.JAEGER_PORT ?? 4318}/v1/traces`);
 sdk.start();
 debug("Opentelemetry instrumentation initialized.");
diff --git a/src/controllers/threading/taskHandler.ts b/src/controllers/threading/taskHandler.ts
@@ -91,12 +91,14 @@ async function runTask({
     });
 
     let activeContext: Context = propagation.extract(context.active(), { traceparent, tracestate });
+    debug(`OTel task ${traceparent} and ${tracestate}`);
     let tracer = trace.getTracer("biothings-explorer-thread")
     span = tracer.startSpan(
       routeNames[route],
       {kind: 1},  // specifies internal span
       activeContext,
     );
+    debug(`OTel span created ${span}`);
 
     span.setAttribute("bte.requestData", JSON.stringify(req.data.queryGraph));
     Telemetry.setOtelSpan(span);

diff --git a/src/controllers/threading/threadHandler.ts b/src/controllers/threading/threadHandler.ts
@@ -244,12 +244,15 @@ export async function runTask(req: Request, res: Response, route: string, useBul
     taskInfo.data.options.caching = false;
   }
 
+  debug(`OTel ${traceparent} and ${tracestate}`);
   if (process.env.USE_THREADING === "false") {
     // Threading disabled, just use the provided function in main event loop
+    debug("OTel enter no threading")
     const response = (await tasks[route](taskInfo)) as TrapiResponse;
     return response;
   } else if (!(queryQueue && useBullSync)) {
     // Redis unavailable or query not to sync queue such as asyncquery_status
+    debug("OTel enter queueTaskToWorkers")
     const response = await queueTaskToWorkers(
       useBullSync ? global.threadpool.sync : global.threadpool.misc,
       taskInfo,
@@ -298,6 +301,7 @@ export async function runTask(req: Request, res: Response, route: string, useBul
     throw new ServerOverloadedError(message, expectedWaitTime);
   }
 
+  debug("OTel enter queryQueue.add")
   const job = await queryQueue.add(taskInfo.data, jobOpts);
   try {
     const response: TrapiResponse = await (job.finished() as Promise<TrapiResponse>);