Celery Prefetching Example

celery_prefetching_example.py

"""
In this example, we're configuring Celery to prefetch 10 tasks at a time. 
This means that each worker will load up to 10 tasks into its memory before 
they are executed. This can help to reduce the time it takes to fetch new 
tasks from the broker, and can improve overall performance.
"""
from celery import Celery

app = Celery('tasks', broker='pyamqp://guest@localhost//')

# Configure Celery to prefetch 10 tasks at a time
app.conf.update(
    worker_prefetch_multiplier=10
)

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