Python-сообщество

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

Отредактировано Singularity (Ноя. 28, 2013 18:50:42)

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

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

{u'celery@desktop': []}

Отредактировано int_0x80 (Ноя. 28, 2013 21:43:40)

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

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

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

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

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

Отредактировано int_0x80 (Ноя. 29, 2013 15:45:38)

Python-сообщество

Уведомления

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

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

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

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

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

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

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

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

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

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

Board footer