File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -225,7 +225,7 @@ def has_requests(self):
225
225
return False
226
226
return not self .requests .empty ()
227
227
228
- async def get_all_requests (self ) -> Dict [RequestType , Request ]:
228
+ async def get_all_requests (self ) -> Dict [RequestType , List [ Request ] ]:
229
229
"""Get all requests in current queue."""
230
230
num_reqs = self .requests .qsize ()
231
231
reqs : ReqList = []
@@ -247,7 +247,7 @@ def __proc_reqs(elem):
247
247
__proc_reqs (elem )
248
248
249
249
# gather requests
250
- reqs_by_type : Dict [RequestType , Request ] = dict ((t , []) for t in RequestType )
250
+ reqs_by_type : Dict [RequestType , List [ Request ] ] = dict ((t , []) for t in RequestType )
251
251
for req in reqs :
252
252
reqs_by_type [req .type ].append (req )
253
253
return reqs_by_type
@@ -300,11 +300,10 @@ def _log_reqs(reqs: ReqList):
300
300
301
301
# handle requests
302
302
for req_type in self .request_priority :
303
- # request exists
304
- if req_type not in reqs_by_type or len ( reqs_by_type ) == 0 :
303
+ reqs : ReqList = reqs_by_type . get ( req_type , [])
304
+ if not reqs :
305
305
continue
306
306
307
- reqs : ReqList = reqs_by_type [req_type ]
308
307
_log_reqs (reqs )
309
308
self .process_request (req_type , reqs , ** kwargs )
310
309
You can’t perform that action at this time.
0 commit comments