Flush buffered init logs through IPC and mark the channel as ready. Called once the ``server-started`` handshake is complete so the functions runtime will accept ``log`` messages.
()
| 326 | |
| 327 | |
| 328 | def _flush_init_log_buf() -> None: |
| 329 | """Flush buffered init logs through IPC and mark the channel as ready. |
| 330 | |
| 331 | Called once the ``server-started`` handshake is complete so the functions |
| 332 | runtime will accept ``log`` messages. |
| 333 | """ |
| 334 | global _ipc_ready, _init_log_buf_bytes # noqa: PLW0603 |
| 335 | _ipc_ready = True |
| 336 | for m in _init_log_buf: |
| 337 | send_message(m) |
| 338 | _init_log_buf.clear() |
| 339 | _init_log_buf_bytes = 0 |
| 340 | |
| 341 | |
| 342 | def flush_init_log_buf_to_stderr() -> None: |
no test coverage detected