(self)
| 71 | time.sleep(0.05) |
| 72 | |
| 73 | def _update_progress(self): |
| 74 | if config.PROGRESSBAR_DISABLED: |
| 75 | return |
| 76 | |
| 77 | if self.q is not None: |
| 78 | queue_items = sum(1 for x in list(self.q) if x is not Wait) |
| 79 | |
| 80 | total = self.total + queue_items |
| 81 | else: |
| 82 | total = self.total |
| 83 | |
| 84 | self.pg.total = total |
| 85 | self.pg.n = self.completed |
| 86 | self.pg.update(0) |
| 87 | |
| 88 | |
| 89 | class AsyncQueue: |
no outgoing calls
no test coverage detected