diff --git a/node_manager.go b/node_manager.go index 0945900..7b09263 100644 --- a/node_manager.go +++ b/node_manager.go @@ -67,6 +67,10 @@ func (nm *defaultNodeManager) ExecuteOnNode(nodes []*Node, command Command, prev break } + if err != nil { + return executed, err + } + nm.RLock() if startingIndex == nm.nodeIndex { nm.RUnlock()