Revision 57de574d flowspec/tasks.py

b/flowspec/tasks.py
7 7 
from flowspy.utils import beanstalkc
8 8 
from django.conf import settings
9 9 

  		





  10
  
  
    
FORMAT = '%(asctime)s %(levelname)s: %(message)s'


  		





  11
  
  
    
logging.basicConfig(format=FORMAT)


  		





  
  10
  
    
import os


  		





  
  11
  
    

  		





  
  12
  
    
cwd = os.getcwd()


  		





  
  13
  
    

  		





  
  14
  
    
LOG_FILENAME = os.path.join(cwd, 'log/celery_jobs.log')


  		





  
  15
  
    

  		





  
  16
  
    
#FORMAT = '%(asctime)s %(levelname)s: %(message)s'


  		





  
  17
  
    
#logging.basicConfig(format=FORMAT)


  		





  
  18
  
    
formatter = logging.Formatter('%(asctime)s %(levelname)s: %(message)s')


  		





  
  19
  
    

  		





  12
  20
  
    
logger = logging.getLogger(__name__)


  		





  13
  21
  
    
logger.setLevel(logging.DEBUG)


  		





  
  22
  
    
handler = logging.FileHandler(LOG_FILENAME)


  		





  
  23
  
    
handler.setFormatter(formatter)


  		





  
  24
  
    
logger.addHandler(handler)


  		





  
  25
  
    

  		





  14
  26
  
    

  		





  15
  27
  
    
@task


  		





  16
  28
  
    
def add(route, callback=None):


  		





  ......




  112
  124
  
    
        elif route.has_expired() and (route.status == 'ADMININACTIVE' or route.status == 'INACTIVE'):


  		





  113
  125
  
    
            route.status = 'EXPIRED'


  		





  114
  126
  
    
            route.response = 'Rule Expired'


  		





  
  127
  
    
            logger.info('Expiring route %s' %route.name)


  		





  115
  128
  
    
            route.save()


  		





  116
  129
  
    
        else:


  		





  117
  130
  
    
            if route.status != 'EXPIRED':


  		












Also available in:
  Unified diff