File tree Expand file tree Collapse file tree 3 files changed +4
-3
lines changed Expand file tree Collapse file tree 3 files changed +4
-3
lines changed Original file line number Diff line number Diff line change 1
1
from dataclasses import dataclass
2
- from multiprocessing import Queue
2
+ from queue import Queue
3
3
from typing import (
4
4
Generic ,
5
5
Literal ,
Original file line number Diff line number Diff line change 3
3
import time
4
4
from collections .abc import AsyncGenerator , Iterable , Iterator
5
5
from concurrent .futures import ProcessPoolExecutor
6
- from multiprocessing import Manager , Queue
6
+ from multiprocessing import Manager
7
7
from queue import Empty as QueueEmpty
8
+ from queue import Queue
8
9
from typing import (
9
10
Any ,
10
11
Generic ,
Original file line number Diff line number Diff line change 4
4
from abc import ABC , abstractmethod
5
5
from collections .abc import AsyncGenerator
6
6
from dataclasses import dataclass
7
- from multiprocessing import Queue
8
7
from queue import Empty as QueueEmpty
8
+ from queue import Queue
9
9
from typing import (
10
10
Any ,
11
11
Generic ,
You can’t perform that action at this time.
0 commit comments