def _check_processing(self):
        now = time.time()
        self.mutex.acquire()
        while self.processing.qsize() and self.processing.top and now < self.processing.top.exetime:
            task = self.processing.get_nowait()
            if task.taskid is None:
                continue
            task.exetime = 0
            self.priority_queue.put(task)
            logger.info("processing: retry %s", task.taskid)
        self.mutex.release()
dataset/ETHPy150Open binux/pyspider/pyspider/scheduler/task_queue.py/TaskQueue._check_processing/swapped operands of `<`