diff --git a/bubuku/features/rebalance.py b/bubuku/features/rebalance.py index 6b3cbe4..8b48c75 100644 --- a/bubuku/features/rebalance.py +++ b/bubuku/features/rebalance.py @@ -85,8 +85,8 @@ def _removal_func(): def run(self, current_actions): # Stop rebalance if someone is restarting if any([a in current_actions for a in ['restart', 'start', 'stop']]): - _LOG.warning("Rebalance stopped, because other blocking events running: {}".format(current_actions)) - return False + _LOG.warning("Rebalance paused, because other blocking events running: {}".format(current_actions)) + return True if self.zk.is_rebalancing(): return True