Fix pep8 to make CI green.

Signed-off-by: George Melikov <mail@gmelikov.ru>

Author: gmelikov

obsender/config.py

@@ -53,4 +53,4 @@
 
 CONF = cfg.CONF
 CONF.register_opts(victoria_metrics_opts, constants.VICTORIA_METRICS_DOMAIN)
-#CONF.register_opts(dpp_events_opts, constants.DPP_EVENTS_DOMAIN)
+# CONF.register_opts(dpp_events_opts, constants.DPP_EVENTS_DOMAIN)

obsender/senders.py

@@ -6,15 +6,15 @@
 import uuid
 
 from concurrent import futures
-#from dpp_client.clients import http
+# from dpp_client.clients import http
 import obsender.vm_client as vm_client
-from requests import exceptions as requests_exceptions
+# from requests import exceptions as requests_exceptions
 import six
 
 from obsender import common
 from obsender import constants
 from obsender import decorators
-from obsender import exceptions
+# from obsender import exceptions
 
 
 DEFAULT_TIMEOUT = 10  # TODO(d.burmistrov): should be config option
@@ -198,7 +198,8 @@ def __init__(self, logger, sender):
         self._sender = sender
 
     def process(self, msg, kwargs):
-        _msg = "[obsender_sender=%s] %s" % (self._sender.__class__.__name__, msg)
+        _msg = "[obsender_sender=%s] %s" % (
+            self._sender.__class__.__name__, msg)
         return _msg, kwargs
 
 

obsender/tests/unit/vm_client/test_push.py

@@ -1,5 +1,5 @@
-import socket
 from functools import partial
+import socket
 
 import pytest
 
@@ -20,7 +20,8 @@ def mock_sendto(monkeypatch):
 
 @pytest.fixture(autouse=True)
 def mock_monotonic(monkeypatch):
-    monkeypatch.setattr('obsender.vm_client.push.monotonic', partial(next, iter([1.0, 2.0])))
+    monkeypatch.setattr(
+        'obsender.vm_client.push.monotonic', partial(next, iter([1.0, 2.0])))
 
 
 @pytest.fixture

obsender/vm_client/helpers.py

@@ -1,6 +1,7 @@
 from __future__ import unicode_literals
 
-from re import compile, sub
+from re import compile
+from re import sub
 
 SANITIZE_METRIC_NAME_REGEX = (
     (compile('\\s+'), '_'),

obsender/vm_client/protocol.py

@@ -10,8 +10,7 @@ def send(self, *args, **kwargs):
 
 
 class BaseUdpProto(object):
-    """The base class for the udp client protocol.
-    """
+    """The base class for the udp client protocol."""
 
     def __init__(self, host, port):
         sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

obsender/vm_client/push.py

@@ -1,15 +1,17 @@
 from __future__ import unicode_literals
 
-import os
 from itertools import starmap
+import os
 
 try:
     from time import monotonic
 except ImportError:  # pragma: no cover
     from monotonic import monotonic
 
-from .helpers import env_bool, sanitize_metric_name
-from .protocol import NullProto, UdpProto
+from .helpers import env_bool
+from .helpers import sanitize_metric_name
+from .protocol import NullProto
+from .protocol import UdpProto
 
 ENV_VARS = {
     'host': (str, 'PUSH_METRICS_HOST'),
@@ -65,9 +67,7 @@ def timer(
 
     def duration(self, bucket, value, **tags):
         # type: (str, float, ...) -> None
-        """
-        Sends duration in ms (float).
-        """
+        """Sends duration in ms (float)."""
 
         self.send(bucket, '{:0.6f}|ms'.format(value), **tags)
 
@@ -113,7 +113,5 @@ def __exit__(self, exc_type, exc_val, exc_tb):
         self.client.duration(self.bucket, elapsed, **self.tags)
 
     def set_tail(self, tail):  # type: (...) -> None
-        """
-        The only public method
-        """
+        """The only public method"""
         self.tail = tail