diff --git a/chain-ops/src/task/broadcast.rs b/chain-ops/src/task/broadcast.rs
index 690b293..14c5bcb 100644
--- a/chain-ops/src/task/broadcast.rs
+++ b/chain-ops/src/task/broadcast.rs
@@ -197,7 +197,9 @@ where
 
                 Self::log_tx_response(source.as_ref(), tx_code, &response);
 
-                if tx_code.is_err() {
+                if tx_code.is_ok() {
+                    self.consecutive_errors = 0;
+                } else {
                     self.consecutive_errors = (self.consecutive_errors + 1) % 5;
 
                     if self.consecutive_errors == 0 {