summaryrefslogtreecommitdiffstats
path: root/src/pybind/mgr/mds_autoscaler
diff options
context:
space:
mode:
authorKefu Chai <kchai@redhat.com>2021-03-27 04:14:34 +0100
committerKefu Chai <kchai@redhat.com>2021-03-27 04:17:22 +0100
commit4faf8a873c2200f964f080b81635875a103ec6c1 (patch)
treefa6cfb4239cc3ff07d858f65eb268834b51a1725 /src/pybind/mgr/mds_autoscaler
parentMerge pull request #40334 from dvanders/pick (diff)
downloadceph-4faf8a873c2200f964f080b81635875a103ec6c1.tar.xz
ceph-4faf8a873c2200f964f080b81635875a103ec6c1.zip
pybind/mgr/mds_autoscaler: add type annotation
Signed-off-by: Kefu Chai <kchai@redhat.com>
Diffstat (limited to 'src/pybind/mgr/mds_autoscaler')
-rw-r--r--src/pybind/mgr/mds_autoscaler/module.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/pybind/mgr/mds_autoscaler/module.py b/src/pybind/mgr/mds_autoscaler/module.py
index 01a9df2f4a8..006d8547c95 100644
--- a/src/pybind/mgr/mds_autoscaler/module.py
+++ b/src/pybind/mgr/mds_autoscaler/module.py
@@ -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')