golden celery

requirements.txt

# celery and it's dependencies
amqp==1.0.8
anyjson==0.3.3
kombu==2.5.6
python-dateutil==1.5
billiard==2.7.3.21
celery==3.0.15

settings.py

# No connection pool to the broker (there's only 1 task per process anyway)
BROKER_POOL_LIMIT = None
CELERYD_MAX_TASKS_PER_CHILD = 1

from billiard.common import restart_state
def _run_silenced(self, func):
    import logging
    try:
        return func(self)
    except Exception:
        logging.exception("Shit has hit the fan in %r", func)
restart_state.step = lambda self, func=restart_state.step: _run_silenced(self, func)