瀏覽代碼

Implements chord.freeze()

Ask Solem 11 年之前
父節點
當前提交
06cb02dc71
共有 1 個文件被更改,包括 3 次插入0 次删除
  1. 3 0
      celery/canvas.py

+ 3 - 0
celery/canvas.py

@@ -552,6 +552,9 @@ class chord(Signature):
         )
         self.subtask_type = 'chord'
 
+    def freeze(self, _id=None):
+        return self.body.freeze(_id)
+
     @classmethod
     def from_dict(self, d, app=None):
         args, d['kwargs'] = self._unpack_args(**kwdict(d['kwargs']))