|
Lines 9544-9549
Link Here
|
| 9544 |
remaining, state_change = self._schedule_tasks_imp() |
9544 |
remaining, state_change = self._schedule_tasks_imp() |
| 9545 |
self._task_queues.merge.schedule() |
9545 |
self._task_queues.merge.schedule() |
| 9546 |
self._status_display.display() |
9546 |
self._status_display.display() |
|
|
9547 |
|
| 9548 |
# Cancel prefetchers if they're the only reason |
| 9549 |
# the main poll loop is still running. |
| 9550 |
if self._failed_pkgs and \ |
| 9551 |
not (self._jobs or self._task_queues.merge): |
| 9552 |
self._task_queues.fetch.clear() |
| 9553 |
|
| 9547 |
return remaining |
9554 |
return remaining |
| 9548 |
|
9555 |
|
| 9549 |
def _schedule_tasks_imp(self): |
9556 |
def _schedule_tasks_imp(self): |
