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

Commit bc9fa4a

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

File tree

1 file changed

+19
-0
lines changed
  • src/rookify/modules/migrate_mds_pools

1 file changed

+19
-0
lines changed

src/rookify/modules/migrate_mds_pools/main.py

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
# -*- coding: utf-8 -*-
22

3+
from collections import OrderedDict
34
from typing import Any, Dict
45
from ..machine import Machine
56
from ..module import ModuleHandler
@@ -71,6 +72,24 @@ def execute(self) -> None:
7172
for pool in pools.values():
7273
self._migrate_pool(pool)
7374

75+
def get_readable_key_value_state(self) -> Dict[str, str]:
76+
migrated_mds_pools = self.machine.get_execution_state_data(
77+
"MigrateMdsPoolsHandler", "migrated_mds_pools", default_value=[]
78+
)
79+
80+
pools = self.machine.get_preflight_state("MigrateMdsPoolsHandler").pools
81+
82+
kv_state_data = OrderedDict()
83+
84+
for pool in pools:
85+
key_name = "ceph MDS pool {0}".format(pool["name"])
86+
kv_state_data[key_name] = self._get_readable_json_dump(pool)
87+
88+
key_name = "ceph MDS pool {0} is created".format(pool["name"])
89+
kv_state_data[key_name] = pool["name"] in migrated_mds_pools
90+
91+
return kv_state_data
92+
7493
def _migrate_pool(self, pool: Dict[str, Any]) -> None:
7594
migrated_mds_pools = self.machine.get_execution_state_data(
7695
"MigrateMdsPoolsHandler", "migrated_mds_pools", default_value=[]

0 commit comments

Comments
 (0)