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))
How to send periodic tasks to specific queue in Celery