from celery import Celery

celery = Celery("myapp")

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

if __name__ == "__main__":
    options = {"BROKER_URL": "amqp://guest:guest@localhost:5672//"}
    celery.Worker(**options).run()