move tracer initialization to lambda init

Author: shreyamalpani

internal/trace/listener.go

@@ -55,8 +55,7 @@ var tracerInitialized = false
 
 // MakeListener initializes a new trace lambda Listener
 func MakeListener(config Config, extensionManager *extension.ExtensionManager) Listener {
-
-	return Listener{
+	l := Listener{
 		ddTraceEnabled:           config.DDTraceEnabled,
 		mergeXrayTraces:          config.MergeXrayTraces,
 		universalInstrumentation: config.UniversalInstrumentation,
@@ -65,6 +64,39 @@ func MakeListener(config Config, extensionManager *extension.ExtensionManager) L
 		traceContextExtractor:    config.TraceContextExtractor,
 		tracerOptions:            config.TracerOptions,
 	}
+
+	// Initialize tracer during Lambda init phase (only if tracing enabled)
+	if l.ddTraceEnabled && !tracerInitialized {
+		l.initTracer()
+	}
+
+	return l
+}
+
+// initTracer starts the Datadog tracer or OpenTelemetry provider
+func (l *Listener) initTracer() {
+	serviceName := os.Getenv("DD_SERVICE")
+	if serviceName == "" {
+		serviceName = "aws.lambda"
+	}
+	extensionNotRunning := !l.extensionManager.IsExtensionRunning()
+	opts := append([]tracer.StartOption{
+		tracer.WithService(serviceName),
+		tracer.WithLambdaMode(extensionNotRunning),
+		tracer.WithGlobalTag("_dd.origin", "lambda"),
+		tracer.WithSendRetries(2),
+	}, l.tracerOptions...)
+	if l.otelTracerEnabled {
+		provider := ddotel.NewTracerProvider(
+			opts...,
+		)
+		otel.SetTracerProvider(provider)
+	} else {
+		tracer.Start(
+			opts...,
+		)
+	}
+	tracerInitialized = true
 }
 
 // HandlerStarted sets up tracing and starts the function execution span if Datadog tracing is enabled
@@ -79,31 +111,6 @@ func (l *Listener) HandlerStarted(ctx context.Context, msg json.RawMessage) cont
 
 	ctx, _ = contextWithRootTraceContext(ctx, msg, l.mergeXrayTraces, l.traceContextExtractor)
 
-	if !tracerInitialized {
-		serviceName := os.Getenv("DD_SERVICE")
-		if serviceName == "" {
-			serviceName = "aws.lambda"
-		}
-		extensionNotRunning := !l.extensionManager.IsExtensionRunning()
-		opts := append([]tracer.StartOption{
-			tracer.WithService(serviceName),
-			tracer.WithLambdaMode(extensionNotRunning),
-			tracer.WithGlobalTag("_dd.origin", "lambda"),
-			tracer.WithSendRetries(2),
-		}, l.tracerOptions...)
-		if l.otelTracerEnabled {
-			provider := ddotel.NewTracerProvider(
-				opts...,
-			)
-			otel.SetTracerProvider(provider)
-		} else {
-			tracer.Start(
-				opts...,
-			)
-		}
-		tracerInitialized = true
-	}
-
 	isDdServerlessSpan := l.universalInstrumentation && l.extensionManager.IsExtensionRunning()
 	functionExecutionSpan, ctx = startFunctionExecutionSpan(ctx, l.mergeXrayTraces, isDdServerlessSpan)