We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a98ff0d commit fd6c7d2Copy full SHA for fd6c7d2
pyproject.toml
@@ -40,7 +40,7 @@ tests = [
40
"pytest-sugar",
41
"pytest-cov>=4.1.0",
42
"pytest-mock",
43
- "mypy==1.5.1",
+ "mypy==1.7.1",
44
"pytest-benchmark",
45
"reflink",
46
]
src/dvc_objects/executors.py
@@ -5,7 +5,6 @@
5
from itertools import islice
6
from typing import (
7
Any,
8
- Awaitable,
9
Callable,
10
Coroutine,
11
Dict,
@@ -117,7 +116,7 @@ async def batch_coros( # noqa: C901
117
116
batch_size = len(coros)
118
assert batch_size > 0
119
120
- def create_taskset(n: int) -> Dict[Awaitable, int]:
+ def create_taskset(n: int) -> Dict[asyncio.Task, int]:
121
return {asyncio.create_task(coro): i for i, coro in islice(it, n)}
122
123
it: Iterator[Tuple[int, Coroutine]] = enumerate(coros)
0 commit comments