Celery Task Example, using Flask.

app.py

#!/usr/bin/env python3


from flask import Flask, jsonify
from celery import Celery

app = Flask(__name__)
app.config["CELERY_BROKER_URL"] = "redis://redis:6379"

celery = Celery(app.name, broker=app.config["CELERY_BROKER_URL"])
celery.conf.update(app.config)


@app.route('/')
def add_task():
    """ A job is created in the celery queue, and executed when resources are available."""
    for i in range(10000):
        add.delay(i, i)
    return jsonify({'status': 'ok'})

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