Running Celery Worker and Queues

[Enmanuel Toribio]

After some struggle I found out how to raise the celery worker, i'm leaving it here so anyone who runs into this problem can deal with it.

Go to the rapidpro root folder and run the following:

python manage.py celery -A temba worker -l info -Q msgs,default,handler,flow

FYI: I'm working on ubuntu server 14.04

[Allan Stockman rugano]

Right. Also you can run the Celery workers as daemons under supervisor. http://michal.karzynski.pl/blog/2014/05/18/setting-up-an-asynchronous-task-queue-for-django-using-celery-redis/ 

[Enmanuel Toribio]

In the end I did the following:

I created a daemon file for celery

nano /etc/default/celeryd

then added the following lines to the file:

CELERYD_NODES=1

CELERY_BIN="/var/www/rapidpro/env/bin/celery"

CELERY_APP="temba"

CELERYD_CHDIR="/var/www/rapidpro/"

CELERYD_LOG_FILE="/var/log/celery/%N.log"

CELERYD_PID_FILE="/var/run/celery/%N.pid"

CELERY_CREATE_MISSING_QUEUES=1

CELERYD_OPTS="--time-limit=300 --concurrency=10 -Q celery,msgs,default,handler,flows -l info -B"

CELERYD_USER="root"

CELERYD_GROUP="root"

CELERY_CREATE_DIRS=1

then downloaded the celeryd file  into /etc/init.d/celeryd

and ran the command

/etc/init.d/celeryd start