()
| 81 | if payload is None: |
| 82 | # Gracefully end the stream with a run_failed event |
| 83 | async def missing_generator() -> AsyncGenerator[str, None]: |
| 84 | yield sse_format( |
| 85 | emit_event(run_id, "run_failed", error="Unknown or expired run id") |
| 86 | ) |
| 87 | |
| 88 | return StreamingResponse(missing_generator(), headers=SSE_HEADERS) |
| 89 |
no test coverage detected