| @@ -1,6 +1,7 | |||
|
|
1 | 1 | from __future__ import absolute_import |
|
|
2 | 2 | |
|
|
3 | 3 | from celery import task |
|
|
4 | from datetime import timedelta, datetime | |
|
|
4 | 5 | |
|
|
5 | 6 | from .models import Experiment |
|
|
6 | 7 | |
| @@ -19,3 +20,19 def task_stop(id_exp): | |||
|
|
19 | 20 | return exp.stop() |
|
|
20 | 21 | |
|
|
21 | 22 | |
|
|
23 | #Task to get status | |
|
|
24 | @task | |
|
|
25 | def task_status(id_exp): | |
|
|
26 | ||
|
|
27 | exp = Experiment.objects.get(pk=id_exp) | |
|
|
28 | if exp.status==2: | |
|
|
29 | run_every = timedelta(minutes=1) | |
|
|
30 | now = datetime.utcnow() | |
|
|
31 | date = now + run_every | |
|
|
32 | task_status.apply_async((id_exp,), eta=date) | |
|
|
33 | print "Monitoring..." | |
|
|
34 | exp.get_status() | |
|
|
35 | return exp.status | |
|
|
36 | ||
|
|
37 | else: | |
|
|
38 | return exp.status | |
General Comments 0
You need to be logged in to leave comments.
Login now