(event_to_signal: Event)
| 505 | completion_event = Event() |
| 506 | |
| 507 | def playwright_stream_factory(event_to_signal: Event): |
| 508 | return gen_sse_from_playwright( |
| 509 | page, |
| 510 | logger, |
| 511 | req_id, |
| 512 | current_ai_studio_model_id or MODEL_NAME, |
| 513 | request, |
| 514 | check_client_disconnected, |
| 515 | event_to_signal, |
| 516 | prompt_length=prompt_length, |
| 517 | timeout=timeout, |
| 518 | ) |
| 519 | |
| 520 | resilient_gen = resilient_stream_generator( |
| 521 | req_id, |
nothing calls this directly
no test coverage detected