(self)
| 117 | return jobstatus |
| 118 | |
| 119 | def run(self): |
| 120 | while self.inqueue.qsize() > 0: |
| 121 | job = self.inqueue.get() |
| 122 | if isinstance(job, jobStatus): |
| 123 | jobstatus = self.queryAsynJob(job) |
| 124 | else: |
| 125 | jobstatus = self.executeCmd(job) |
| 126 | |
| 127 | self.output.put(jobstatus) |
| 128 | self.inqueue.task_done() |
| 129 | |
| 130 | |
| 131 | class jobThread(threading.Thread): |
nothing calls this directly
no test coverage detected