async Queue get blocks when empty, so don't handle empty exception

This commit is contained in:
Dave Pearson
2023-05-17 12:29:03 +01:00
parent 82924c2d7c
commit a42250daa3

View File

@@ -1,6 +1,6 @@
from __future__ import annotations from __future__ import annotations
from asyncio import Queue, QueueEmpty from asyncio import Queue
from dataclasses import dataclass from dataclasses import dataclass
from pathlib import Path from pathlib import Path
from typing import ClassVar, Iterable, Iterator from typing import ClassVar, Iterable, Iterator
@@ -293,10 +293,7 @@ class DirectoryTree(Tree[DirEntry]):
"""Background loading queue processor.""" """Background loading queue processor."""
worker = get_current_worker() worker = get_current_worker()
while not worker.is_cancelled: while not worker.is_cancelled:
try: self._load_directory(await self._to_load.get())
self._load_directory(await self._to_load.get())
except QueueEmpty:
pass
def _on_tree_node_expanded(self, event: Tree.NodeExpanded) -> None: def _on_tree_node_expanded(self, event: Tree.NodeExpanded) -> None:
event.stop() event.stop()