diff --git a/migrator/stats.go b/migrator/stats.go index f73e6bf40..6f42d96f6 100644 --- a/migrator/stats.go +++ b/migrator/stats.go @@ -169,7 +169,7 @@ func remakeQueue(sq *engine.StatQueue) (out *engine.StatQueue) { MinItems: sq.MinItems, } for mId, metric := range sq.SQMetrics { - id := utils.StatsJoin(utils.SplitConcatenatedKey(mId)...) + id := utils.ConcatenatedKey(utils.SplitConcatenatedKey(mId)...) out.SQMetrics[id] = metric } return diff --git a/migrator/stats_test.go b/migrator/stats_test.go index 90b156272..5773ddd3f 100644 --- a/migrator/stats_test.go +++ b/migrator/stats_test.go @@ -158,9 +158,9 @@ func TestRemakeQueue(t *testing.T) { EventID: "ev1", }}, SQMetrics: map[string]engine.StatMetric{ - "*tcc": nil, - "*sum:Usage": nil, - "*avreage:Cost": nil, + "*tcc": nil, + "*sum:~Usage": nil, + "*avreage:~Cost": nil, }, MinItems: 2, } @@ -169,9 +169,9 @@ func TestRemakeQueue(t *testing.T) { ID: sq.ID, SQItems: sq.SQItems, SQMetrics: map[string]engine.StatMetric{ - "*tcc": nil, - "*sum#Usage": nil, - "*avreage#Cost": nil, + "*tcc": nil, + "*sum:~Usage": nil, + "*avreage:~Cost": nil, }, MinItems: sq.MinItems, }