bstiel · December 15, 2023 14:15
diff --git a/Procfile b/Procfile
 worker: celery --app=worker.app worker --pool=gevent --concurrency=10 --loglevel=INFO
 producer: python producer.py
diff --git a/producer.py b/producer.py
 from worker import app

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

 if __name__ == "__main__":
    main()
diff --git a/worker.py b/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)
	worker: celery --app=worker.app worker --pool=gevent --concurrency=10 --loglevel=INFO
	producer: python producer.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)