doesn't have a remove() method until python-2.5.
svn path=/main/trunk/; revision=10984
self._add_task = self._task_queues.prefetch.add
self._prefetchers = weakref.WeakValueDictionary()
- self._pkg_queue = deque()
+ self._pkg_queue = []
self._completed_tasks = set()
self._failed_pkgs = []
self._failed_fetches = []
self._main_loop()
finally:
# discard remaining packages if necessary
- pkg_queue.clear()
+ del pkg_queue[:]
self._completed_tasks.clear()
self._digraph = None
self._task_queues.prefetch.clear()
def _choose_pkg(self):
if self._max_jobs < 2:
- return self._pkg_queue.popleft()
+ return self._pkg_queue.pop(0)
self._prune_digraph()