Celery: как получить список задач, ожидающих свою очередь на выполнение?

Question

[m0ody]

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

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

Судя по документации, таски, ожидающие свою очередь должна возвращать функция i.scheduled(), но она возвращает пустой массив:

from celery.task.control import inspect
i = inspect()
i.scheduled() # => {u'celery@desktop': []}

Answer 1

[alz]

Reserved tasks are tasks that has been received, but is still waiting to be executed.

scheduled - это задачи с отложенным выполнением

Comments

[m0ody]

Не совсем понятна логика работы функции reserved. Добавил я 150 заданий, из них выполнилось 10, а reserved возвращает то пустой результат, то 1, 2 задачи.