Using celery with redis in my django app Everything was working fine until I ran into a problem. The location of the redis files was changed and redis could not access them. After searching, it turns out that this is…
I have taken a free trial for Redis and it gave me an endpoint with a password. I haven't done anything with Redis or celery before so I really don't have any idea how it works. From the Docs of…
I'm using django with celery, celery beat, and redis to run periodic tasks. The problem I'm having is that tasks registered in celery are received but not executed. Also, the task stops in the middle even though I have not…
I need some help, My setup is Django, Postgres, Celery, Redis – all dockerized. Besides regular user-related features, the app should scrape info in the background mode. What I need is to launch the scraping function manually from management command…
As i was going through the Celery implementation from the Celery documentation, celery -A tasks worker --loglevel=INFO gave output unexpected that from the documentation, File "d:101_all_projectscelery-testingvenvlibsite-packagesceleryplatforms.py", line 9, in import grp ModuleNotFoundError: No module named 'grp' Is this because i…
I'm attempting to have an asynchronous task kicked off in a Flask route, and use JS to poll the task status location and retrieve the result when it is complete. The task shows as "PENDING" and doesn't ever succeeded or…
I am trying to run a simple workflow using celery and using this documentation. I am using chain to sequentially run the tasks, with following workflow Extract a file, tokenize it and load JSON dumps of sentence tokens of a…
I have a following project directory: azima: __init.py main.py tasks.py monitor.py tasks.py from .main import app @app.task def add(x, y): return x + y @app.task def mul(x, y): return x * y @app.task def xsum(numbers): return sum(numbers) main.py from celery…
I want to use Сelere with Redis as backend, I'll have a process that create tasks, stores ids and then runs again and checks statuses. How to clear results and statuses that I don't need anymore, could I restrict time…
I am trying to create a an API endpoint that will start a classification task asynchronously in a Django backend and I want to be able to retrieve the result later on. This is what I have done so far:…