File tree Expand file tree Collapse file tree 2 files changed +0
-8
lines changed
Expand file tree Collapse file tree 2 files changed +0
-8
lines changed Original file line number Diff line number Diff line change @@ -2825,8 +2825,6 @@ async def run(self) -> T:
28252825 and not self ._session ._transaction .has_completed_command
28262826 ):
28272827 self ._session ._transaction .set_starting ()
2828- else :
2829- raise
28302828
28312829 # Specialized catch on write operation
28322830 if not self ._is_read :
@@ -2867,8 +2865,6 @@ async def run(self) -> T:
28672865 and not self ._session ._transaction .has_completed_command
28682866 ):
28692867 self ._session ._transaction .set_starting ()
2870- else :
2871- raise
28722868
28732869 if self ._client .topology_description .topology_type == TOPOLOGY_TYPE .Sharded :
28742870 self ._deprioritized_servers .append (self ._server )
Original file line number Diff line number Diff line change @@ -2815,8 +2815,6 @@ def run(self) -> T:
28152815 and not self ._session ._transaction .has_completed_command
28162816 ):
28172817 self ._session ._transaction .set_starting ()
2818- else :
2819- raise
28202818
28212819 # Specialized catch on write operation
28222820 if not self ._is_read :
@@ -2857,8 +2855,6 @@ def run(self) -> T:
28572855 and not self ._session ._transaction .has_completed_command
28582856 ):
28592857 self ._session ._transaction .set_starting ()
2860- else :
2861- raise
28622858
28632859 if self ._client .topology_description .topology_type == TOPOLOGY_TYPE .Sharded :
28642860 self ._deprioritized_servers .append (self ._server )
You can’t perform that action at this time.
0 commit comments