better error handling

streamingfast · Oct 4, 2023 · 70e08d9 · 70e08d9
1 parent fd3f70f
commit 70e08d9
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/accountresolver/processor.go b/accountresolver/processor.go
@@ -208,7 +208,9 @@ func (p *Processor) processMergeBlocksFiles(ctx context.Context, cursor *Cursor,
 		return br, nil
 	})
 	writerNailer.OnTerminating(func(err error) {
-		panic(fmt.Errorf("writing bundle file: %w", err))
+		if err != nil {
+			panic(fmt.Errorf("writing bundle file: %w", err))
+		}
 	})
 	writerNailer.Start(ctx)
 
@@ -240,7 +242,9 @@ func (p *Processor) processMergeBlocksFiles(ctx context.Context, cursor *Cursor,
 			return b, nil
 		})
 		decoderNailer.OnTerminating(func(err error) {
-			panic(fmt.Errorf("encoding block: %w", err))
+			if err == nil {
+				panic(fmt.Errorf("encoding block: %w", err))
+			}
 		})
 		decoderNailer.Start(ctx)