summaryrefslogtreecommitdiff
path: root/frameworks/middleware/examples/celery/exec_task.py
diff options
context:
space:
mode:
authorManuel Traut <manut@mecka.net>2014-03-16 20:25:02 +0100
committerManuel Traut <manut@mecka.net>2014-03-16 20:25:02 +0100
commit6f4862dba013c38bfba0109ba9363195b5171c7b (patch)
treefe366d5a7ccc01860b047c551bda12324c7029ad /frameworks/middleware/examples/celery/exec_task.py
parent5761d1eb8a47437375c4f61bb54d09e60b67c816 (diff)
parent2f46ad6a6f7393dc7898672a7ea3337395bafae9 (diff)
Merge ../projects/schulung
Diffstat (limited to 'frameworks/middleware/examples/celery/exec_task.py')
-rw-r--r--frameworks/middleware/examples/celery/exec_task.py15
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")