From: Varsha Rao Date: Thu, 29 Oct 2020 10:58:31 +0000 (+0530) Subject: mgr/rook: Udpate to mypy py3 type style in _create(), _update() and apply() X-Git-Tag: v16.1.0~697^2~2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=89176cab9bfb69295acb68ff52ad28c0460c375f;p=ceph.git mgr/rook: Udpate to mypy py3 type style in _create(), _update() and apply() Signed-off-by: Varsha Rao --- diff --git a/src/pybind/mgr/rook/rook_cluster.py b/src/pybind/mgr/rook/rook_cluster.py index 953b707da0db..ad3590145eba 100644 --- a/src/pybind/mgr/rook/rook_cluster.py +++ b/src/pybind/mgr/rook/rook_cluster.py @@ -384,18 +384,15 @@ class RookCluster(object): else: raise - def apply_filesystem(self, spec): - # type: (ServiceSpec) -> None + def apply_filesystem(self, spec: ServiceSpec) -> None: # TODO use spec.placement # TODO warn if spec.extended has entries we don't kow how # to action. - def _update_fs(new): - # type: (cfs.CephFilesystem) -> cfs.CephFilesystem + def _update_fs(new: cfs.CephFilesystem) -> cfs.CephFilesystem: new.spec.metadataServer.activeCount = spec.placement.count or 1 return new - def _create_fs(): - # type: () -> cfs.CephFilesystem + def _create_fs() -> cfs.CephFilesystem: return cfs.CephFilesystem( apiVersion=self.rook_env.api_name, metadata=dict( @@ -423,8 +420,7 @@ class RookCluster(object): assert spec.subcluster is None name = realm - def _create_zone(): - # type: () -> cos.CephObjectStore + def _create_zone() -> cos.CephObjectStore: port = None secure_port = None if spec.ssl: @@ -447,7 +443,7 @@ class RookCluster(object): ) ) - def _update_zone(new): + def _update_zone(new: cos.CephObjectStore) -> cos.CephObjectStore: new.spec.gateway.instances = spec.placement.count or 1 return new