def get_list(amount):
    return [i for i in range(amount)]

@task
def process_item(item):
    pass

@task
def dmap(it, callback):
    callback = subtask(callback)
return group(callback.clone([arg]) for arg in it)()
Как связать задачу Celery, которая возвращает список в группу?