To run a stand-alone celery worker locally you'll need a broker (e.g. redis
):
sudo docker run -d -p 6379:6379 --name winnow-redis redis
or if you already have winnow-redis
container
sudo docker start winnow-redis
Run celery worker:
celery -A task_queue.application worker --loglevel=INFO
Test worker:
from task_queue.tasks import run_pipeline
run_pipeline.delay().get(timeout=2)