File tree Expand file tree Collapse file tree 4 files changed +0
-8
lines changed Expand file tree Collapse file tree 4 files changed +0
-8
lines changed Original file line number Diff line number Diff line change @@ -256,8 +256,6 @@ async def _check_server(self) -> ServerDescription:
256
256
start = time .monotonic ()
257
257
try :
258
258
return await self ._check_once ()
259
- except asyncio .CancelledError :
260
- raise
261
259
except ReferenceError :
262
260
raise
263
261
except Exception as error :
Original file line number Diff line number Diff line change @@ -503,8 +503,6 @@ async def _process_change(
503
503
504
504
self ._description = new_td
505
505
await self ._update_servers ()
506
- # TODO: Verify that app errors update the $clusterTime.
507
- # self._receive_cluster_time_no_lock(server_description.cluster_time)
508
506
509
507
if self ._publish_tp and not suppress_event :
510
508
assert self ._events is not None
Original file line number Diff line number Diff line change @@ -254,8 +254,6 @@ def _check_server(self) -> ServerDescription:
254
254
start = time .monotonic ()
255
255
try :
256
256
return self ._check_once ()
257
- except asyncio .CancelledError :
258
- raise
259
257
except ReferenceError :
260
258
raise
261
259
except Exception as error :
Original file line number Diff line number Diff line change @@ -503,8 +503,6 @@ def _process_change(
503
503
504
504
self ._description = new_td
505
505
self ._update_servers ()
506
- # TODO: Verify that app errors update the $clusterTime.
507
- # self._receive_cluster_time_no_lock(server_description.cluster_time)
508
506
509
507
if self ._publish_tp and not suppress_event :
510
508
assert self ._events is not None
You can’t perform that action at this time.
0 commit comments