celery_redis_task_queue_with_async_addition_task.py

1# Save this as tasks.py
2from celery import Celery
3
4# Create the celery instance (app)
5# Note: 'redis://localhost' assumes you have a Redis broker running locally
6app = Celery('tasks', broker='redis://localhost:6379/0')
7
8@app.task
9def add(x, y):
10    return x + y
11
12# To run the worker, use the command:
13# celery -A tasks worker --loglevel=INFO
14
15# To call the task from another script:
16# from tasks import add
17# result = add.delay(4, 4)
18# print(result.get(timeout=1))