@periodic_task(run_every=crontab(minute='5'), queue='celery_periodic',
    options={'queue': 'celery_periodic'})
def recalc_last_hour():
    dt = datetime.utcnow()
How to send periodic tasks to specific queue in Celery