Fix: Ensure results are rendered in report when there are failed shards

awslabs · Mar 29, 2023 · 6654b17 · 6654b17
1 parent b1bde6d
commit 6654b17
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/analyse/cmd.go b/analyse/cmd.go
@@ -100,9 +100,7 @@ func (c *CMD) deregisterConsumer(streamArn, consumerArn *string) {
 
 func (c *CMD) processShards(ctx context.Context, consumerArn string) ([]*service.ProcessOutput, error) {
 	var (
-		output   []*service.ProcessOutput
 		bar      *pb.ProgressBar
-		err      error
 		shardIDs []string
 	)
 	if len(c.shardIDs) > 0 {
@@ -119,11 +117,7 @@ func (c *CMD) processShards(ctx context.Context, consumerArn string) ([]*service
 		bar = pb.StartNew(l)
 	}
 	defer bar.Finish()
-	output, err = c.processor.Process(ctx, consumerArn, shardIDs, len(c.shardIDs) == 0, func() { bar.Increment() })
-	if err != nil {
-		return nil, err
-	}
-	return output, nil
+	return c.processor.Process(ctx, consumerArn, shardIDs, len(c.shardIDs) == 0, func() { bar.Increment() })
 }
 
 type discover interface {