Revision 736b67bf flowspec/tasks.py

b/flowspec/tasks.py
123 123
        routes = routes.filter(name=route_name)
124 124
    for route in routes:
125 125
        if route.has_expired() and (route.status != 'EXPIRED' and route.status != 'ADMININACTIVE' and route.status != 'INACTIVE'):
126
            logger.info('Expiring route %s' %route.name)
127
            subtask(delete).delay(route, reason="EXPIRED")
126
            if route.status != 'ERROR':
127
                logger.info('Expiring %s route %s' %(route.status, route.name))
128
                subtask(delete).delay(route, reason="EXPIRED")
128 129
#        elif route.has_expired() and (route.status == 'ADMININACTIVE' or route.status == 'INACTIVE'):
129 130
#            route.status = 'EXPIRED'
130 131
#            route.response = 'Rule Expired'

Also available in: Unified diff