Live TUI monitor for deferred jobs — deferred

Displays a live-updating terminal dashboard for a parade_deferred object. Adapts to the backend: SLURM gets a rich per-chunk table with metrics and log tailing; local/crew/mirai get a progress bar with resolved/unresolved counts.

Usage

deferred_top(
  d,
  refresh = 3,
  nlog = 20,
  clear = TRUE,
  once = FALSE,
  max_rows = 20L
)

Arguments

d: A parade_deferred object (from submit())
refresh: Seconds between display updates (default 3)
nlog: Number of log lines to show (SLURM only, default 20)
clear: Clear screen between updates (default TRUE)
once: Single-shot mode: display once and return (default FALSE)
max_rows: Maximum chunk rows to display (default 20). Remaining chunks are summarised in a single line.

Value

The input deferred object (invisibly)

Details

Progress is tracked via index file counting (index-NNNN.rds in d$index_dir), which works across all backends.

Examples

# \donttest{
grid <- data.frame(x = 1:6, g = rep(1:3, 2))
fl <- flow(grid) |>
  stage("s", function(x) { Sys.sleep(1); list(y = x^2) },
         schema = returns(y = dbl())) |>
  distribute(dist_local(by = "g"))
d <- submit(fl)
deferred_top(d, refresh = 1, once = TRUE)
#> parade::deferred_top  -
#> 
#> Run: 783950b5  Backend: local  Submitted: 2026-03-30 16:38:41.769472
#> Elapsed: 0:00:03  By: g  Mode: index
#> Stages: s
#> 
#> Progress [........................]    0%  (0/3 chunks)
#>   total=3  resolved=3  unresolved=0
#> 
#> (All chunks completed)
#> 
# }