Commit e2a707a
Eric Bower
·
2026-05-16 11:18:50 -0400 EDT
parent 9d1e6dd
chore(wait): continue polling every 1s but only print waiting status every 5s
1 files changed,
+10,
-5
+10,
-5
| ... | ... | @@ -1472,6 +1472,7 @@ fn wait(cfg: *Cfg, matchers: std.ArrayList(SessionMatch)) !void { | |
| 1472 | 1472 | var zero_match_iters: u32 = 0; | |
| 1473 | 1473 | ||
| 1474 | 1474 | var agg_exit_code: u8 = 0; | |
| 1475 | + | var last_print: i64 = 0; | |
| 1475 | 1476 | while (true) { | |
| 1476 | 1477 | agg_exit_code = 0; | |
| 1477 | 1478 | var sessions = try util.get_session_entries(alloc, cfg.socket_dir); |
| ... | ... | @@ -1506,11 +1507,15 @@ fn wait(cfg: *Cfg, matchers: std.ArrayList(SessionMatch)) !void { | |
| 1506 | 1507 | continue; | |
| 1507 | 1508 | } | |
| 1508 | 1509 | if (session.task_ended_at == 0) { | |
| 1509 | - | try stdout.print( | |
| 1510 | - | "[{d}] waiting task={s}\n", | |
| 1511 | - | .{ std.time.timestamp(), session.name }, | |
| 1512 | - | ); | |
| 1513 | - | try stdout.flush(); | |
| 1510 | + | const now = std.time.timestamp(); | |
| 1511 | + | if (now - last_print >= 5) { | |
| 1512 | + | try stdout.print( | |
| 1513 | + | "[{d}] waiting task={s}\n", | |
| 1514 | + | .{ now, session.name }, | |
| 1515 | + | ); | |
| 1516 | + | try stdout.flush(); | |
| 1517 | + | last_print = now; | |
| 1518 | + | } | |
| 1514 | 1519 | continue; | |
| 1515 | 1520 | } | |
| 1516 | 1521 | try stdout.print( |