Revision 4008c8ed lib/jqueue.py

b/lib/jqueue.py
945 945 

  		





  946
  946
  
    
      status = job.CalcStatus()


  		





  947
  947
  
    

  		





  948
  
  
    
      if status in (constants.JOB_STATUS_QUEUED, ):


  		





  
  948
  
    
      if status in (constants.JOB_STATUS_QUEUED,


  		





  
  949
  
    
                    constants.JOB_STATUS_WAITLOCK):


  		





  949
  950
  
    
        self._wpool.AddTask((job, ))


  		





  950
  951
  
    

  		





  951
  952
  
    
      elif status in (constants.JOB_STATUS_RUNNING,


  		





  952
  
  
    
                      constants.JOB_STATUS_WAITLOCK,


  		





  953
  953
  
    
                      constants.JOB_STATUS_CANCELING):


  		





  954
  954
  
    
        logging.warning("Unfinished job %s found: %s", job.id, job)


  		





  955
  955
  
    
        job.MarkUnfinishedOps(constants.OP_STATUS_ERROR,


  		












Also available in:
  Unified diff