]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
cephadm: add 'is_paused' field in orch status output 46570/head
authorGuillaume Abrioux <gabrioux@redhat.com>
Fri, 3 Jun 2022 15:16:54 +0000 (17:16 +0200)
committerGuillaume Abrioux <gabrioux@redhat.com>
Wed, 8 Jun 2022 13:27:09 +0000 (15:27 +0200)
it can be convenient for automation tool if `orch status` output reports
whether the upgrade is currently paused.

Fixes: https://tracker.ceph.com/issues/55843
Signed-off-by: Guillaume Abrioux <gabrioux@redhat.com>
(cherry picked from commit de1c428dfe9744b0585a42f1862b4f9ee46c22b2)

src/pybind/mgr/cephadm/upgrade.py
src/pybind/mgr/orchestrator/_interface.py
src/pybind/mgr/orchestrator/module.py

index 3cedae582442d75d43640beb16b47b01dd1010d5..764992716b3bb91426237baf85b113e9fde7d5ce 100644 (file)
@@ -147,6 +147,7 @@ class CephadmUpgrade:
             r.target_image = self.target_image
             r.in_progress = True
             r.progress, r.services_complete = self._get_upgrade_info()
+            r.is_paused = self.upgrade_state.paused
 
             if self.upgrade_state.daemon_types is not None:
                 which_str = f'Upgrading daemons of type(s) {",".join(self.upgrade_state.daemon_types)}'
index 61ef4f5da8089c4a788d899c39269a1ea869d3f8..83dbccf5df2206819ffa16ce6ad81b048b960b44 100644 (file)
@@ -773,6 +773,7 @@ class UpgradeStatusSpec(object):
         self.which: str = '<unknown>'  # for if user specified daemon types, services or hosts
         self.progress: Optional[str] = None  # How many of the daemons have we upgraded
         self.message = ""  # Freeform description
+        self.is_paused: bool = False  # Is the upgrade paused?
 
 
 def handle_type_error(method: FuncT) -> FuncT:
index c9de02f0c80e2b53f258a4cd4ba05b1089762434..a113b098929352fe4616e0274b839498d12adf1e 100644 (file)
@@ -1418,6 +1418,7 @@ Usage:
             'services_complete': status.services_complete,
             'progress': status.progress,
             'message': status.message,
+            'is_paused': status.is_paused,
         }
         out = json.dumps(r, indent=4)
         return HandleCommandResult(stdout=out)