(self, task, it, **options)
| 1377 | return cls(*cls._unpack_args(d['kwargs']), app=app, **d['options']) |
| 1378 | |
| 1379 | def __init__(self, task, it, **options): |
| 1380 | super().__init__(self._task_name, (), |
| 1381 | {'task': task, 'it': regen(it)}, immutable=True, **options |
| 1382 | ) |
| 1383 | |
| 1384 | def apply_async(self, args=None, kwargs=None, **opts): |
| 1385 | # need to evaluate generators |