README.md

Celery doesn't always restart. Try to make a reproducible test case for celery related code.

Run:

vagrant up
ssh-copy-id vagrant@localhost -p 2222
ansible -m ping all
ansible-playbook setup.yml

after SSH-ing into the machine:

#shell 1
celery -A tasks worker --loglevel=info
#shell 2
ipython -i /vagrant/run.py

ansible.cfg

[defaults]
hostfile=hosts.ini
remote_user=vagrant

hosts.ini

[machine]
localhost ansible_ssh_port=2222 ansible_ssh_user=vagrant

run.py

# http://celery.readthedocs.org/en/latest/getting-started/first-steps-with-celery.html#id12
import tasks

result = tasks.add.delay(4, 4)

print(result.ready())
print(result.get(timeout=1))

setup.yml

---
- hosts: machine
  sudo: True
  tasks:
      - apt: name=supervisor
      - apt: name=python-pip
      - apt: name=rabbitmq-server
      - pip: name=celery
      - pip: name=ipython

tasks.py

from celery import Celery

app = Celery('tasks', broker='amqp://guest@localhost//', backend='amqp')


@app.task
def add(x, y):
    return x + y

Vagrantfile

# -*- mode: ruby -*-
# vi: set ft=ruby :

# Vagrantfile API/syntax version. Don't touch unless you know what you're doing!
VAGRANTFILE_API_VERSION = "2"

Vagrant.configure(VAGRANTFILE_API_VERSION) do |config|
  config.vm.box = "hashicorp/precise64"
  config.vm.provider "virtualbox" do |vb|
    vb.customize ["modifyvm", :id, "--memory", "256"]
  end
end