def get_range(x):
    return list(range(x))

@task
def mapper(nr):
    return nr * 2

@task
def reducer(nrs):
    return sum(nrs)

@task
def double_then_sum(nrs):
    pass
Celery - group inside a chain