tsqueue

#!/usr/bin/env bash
set -euo pipefail

# shellcheck disable=SC1091
source "$(dirname "$0")/tiny_sched_common.sh"
load_config

printf "%8s %-20s %-10s %6s %6s %s\n" JOBID NAME STATE CPUS TIME SUBMIT

print_dir() {
  local dir=$1 state=$2 f
  for f in "$dir"/*.meta; do
    [ -f "$f" ] || continue
    local jid name cpus submit start end now dur atid jid_disp shown_state
    jid=$(meta_get "$f" job_id || echo 0)
    name=$(meta_get "$f" job_name || echo job$jid)
    cpus=$(meta_get "$f" req_cpus || echo 1)
    submit=$(meta_get "$f" submit_ts || echo "")
    start=$(meta_get "$f" start_time || echo "")
    end=$(meta_get "$f" end_time || echo "")
    now=$(date +%s)
    dur=0
    if [ -n "$start" ]; then
      if [ -n "$end" ] && [ "$end" -gt 0 ]; then
        dur=$(( end - start ))
      else
        dur=$(( now - start ))
      fi
    fi
    atid=$(meta_get "$f" array_task_id || echo "")
    if [ -n "$atid" ]; then jid_disp="${jid}_${atid}"; else jid_disp="$jid"; fi
    shown_state=$state
    # If meta file has explicit state (may have changed after directory move), prefer it
    meta_state=$(meta_get "$f" state || echo "$state")
    if [ -n "$meta_state" ]; then shown_state=$meta_state; fi
    printf "%8s %-20s %-10s %6s %6s %s\n" "$jid_disp" "$name" "$shown_state" "$cpus" "$dur" "$submit"
  done
}

print_dir "$TJS_PENDING_DIR" PENDING
print_dir "$TJS_RUNNING_DIR" RUNNING
print_dir "$TJS_COMPLETED_DIR" COMPLETED
print_dir "$TJS_FAILED_DIR" FAILED