autopep8

setup.py

@@ -31,10 +31,10 @@
     description='Really simple async Redis client for Tornado',
     author='Josh Marshall',
     author_email='catchjosh@gmail.com',
-    url = "http://github.com/joshmarshall/toredis/",
-    license = "http://www.apache.org/licenses/LICENSE-2.0",
-    packages=['toredis',],
+    url="http://github.com/joshmarshall/toredis/",
+    license="http://www.apache.org/licenses/LICENSE-2.0",
+    packages=['toredis'],
     package_data={'toredis': ['commands.json']},
-    install_requires=['tornado',],
+    install_requires=['tornado'],
     **kwargs
 )

tests/test_client.py

@@ -3,12 +3,14 @@
 import time
 from toredis.client import Client
 
+
 class TestClient(AsyncTestCase):
     """ Test the client """
 
     def test_connect(self):
         client = Client(ioloop=self.io_loop)
         result = {}
+
         def callback():
             result["connected"] = True
             self.stop()
@@ -20,6 +22,7 @@ def callback():
     def test_set_command(self):
         client = Client(ioloop=self.io_loop)
         result = {}
+
         def set_callback(response):
             result["set"] = response
             self.stop()
@@ -38,10 +41,10 @@ def test_set_no_callback(self):
         with self.assertRaises(Exception):
             client.set("foo", "bar1")
 
-
     def test_get_command(self):
         client = Client(ioloop=self.io_loop)
         result = {}
+
         def get_callback(response):
             result["get"] = response
             self.stop()
@@ -83,6 +86,7 @@ def sub_callback(response):
     def test_pub_command(self):
         client = Client(ioloop=self.io_loop)
         result = {}
+
         def pub_callback(response):
             result["pub"] = response
             self.stop()
@@ -91,12 +95,11 @@ def pub_callback(response):
         self.wait()
         # blocks
         self.assertTrue("pub" in result)
-        self.assertEqual(result["pub"], 0) # no subscribers yet
+        self.assertEqual(result["pub"], 0)  # no subscribers yet
 
     def test_disconnect(self):
         client = Client(ioloop=self.io_loop)
         client.connect()
         client.disconnect()
         with self.assertRaises(IOError):
             client._stream.read_bytes(1024, lambda x: x)
-

tests/test_handler.py

@@ -6,6 +6,7 @@
 import redis
 import time
 
+
 class Handler(RequestHandler):
 
     @asynchronous
@@ -20,22 +21,24 @@ def on_receive(self, msg):
         if msg_type == "message":
             self.finish({"message": msg})
 
+
 class TestRedis(AsyncHTTPTestCase):
 
     def get_app(self):
         return Application([(r"/", Handler)])
 
     def get_new_ioloop(self):
-        return IOLoop.instance() # the default Client loop
+        return IOLoop.instance()  # the default Client loop
 
     def test_subscribe(self):
         """ Tests a subscription message """
 
         conn = redis.Redis()
+
         def publish_message():
             conn.publish("foo", "bar")
 
-        self.io_loop.add_timeout(time.time()+0.5, publish_message)
+        self.io_loop.add_timeout(time.time() + 0.5, publish_message)
         response = self.fetch("/")
         # blocks
         self.assertEqual(response.code, 200)