RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2024-12-26 21:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

pybind/mgr/mds_autoscaler: add type annotation

Browse Source 
Signed-off-by: Kefu Chai <kchai@redhat.com>
This commit is contained in:
Kefu Chai 2021-03-27 11:14:34 +08:00
parent 76724ad716
commit 4faf8a873c
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/mypy.ini
View File

@ -52,6 +52,9 @@ disallow_untyped_defs = True
[mypy-localpool.*]
disallow_untyped_defs = True
[mypy-mds_autoscaler.*]
disallow_untyped_defs = True
[mypy-orchestrator.*]
disallow_untyped_defs = True

8
src/pybind/mgr/mds_autoscaler/module.py
View File

@ -3,7 +3,7 @@ Automatically scale MDSs based on status of the file-system using the FSMap
"""
import logging
from typing import Optional, List, Set
from typing import Any, Optional
from mgr_module import MgrModule
from ceph.deployment.service_spec import ServiceSpec
import orchestrator
@ -16,7 +16,7 @@ class MDSAutoscaler(orchestrator.OrchestratorClientMixin, MgrModule):
"""
MDS autoscaler.
"""
def __init__(self, *args, **kwargs):
def __init__(self, *args: Any, **kwargs: Any) -> None:
MgrModule.__init__(self, *args, **kwargs)
self.set_mgr(self)
@ -52,7 +52,7 @@ class MDSAutoscaler(orchestrator.OrchestratorClientMixin, MgrModule):
return fs['mdsmap']['max_mds']
assert False
def verify_and_manage_mds_instance(self, fs_map: dict, fs_name: str):
def verify_and_manage_mds_instance(self, fs_map: dict, fs_name: str) -> None:
assert fs_map is not None
try:
@ -84,7 +84,7 @@ class MDSAutoscaler(orchestrator.OrchestratorClientMixin, MgrModule):
self.log.exception(f"fs {fs_name}: exception while updating service: {e}")
pass
def notify(self, notify_type, notify_id):
def notify(self, notify_type: str, notify_id: str) -> None:
if notify_type != 'fs_map':
return
fs_map = self.get('fs_map')