(self)
| 147 | return not self._has_errors |
| 148 | |
| 149 | def _next(self): |
| 150 | for i in range(len(self._pending)): |
| 151 | item = self._pending[i] |
| 152 | if item.permutations == 0: |
| 153 | if item.src not in self._permutations: |
| 154 | self._permutations[item.src] = item.get_permutations() |
| 155 | item.permutations = self._permutations[item.src] |
| 156 | |
| 157 | with self._mutex: |
| 158 | if self._thread_count == 0 or item.permutations + self._thread_count <= self.max_thread_count: |
| 159 | return self._pending.pop(i) |
| 160 | |
| 161 | return None |
| 162 | |
| 163 | def _worker(self, item): |
| 164 | logging.info(f'Building {item}') |
no test coverage detected