Fix linting errors on consumer.py

Author: pberganza-applaudostudios

analytics/consumer.py

@@ -4,7 +4,6 @@
 import backoff
 import json
 
-from analytics.version import VERSION
 from analytics.request import post, APIError, DatetimeSerializer
 
 try:
@@ -23,8 +22,9 @@ class Consumer(Thread):
     """Consumes the messages from the client's queue."""
     log = logging.getLogger('segment')
 
-    def __init__(self, queue, write_key, flush_at=100, host=None, on_error=None,
-                 flush_interval=0.5, gzip=False, retries=10, timeout=15):
+    def __init__(self, queue, write_key, flush_at=100, host=None,
+                 on_error=None, flush_interval=0.5, gzip=False, retries=10,
+                 timeout=15):
         """Create a consumer thread."""
         Thread.__init__(self)
         # Make consumer a daemon thread so that it doesn't block program exit
@@ -38,7 +38,8 @@ def __init__(self, queue, write_key, flush_at=100, host=None, on_error=None,
         self.gzip = gzip
         # It's important to set running in the constructor: if we are asked to
         # pause immediately after construction, we might set running to True in
-        # run() *after* we set it to False in pause... and keep running forever.
+        # run() *after* we set it to False in pause... and keep running
+        # forever.
         self.running = True
         self.retries = retries
         self.timeout = timeout
@@ -113,14 +114,19 @@ def request(self, batch):
 
         def fatal_exception(exc):
             if isinstance(exc, APIError):
-                # retry on server errors and client errors with 429 status code (rate limited),
+                # retry on server errors and client errors
+                # with 429 status code (rate limited),
                 # don't retry on other client errors
                 return (400 <= exc.status < 500) and exc.status != 429
             else:
                 # retry on all other errors (eg. network)
                 return False
 
-        @backoff.on_exception(backoff.expo, Exception, max_tries=self.retries + 1, giveup=fatal_exception)
+        @backoff.on_exception(
+            backoff.expo,
+            Exception,
+            max_tries=self.retries + 1,
+            giveup=fatal_exception)
         def send_request():
             post(self.write_key, self.host, gzip=self.gzip,
                  timeout=self.timeout, batch=batch)