working writer

Author: gary-huang

dd-java-agent/agent-llmobs/src/main/java/datadog/trace/llmobs/domain/DDLLMObsSpan.java

@@ -39,6 +39,8 @@ public class DDLLMObsSpan implements LLMObsSpan {
 
   private boolean finished = false;
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(DDLLMObsSpan.class);
+
   public DDLLMObsSpan(
       @Nonnull String kind,
       String spanName,
@@ -85,6 +87,7 @@ public void annotateIO(List<LLMObs.LLMMessage> inputData, List<LLMObs.LLMMessage
     if (finished) {
       return;
     }
+    LOGGER.warn("ANNOTATE IN {} OUT {}", inputData, outputData);
     if (inputData != null && !inputData.isEmpty()) {
       this.span.setTag(INPUT, inputData);
     }

dd-trace-core/src/main/java/datadog/trace/common/writer/DDIntakeWriter.java

@@ -12,6 +12,8 @@
 import java.util.EnumMap;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class DDIntakeWriter extends RemoteWriter {
 
@@ -40,6 +42,8 @@ public static class DDIntakeWriterBuilder {
 
     private SingleSpanSampler singleSpanSampler;
 
+    private static final Logger log = LoggerFactory.getLogger(DDIntakeWriterBuilder.class);
+
     public DDIntakeWriterBuilder addTrack(final TrackType trackType, final RemoteApi intakeApi) {
       tracks.put(trackType, intakeApi);
       return this;
@@ -98,6 +102,7 @@ public DDIntakeWriterBuilder singleSpanSampler(SingleSpanSampler singleSpanSampl
     }
 
     public DDIntakeWriter build() {
+      log.debug("DDINTAKEWRITER TRACKS {}", tracks);
       if (tracks.isEmpty()) {
         throw new IllegalArgumentException("At least one track needs to be configured");
       }
@@ -111,7 +116,11 @@ public DDIntakeWriter build() {
                 .map(this::createDispatcher)
                 .toArray(PayloadDispatcher[]::new);
         dispatcher = new CompositePayloadDispatcher(dispatchers);
+        for (PayloadDispatcher dispatcher2 : dispatchers) {
+          log.debug("COMP DISPATCHER {}", dispatcher2);
+        }
       }
+      log.debug("DISPATCHER {}", dispatcher);
 
       final TraceProcessingWorker traceProcessingWorker =
           new TraceProcessingWorker(

dd-trace-core/src/main/java/datadog/trace/common/writer/ddintake/DDEvpProxyApi.java

@@ -128,6 +128,7 @@ private DDEvpProxyApi(
   public Response sendSerializedTraces(Payload payload) {
     final int sizeInBytes = payload.sizeInBytes();
 
+    log.debug("SENDING PL {} TO TRACK {}", payload, trackType);
     Request.Builder builder =
         new Request.Builder()
             .url(proxiedApiUrl)

dd-trace-core/src/main/java/datadog/trace/core/CoreTracer.java

@@ -673,6 +673,7 @@ private CoreTracer(
     } else {
       this.writer = writer;
     }
+    log.debug("STARTED WRITER {}", this.writer);
 
     if (config.isCiVisibilityEnabled()
         && (config.isCiVisibilityAgentlessEnabled()