(request: Request)
| 382 | |
| 383 | @app.post("/v1/pause") |
| 384 | async def pause(request: Request) -> Response: |
| 385 | # todo: support wait_for_inflight_requests(default False), clear_cache(default True) arguments |
| 386 | request_id = f"control-{uuid.uuid4()}" |
| 387 | control_request = ControlRequest(request_id, "pause") |
| 388 | control_response = await app.state.engine_client.run_control_method(control_request) |
| 389 | return control_response.to_api_json_response() |
| 390 | |
| 391 | |
| 392 | @app.post("/v1/resume") |
nothing calls this directly
no test coverage detected