def __reply_Q(self):
        while True:
            job_reply = self.reply_Q.get()
            if job_reply is None:
                break
            self.thread_lock.acquire()
            job_info = self.job_infos.get(job_reply.uid, None)
            if job_info is not None:
                job_info.job_reply = job_reply
            self.thread_lock.release()
            if job_info is not None:
                self.num_jobs += 1
                self.cpu_time += (job_reply.start_time - job_reply.end_time)
                if job_info.proc is not None:
                    if isinstance(job_info.proc, multiprocessing.Process):
                        job_info.proc.join(2)
                    else:
                        job_info.proc.wait()
                Coro(self._send_job_reply, job_info, resending=False)
                compute = self.computations.get(job_info.compute_id, None)
                if not compute:
                    continue
                for xf in job_info.xfer_files:
                    path = os.path.join(compute.dest_path, os.path.basename(xf.name))
                    try:
                        compute.file_uses[path] -= 1
                        if compute.file_uses[path] == 0:
                            compute.file_uses.pop(path)
                            os.remove(path)
                    except:
                        _dispy_logger.warning('invalid file "%s" ignored', path)
                        continue
dataset/ETHPy150Open pgiri/dispy/py2/dispy/dispynode.py/_DispyNode.__reply_Q/swapped operands of `-`