fix flake8 issues

Author: Junchao Wu

tchannel/handler.py

@@ -94,10 +94,6 @@ def handle_pre_call(self, message_id, message, connection):
         :param message_id: message id
         :param message: CallRequestMessage or CallRequestContinueMessage
         :param connection: tornado connection
-
-        :except InvalidChecksumException:
-            Raise InvalidChecksumException when the checksum in the message
-            is wrong.
         """
         try:
             req = connection.request_message_factory.build(message_id, message)

tchannel/thrift/transport/tornado_base.py

@@ -38,7 +38,6 @@
     from toro import Queue
 
 
-
 class TChannelTornadoTransportBase(TChannelTransportBase):
     """A Thrift Transport to send requests over an open TChannel connection.
 

tchannel/tornado/connection.py

@@ -49,7 +49,6 @@
     import toro as queues
 
 
-
 log = logging.getLogger('tchannel')
 
 

tchannel/tornado/stream.py

@@ -36,7 +36,6 @@
     from toro import Condition
 
 
-
 @tornado.gen.coroutine
 def read_full(stream):
     """Read the full contents of the given stream into memory.

tchannel/zipkin/formatters.py

@@ -48,7 +48,6 @@
     import json
 
 
-
 def hex_str(n):
     return '%0.16x' % (n,)
 

tests/integration/test_client_server.py

@@ -56,14 +56,14 @@ def test_tornado_client_with_server_not_there(random_open_port):
 # increase the LARGE_AMOUNT to even bigger
 @pytest.mark.gen_test
 @pytest.mark.parametrize('arg2, arg3', [
-        ("", big_arg()),
-        (big_arg(), ""),
-        ("test", big_arg()),
-        (big_arg(),  "test"),
-        (big_arg(), big_arg()),
-        ("", ""),
-        ("test", "test"),
-    ],
+    ("", big_arg()),
+    (big_arg(), ""),
+    ("test", big_arg()),
+    (big_arg(),  "test"),
+    (big_arg(), big_arg()),
+    ("", ""),
+    ("test", "test"),
+],
     ids=lambda arg: str(len(arg))
 )
 def test_tchannel_call_request_fragment(tchannel_server,

tests/integration/tornado/test_connection_reuse.py

@@ -90,11 +90,11 @@ def reverse(request, response, opts):
     @gen.coroutine
     def loop2(n):
         results = yield [
-           server2.request(hostport1).send(
+            server2.request(hostport1).send(
                 InMemStream('reverse'),
                 InMemStream(),
                 InMemStream('foo')
-           ) for i in xrange(n)
+            ) for i in xrange(n)
         ]
         for resp in results:
             body = yield resp.get_body()

tests/integration/trace/test_zipkin_trace.py

@@ -36,9 +36,6 @@
     from StringIO import StringIO
 
 
-
-
-
 @tornado.gen.coroutine
 def handler2(request, response, proxy):
     response.set_body_s(InMemStream("from handler2"))

tests/test_handler.py

@@ -38,10 +38,10 @@ def req():
     request.service = ""
     request.checksum = None
     request.argstreams = [
-            InMemStream("test"),
-            InMemStream(),
-            InMemStream()
-        ]
+        InMemStream("test"),
+        InMemStream(),
+        InMemStream()
+    ]
     request.tracing = Trace()
     request.id = 0
     request.argstreams[0].close()

tests/test_messages.py

@@ -247,14 +247,14 @@ def test_equality_check_against_none(init_request_with_headers):
 # increase the LARGE_AMOUNT to even bigger
 @pytest.mark.gen_test
 @pytest.mark.parametrize('arg2, arg3', [
-        ("", big_arg()),
-        (big_arg(), ""),
-        ("test", big_arg()),
-        (big_arg(),  "test"),
-        (big_arg(), big_arg()),
-        ("", ""),
-        ("test", "test"),
-    ],
+    ("", big_arg()),
+    (big_arg(), ""),
+    ("test", big_arg()),
+    (big_arg(),  "test"),
+    (big_arg(), big_arg()),
+    ("", ""),
+    ("test", "test"),
+],
     ids=lambda arg: str(len(arg))
 )
 def test_message_fragment(arg2, arg3, connection):