diff options
| author | Manuel Traut <manut@mecka.net> | 2014-03-16 20:25:02 +0100 |
|---|---|---|
| committer | Manuel Traut <manut@mecka.net> | 2014-03-16 20:25:02 +0100 |
| commit | 6f4862dba013c38bfba0109ba9363195b5171c7b (patch) | |
| tree | fe366d5a7ccc01860b047c551bda12324c7029ad /frameworks/middleware/examples/celery/exec_task.py | |
| parent | 5761d1eb8a47437375c4f61bb54d09e60b67c816 (diff) | |
| parent | 2f46ad6a6f7393dc7898672a7ea3337395bafae9 (diff) | |
Merge ../projects/schulung
Diffstat (limited to 'frameworks/middleware/examples/celery/exec_task.py')
| -rw-r--r-- | frameworks/middleware/examples/celery/exec_task.py | 15 |
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") |
