Skip to content

Commit

Permalink
pybind/mgr: use annotation style without comment
Browse files Browse the repository at this point in the history
* use annotation style without comment
* add noqa to import statement to prevent flake8 from complaining
  those which import typing modules

to silence the warnings like:

```
flake8 run-test: commands[0] | flake8 --config=tox.ini alerts balancer cephadm cli_api crash devicehealth diskprediction_local hello iostat localpool nfs orchestrator prometheus selftest
cephadm/schedule.py:5:1: F401 'typing.Callable' imported but unused
cephadm/schedule.py:8:1: F401 'ceph.deployment.service_spec.ServiceSpec' imported but unused
cephadm/tests/fixtures.py:17:1: F401 'orchestrator.OrchResult' imported but unused
orchestrator/module.py:4:1: F401 'typing.Set' imported but unused
orchestrator/module.py:17:1: F401 'ceph.deployment.inventory.Device' imported but unused
prometheus/module.py:17:1: F401 'typing.DefaultDict' imported but unused
6     F401 'typing.Callable' imported but unused
ERROR: InvocationError for command /home/jenkins-build/build/workspace/ceph-pull-requests/src/pybind/mgr/.tox/flake8/bin/flake8 --config=tox.ini alerts
```

Signed-off-by: Kefu Chai <tchaikov@gmail.com>
  • Loading branch information
tchaikov committed Nov 24, 2022
1 parent 2413da8 commit ef391e9
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 8 deletions.
4 changes: 2 additions & 2 deletions src/pybind/mgr/cephadm/schedule.py
Original file line number Diff line number Diff line change
Expand Up @@ -141,13 +141,13 @@ def matches_rank_map(
class HostAssignment(object):

def __init__(self,
spec, # type: ServiceSpec
spec: ServiceSpec,
hosts: List[orchestrator.HostSpec],
unreachable_hosts: List[orchestrator.HostSpec],
draining_hosts: List[orchestrator.HostSpec],
daemons: List[orchestrator.DaemonDescription],
networks: Dict[str, Dict[str, Dict[str, List[str]]]] = {},
filter_new_host=None, # type: Optional[Callable[[str],bool]]
filter_new_host: Optional[Callable[[str],bool]] = None,
allow_colo: bool = False,
primary_daemon_type: Optional[str] = None,
per_host_daemon_type: Optional[str] = None,
Expand Down
3 changes: 1 addition & 2 deletions src/pybind/mgr/cephadm/tests/fixtures.py
Original file line number Diff line number Diff line change
Expand Up @@ -134,8 +134,7 @@ def with_cephadm_module(module_options=None, store=None):
yield m


def wait(m, c):
# type: (CephadmOrchestrator, OrchResult) -> Any
def wait(m: CephadmOrchestrator, c: OrchResult) -> Any:
return raise_if_exception(c)


Expand Down
6 changes: 3 additions & 3 deletions src/pybind/mgr/orchestrator/module.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
# fallback to normal sort
natsorted = sorted # type: ignore

from ceph.deployment.inventory import Device
from ceph.deployment.inventory import Device # noqa: F401; pylint: disable=unused-variable
from ceph.deployment.drive_group import DriveGroupSpec, DeviceSelection, OSDMethod
from ceph.deployment.service_spec import PlacementSpec, ServiceSpec, service_spec_allow_invalid_from_json, TracingSpec
from ceph.deployment.hostspec import SpecValidationError
Expand Down Expand Up @@ -227,8 +227,8 @@ class OrchestratorCli(OrchestratorClientMixin, MgrModule,

def __init__(self, *args: Any, **kwargs: Any) -> None:
super(OrchestratorCli, self).__init__(*args, **kwargs)
self.ident = set() # type: Set[str]
self.fault = set() # type: Set[str]
self.ident: Set[str] = set()
self.fault: Set[str] = set()
self._load()
self._refresh_health()

Expand Down
2 changes: 1 addition & 1 deletion src/pybind/mgr/prometheus/module.py
Original file line number Diff line number Diff line change
Expand Up @@ -1043,7 +1043,7 @@ def get_pg_status(self) -> None:
pg_summary = self.get('pg_summary')

for pool in pg_summary['by_pool']:
num_by_state = defaultdict(int) # type: DefaultDict[str, int]
num_by_state: DefaultDict[str, int] = defaultdict(int)

for state_name, count in pg_summary['by_pool'][pool].items():
for state in state_name.split('+'):
Expand Down

0 comments on commit ef391e9

Please sign in to comment.