Ask Solem 9 years ago
parent
commit
a5f5b63a4b
2 changed files with 2 additions and 2 deletions
  1. 2 1
      celery/canvas.py
  2. 0 1
      celery/datastructures.py

+ 2 - 1
celery/canvas.py

@@ -870,7 +870,8 @@ class chord(Signature):
         if not isinstance(self.tasks, group):
             self.tasks = group(self.tasks)
         bodyres = self.body.freeze(_id, parent_id=self.id, root_id=root_id)
-        self.tasks.freeze(parent_id=parent_id, root_id=root_id, chord=self.body)
+        self.tasks.freeze(
+            parent_id=parent_id, root_id=root_id, chord=self.body)
         self.id = self.tasks.id
         self.body.set_parent_id(self.id)
         return bodyres

+ 0 - 1
celery/datastructures.py

@@ -13,7 +13,6 @@ import time
 
 from collections import defaultdict, Mapping, MutableMapping, MutableSet
 from heapq import heapify, heappush, heappop
-from functools import partial
 from itertools import chain
 
 from billiard.einfo import ExceptionInfo  # noqa