(self, header, body=None, task='celery.chord',
args=None, kwargs=None, app=None, **options)
| 2041 | return (header, body), kwargs |
| 2042 | |
| 2043 | def __init__(self, header, body=None, task='celery.chord', |
| 2044 | args=None, kwargs=None, app=None, **options): |
| 2045 | args = args if args else () |
| 2046 | kwargs = kwargs if kwargs else {'kwargs': {}} |
| 2047 | super().__init__(task, args, |
| 2048 | {**kwargs, 'header': _maybe_group(header, app), |
| 2049 | 'body': maybe_signature(body, app=app)}, app=app, **options |
| 2050 | ) |
| 2051 | self.subtask_type = 'chord' |
| 2052 | |
| 2053 | def __call__(self, body=None, **options): |
| 2054 | return self.apply_async((), {'body': body} if body else {}, **options) |
nothing calls this directly
no test coverage detected