minor fix if statement

initia-labs · Feb 7, 2025 · 62cb37b · 62cb37b
1 parent e8f81de
commit 62cb37b
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/node/broadcaster/broadcaster.go b/node/broadcaster/broadcaster.go
@@ -191,14 +191,13 @@ func (b *Broadcaster) loadPendingTxs(ctx types.Context, stage types.BasicDB, las
 		return err
 	}
 
-	if len(reProcessingTxs) == 0 {
-		return nil
-	}
-	processedMsgsBatch, err := b.pendingTxsToProcessedMsgsBatch(ctx, reProcessingTxs)
-	if err != nil {
-		return err
+	if len(reProcessingTxs) != 0 {
+		processedMsgsBatch, err := b.pendingTxsToProcessedMsgsBatch(ctx, reProcessingTxs)
+		if err != nil {
+			return err
+		}
+		b.pendingProcessedMsgsBatch = append(b.pendingProcessedMsgsBatch, processedMsgsBatch...)
 	}
-	b.pendingProcessedMsgsBatch = append(b.pendingProcessedMsgsBatch, processedMsgsBatch...)
 	return nil
 }