@periodic_task(run_every=crontab(minute='5'), queue='celery_periodic',
    options={'queue': 'celery_periodic'})
def recalc_last_hour():
    dt = datetime.utcnow()
prev_hour = datetime(dt.year, dt.month, dt.day, dt.hour) - timedelta(hours=1)
log.debug('Generating task for hour %s', str(prev_hour))
recalc_hour.delay(prev_hour)
How to send periodic tasks to specific queue in Celery