This repository was archived by the owner on Dec 16, 2025. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +24
-1
lines changed
src/rookify/modules/create_rook_cluster Expand file tree Collapse file tree 1 file changed +24
-1
lines changed Original file line number Diff line number Diff line change 11# -*- coding: utf-8 -*-
22
3- from typing import Any
3+ from collections import OrderedDict
4+ from typing import Any , Dict
45from ..exception import ModuleException
56from ..machine import Machine
67from ..module import ModuleHandler
@@ -157,6 +158,28 @@ def _watch_cluster_phase_callback(self, event_object: Any) -> Any:
157158
158159 return None
159160
161+ def get_readable_key_value_state (self ) -> Dict [str , str ]:
162+ kv_state_data = OrderedDict ()
163+
164+ cluster_definition = self .machine .get_preflight_state_data (
165+ "CreateRookClusterHandler" , "cluster_definition"
166+ )
167+ cluster_name = self ._config ["rook" ]["cluster" ]["name" ]
168+
169+ if cluster_definition is None :
170+ kv_state_data [cluster_name ] = "Not created yet"
171+ else :
172+ kv_state_data [cluster_name ] = self ._get_readable_json_dump (
173+ cluster_definition
174+ )
175+
176+ is_generated = self .machine .get_execution_state_data (
177+ "CreateRookClusterHandler" , "generated" , default_value = False
178+ )
179+ kv_state_data ["{0} is generated" .format (cluster_name )] = str (is_generated )
180+
181+ return kv_state_data
182+
160183 @staticmethod
161184 def register_execution_state (
162185 machine : Machine , state_name : str , handler : ModuleHandler , ** kwargs : Any
You can’t perform that action at this time.
0 commit comments