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)()
process_list = get_list.s(10) | dmap.s(process_item.s())
How to chain a Celery task that returns a list into a group?