tasks.py

from celery import Celery

celery = Celery('tasks', backend='amqp',
                broker='amqp://guest:guest@localhost:5672/md5')

class Borked(Exception):
    pass

@celery.task
def add(x, y):
    raise Borked('DEAD!')
    return x + y