Skip to content
This repository was archived by the owner on Dec 16, 2025. It is now read-only.

Commit ae5399c

Browse files
committed
Return representive state data for module migrate_mgrs
Signed-off-by: Tobias Wolf <[email protected]>
1 parent ac40e55 commit ae5399c

File tree

1 file changed

+11
-2
lines changed
  • src/rookify/modules/migrate_mgrs

1 file changed

+11
-2
lines changed

src/rookify/modules/migrate_mgrs/main.py

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
# -*- coding: utf-8 -*-
22

33
from time import sleep
4-
from typing import Any
4+
from typing import Any, Dict
55
from ..exception import ModuleException
66
from ..machine import Machine
77
from ..module import ModuleHandler
@@ -22,9 +22,18 @@ def preflight(self) -> None:
2222
def execute(self) -> None:
2323
state_data = self.machine.get_preflight_state("AnalyzeCephHandler").data
2424

25-
for node, _ in state_data["node"]["ls"]["mgr"].items():
25+
for node in state_data["node"]["ls"]["mgr"].keys():
2626
self._migrate_mgr(node)
2727

28+
def get_readable_key_value_state(self) -> Dict[str, str]:
29+
state_data = self.machine.get_preflight_state("AnalyzeCephHandler").data
30+
31+
return {
32+
"ceph mgr daemons": self._get_readable_json_dump(
33+
list(state_data["node"]["ls"]["mgr"].keys())
34+
)
35+
}
36+
2837
def _migrate_mgr(self, mgr_host: str) -> None:
2938
migrated_mgrs = self.machine.get_execution_state_data(
3039
"MigrateMgrsHandler", "migrated_mgrs", default_value=[]

0 commit comments

Comments
 (0)