flakes

celery/canvas.py

@@ -268,7 +268,7 @@ class chain(Signature):
 
     def __init__(self, *tasks, **options):
         tasks = (regen(tasks[0]) if len(tasks) == 1 and is_list(tasks[0])
-                else tasks)
+                 else tasks)
         Signature.__init__(
             self, 'celery.chain', (), {'tasks': tasks}, **options
         )

celery/contrib/migrate.py

@@ -236,7 +236,8 @@ def start_filter(app, conn, filter, limit=None, timeout=1.0,
                  consume_from=None, state=None, **kwargs):
     state = state or State()
     queues = prepare_queues(queues)
-    consume_from = [_maybe_queue(app, q) for q in consume_from or queues.keys()]
+    consume_from = [_maybe_queue(app, q)
+                    for q in consume_from or queues.keys()]
     if isinstance(tasks, basestring):
         tasks = set(tasks.split(','))
     if tasks is None: