diff --git a/internal/extension/extension.go b/internal/extension/extension.go index 839ddfa..984c2bf 100644 --- a/internal/extension/extension.go +++ b/internal/extension/extension.go @@ -132,7 +132,6 @@ func (em *ExtensionManager) SendStartInvocationRequest(ctx context.Context, even ctx = context.WithValue(ctx, DdParentId, parentId) } samplingPriority := response.Header.Get(string(DdSamplingPriority)) - samplingPriority = "0.3" fmt.Printf("[DEBUG] [extension.go] [SendStartInvocationRequest()] Sampling priority: %s\n", samplingPriority) if samplingPriority != "" { ctx = context.WithValue(ctx, DdSamplingPriority, samplingPriority) diff --git a/internal/trace/listener.go b/internal/trace/listener.go index 81a17db..562783e 100644 --- a/internal/trace/listener.go +++ b/internal/trace/listener.go @@ -160,6 +160,7 @@ func startFunctionExecutionSpan(ctx context.Context, mergeXrayTraces bool, isDdS resourceName = string(extension.DdSeverlessSpan) } + fmt.Printf("[DEBUG] [lambda-go] startFunctionExecutionSpan() context: %+v\n", parentSpanContext) span := tracer.StartSpan( "aws.lambda", // This operation name will be replaced with the value of the service tag by the Forwarder tracer.SpanType("serverless"),