(self, req_group: List[Req])
| 27 | self.router_max_new_token_len = args.router_max_new_token_len |
| 28 | |
| 29 | def extend(self, req_group: List[Req]): |
| 30 | for req in req_group: |
| 31 | req.sample_params.suggested_dp_index = self.dp_index |
| 32 | self.waiting_req_list.extend(req_group) |
| 33 | return |
| 34 | |
| 35 | def get_wait_req_num(self): |
| 36 | return len(self.waiting_req_list) |
no outgoing calls
no test coverage detected