(request)
| 179 | requests = [tool_payload(i, payload_bytes, turn) for i in range(count)] |
| 180 | |
| 181 | def append(request): |
| 182 | started = time.perf_counter_ns() |
| 183 | if config["transport"] == "rpc": |
| 184 | response = fixture.rpc(request)["ProvenanceEnvelopesCommitted"] |
| 185 | acks = response["acknowledgements"] |
| 186 | else: |
| 187 | fixture.hook("post-tool", request) |
| 188 | acks = [] |
| 189 | return (time.perf_counter_ns() - started) / 1e6, acks |
| 190 | |
| 191 | # Pool creation is outside the timer; lazy thread startup is included in wall time. |
| 192 | with concurrent.futures.ThreadPoolExecutor(max_workers=config["workers"]) as pool: |
no test coverage detected