Как правильно организовать очереди celery redis?

Question

[mr_drinkens89]

День добрый.Подскажите, знающие люди.
Я создал свое приложение "рассылка". Ситуация такая,что надо создавать несколько рассылок (штук 10),и у каждой задавать свое время (день,месяц,время).
В таск я указал

@task(name='mailer.send_db_mail', default_retry_delay=SEND_RETRY_DELAY)
def send_db_mail(*args, **kwargs):
    from mailer.send_mail import SendMail
    from models import MailTemplate,Subscriber

    try:
        subscriber = Subscriber.objects.filter(is_finish=False).order_by("date_send")[0]
        if subscriber:
                   #рассылаем

то есть когда рассылка завершается - ставится чекер неактивности.
Как мне организовать очереди?чтоб если прошлая рассылка еще не завершилась - ожидаем.
спасибо

Answer 1

[Вадим Шандринов]

В селери есть группировки тасков celery.readthedocs.org/en/latest/userguide/canvas....
Наверно вам подойдет chain - каждая следующая задача выполняется после окончания предыдущей.

Comments

[mr_drinkens89]

Вадим,а можно небольшой пример,как это будет выглядеть?
спасибо

[Вадим Шандринов]

Там же пример есть:
from celery import chain
res = chain(add.s(2, 2), add.s(4), add.s(8))()
res.get()
можно эти таски засунуть в список и сделать chain(*task_list)
а вообще - пробовать и экспериментировать! :) я же не знаю ваши граничные и начальные условия...

[Вадим Шандринов]

одна задача - запускалка chain, другая задачка - собственно рассылка. в первой формируется цепочка из инстансов второй и запускается. ктт.

[mr_drinkens89]

Вадим Шандринов: Вадим,благодарю!