diff options
| author | Jan Altenberg <jan@linutronix.de> | 2014-05-28 09:59:44 +0200 |
|---|---|---|
| committer | Jan Altenberg <jan@linutronix.de> | 2014-05-28 09:59:44 +0200 |
| commit | aa917ad3ea5d20f1d2eed18e188f999206805ced (patch) | |
| tree | 28b6821452945f42f475baed5b79ef0e9810930c /frameworks/middleware/examples/celery/exec_task.py | |
| parent | cf0a003df645cec7f4f8405f9f03402b9dcf050e (diff) | |
| parent | 541d5387d74bc185fd95124b1c9071748c859914 (diff) | |
Merge branch 'master' into kconfig_jan
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") |
