]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
pybind/mgr/prometheus: PEP8 cleanups
authorKefu Chai <kchai@redhat.com>
Sun, 31 Jan 2021 09:46:09 +0000 (17:46 +0800)
committerKefu Chai <kchai@redhat.com>
Wed, 3 Feb 2021 09:17:24 +0000 (17:17 +0800)
Signed-off-by: Kefu Chai <kchai@redhat.com>
src/pybind/mgr/prometheus/__init__.py
src/pybind/mgr/prometheus/module.py
src/pybind/mgr/tox.ini

index 763a84261e6e94bed099ad40d90205c07fe2b0e5..d39184947b44ae882779b3e00a06b1b4cab158af 100644 (file)
@@ -1,2 +1 @@
 from .module import Module, StandbyModule
-
index 7eae269bf055b02d7a10948600c333d7be726aa7..ac586684a25c014f6aecad080f38a7db05543420 100644 (file)
@@ -112,7 +112,7 @@ NUM_OBJECTS = ['degraded', 'misplaced', 'unfound']
 
 alert_metric = namedtuple('alert_metric', 'name description')
 HEALTH_CHECKS = [
-    alert_metric('SLOW_OPS', 'OSD or Monitor requests taking a long time to process' ),
+    alert_metric('SLOW_OPS', 'OSD or Monitor requests taking a long time to process'),
 ]
 
 
@@ -237,6 +237,7 @@ class MetricCollectionThread(threading.Thread):
         self.active = False
         self.event.set()
 
+
 class Module(MgrModule):
     COMMANDS = [
         {
@@ -512,11 +513,14 @@ class Module(MgrModule):
                     v, err = 0, 0
 
                     if check.name == "SLOW_OPS":
-                        # 42 slow ops, oldest one blocked for 12 sec, daemons [osd.0, osd.3] have slow ops.
+                        # 42 slow ops, oldest one blocked for 12 sec, daemons [osd.0, osd.3] have
+                        # slow ops.
                         v, err = _get_value(message)
 
                     if err:
-                        self.log.error("healthcheck {} message format is incompatible and has been dropped".format(check.name))
+                        self.log.error(
+                            "healthcheck %s message format is incompatible and has been dropped",
+                            check.name)
                         # drop the metric, so it's no longer emitted
                         del self.metrics[path]
                         continue
@@ -615,7 +619,8 @@ class Module(MgrModule):
         all_mgrs = list(standbys)
         all_mgrs.append(active)
 
-        all_modules = {module.get('name'):module.get('can_run') for module in mgr_map['available_modules']}
+        all_modules = {module.get('name'): module.get('can_run')
+                       for module in mgr_map['available_modules']}
 
         for mgr in all_mgrs:
             host_version = servers.get((mgr, 'mgr'), ('', ''))
@@ -1271,7 +1276,8 @@ class Module(MgrModule):
         # Make the cache timeout for collecting configurable
         self.scrape_interval = cast(float, self.get_localized_module_option('scrape_interval'))
 
-        self.stale_cache_strategy = cast(str, self.get_localized_module_option('stale_cache_strategy'))
+        self.stale_cache_strategy = cast(
+            str, self.get_localized_module_option('stale_cache_strategy'))
         if self.stale_cache_strategy not in [self.STALE_CACHE_FAIL,
                                              self.STALE_CACHE_RETURN]:
             self.stale_cache_strategy = self.STALE_CACHE_FAIL
index e1ddc74396e1636c1af1bb1d6085f44f06f85bd4..bd0d7c861fd07d021adaba9b578294f28c758fd3 100644 (file)
@@ -89,6 +89,7 @@ deps =
 modules =
     cephadm
     orchestrator
+    prometheus
     telemetry
 commands =
     python --version