@@ -0,0 +1,435 @@
+import time%0Afrom datetime import datetime%0A%0Afrom celery import Celery%0A%0A%0Aapp = Celery(%22tasks%22, broker=%22amqp://%22, backend=%22amqp%22)%0A%0A%0A@app.task%0Adef add(x, y):%0A    return x + y%0A%0A%0A@app.task%0Adef sleep(seconds):%0A    time.sleep(seconds)%0A%0A%0A@app.task%0Adef echo(msg, timestamp=False):%0A    return %22%25s: %25s%22 %25 (datetime.now(), msg) if timestamp else msg%0A%0A%0A@app.task%0Adef error(msg):%0A    raise Exception(msg)%0A%0A%0Aif __name__ == %22__main__%22:%0A    app.start()%0A

Add example tasks module