sort the import order

Author: Junchao Wu

examples/stream_client.py

@@ -20,12 +20,14 @@
 
 import os
 import sys
+
 import tornado
 import tornado.ioloop
 
 from options import get_args
 from tchannel.tornado import TChannel
-from tchannel.tornado.stream import InMemStream, PipeStream
+from tchannel.tornado.stream import InMemStream
+from tchannel.tornado.stream import PipeStream
 from tchannel.tornado.util import print_arg
 
 

examples/tchannel_server.py

@@ -22,9 +22,9 @@
 
 import tornado.ioloop
 
-from tchannel.tornado import TChannel
-from options import get_args
 from handler import get_example_handler
+from options import get_args
+from tchannel.tornado import TChannel
 
 
 def main():  # pragma: no cover

examples/thrift_examples/client.py

@@ -18,12 +18,13 @@
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 # THE SOFTWARE.
 
-from tornado import ioloop, gen
-
-from tchannel.tornado import TChannel
-from tchannel.thrift import TChannelProtocolFactory, TChannelTornadoTransport
+from tornado import gen
+from tornado import ioloop
 
 from hello import HelloService
+from tchannel.thrift import TChannelProtocolFactory
+from tchannel.thrift import TChannelTornadoTransport
+from tchannel.tornado import TChannel
 
 
 @gen.coroutine

examples/thrift_examples/hello/HelloService.py

@@ -26,14 +26,19 @@
 #  options string: py:tornado,dynamic,utf8strings
 #
 
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-from ttypes import *
+from thrift.protocol.TBase import TBase
+from thrift.protocol.TBase import TExceptionBase
+from thrift.Thrift import TApplicationException
+from thrift.Thrift import TException
+from thrift.Thrift import TMessageType
 from thrift.Thrift import TProcessor
-from thrift.protocol.TBase import TBase, TExceptionBase
-
-from tornado import gen
-from tornado import concurrent
+from thrift.Thrift import TType
 from thrift.transport import TTransport
+from tornado import concurrent
+from tornado import gen
+
+from ttypes import *
+
 
 class Iface(object):
   def hello(self, name):

examples/thrift_examples/hello/constants.py

@@ -26,6 +26,9 @@
 #  options string: py:tornado,dynamic,utf8strings
 #
 
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-from ttypes import *
+from thrift.Thrift import TApplicationException
+from thrift.Thrift import TException
+from thrift.Thrift import TMessageType
+from thrift.Thrift import TType
 
+from ttypes import *

examples/thrift_examples/hello/ttypes.py

@@ -26,8 +26,9 @@
 #  options string: py:tornado,dynamic,utf8strings
 #
 
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
-
-from thrift.protocol.TBase import TBase, TExceptionBase
-
-
+from thrift.protocol.TBase import TBase
+from thrift.protocol.TBase import TExceptionBase
+from thrift.Thrift import TApplicationException
+from thrift.Thrift import TException
+from thrift.Thrift import TMessageType
+from thrift.Thrift import TType

examples/thrift_examples/server.py

@@ -20,10 +20,10 @@
 
 from tornado import ioloop
 
-from tchannel import thrift
-from tchannel.tornado import TChannel, TornadoDispatcher
-
 from hello import HelloService
+from tchannel import thrift
+from tchannel.tornado import TChannel
+from tchannel.tornado import TornadoDispatcher
 
 
 class HelloServiceHandler(object):

examples/tornado_client.py

@@ -24,8 +24,8 @@
 
 import time
 
-import tornado.iostream
 import tornado.ioloop
+import tornado.iostream
 
 from options import get_args
 from tchannel.tornado.connection import StreamConnection

tchannel/event.py

@@ -19,9 +19,11 @@
 # THE SOFTWARE.
 
 from __future__ import absolute_import
-from enum import IntEnum
+
 import logging
 
+from enum import IntEnum
+
 log = logging.getLogger('tchannel')
 
 

tchannel/frame.py

@@ -23,9 +23,8 @@
 from collections import namedtuple
 
 from . import rw
-from .io import BytesIO
 from .exceptions import ReadException
-
+from .io import BytesIO
 
 FrameHeader = namedtuple('FrameHeader', 'message_type message_id')
 Frame = namedtuple('Frame', 'header payload')

tchannel/handler.py

@@ -19,9 +19,10 @@
 # THE SOFTWARE.
 from __future__ import absolute_import
 
-from .messages import Types, ErrorCode
-from .messages import PingResponseMessage
 from .exceptions import InvalidChecksumException
+from .messages import ErrorCode
+from .messages import PingResponseMessage
+from .messages import Types
 
 
 class RequestHandler(object):

tchannel/io.py

@@ -20,7 +20,6 @@
 
 from __future__ import absolute_import
 
-
 try:
     from cStringIO import StringIO as BytesIO
 except ImportError:  # pragma: no cover

tchannel/messages/call_request.py

@@ -20,10 +20,10 @@
 
 from __future__ import absolute_import
 
+from . import common
+from .. import rw
 from .call_request_continue import CallRequestContinueMessage
 from .types import Types
-from .. import rw
-from . import common
 
 
 class CallRequestMessage(CallRequestContinueMessage):

tchannel/messages/call_request_continue.py

@@ -20,10 +20,10 @@
 
 from __future__ import absolute_import
 
