diff --git a/service/internal/pipelines/pipelines_test.go b/service/internal/pipelines/pipelines_test.go index 2bc2ed63096..2802d68dbf5 100644 --- a/service/internal/pipelines/pipelines_test.go +++ b/service/internal/pipelines/pipelines_test.go @@ -53,7 +53,7 @@ func TestBuild(t *testing.T) { { name: "pipelines_simple_multi_proc.yaml", receiverIDs: []component.ID{component.NewID("examplereceiver")}, - processorIDs: []component.ID{component.NewID("exampleprocessor"), component.NewID("exampleprocessor")}, + processorIDs: []component.ID{component.NewID("exampleprocessor"), component.NewIDWithName("exampleprocessor", "1")}, exporterIDs: []component.ID{component.NewID("exampleexporter")}, expectedRequests: 1, }, diff --git a/service/internal/pipelines/testdata/pipelines_simple_multi_proc.yaml b/service/internal/pipelines/testdata/pipelines_simple_multi_proc.yaml index bb51c870843..262f41ce6ab 100644 --- a/service/internal/pipelines/testdata/pipelines_simple_multi_proc.yaml +++ b/service/internal/pipelines/testdata/pipelines_simple_multi_proc.yaml @@ -3,6 +3,7 @@ receivers: processors: exampleprocessor: + exampleprocessor/1: exporters: exampleexporter: @@ -11,15 +12,15 @@ service: pipelines: traces: receivers: [examplereceiver] - processors: [exampleprocessor, exampleprocessor] + processors: [exampleprocessor, exampleprocessor/1] exporters: [exampleexporter] metrics: receivers: [examplereceiver] - processors: [exampleprocessor, exampleprocessor] + processors: [exampleprocessor, exampleprocessor/1] exporters: [exampleexporter] logs: receivers: [examplereceiver] - processors: [exampleprocessor, exampleprocessor] + processors: [exampleprocessor, exampleprocessor/1] exporters: [exampleexporter]