I have the following use case using Celery and Flask.

I have built my app on Flask. I connected Celery to work with queue. I used Redis as broker for Celery. I am going to create more than 3 million jobs and each job takes about 2 seconds to 20 seconds, so it will run for a long time. I want to monitor worker’s status, how many tasks completed and how many tasks are left. Here my related project codes: