Вы можете сделать задачу с истекающим сроком довольно легко:
my_task.apply_async(expires=10)
Но я не понимаю, как сделать это с цепочкой. Делаете ли вы:
chain(task.s(), task2.s()).apply_async(expires=10)
Или вы устанавливаете срок действия для отдельных задач? Или что-то еще?
Мой вариант использования заключается в том, что мы очищаем RSS-каналы (затем анализируем их, затем делаем их доступными для поиска, затем и того и другого), и мы хотим, чтобы наши задачи очистки истекали через определенный период времени. ,
Итак, что-то вроде:
chain(scrape_rss.s(url=url), parse_feed.s(), add_feed_to_index.s())
Спасибо за любые комментарии, которыми могут поделиться люди. Кажется, это совершенно недокументировано.