return self._apply_misc([spec], dry_run, format, no_overwrite)
+ def _is_module_enabled(self, module: str) -> bool:
+ mgr_map = self.get('mgr_map')
+ return (
+ module in mgr_map.get('modules', [])
+ or module in mgr_map.get('always_on_modules', [])
+ )
+
+
+
def _create_nvmeof_metadata_pool_if_needed(self) -> None:
+ if not self._is_module_enabled('nvmeof'):
+ raise OrchestratorError('nvmeof module must be enabled to use .nvmeof pool')
self.remote('nvmeof', 'create_pool_if_not_exists')
@OrchestratorCLICommand.Write('orch apply nvmeof')