# test_celery.py
import celery

app = celery.Celery(
    'test_celery'
    ,broker =  'redis://a.redis.server:6379/9'
)

app.conf.update(
    CELERY_RESULT_BACKEND = 'redis://a.redis.server:6379/9'
)

@app.task()
def add(x, y):
    return x + y

if __name__ == '__main__':
    result = add.delay(1,1).get()
    print(result)
    # result is 2, works on both 

    result = celery.chain([
        add.si(1,1)
    ])().get()
    print(result)
    # result is 2, works on both 

    result = celery.group([
        add.si(1,1)
        ,add.si(2,2)
    ])().get()
    print(result)
    # result is [2, 4], works on both 

    result = celery.chain([
        add.si(1,1)
        ,add.si(2,2)
    ])().get()
    print(result)
    # result is hang on windows and 4 on linux