DjangoBB LoFi version

Полная версия: Celery: как получить список задач в очереди?

Начало » Python для экспертов » Celery: как получить список задач в очереди?

int_0x80

Ноя. 28, 2013 16:24:04

Коллеги, добавил я например в celery 10000 тасков, которые должны выполниться через несколько дней. Как мне получить список задач из очереди которые еще не выполнились, чтобы, например, пользователь мог завершить необходимые.

Singularity

Ноя. 28, 2013 18:50:17

from celery.task.control import inspect
i = inspect()
i.active()

http://docs.celeryproject.org/en/latest/userguide/workers.html?highlight=revoke#dump-of-scheduled-eta-tasks

int_0x80

Ноя. 28, 2013 21:36:45

Singularity, i.active() возвращает задачи, которые выполняются в данный момент времени, а мне помимо них нужны и задачи, которые ждут своей очереди на исполнение.
i.scheduled() возвращает

{u'celery@desktop': []}

Singularity

Ноя. 29, 2013 04:13:39

ну так может у тебя нет задач в очереди ?

int_0x80

Ноя. 29, 2013 15:45:24

Singularity
ну так может у тебя нет задач в очереди ?

i.reserved() помогла, спасибо.