mapic: Skip unknown pushes

just in case we ever change the push url logic
livepeer · Nov 14, 2022 · 729de88 · 729de88
1 parent a62a21d
commit 729de88
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/app/mistapiconnector/stats_collector.go b/internal/app/mistapiconnector/stats_collector.go
@@ -96,8 +96,8 @@ func createMetricsEvent(nodeID, region string, info *streamInfo, metrics *stream
 	for i, push := range metrics.pushes {
 		pushInfo := info.pushStatus[push.OriginalURI]
 		if pushInfo == nil {
-			pushInfo = &pushStatus{}
-			info.pushStatus[push.OriginalURI] = pushInfo
+			glog.Infof("Mist exported metrics from unknown push. streamId=%q pushURL=%q", info.id, push.OriginalURI)
+			continue
 		}
 		var metrics *data.MultistreamMetrics
 		if push.Stats != nil {