顺序提交一批请求,收集所有返回结果。
(engine, payloads: List[dict])
| 96 | |
| 97 | |
| 98 | def _submit_batch(engine, payloads: List[dict]) -> List[dict]: |
| 99 | """顺序提交一批请求,收集所有返回结果。""" |
| 100 | results = [] |
| 101 | for payload in payloads: |
| 102 | result = engine.submit_request(dict(payload)) |
| 103 | results.append(result) |
| 104 | return results |
| 105 | |
| 106 | |
| 107 | def _submit_concurrent(engine, payload: dict, n_threads: int, per_thread: int): |
nothing calls this directly
no test coverage detected