Procfile

worker: celery --app=worker.app worker --pool=gevent --concurrency=10 --loglevel=INFO
producer: python producer.py

producer.py

from worker import app

def main():
    while True:
        time.sleep(2)
        app.send_task("sleep")

if __name__ == "__main__":
    main()

worker.py

from celery import Celery
import time
import inspect

app = Celery(
    "worker",
    broker="redis://localhost:6370/0",
    broker_connection_retry_on_startup=True,
    broker_connection_retry=True,
)


@app.task(name="sleep")
def sleep():
    print(inspect.getmodule(time.sleep))
    time.sleep(0.5)