|
@@ -604,6 +604,7 @@ class chord(Signature):
|
|
def apply_async(self, args=(), kwargs={}, task_id=None,
|
|
def apply_async(self, args=(), kwargs={}, task_id=None,
|
|
producer=None, publisher=None, connection=None,
|
|
producer=None, publisher=None, connection=None,
|
|
router=None, result_cls=None, **options):
|
|
router=None, result_cls=None, **options):
|
|
|
|
+ args = tuple(args) + tuple(self.args) if args else self.args
|
|
body = kwargs.get('body') or self.kwargs['body']
|
|
body = kwargs.get('body') or self.kwargs['body']
|
|
kwargs = dict(self.kwargs, **kwargs)
|
|
kwargs = dict(self.kwargs, **kwargs)
|
|
body = body.clone(**options)
|
|
body = body.clone(**options)
|