diff --git a/trace/otlp.go b/trace/otlp.go index e3733c4e..7f4dc60a 100644 --- a/trace/otlp.go +++ b/trace/otlp.go @@ -18,7 +18,6 @@ func NewOtlpGrpcClientConnection(ctx context.Context, host string, dialOptions . dialContextOptions := []grpc.DialOption{ grpc.WithTransportCredentials(insecure.NewCredentials()), - grpc.WithBlock(), } dialContextOptions = append(dialContextOptions, dialOptions...) diff --git a/trace/otlp_test.go b/trace/otlp_test.go index d688138e..f520f2da 100644 --- a/trace/otlp_test.go +++ b/trace/otlp_test.go @@ -34,6 +34,7 @@ func TestNewOtlpGrpcInsecureConnectionSuccess(t *testing.T) { context.Background(), "bufnet", grpc.WithContextDialer(bufDialer), + grpc.WithBlock(), ) assert.NoError(t, err) @@ -51,7 +52,11 @@ func TestNewOtlpGrpcInsecureConnectionError(t *testing.T) { ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(1*time.Microsecond)) defer cancel() - _, err := trace.NewOtlpGrpcClientConnection(ctx, "https://example.com") + _, err := trace.NewOtlpGrpcClientConnection( + ctx, + "https://example.com", + grpc.WithBlock(), + ) assert.Error(t, err) assert.Contains(t, err.Error(), "context deadline exceeded") }