@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))
Как отправлять периодические задачи в определенную очередь в Celery