@@ -20,9 +20,7 @@ import (
20
20
"github.com/DataDog/datadog-lambda-go/internal/logger"
21
21
"github.com/DataDog/datadog-lambda-go/internal/version"
22
22
"github.com/aws/aws-lambda-go/lambdacontext"
23
- "go.opentelemetry.io/otel"
24
23
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace"
25
- ddotel "gopkg.in/DataDog/dd-trace-go.v1/ddtrace/opentelemetry"
26
24
"gopkg.in/DataDog/dd-trace-go.v1/ddtrace/tracer"
27
25
)
28
26
@@ -79,16 +77,17 @@ func (l *Listener) HandlerStarted(ctx context.Context, msg json.RawMessage) cont
79
77
}
80
78
81
79
ctx , _ = contextWithRootTraceContext (ctx , msg , l .mergeXrayTraces , l .traceContextExtractor )
80
+ fmt .Printf ("Extension running: %t" , l .extensionManager .IsExtensionRunning ())
82
81
83
82
if ! tracerInitialized {
84
83
serviceName := os .Getenv ("DD_SERVICE" )
85
84
if serviceName == "" {
86
85
serviceName = "aws.lambda"
87
86
}
88
- extensionNotRunning := ! l . extensionManager . IsExtensionRunning ()
87
+ // Remove Lambda mode
89
88
opts := append ([]tracer.StartOption {
90
89
tracer .WithService (serviceName ),
91
- tracer .WithLambdaMode (extensionNotRunning ),
90
+ // tracer.WithLambdaMode(extensionNotRunning),
92
91
tracer .WithGlobalTag ("_dd.origin" , "lambda" ),
93
92
tracer .WithSendRetries (2 ),
94
93
}, l .tracerOptions ... )
@@ -144,16 +143,7 @@ func (l *Listener) HandlerStarted(ctx context.Context, msg json.RawMessage) cont
144
143
}
145
144
// End parsing DD_TRACE_SAMPLING_RULES
146
145
147
- if l .otelTracerEnabled {
148
- provider := ddotel .NewTracerProvider (
149
- opts ... ,
150
- )
151
- otel .SetTracerProvider (provider )
152
- } else {
153
- tracer .Start (
154
- opts ... ,
155
- )
156
- }
146
+ tracer .Start (opts ... )
157
147
tracerInitialized = true
158
148
}
159
149
0 commit comments