flakes

celery/app/builtins.py

@@ -344,7 +344,6 @@ def add_chord_task(app):
             app = self.app
             propagate = default_propagate if propagate is None else propagate
             group_id = uuid()
-            AsyncResult = app.AsyncResult
 
             # - convert back to group if serialized
             tasks = header.tasks if isinstance(header, group) else header

celery/canvas.py

@@ -519,7 +519,6 @@ class group(Signature):
         new_tasks, results = [], []
         for task in self.tasks:
             task = maybe_signature(task, app=self._app).clone()
-            topts = task.options
             results.append(task.freeze(group_id=group_id, chord=chord))
             new_tasks.append(task)
         self.tasks = self.kwargs['tasks'] = new_tasks
@@ -591,8 +590,8 @@ class chord(Signature):
         return app.tasks['celery.chord']
 
     def apply_async(self, args=(), kwargs={}, task_id=None,
-            producer=None, publisher=None, connection=None,
-            router=None, result_cls=None, **options):
+                    producer=None, publisher=None, connection=None,
+                    router=None, result_cls=None, **options):
         body = kwargs.get('body') or self.kwargs['body']
         kwargs = dict(self.kwargs, **kwargs)
         body = body.clone(**options)