@@ -582,7 +582,7 @@ func TestGRPCArrowReceiver(t *testing.T) {
582
582
cfg := factory .CreateDefaultConfig ().(* Config )
583
583
cfg .GRPC .NetAddr .Endpoint = addr
584
584
cfg .GRPC .IncludeMetadata = true
585
- id := component .NewID (component . MustNewType ( "arrow" ) )
585
+ id := component .NewID (componentmetadata . Type )
586
586
tt := componenttest .NewNopTelemetrySettings ()
587
587
ocr := newReceiver (t , factory , tt , cfg , id , sink , nil )
588
588
@@ -695,7 +695,7 @@ func TestGRPCArrowReceiverAuth(t *testing.T) {
695
695
cfg .GRPC .Auth = & configauth.Authentication {
696
696
AuthenticatorID : authID ,
697
697
}
698
- id := component .NewID (component . MustNewType ( "arrow" ) )
698
+ id := component .NewID (componentmetadata . Type )
699
699
tt := componenttest .NewNopTelemetrySettings ()
700
700
ocr := newReceiver (t , factory , tt , cfg , id , sink , nil )
701
701
@@ -762,7 +762,7 @@ func TestConcurrentArrowReceiver(t *testing.T) {
762
762
cfg := factory .CreateDefaultConfig ().(* Config )
763
763
cfg .GRPC .NetAddr .Endpoint = addr
764
764
cfg .GRPC .IncludeMetadata = true
765
- id := component .NewID (component . MustNewType ( "arrow" ) )
765
+ id := component .NewID (componentmetadata . Type )
766
766
tt := componenttest .NewNopTelemetrySettings ()
767
767
ocr := newReceiver (t , factory , tt , cfg , id , sink , nil )
768
768
0 commit comments