Django/Celery - Filter each task result with periodic_task_name

Question

I am quite new to Celery. Here is my code for configuring 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="*"),
    },
}

I am wondering how to query the associated tasks for the periodic task get-newyorktimes-api in my view to pass the result of each into the context. I tried:

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

It returned an empty queryset even though I've run the task successfully multiple times. Where is my fault in this Task filter?

SpaceShaman · Accepted Answer · 2025-11-05 15:56:56Z

0

Starting from Celery 5.5.3 and newer, the periodic_task_name argument should no longer be passed directly to apply_async.
Instead, it needs to be included in the task headers, for example:

task.apply_async(headers={"periodic_task_name": "task_name"})

This change aligns with the updated task serialization behavior in newer Celery versions.

answered Nov 5 at 15:56

SpaceShaman

104 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Django/Celery - Filter each task result with periodic_task_name

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related