File tree Expand file tree Collapse file tree 4 files changed +10
-4
lines changed Expand file tree Collapse file tree 4 files changed +10
-4
lines changed Original file line number Diff line number Diff line change 17
17
18
18
import asyncio
19
19
import builtins
20
+ import functools
20
21
import random
21
22
import socket
22
23
import sys
41
42
42
43
43
44
def _handle_reauth (func : F ) -> F :
45
+ @functools .wraps (func )
44
46
async def inner (* args : Any , ** kwargs : Any ) -> Any :
45
47
no_reauth = kwargs .pop ("no_reauth" , False )
46
48
from pymongo .asynchronous .pool import AsyncConnection
@@ -88,6 +90,7 @@ async def _backoff(
88
90
89
91
90
92
def _retry_overload (func : F ) -> F :
93
+ @functools .wraps (func )
91
94
async def inner (* args : Any , ** kwargs : Any ) -> Any :
92
95
no_retry = kwargs .pop ("no_retry" , False )
93
96
attempt = 0
Original file line number Diff line number Diff line change 17
17
18
18
import asyncio
19
19
import builtins
20
+ import functools
20
21
import random
21
22
import socket
22
23
import sys
41
42
42
43
43
44
def _handle_reauth (func : F ) -> F :
45
+ @functools .wraps (func )
44
46
def inner (* args : Any , ** kwargs : Any ) -> Any :
45
47
no_reauth = kwargs .pop ("no_reauth" , False )
46
48
from pymongo .message import _BulkWriteContext
@@ -88,6 +90,7 @@ def _backoff(
88
90
89
91
90
92
def _retry_overload (func : F ) -> F :
93
+ @functools .wraps (func )
91
94
def inner (* args : Any , ** kwargs : Any ) -> Any :
92
95
no_retry = kwargs .pop ("no_retry" , False )
93
96
attempt = 0
Original file line number Diff line number Diff line change 12
12
# See the License for the specific language governing permissions and
13
13
# limitations under the License.
14
14
15
- """Test the CSOT unified spec tests ."""
15
+ """Test Client Backpressure spec."""
16
16
from __future__ import annotations
17
17
18
18
import sys
38
38
}
39
39
40
40
41
- class TestCSOT (AsyncIntegrationTest ):
41
+ class TestBackpressure (AsyncIntegrationTest ):
42
42
RUN_ON_LOAD_BALANCER = True
43
43
44
44
@async_client_context .require_failCommand_appName
Original file line number Diff line number Diff line change 12
12
# See the License for the specific language governing permissions and
13
13
# limitations under the License.
14
14
15
- """Test the CSOT unified spec tests ."""
15
+ """Test Client Backpressure spec."""
16
16
from __future__ import annotations
17
17
18
18
import sys
38
38
}
39
39
40
40
41
- class TestCSOT (IntegrationTest ):
41
+ class TestBackpressure (IntegrationTest ):
42
42
RUN_ON_LOAD_BALANCER = True
43
43
44
44
@client_context .require_failCommand_appName
You can’t perform that action at this time.
0 commit comments