From: Almen Ng Date: Fri, 1 Oct 2021 18:00:20 +0000 (-0400) Subject: mgr/volumes: fix various flake8 issues X-Git-Tag: v17.1.0~761^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F43387%2Fhead;p=ceph.git mgr/volumes: fix various flake8 issues Fixes: https://tracker.ceph.com/issues/51380 Signed-off-by: Almen Ng --- diff --git a/src/pybind/mgr/volumes/module.py b/src/pybind/mgr/volumes/module.py index fcbb2a2d9a83..a0a039acca36 100644 --- a/src/pybind/mgr/volumes/module.py +++ b/src/pybind/mgr/volumes/module.py @@ -12,18 +12,22 @@ log = logging.getLogger(__name__) goodchars = '[A-Za-z0-9-_.]' + class VolumesInfoWrapper(): def __init__(self, f, context): self.f = f self.context = context + def __enter__(self): log.info("Starting {}".format(self.context)) + def __exit__(self, exc_type, exc_value, tb): if exc_type is not None: log.error("Failed {}:\n{}".format(self.context, "".join(traceback.format_exception(exc_type, exc_value, tb)))) else: log.info("Finishing {}".format(self.context)) + def mgr_cmd_wrap(f): def wrap(self, inbuf, cmd): astr = [] @@ -34,6 +38,7 @@ def mgr_cmd_wrap(f): return f(self, inbuf, cmd) return wrap + class Module(orchestrator.OrchestratorClientMixin, MgrModule): COMMANDS = [ { @@ -527,8 +532,8 @@ class Module(orchestrator.OrchestratorClientMixin, MgrModule): @mgr_cmd_wrap def _cmd_fs_subvolumegroup_pin(self, inbuf, cmd): return self.vc.pin_subvolume_group(vol_name=cmd['vol_name'], - group_name=cmd['group_name'], pin_type=cmd['pin_type'], - pin_setting=cmd['pin_setting']) + group_name=cmd['group_name'], pin_type=cmd['pin_type'], + pin_setting=cmd['pin_setting']) @mgr_cmd_wrap def _cmd_fs_subvolumegroup_snapshot_create(self, inbuf, cmd): @@ -585,9 +590,9 @@ class Module(orchestrator.OrchestratorClientMixin, MgrModule): @mgr_cmd_wrap def _cmd_fs_subvolume_pin(self, inbuf, cmd): return self.vc.subvolume_pin(vol_name=cmd['vol_name'], - sub_name=cmd['sub_name'], pin_type=cmd['pin_type'], - pin_setting=cmd['pin_setting'], - group_name=cmd.get('group_name', None)) + sub_name=cmd['sub_name'], pin_type=cmd['pin_type'], + pin_setting=cmd['pin_setting'], + group_name=cmd.get('group_name', None)) @mgr_cmd_wrap def _cmd_fs_subvolume_snapshot_protect(self, inbuf, cmd): @@ -609,9 +614,9 @@ class Module(orchestrator.OrchestratorClientMixin, MgrModule): @mgr_cmd_wrap def _cmd_fs_clone_status(self, inbuf, cmd): return self.vc.clone_status( - vol_name=cmd['vol_name'], clone_name=cmd['clone_name'], group_name=cmd.get('group_name', None)) + vol_name=cmd['vol_name'], clone_name=cmd['clone_name'], group_name=cmd.get('group_name', None)) @mgr_cmd_wrap def _cmd_fs_clone_cancel(self, inbuf, cmd): return self.vc.clone_cancel( - vol_name=cmd['vol_name'], clone_name=cmd['clone_name'], group_name=cmd.get('group_name', None)) + vol_name=cmd['vol_name'], clone_name=cmd['clone_name'], group_name=cmd.get('group_name', None))