File tree Expand file tree Collapse file tree 1 file changed +10
-3
lines changed Expand file tree Collapse file tree 1 file changed +10
-3
lines changed Original file line number Diff line number Diff line change @@ -68,13 +68,20 @@ def decrement_server_load(request: Request):
68
68
def load_aware_call (func ):
69
69
70
70
@functools .wraps (func )
71
- async def wrapper (* args , raw_request : Request , ** kwargs ):
71
+ async def wrapper (* args , ** kwargs ):
72
+ raw_request = kwargs .get ("raw_request" ,
73
+ args [1 ] if len (args ) > 1 else None )
74
+
75
+ if raw_request is None :
76
+ raise ValueError (
77
+ "raw_request required when server load tracking is enabled" )
78
+
72
79
if not raw_request .app .state .enable_server_load_tracking :
73
- return await func (* args , raw_request = raw_request , ** kwargs )
80
+ return await func (* args , ** kwargs )
74
81
75
82
raw_request .app .state .server_load_metrics += 1
76
83
try :
77
- response = await func (* args , raw_request = raw_request , ** kwargs )
84
+ response = await func (* args , ** kwargs )
78
85
except Exception :
79
86
raw_request .app .state .server_load_metrics -= 1
80
87
raise
You can’t perform that action at this time.
0 commit comments