1 files changed, 15 insertions, 0 deletions
diff --git a/frameworks/middleware/examples/celery/exec_task.py b/frameworks/middleware/examples/celery/exec_task.py
new file mode 100644
index 0000000..9169250
--- /dev/null
+++ b/frameworks/middleware/examples/celery/exec_task.py
@@ -0,0 +1,15 @@
+import os
+
+from celery import Celery
+
+app = Celery ('tasks', broker='sqla+sqlite:///celerydb.sqlite',
+                       backend='db+sqlite:///results.sqlite')
+
+@app.task
+def execute (command):
+    return os.system (command)
+
+@app.task
+def execute2 (command):
+    if os.system (command):
+       raise Exception ("command not found")