Django/Celery - Фильтруйте результат каждой задачи по имени периодической_задачи

Я совсем новичок в Celery. Вот мой код для конфигурирования Celery Beat.

app.conf.beat_schedule = {

# EMAILS
'send-feedback-mail-every-2-weeks': {
    'task': 'stocks.tasks.send_ask_feedback',
    'schedule': crontab(day_of_week=6),
},

'get-terminal-data-frequently': {
    'task': 'stocks.tasks.get_terminal_data_func',
    'schedule': crontab(minute="*"),
},

# NEWS
'get-newyorktimes-api': {
    'task': 'stocks.tasks.get_news_nyt',
    'schedule': crontab(minute="*"),
},

Мне интересно, как запросить связанные задачи для периодической задачи 'get-newyorktimes-api' в моем представлении, чтобы передать результат каждой из них в контекст. Я пробовал:

context['celery'] = TaskResult.objects.filter(periodic_task_name='get-newyorktimes-api')

Он возвращает пустой набор запросов, хотя я успешно запускал задачу несколько раз. Где моя ошибка в этом фильтре задачи?

Вернуться на верх