My celery progress always crash in 00:00:00.And I don't know why..I don't define an app called LogAnalysis and I never define a method called reindex_log.But The log told me can't not find that method. Error Log: [2019-07-29 23:50:02,949: INFO/ForkPoolWorker-5] changed:…
I am using Flask with Celery and I am trying to lock a specific task so that it can only be run one at a time. In the celery docs it gives a example of doing this Celery docs, Ensuring…
I'm using a docker-compose. I have a web and a worker service. version: '3' services: web: build: . environment: - "*" links: - redis - memcached ports: - "80:8001" - "443:8001" worker: build: . command: ["/bin/bash", "/home/django/start_celery.sh"] environment: - "*"…
I have a race condition in Celery. Inspired by this - http://ask.github.io/celery/cookbook/tasks.html#ensuring-a-task-is-only-executed-one-at-a-time I decided to use memcache to add locks to my tasks. These are the changes I made: python-memcached # settings for memcache CACHES = { 'default': { 'BACKEND':…