diff --git a/codex_retry_gateway_tui.py b/codex_retry_gateway_tui.py index 75079d7..a74031b 100644 --- a/codex_retry_gateway_tui.py +++ b/codex_retry_gateway_tui.py @@ -1571,12 +1571,15 @@ def print_once(snapshot: dict[str, Any], filter_text: str = "") -> None: print(status_summary(status_payload, status_error)) print("requests") for row in snapshot.get("requests") or []: - print( - f"{row['seq']:>6} {short_text(primary_request_id(row), 16):<16} {short_text(row.get('thread_id'), 14):<14} {status_symbol(row)} {row.get('status_code') or '-':<4} " - f"{short_text(row['path'], 20):<20} {short_text(row['model'] or row['requested_model'] or row['forwarded_model'], 16):<16} " - f"{short_text(request_usage_summary(row), 26):<26} {request_chunk_progress(row):<14} {format_ms(row['duration_ms']):<8} {request_updated_elapsed(row):<8} " - f"{format_count(row['upstream_attempt_count'] or 0):<4} {short_text(row['error'], 30)}" - ) + try: + print( + f"{row['seq']:>6} {short_text(primary_request_id(row), 16):<16} {short_text(row.get('thread_id'), 14):<14} {status_symbol(row)} {row.get('status_code') or '-':<4} " + f"{short_text(row['path'], 20):<20} {short_text(row['model'] or row['requested_model'] or row['forwarded_model'], 16):<16} " + f"{short_text(request_usage_summary(row), 26):<26} {request_chunk_progress(row):<14} {format_ms(row['duration_ms']):<8} {request_updated_elapsed(row):<8} " + f"{format_count(row['upstream_attempt_count'] or 0):<4} {short_text(row['error'], 30)}" + ) + except BrokenPipeError: + return def main(argv: list[str] | None = None) -> int: