diff --git a/src/kubernetes_upgrade.py b/src/kubernetes_upgrade.py index 098f1d076..1501f37a8 100644 --- a/src/kubernetes_upgrade.py +++ b/src/kubernetes_upgrade.py @@ -222,6 +222,7 @@ def determine_partition() -> int: action_event.fail(message) return if force: + logger.warning(f"Resume upgrade event with {force=}") # If a unit was unhealthy and the upgrade was forced, only the next unit will # upgrade. As long as 1 or more units are unhealthy, the upgrade will need to be # forced for each unit. @@ -232,12 +233,10 @@ def determine_partition() -> int: # also applicable `if not force`, but is unlikely to happen since all units are # healthy `if not force`. message = f"Attempting to upgrade unit {self._partition}" - action_event.set_results({"result": message}) - logger.warning(f"Resume upgrade event succeeded: {message}") else: message = f"Upgrade resumed. Unit {self._partition} is upgrading next" - action_event.set_results({"result": message}) - logger.debug(f"Resume upgrade event succeeded: {message}") + action_event.set_results({"result": message}) + logger.debug(f"Resume upgrade event succeeded: {message}") @property def authorized(self) -> bool: