File tree Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Expand file tree Collapse file tree 3 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -1141,7 +1141,7 @@ def __init__(
1141
1141
"""
1142
1142
if not isinstance (root_collection , AsyncCollection ):
1143
1143
raise TypeError (
1144
- f"root_collection must be an instance of AsyncCollection[Any] , not { type (root_collection )} "
1144
+ f"root_collection must be an instance of AsyncCollection, not { type (root_collection )} "
1145
1145
)
1146
1146
1147
1147
if not root_collection .write_concern .acknowledged :
@@ -1494,7 +1494,7 @@ def __init__(
1494
1494
"""
1495
1495
if not isinstance (root_collection , AsyncCollection ):
1496
1496
raise TypeError (
1497
- f"root_collection must be an instance of AsyncCollection[Any] , not { type (root_collection )} "
1497
+ f"root_collection must be an instance of AsyncCollection, not { type (root_collection )} "
1498
1498
)
1499
1499
_disallow_transactions (session )
1500
1500
Original file line number Diff line number Diff line change @@ -1133,7 +1133,7 @@ def __init__(
1133
1133
"""
1134
1134
if not isinstance (root_collection , Collection ):
1135
1135
raise TypeError (
1136
- f"root_collection must be an instance of Collection[Any] , not { type (root_collection )} "
1136
+ f"root_collection must be an instance of Collection, not { type (root_collection )} "
1137
1137
)
1138
1138
1139
1139
if not root_collection .write_concern .acknowledged :
@@ -1482,7 +1482,7 @@ def __init__(
1482
1482
"""
1483
1483
if not isinstance (root_collection , Collection ):
1484
1484
raise TypeError (
1485
- f"root_collection must be an instance of Collection[Any] , not { type (root_collection )} "
1485
+ f"root_collection must be an instance of Collection, not { type (root_collection )} "
1486
1486
)
1487
1487
_disallow_transactions (session )
1488
1488
Original file line number Diff line number Diff line change @@ -613,7 +613,7 @@ def buffer_updated(self, nbytes: int) -> None:
613
613
result = self ._pending_messages .popleft ()
614
614
else :
615
615
result = asyncio .get_running_loop ().create_future ()
616
- # Future[Any] has been cancelled, close this connection
616
+ # Future has been cancelled, close this connection
617
617
if result .done ():
618
618
self .close (None )
619
619
return
You can’t perform that action at this time.
0 commit comments