PEP8ify

celery/bin/celerybeat.py

@@ -120,8 +120,6 @@ class Beat(object):
         platform.install_signal_handler("SIGINT", _sync)
 
 
-
-
 def parse_options(arguments):
     """Parse the available options to ``celeryd``."""
     parser = optparse.OptionParser(option_list=OPTION_LIST)

celery/bin/celeryd.py

@@ -58,7 +58,7 @@
 
 .. cmdoption:: --maxtasksperchild
 
-    Maximum number of tasks a pool worker can execute before it's 
+    Maximum number of tasks a pool worker can execute before it's
     terminated and replaced by a new worker.
 
 """

celery/bin/celeryd_multi.py

@@ -108,7 +108,7 @@ def multi_args(p, cmd="celeryd", append="", prefix="", suffix=""):
         names = map(str, range(1, int(names[0]) + 1))
         prefix = "celery"
     cmd = options.pop("--cmd", cmd)
-    append = options.pop("--append", append) 
+    append = options.pop("--append", append)
     hostname = options.pop("--hostname",
                    options.pop("-n", socket.gethostname()))
     prefix = options.pop("--prefix", prefix) or ""
@@ -131,13 +131,12 @@ def multi_args(p, cmd="celeryd", append="", prefix="", suffix=""):
         yield this_name, line, expand
 
 
-
-
 def names(argv, cmd):
     p = NamespacedOptionParser(argv)
     print("\n".join(hostname
                         for hostname, _, _ in multi_args(p, cmd)))
 
+
 def get(argv, cmd):
     wanted = argv[0]
     p = NamespacedOptionParser(argv[1:])
@@ -152,12 +151,14 @@ def start(argv, cmd):
     print("\n".join(worker
                         for _, worker, _ in multi_args(p, cmd)))
 
+
 def expand(argv, cmd=None):
     template = argv[0]
     p = NamespacedOptionParser(argv[1:])
     for _, _, expander in multi_args(p, cmd):
         print(expander(template))
 
+
 def help(argv, cmd=None):
     print("""Some examples:
 
@@ -217,7 +218,6 @@ def help(argv, cmd=None):
     celeryd -n xuzzy.myhost -c 3
 """)
 
-
 COMMANDS = {"start": start,
             "names": names,
             "expand": expand,
@@ -225,7 +225,9 @@ COMMANDS = {"start": start,
             "help": help}
 
 def usage():
-    print("Please use one of the following commands: %s" % ", ".join(COMMANDS.keys()))
+    print("Please use one of the following commands: %s" % (
+        ", ".join(COMMANDS.keys())))
+
 
 def celeryd_multi(argv, cmd="celeryd"):
     if len(argv) == 0:
@@ -239,6 +241,7 @@ def celeryd_multi(argv, cmd="celeryd"):
         usage()
         sys.exit(1)
 
+
 def main():
     celeryd_multi(sys.argv[1:])
 

celery/conf.py

@@ -210,5 +210,6 @@ def _init_routing_table(queues):
 
     return dict((queue, _defaults(opts)) for queue, opts in queues.items())
 
+
 def get_routing_table():
     return _init_routing_table(QUEUES)

celery/routes.py

@@ -40,7 +40,6 @@ def prepare(routes):
     return map(expand_route, routes)
 
 
-
 def firstmatcher(method):
     """With a list of instances, find the first instance that returns a
     value for the given method."""

celery/tests/test_routes.py

@@ -110,5 +110,3 @@ class test_lookup_disabled(unittest.TestCase):
         for i, (router, state) in enumerate((R1, R2, R3, R4, R5, R6)):
             self.assertEqual(routes.lookup_disabled(router, "celery.ping"),
                              state, "ok %d" % i)
-
-