diff --git a/receiver/sapmreceiver/trace_receiver_test.go b/receiver/sapmreceiver/trace_receiver_test.go index 4da189a3f6b3..18286090f0e2 100644 --- a/receiver/sapmreceiver/trace_receiver_test.go +++ b/receiver/sapmreceiver/trace_receiver_test.go @@ -19,6 +19,7 @@ import ( "github.com/signalfx/sapm-proto/sapmprotocol" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" + "go.opentelemetry.io/collector/component" "go.opentelemetry.io/collector/component/componenttest" "go.opentelemetry.io/collector/config/confighttp" "go.opentelemetry.io/collector/config/configtls" @@ -243,6 +244,9 @@ func compressZstd(reqBytes []byte) ([]byte, error) { func setupReceiver(t *testing.T, config *Config, sink *consumertest.TracesSink) receiver.Traces { params := receivertest.NewNopCreateSettings() + params.TelemetrySettings.ReportStatus = func(event *component.StatusEvent) { + require.NoError(t, event.Err()) + } sr, err := newReceiver(params, config, sink) assert.NoError(t, err, "should not have failed to create the SAPM receiver") t.Log("Starting") @@ -250,8 +254,6 @@ func setupReceiver(t *testing.T, config *Config, sink *consumertest.TracesSink) require.NoError(t, sr.Start(context.Background(), componenttest.NewNopHost()), "should not have failed to start trace reception") require.NoError(t, sr.Start(context.Background(), componenttest.NewNopHost()), "should not fail to start log on second Start call") - // If there are errors reported through host.ReportFatalError() this will retrieve it. - <-time.After(500 * time.Millisecond) t.Log("Trace Reception Started") return sr }