celery — Easy Playground

Distributed task queue for async job processing

Getting started with celeryRun locally

Install

pip install celery[redis]

Python CodeRun locally

# Install: pip install celery[redis]
from celery import Celery

app = Celery("tasks", broker="redis://localhost:6379")

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

# Usage:
# result = add.delay(4, 4)
# print(result.get())

# Install: pip install celery[redis]
from celery import Celery

app = Celery("tasks", broker="redis://localhost:6379")

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

# Usage:
# result = add.delay(4, 4)
# print(result.get())

Expected Output

# Expected output shown below
# (Run locally with: celery)

celery is a third-party package. Distributed task queue for async job processing. Install with: pip install celery[redis]

Challenge

Try modifying the code above to explore different behaviors. Can you extend the example to handle a new use case?

View all Easy examples for celery