Function maybeRunDueJobs

src/index.js:1237–1361

(directory, client, sessionID, options = {})

    // active-run guard, recover instead of waiting for another manual command.
    if ((live.type === "busy" || live.type === "retry") && options.recoverStaleActive !== false && staleActiveRun(sessionID)) {
      sessionStatuses.set(sessionID, "idle")
      sessionStatusSeenAt.set(sessionID, now())
      return "idle"
    }
    sessionStatuses.set(sessionID, live.type)
    sessionStatusSeenAt.set(sessionID, now())
    return live.type
  }

  const fallback = activeRuns.has(sessionID) && !staleActiveRun(sessionID) ? "busy" : "idle"
  sessionStatuses.set(sessionID, fallback)
  sessionStatusSeenAt.set(sessionID, now())
  return fallback
}

async function sessionIsIdle(client, sessionID, directory, options = {}) {
  return await sessionStatusType(client, sessionID, directory, options) === "idle"
}

function scheduleIdleWork(directory, client, sessionID) {
  const previous = idleTimers.get(sessionID)
  if (previous) clearTimeout(previous)
  const timer = setTimeout(() => {
    idleTimers.delete(sessionID)
    Promise.resolve()
      .then(async () => {
        if (!await sessionIsIdle(client, sessionID, directory)) {
          await scheduleDueWork(directory, client, sessionID, BUSY_RETRY_MS)
          return
        }
        await finalizeActiveRun(directory, client, sessionID)
        if (!await sessionIsIdle(client, sessionID, directory)) {
          await scheduleDueWork(directory, client, sessionID, BUSY_RETRY_MS)
          return
        }
        await maybeRunDueJobs(directory, client, sessionID)
      })
      .catch((error) => {
        toast(client, `Loop idle handler failed: ${sdkErrorMessage(error)}`, "error").catch(() => {})
        appendLoopLog(directory, "idle-error", { sessionID, error: sdkErrorMessage(error) }).catch(() => {})
      })
  }, IDLE_DEBOUNCE_MS)
  idleTimers.set(sessionID, timer)
}

function jobDueAt(job, current = now()) {
  if (isGoalJob(job) && ["completed", "blocked", "cleared"].includes(job.goalStatus)) return Infinity
  if (!job.enabled || job.paused) return Infinity
  if (job.maxRuns > 0 && (job.runCount || 0) >= job.maxRuns) return Infinity
  if (job.watchPaths?.length) return Infinity
  const created = Date.parse(job.createdAt || new Date().toISOString())
  if (job.maxRuntimeMs > 0 && current - created >= job.maxRuntimeMs) return current
  if (job.intervalMs === 0) return current
  if (!job.lastRunAt) return current
  return job.lastRunAt + (job.intervalMs || 0)
}

function nextDueDelay(state) {