Function waitForTerminal

cli/scheduler_command.go:634–653

waitForTerminal polls the remote client until the job reaches a terminal state or ctx is cancelled.

(ctx context.Context, c *scheduler.RemoteClient, id scheduler.JobID)

// waitForTerminal polls the remote client until the job reaches a
// terminal state or ctx is cancelled.
func waitForTerminal(ctx context.Context, c *scheduler.RemoteClient, id scheduler.JobID) {
	t := time.NewTicker(500 * time.Millisecond)
	defer t.Stop()
	for {
		select {
		case <-ctx.Done():
			fmt.Println(colorize("  ⚠ "+i18n.T("scheduler.wait_ctx_cancelled"), ColorYellow))
			return
		case <-t.C:
			j, err := c.Query(ctx, id)
			if err != nil {
				continue
			}
			if j.Status.IsTerminal() {
				fmt.Println(colorize(fmt.Sprintf("  ✔ job %s → %s", id, j.Status), ColorGreen))
				return
			}
		}
	}
}

// ─── Argument parsers ─────────────────────────────────────────