-from .types import Types
-from .. import rw
 from . import common
+from .. import rw
 from .call_continue import CallContinueMessage
+from .types import Types
 
 
 class CallRequestContinueMessage(CallContinueMessage):

tchannel/messages/call_response.py

@@ -20,10 +20,10 @@
 
 from __future__ import absolute_import
 
+from . import common
+from .. import rw
 from .call_response_continue import CallResponseContinueMessage
 from .types import Types
-from .. import rw
-from . import common
 
 
 class CallResponseMessage(CallResponseContinueMessage):

tchannel/messages/call_response_continue.py

@@ -20,10 +20,10 @@
 
 from __future__ import absolute_import
 
+from . import common
+from .. import rw
 from .call_continue import CallContinueMessage
 from .types import Types
-from .. import rw
-from . import common
 
 
 class CallResponseContinueMessage(CallContinueMessage):

tchannel/messages/common.py

@@ -21,8 +21,10 @@
 from __future__ import absolute_import
 
 import zlib
-import crcmod.predefined
 from collections import namedtuple
+
+import crcmod.predefined
+
 from enum import IntEnum
 
 from .. import rw
@@ -112,29 +114,29 @@ def compute_checksum(checksum_type, args, csum=0):
     return csum
 
 
-def generate_checksum(message, pre_csum=0):
+def generate_checksum(message, previous_csum=0):
     """Generate checksum for messages with
         CALL_REQ, CALL_REQ_CONTINUE,
         CALL_RES,CALL_RES_CONTINUE types.
 
     :param message: outgoing message
-    :param pre_csum: accumulated checksum value
+    :param previous_csum: accumulated checksum value
     """
     if message.message_type in CHECKSUM_MSG_TYPES:
         csum = compute_checksum(
             message.checksum[0],
             message.args,
-            pre_csum,
+            previous_csum,
         )
 
         message.checksum = (message.checksum[0], csum)
 
 
-def verify_checksum(message, pre_csum=0):
+def verify_checksum(message, previous_csum=0):
     """Verify checksum for incoming message.
 
     :param message: incoming message
-    :param pre_csum: accumulated checksum value
+    :param previous_csum: accumulated checksum value
 
     :return return True if message checksum type is None
     or checksum is correct
@@ -143,7 +145,7 @@ def verify_checksum(message, pre_csum=0):
         csum = compute_checksum(
             message.checksum[0],
             message.args,
-            pre_csum,
+            previous_csum,
         )
 
         if csum == message.checksum[1]:

tchannel/messages/error.py

@@ -22,10 +22,10 @@
 
 import enum
 
+from . import common
 from .. import rw
 from .base import BaseMessage
 from .types import Types
-from . import common
 
 
 @enum.unique

tchannel/messages/init_request.py

@@ -20,10 +20,10 @@
 
 from __future__ import absolute_import
 
+from .. import rw
 from .base import BaseMessage
 from .common import PROTOCOL_VERSION
 from .types import Types
-from .. import rw
 
 
 class InitRequestMessage(BaseMessage):

tchannel/messages/init_response.py

@@ -20,9 +20,9 @@
 
 from __future__ import absolute_import
 
-from .types import Types
-from .init_request import InitRequestMessage
 from .. import rw
+from .init_request import InitRequestMessage
+from .types import Types
 
 
 class InitResponseMessage(InitRequestMessage):

tchannel/net.py

@@ -20,10 +20,11 @@
 
 from __future__ import absolute_import
 
-import socket
 import fcntl
+import socket
 import struct
 
+
 # TODO This module is unix-only. Figure out something for Windows.
 
 

tchannel/rw.py

@@ -24,7 +24,6 @@
 
 from .exceptions import ReadException
 
-
 skip = '_'
 
 

tchannel/tcurl.py

@@ -20,6 +20,7 @@
 
 from __future__ import absolute_import
 
+import argparse
 import collections
 import contextlib
 import cProfile
@@ -29,13 +30,12 @@
 import sys
 import time
 
-import argparse
 import tornado.ioloop
-from .tornado.stream import InMemStream
-from .tornado.util import print_arg
+
 from .tornado import TChannel
 from .tornado.dispatch import TornadoDispatcher
-
+from .tornado.stream import InMemStream
+from .tornado.util import print_arg
 
 log = logging.getLogger('tchannel')
 

tchannel/thrift/protocol.py

@@ -23,7 +23,9 @@
 from collections import namedtuple
 
 from thrift import Thrift
-from thrift.protocol import TProtocol, TBinaryProtocol, fastbinary
+from thrift.protocol import TBinaryProtocol
+from thrift.protocol import TProtocol
+from thrift.protocol import fastbinary
 
 from .transport import TChannelTransportBase
 

tchannel/thrift/server.py

@@ -22,8 +22,9 @@
 
 import inspect
 
-from thrift.transport import TTransport
 from thrift.protocol import TBinaryProtocol
+from thrift.transport import TTransport
+
 from tchannel.tornado.stream import InMemStream
 
 

tchannel/thrift/transport/tornado.py

@@ -21,8 +21,10 @@
 from __future__ import absolute_import
 
 from tornado import gen
+
 from tchannel.io import BytesIO
 from tchannel.tornado.stream import InMemStream
+
 from .tornado_base import TChannelTornadoTransportBase