nvm moved it here
This commit is contained in:
+1
-1
@@ -175,6 +175,7 @@ class Backend:
|
|||||||
|
|
||||||
acquired = False
|
acquired = False
|
||||||
try:
|
try:
|
||||||
|
self.metrics._request_start(request_metrics)
|
||||||
if self.allow_parallel_requests is False:
|
if self.allow_parallel_requests is False:
|
||||||
log.debug(f"Waiting to aquire Sem for reqnum:{request_metrics.reqnum}")
|
log.debug(f"Waiting to aquire Sem for reqnum:{request_metrics.reqnum}")
|
||||||
await self.sem.acquire()
|
await self.sem.acquire()
|
||||||
@@ -184,7 +185,6 @@ class Backend:
|
|||||||
)
|
)
|
||||||
else:
|
else:
|
||||||
log.debug(f"Starting request for reqnum:{request_metrics.reqnum}")
|
log.debug(f"Starting request for reqnum:{request_metrics.reqnum}")
|
||||||
self.metrics._request_start(request_metrics)
|
|
||||||
done, pending = await wait(
|
done, pending = await wait(
|
||||||
[
|
[
|
||||||
create_task(make_request()),
|
create_task(make_request()),
|
||||||
|
|||||||
Reference in New Issue
Block a user