fix: return error on unmarshal failure

Bisonai · Aug 9, 2024 · 04f6e8e · 04f6e8e
1 parent 1de81dc
commit 04f6e8e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -180,7 +180,7 @@ func (c *Collector) redisRouter(ctx context.Context, msg *redis.Message) error {
 	var data *aggregator.SubmissionData
 	err := json.Unmarshal([]byte(msg.Payload), &data)
 	if err != nil {
-		return nil
+		return err
 	}
 
 	go c.processIncomingData(ctx, data)