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

@task
def process_item(item):
    pass

@task
def dmap(it, callback):
    pass
How to chain a Celery task that returns a list into a group?