From 3a0d895ea1d10ccf925029673a5a11b761627d0b Mon Sep 17 00:00:00 2001 From: Tyler Yahn Date: Tue, 27 Sep 2022 12:21:40 -0700 Subject: [PATCH] Add aggregator to pipeline --- sdk/metric/pipeline.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sdk/metric/pipeline.go b/sdk/metric/pipeline.go index 3a81020ff0d..9eb86f593ac 100644 --- a/sdk/metric/pipeline.go +++ b/sdk/metric/pipeline.go @@ -233,6 +233,10 @@ func (i *inserter[N]) Instrument(inst view.Instrument, instUnit unit.Unit) ([]in } if a != nil { aggs = append(aggs, a) + err = i.pipeline.addAggregator(inst.Scope, inst.Name, inst.Description, instUnit, a) + if err != nil { + errs.append(err) + } } }