diff --git a/src/webqueue2api/parser/queue.py b/src/webqueue2api/parser/queue.py index 79eff5e..60fece4 100644 --- a/src/webqueue2api/parser/queue.py +++ b/src/webqueue2api/parser/queue.py @@ -86,6 +86,8 @@ def __get_items(self, headers_only: bool) -> list: valid_items.append(item) items = multi_item_processes.starmap_async(Item, [(self.name, item, headers_only) for item in valid_items]).get() + multi_item_processes.close() + multi_item_processes.join() return items