]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
pybind/mgr: add_tox_test: Add mypy to TOX_ENVS
authorSebastian Wagner <sebastian.wagner@suse.com>
Fri, 13 Dec 2019 11:01:57 +0000 (12:01 +0100)
committerSebastian Wagner <sebastian.wagner@suse.com>
Fri, 13 Dec 2019 14:34:38 +0000 (15:34 +0100)
Signed-off-by: Sebastian Wagner <sebastian.wagner@suse.com>
src/pybind/mgr/CMakeLists.txt
src/pybind/mgr/cephadm/module.py
src/pybind/mgr/orchestrator.py

index e8fc630d2cd2ae5a23dcb331ef4fc28c755bad86..f7e200b1f889d56430e97219a2b2f54900c6b44a 100644 (file)
@@ -6,7 +6,7 @@ add_subdirectory(ansible)
 
 if(WITH_TESTS)
   include(AddCephTest)
-  add_tox_test(mgr ${CMAKE_CURRENT_SOURCE_DIR})
+  add_tox_test(mgr ${CMAKE_CURRENT_SOURCE_DIR} TOX_ENVS mypy)
 endif()
 
 # Location needs to match default setting for mgr_module_path, currently:
index 07f2d24d0cdc9705d900b049687c2b3dcdc0bed9..660d666c1fe874d9b17ebe429cd0f303e7175927 100644 (file)
@@ -1119,7 +1119,7 @@ class CephadmOrchestrator(MgrModule, orchestrator.Orchestrator):
                                    extra_args=extra_args)
 
     def update_mons(self, spec):
-        # type: (List[orchestrator.HostSpec]) -> orchestrator.Completion
+        # type: (orchestrator.StatefulServiceSpec) -> orchestrator.Completion
         """
         Adjust the number of cluster managers.
         """
@@ -1488,7 +1488,8 @@ class BaseScheduler(object):
         # type: (orchestrator.PlacementSpec) -> None
         self.placement_spec = placement_spec
 
-    def place(self):
+    def place(self, host_pool, count=None):
+        # type: (List, Optional[int]) -> List[HostSpec]
         raise NotImplementedError
 
 
@@ -1502,7 +1503,7 @@ class SimpleScheduler(BaseScheduler):
         super(SimpleScheduler, self).__init__(placement_spec)
 
     def place(self, host_pool, count=None):
-        # type: (List, Optional(int)) -> List
+        # type: (List, Optional[int]) -> List[HostSpec]
         if not host_pool:
             raise Exception('List of host candidates is empty')
         host_pool = [HostSpec(x, '', '') for x in host_pool]
@@ -1523,10 +1524,10 @@ class NodeAssignment(object):
     """
 
     def __init__(self,
-                 spec=None,  # type: orchestrator.PlacementSpec
-                 scheduler=None,  # type: BaseScheduler
-                 get_hosts_func=None,  # type: Callable
-                 service_type=None,  # type: str
+                 spec=None,  # type: Optional[orchestrator.StatefulServiceSpec]
+                 scheduler=None,  # type: Optional[BaseScheduler]
+                 get_hosts_func=None,  # type: Optional[Callable]
+                 service_type=None,  # type: Optional[str]
                  ):
         assert spec and get_hosts_func and service_type
         self.spec = spec
@@ -1535,7 +1536,7 @@ class NodeAssignment(object):
         self.service_type = service_type
 
     def load(self):
-        # type: () -> orchestrator.PlacementSpec
+        # type: () -> orchestrator.StatefulServiceSpec
         """
         Load nodes into the spec.placement.nodes container.
         """
@@ -1565,7 +1566,7 @@ class NodeAssignment(object):
         # If no imperative or declarative host assignments, use the scheduler to pick from the
         # host pool (assuming `count` is set)
         if not self.spec.placement.label and not self.spec.placement.nodes and self.spec.placement.count:
-            logger.info("Found num spec. Looking for labeled nodes.".format(self.scheduler))
+            logger.info("Found num spec. Looking for labeled nodes.")
             # TODO: actually query for labels (self.service_type)
             candidates = self.scheduler.place([x[0] for x in self.get_hosts_func()],
                                               count=self.spec.placement.count)
index 30ca32f8f8d83896ef33d962593ab0ee7d009334..27d3b8f3d35bf831d00f1ae179e68a702cafe25b 100644 (file)
@@ -1219,8 +1219,8 @@ class StatelessServiceSpec(object):
 
 
 class NFSServiceSpec(StatelessServiceSpec):
-    def __init__(self, name, pool=None, namespace=None, count=1, placement=None):
-        super(NFSServiceSpec, self).__init__(name, placement, count)
+    def __init__(self, name, pool=None, namespace=None, placement=None):
+        super(NFSServiceSpec, self).__init__(name, placement)
 
         #: RADOS pool where NFS client recovery data is stored.
         self.pool = pool