Revision 4008c8ed

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