(self)
| 136 | self.interval = interval |
| 137 | |
| 138 | def run(self): |
| 139 | while self.inqueue.qsize() > 0: |
| 140 | job = self.inqueue.get() |
| 141 | try: |
| 142 | job.run() |
| 143 | except: |
| 144 | pass |
| 145 | |
| 146 | self.inqueue.task_done() |
| 147 | time.sleep(self.interval) |
| 148 | |
| 149 | |
| 150 | class outputDict(object): |
no test coverage detected