|
@@ -514,10 +514,6 @@ class Celery(object):
|
|
def Beat(self, **kwargs):
|
|
def Beat(self, **kwargs):
|
|
return self.subclass_with_self('celery.apps.beat:Beat')
|
|
return self.subclass_with_self('celery.apps.beat:Beat')
|
|
|
|
|
|
- @cached_property
|
|
|
|
- def TaskSet(self):
|
|
|
|
- return self.subclass_with_self('celery.task.sets:TaskSet')
|
|
|
|
-
|
|
|
|
@cached_property
|
|
@cached_property
|
|
def Task(self):
|
|
def Task(self):
|
|
return self.create_task_cls()
|
|
return self.create_task_cls()
|
|
@@ -530,12 +526,22 @@ class Celery(object):
|
|
def AsyncResult(self):
|
|
def AsyncResult(self):
|
|
return self.subclass_with_self('celery.result:AsyncResult')
|
|
return self.subclass_with_self('celery.result:AsyncResult')
|
|
|
|
|
|
|
|
+ @cached_property
|
|
|
|
+ def ResultSet(self):
|
|
|
|
+ return self.subclass_with_self('celery.result:ResultSet')
|
|
|
|
+
|
|
@cached_property
|
|
@cached_property
|
|
def GroupResult(self):
|
|
def GroupResult(self):
|
|
return self.subclass_with_self('celery.result:GroupResult')
|
|
return self.subclass_with_self('celery.result:GroupResult')
|
|
|
|
|
|
|
|
+ @cached_property
|
|
|
|
+ def TaskSet(self): # XXX compat
|
|
|
|
+ """Deprecated! Please use :class:`celery.group` instead."""
|
|
|
|
+ return self.subclass_with_self('celery.task.sets:TaskSet')
|
|
|
|
+
|
|
@cached_property
|
|
@cached_property
|
|
def TaskSetResult(self): # XXX compat
|
|
def TaskSetResult(self): # XXX compat
|
|
|
|
+ """Deprecated! Please use :attr:`GroupResult` instead."""
|
|
return self.subclass_with_self('celery.result:TaskSetResult')
|
|
return self.subclass_with_self('celery.result:TaskSetResult')
|
|
|
|
|
|
@property
|
|
@property
|