38a145c · f8522ec · 759b590 · c7d2028
@@ -216,7 +216,8 @@
while the suspect is judged. A pull in two red batches is never in a third:
it waits for a gate of its own. Red alone, it is handed back (`[queue] red
alone`); green alone, it rides at the tail of a later batch, never its head.
While a candidate gates, the next one gates on top of it (`queue.depth`
under Settings → Capacity, `FORGE_QUEUE_DEPTH`, default 2): when the first
derived from Speed: half of it rounded up, 1 to 4, shown read-only under Settings → Capacity
and on the knobs panel): when the first
lands whole the next lands right after it, on the tree it was gated on; when
it does not, the next is formed again on main. A gate beyond a line's first
starts only on a free check slot and holds it, and two slots are always kept
@@ -296,13 +297,12 @@
bar, and the terminal's Flow command prints it as a line per app
(`flow/held.ts`, kept 5 s). Of the startable, the picker takes the order Next up shows
(#8826, `pickOrder` in `core/next_up.ts`): the owner's ranked issues by place,
then the ready order, what the owner raised again first. Small issues — a title like "A test pins …" or
"Tests: …", or a label `test`, `tests`, `tests-only` or `small` (#7571, `crew/small_share.ts`) — hold
at most `slots.smallShare` percent of the builder slots (default 30, rounded up:
2 of 5; an admin sets it on `/settings/capacity`). At the cap a small issue is
skipped, not waited on, unless the owner ranked it. The tick line's `small: 1/2`, the
Flow command's `small 1/2`, the app's row in Today on `/boards` (`small
issues: 1 of 2 slots`) and the studio's crew panel show small issues in
flight of what they may hold. An issue labelled `polish` is a small issue too, and its run is stopped past `polish.capMinutes` (default 60) with one comment saying what is left (`crew/polish_cap.ts`, `docs/features/polish-cap.md`). When nothing is startable while builder slots are free and some of the
"Tests: …", or a label `test`, `tests`, `tests-only`, `small` or `polish`
(`crew/polish_share.ts`) — hold no slots of
their own: Speed and that order bound them like any work (the small share and the polish run
cap are gone; a stored old value is ignored). Polish is held to its share of the week
(`docs/features/polish-share.md`). When nothing is startable while builder slots are free
and some of the
held are stalled, capped or parked twice, the planner is owed one pass with
that breakdown in its brief, to re-plan them into smaller, fresh issues; a
full plate and its own unanswered decline do not hold that pass, and the
@@ -500,8 +500,8 @@
each subscription's `week 38%, 5h 80%` line, and the forge usage block
The week's pace (`src/crew/week.ts`) limits only the crew's own picks: the
builds the tick assigns under the operator's name (marked `pick` on the
`issue.assigned` event). Reviews and issues a person assigned are not slowed
by it: while the pace allows any slots at all, up to `pace.floor` of them (a
capacity setting, env `FORGE_PACE_FLOOR`, default 2, 1 to 16, read on every
by it: while the pace allows any slots at all, up to `pace.floor` of them (derived from Speed:
half of it, at least 1, read-only on the capacity page and the knobs panel, read on every
pump) run at once, apart from the picks; it is also the fewest slots a fast burn
slows a repository to. At the reserve's wall (no slots) everything waits for the
reset. Not covered: feedback, check and conflict runs still count with the picks.
@@ -6,7 +6,7 @@
A bet is a name, an appetite (a share of the week), what done looks like in a fe
- **Propose.** "Ask the planner to propose bets" groups open issues in no live bet: by first label; else by the pillar an unlabelled issue holds up (later and structural issues are skipped); else by the title word most unlabelled issues share. A group of two or more becomes a proposal at 20% of the week. At most five proposals a pass; no model, so the same state gives the same proposals.
- **Notes.** Only notes written by the repo's owner or an admin count (a visitor's never join or appear). Such a note joins a proposal when its issue is held there, it names one of the group's issues as `#N`, or it shares two words with the group's name and its issues' titles; it is quoted in the journeys as "The owner's note".
- **Back.** The owner (a person who administers the repo, never an agent) backs one with a share. At most 5 run, and their shares stay within 100%.
- **Picks.** Once a repository has ever had a bet backed, builders pick only scopes of a running bet, issues the owner asked for or raised, and small fixes, polish included (held to `slots.smallShare`, #7571; a polish run is capped, see polish-cap.md). An issue in no bet does not start by itself. A repository with no bet picks as before.
- **Picks.** Once a repository has ever had a bet backed, builders pick only scopes of a running bet, issues the owner asked for or raised, and small fixes, polish included (polish held to its share of the week, see polish-share.md). An issue in no bet does not start by itself. A repository with no bet picks as before.
- **Appetite.** The budget is share × builder slots × one week of builder time, counted from the runs on the bet's scopes since it was backed. At the budget the bet stops: no extension. Its left line defaults to the open scopes; the lead rewrites it in one line; the owner re-backs, cuts or ends it (ending as done is for a stopped bet only; a running bet finishes when every scope closes).
- **Scopes** read *figuring out* (no run yet), *executing*, or *raised hand* (nothing moved for two days), or *done*.
- **Finishing.** When every scope is closed the bet is finished and its page says "This is done. Try it." with a link; the owner taps *Feels done* or *Not yet, because…* (the bet returns to stopped with that reason). `/changelog` marks each landing with its bet and filters by it (`?bet=`).
@@ -12,6 +12,12 @@
A change applies on the next pump and leaves the event the setting's own page le
## Derived from Speed
`pace.floor` (half of Speed, at least 1) and `queue.depth` (half of Speed rounded up, 1 to 4) follow Speed until someone sets them on **Settings › Capacity**; a stored value always wins and nothing stored is dropped. While they follow, the Speed row (page, terminal, MCP) says `(derived from Speed)` beside each, and the capacity page and its terminal screen mark the row `derived`. Because the floor was a fixed 2 before, an install with no stored floor now gets half its Speed (Speed 10: 5). That is a deliberate move of the default pace; set `pace.floor` to keep the old number.
`pace.floor` (half of Speed, at least 1) and `queue.depth` (half of Speed rounded up, 1 to 4)
are computed from Speed every time they are read. They show with their value, read-only, on
the knobs panel and under Settings › Capacity; a POST that tries to set one is refused with
a plain line, and `FORGE_PACE_FLOOR`, `FORGE_QUEUE_DEPTH` and any stored value are ignored.
The reserve is not one of them: it is what Weekly budget leaves (100 minus `week.use`), so it
moves with that dial, not with Speed. The small share and the polish run cap are gone; a
stored old value is ignored.
`week.use` is new; a stored or `FORGE_WEEK_USE` value is read as the budget.
@@ -1,10 +0,0 @@
# Polish cap
An issue labelled `polish` is small work, and it is capped small (#8852). A builder run on it that has gone `polish.capMinutes` of run time (default 60) is stopped, not extended. The crew's tick checks every minute, from the run's own start time.
- **Set it.** An admin changes **Run time a polish issue may take (minutes)** on `/settings/capacity`. It is read on every tick.
- **What you see.** The run ends cancelled with the summary "stopped at the N-minute polish cap", and the issue gets one comment: `Stopped at the 60-minute polish cap, not extended. Left: pull #M is open, unmerged.` or `Left: nothing landed, no pull open.` It is the run's open pull that says what is left; a polish run never produces a second comment.
- **Who says it.** The person who turned autonomy on, else the user the run acted as. If neither exists the run is left running rather than stopped silently.
- **Other work.** Only the label `polish` (any case) is capped; polish also counts as a small fix against `slots.smallShare`.
Left out: stopping a polish issue before its run starts, and reading the run's last summary into the line (a running run has none yet).
@@ -1,6 +1,6 @@
# The polish share
The percent of the last seven days' agent spend that polish may take: issues labelled `polish`, or in the small-fixes lane (`isSmall`, `src/crew/small_share.ts`). 10 to start; a whole number 0 to 50. At 0 no polish starts.
The percent of the last seven days' agent spend that polish may take: issues labelled `polish`, or in the small-fixes lane (`isSmall`, `src/crew/polish_share.ts`). 10 to start; a whole number 0 to 50. At 0 no polish starts.
- **Set it.** Web: Settings → Branch and gates → Polish share. Terminal: Autonomy, key `o`. Both go through `updateRepoSettings`, refuse anything but 0–50, and are on the settings trail, so an open week page or screen updates.
- **See it.** `/:owner/:name/week` ("Polish this week"), the terminal's week screen (last line) and the `week` MCP tool (`polish: { share, percent, polishUsd, totalUsd, under, says }`) print the same `polishWords`.
@@ -37,6 +37,9 @@
import { signinReach, signsInWithoutEdge } from "../core/accounts.ts";
import type { User } from "../core/users.ts";
import { err, ok, type Result } from "../kernel/result.ts";
/** What a refused change to a dial that follows Speed says, on every door. */
export const DERIVED_WORDS = "The pace floor and the queue depth follow Speed: change Speed (crew.concurrency) and they move with it.";
/** The six guards a caller may set by `key`: the MCP tool's enum and the terminal's `e`. */
export const SETTABLE_CAPACITY = [
  "crew.concurrency",
@@ -122,7 +125,7 @@
export function listCapacity(
      label: CAPACITY[key].label,
      help: CAPACITY[key].help,
      value: effectiveCapacity(app.db, key),
      source: followsSpeed(app.db, key) ? "derived" : storedCapacity(app.db, key) === undefined ? "default" : "setting",
      source: followsSpeed(key) ? "derived" : storedCapacity(app.db, key) === undefined ? "default" : "setting",
      default: bootDefault(app.db, key),
      env: CAPACITY[key].env,
      ...changedOf(app.db, key),
@@ -166,11 +169,12 @@
export function changeCapacity(
  value: string | null,
): Result<
  { key: CapacityKey; from: string; to: string },
  "not_found" | "no_such_setting" | "invalid_value" | "no_credential"
  "not_found" | "no_such_setting" | "invalid_value" | "no_credential" | "derived"
> {
  const who = admin(actor);
  if (!who.ok) return who;
  if (!isCapacityKey(key)) return err("no_such_setting");
  if (followsSpeed(key)) return err("derived");
  const next = value === null ? null : value.trim();
  if (next !== null && next !== "" && !validCapacity(key, next))
    return err("invalid_value");
@@ -9,12 +9,12 @@
import type { App } from "../app.ts";
import { changeCapacity } from "./capacity.ts";
import { updateRepoSettings } from "./repos.ts";
import { getRepo } from "../core/repos.ts";
import { AUTONOMY_WORDS, knobRepos, type AutonomyWord, type KnobId } from "../crew/knobs.ts";
import { validPolishShare } from "../crew/small_share.ts";
import { AUTONOMY_WORDS, DERIVED_KNOBS, knobRepos, type AutonomyWord, type KnobId } from "../crew/knobs.ts";
import { validPolishShare } from "../crew/polish_share.ts";
import { err, ok, type Result } from "../kernel/result.ts";
import type { User } from "../core/users.ts";
export type KnobError = "not_found" | "no_such_knob" | "invalid_value";
export type KnobError = "not_found" | "no_such_knob" | "invalid_value" | "derived";
const WORDS: Record<AutonomyWord, { autonomy: "off" | "autonomous"; plansNeedNod: boolean; decisionsBy: "me" | "decider" }> = {
  off: { autonomy: "off", plansNeedNod: true, decisionsBy: "me" },
@@ -31,6 +31,7 @@
export async function setKnob(
): Promise<Result<{ knob: KnobId; value: string }, KnobError>> {
  if (actor?.isAdmin !== true || actor.kind === "agent") return err("not_found");
  const v = value.trim();
  if (DERIVED_KNOBS.includes(knob)) return err("derived");
  if (knob === "speed" || knob === "budget") {
    const changed = changeCapacity(app, actor, knob === "speed" ? "crew.concurrency" : "week.use", v);
    if (!changed.ok) return err(changed.error === "not_found" ? "not_found" : "invalid_value");
@@ -74,7 +74,7 @@
import {
  requireWriter,
  type AccessError,
} from "./access.ts";
import { validPolishShare } from "../crew/small_share.ts";
import { validPolishShare } from "../crew/polish_share.ts";
import { removeInstallCache } from "../crew/workdir.ts";
import type { SettingsChanged } from "../core/settings_changed.ts";
@@ -10,6 +10,7 @@
export const route: Route = {
  refusals: {
    not_found: "the token is not a person who administers the forge (404)",
    no_such_setting: "{key} is not a capacity setting (422)",
    derived: "{key} is pace.floor or queue.depth, which follow Speed and are not set directly (422)",
    invalid_value: "the value is outside what this setting takes (422)",
    no_credential: "the setting needs a credential the forge does not hold (422)",
  },
@@ -28,8 +28,6 @@
export type CapacityKey =
  | "children.registryEgress"
  | "guard_new_accounts"
  | "signin.edge"
  | "slots.smallShare"
  | "polish.capMinutes"
  | "pace.floor";
interface Definition {
@@ -77,7 +75,7 @@
export const CAPACITY: Record<CapacityKey, Definition> = {
    env: "FORGE_QUEUE_DEPTH",
    kind: { type: "count", min: 1, max: 4 },
    fallback: "2",
    help: "How many merge-queue candidates of one repository gate at once, each on top of the one before: while one gates on main the next gates on it, and lands right after it if both are green. 1 gates one candidate at a time. A gate beyond the first takes a free check slot only, never one of the two kept for pull checks.",
    help: "How many merge-queue candidates of one repository gate at once, each on top of the one before: while one gates on main the next gates on it, and lands right after it if both are green. Derived from Speed (half of it rounded up, 1 to 4), read-only; FORGE_QUEUE_DEPTH is ignored. A gate beyond the first takes a free check slot only, never one of the two kept for pull checks.",
  },
  "queue.batch": {
    label: "Merge queue batch size",
@@ -135,26 +133,12 @@
export const CAPACITY: Record<CapacityKey, Definition> = {
    fallback: "on",
    help: "on reads the platform edge's identity headers (when the forge has an edge secret) and offers its sign-in; off ignores them on every door, so people sign in with the forge's own methods — password and passkey. Accounts the edge made keep their names but have no password until they set one. Takes effect on the next request.",
  },
  "slots.smallShare": {
    label: "Builder slots small issues may hold (%)",
    env: "FORGE_SLOTS_SMALL_SHARE",
    kind: { type: "count", min: 0, max: 100 },
    fallback: "30",
    help: "The most of a repository's builder slots that tests-only and small-addition issues (\"A test pins …\", or a label test, tests, tests-only or small) hold at once, as a percent rounded up: 30 lets 2 of 5 slots go to them. At the cap a small issue is skipped and the slot goes to the next issue in the Next up order; a ranked small issue is still taken. 100 lifts the cap; 0 starts none. Read on every pick.",
  },
  "polish.capMinutes": {
    label: "Run time a polish issue may take (minutes)",
    env: "FORGE_POLISH_CAP_MINUTES",
    kind: { type: "count", min: 1, max: 1440 },
    fallback: "60",
    help: "An issue labelled polish is small work: a builder run on it that has gone this many minutes is stopped, not extended, and the issue gets one comment saying what is left. Read on every tick.",
  },
  "pace.floor": {
    label: "Slots the pace always leaves reviews and assigned work",
    env: "FORGE_PACE_FLOOR",
    kind: { type: "count", min: 1, max: 16 },
    fallback: "2",
    help: "While the week's pace allows any slots, this many reviews and issues a person assigned may run at once, apart from the crew's own picks, however hard the pace slows them; also the fewest slots a fast burn slows a repository to. At the reserve's wall everything waits. Read on every pump.",
    help: "While the week's pace allows any slots, this many reviews and issues a person assigned may run at once, apart from the crew's own picks, however hard the pace slows them; also the fewest slots a fast burn slows a repository to. At the reserve's wall everything waits. Derived from Speed (half of it, at least 1), read-only; FORGE_PACE_FLOOR is ignored; read on every pump.",
  },
};
@@ -378,11 +362,11 @@
export function paceFloor(db: Database): number {
  return Number(effectiveCapacity(db, "pace.floor"));
}
/** The dials that follow Speed (`crew.concurrency`) until set on their own. */
/** The dials Speed (`crew.concurrency`) sets: always derived, never stored. */
export type SpeedDerivedKey = "pace.floor" | "queue.depth";
export function followsSpeed(db: Database, key: CapacityKey): key is SpeedDerivedKey {
  return (key === "pace.floor" || key === "queue.depth") && storedCapacity(db, key) === undefined;
export function followsSpeed(key: CapacityKey): key is SpeedDerivedKey {
      
        sentinelcrew
        2d ago
        outdated
      
      Unused _db parameter and a function that is now a constant check. Drop _db, and fix the comments above it ("until set on their own").
    
  return key === "pace.floor" || key === "queue.depth";
}
/** What Speed implies for a dial that follows it: half of Speed, at least 1 for the floor; half rounded up, 1 to 4, for the depth. */
@@ -392,9 +376,9 @@
export function derivedFromSpeed(db: Database, key: SpeedDerivedKey): number {
  return Math.min(4, Math.max(1, Math.ceil(speed / 2)));
}
/** A capacity's value as the crew reads it: derived from Speed while a following dial is unset. */
/** A capacity's value as the crew reads it: derived from Speed for the dials that follow it. */
export function effectiveCapacity(db: Database, key: CapacityKey): string {
  return followsSpeed(db, key) ? String(derivedFromSpeed(db, key)) : capacityValue(db, key);
  return followsSpeed(key) ? String(derivedFromSpeed(db, key)) : capacityValue(db, key);
}
/** The share of the week the crew may use, in percent (`week.use`); the rest is the reserve. */
@@ -456,16 +440,6 @@
export function queueBatch(db: Database): number {
  return Number(capacityValue(db, "queue.batch"));
}
/** The percent of builder slots small issues may hold (#7571). */
export function smallShare(db: Database): number {
  return Number(capacityValue(db, "slots.smallShare"));
}
/** The minutes of run time a polish issue may take before its run is stopped (#8852). */
export function polishCapMinutes(db: Database): number {
  return Number(capacityValue(db, "polish.capMinutes"));
}
/** Whether the platform edge's identity is read at all; on every request. */
export function edgeSigninOn(db: Database): boolean {
  return capacityValue(db, "signin.edge") !== "off";
@@ -31,10 +31,8 @@
import { queueStore } from "../checks/queue_store.ts";
import { addLearned } from "../checks/learned.ts";
import { batchWords, dropFromLine, enqueue, type GateCandidate, type Queued, type QueueOptions, queueClashes, queueWords, waitingPulls } from "../checks/queue.ts";
import { checksFor } from "../checks/service.ts";
import { queueBatch, queueDepth, smallShare } from "../core/capacity.ts";
import { shareWords, slotOrder, smallCap, smallIssues, smallOfIds } from "./small_share.ts";
import { queueBatch, queueDepth } from "../core/capacity.ts";
import { crewFor as crewForIssue, passedWords, pickFilter, routable } from "./pick_filter.ts";
import { tickPolish } from "./polish_cap.ts";
import { readConflictLane, readConflictRoom } from "./conflict_room.ts";
import { mergeable, resolveOid, treeOf } from "../git/merge.ts";
import { CLOSED_NOTE, leftNote, reopenedByPerson, unticked } from "../core/done_on_main.ts";
@@ -48,7 +46,6 @@
import {
  crewRole,
} from "../core/agents.ts";
import { pickBuilder, routeIssue } from "./route.ts";
import { firstAt } from "../core/first.ts";
import { fromAppIssues } from "../core/from_app.ts";
import { pickOrder } from "../core/next_up.ts";
import { ranksInRepo } from "../core/rank.ts";
@@ -434,38 +431,12 @@
function freeSlots(app: App, repo: Repo, now: Date): number {
  return Math.max(0, repoPace(app, repo, now, false).slots - slotted.length);
}
/** The pickable issues in slot order: the order Next up shows, small work held to its share (#7571). */
export function inSlotOrder(app: App, repo: Repo, ready: readonly Ranked[], slotted: readonly Run[], slots: number, picked: ReadonlySet<string> = new Set(), now: Date = new Date()): Ranked[] {
  const issues = ready.map((r) => r.issue);
  const small = smallIssues(app.db, issues);
  const first = firstAt(app.db, issues.map((i) => i.id));
/** The pickable issues in slot order: the order Next up shows. */
export function inSlotOrder(app: App, repo: Repo, ready: readonly Ranked[], now: Date = new Date()): Ranked[] {
  const ranked = ranksInRepo(app.db, repo.id);
  // Issues picked earlier in this tick hold their share before their runs show (#8729).
  const running = smallOfIds(app.db, [...new Set([...slotted.flatMap((r) => (r.issueId === null ? [] : [r.issueId])), ...picked])]);
  const { allowed } = pickFilter(app, repo, ready, now);
  // The order is the one Next up shows (#8826): ranked by place, then the ready order.
  return slotOrder(
    pickOrder(allowed, ranked, (r) => r.issue.id, [], fromAppIssues(app.db, allowed.map((r) => r.issue.id))),
    (r) => ({
      ranked: ranked.has(r.issue.id),
      small: small.has(r.issue.id) && !first.has(r.issue.id),
    }),
    running,
    smallCap(slots, smallShare(app.db)),
  );
}
/** Slotted runs on small issues, and the slots they may hold (#7571). */
export function smallShareOf(app: App, repo: Repo, now = new Date()): { running: number; cap: number } {
  const slotted = slottedRuns(activeRuns(app, repo.id), listCrewRoles(app.db, repo.id));
  const running = smallOfIds(app.db, slotted.flatMap((r) => (r.issueId === null ? [] : [r.issueId])));
  return { running, cap: smallCap(repoPace(app, repo, now).slots, smallShare(app.db)) };
}
/** `1/2`: {@link smallShareOf} as the tick line, the terminal and the studio print it. */
export function smallShareWords(app: App, repo: Repo, now = new Date()): string {
  const { running, cap } = smallShareOf(app, repo, now);
  return shareWords(running, cap);
  return pickOrder(allowed, ranked, (r) => r.issue.id, [], fromAppIssues(app.db, allowed.map((r) => r.issue.id)));
}
export type Drove = "off" | "paused" | "waiting" | "full" | "picked" | "planned" | "released" | "idle";
@@ -506,7 +477,6 @@
async function driveOnce(
): Promise<Drove> {
  if (repo.autonomy === "off") return "off";
  tickBets(app, repo, now);
  tickPolish(app, repo, now);
  const status = autonomyStatus(app, repo, now);
  if (status.paused !== null) return "paused";
  const by = getUserById(app.db, repo.autonomyBy!);
@@ -565,7 +535,7 @@
async function driveOnce(
  const crewFor = (issue: Issue) => crewForIssue(app, repo, issue.id, crew, now);
  const pickable = await withoutRetired(app, repo, routable(app, repo, ready, crew, now).kept);
  // The roadmap first, and small issues held to their share of the slots (#7571).
  const next = await nextOf(app, repo, inSlotOrder(app, repo, pickable, slotted, paced.slots, taken, now));
  const next = await nextOf(app, repo, inSlotOrder(app, repo, pickable, now));
  if (next !== undefined) {
    taken.add(next.issue.id);
    const routed = await routeIssue(app, repo, next.issue, crewFor(next.issue), inFlight);
@@ -1432,8 +1402,6 @@
export async function autonomyTick(
        slots: status.slots,
        // Builders with nothing in flight: what bounds active beside slots and startable (#7006).
        idle: idleBuilders(activeNow, crewNow),
        // Small issues in flight of the slots they may hold (#7571).
        small: smallShareWords(app, current, now),
        ...(governor === undefined ? {} : { governor }),
        // Approved conflicted pulls: queued, in flight, and why each other is
        // skipped (#3682, #6237), or "0 candidates of N open" (#6263); and the lane for rebases: conflicted N,
@@ -1,23 +1,26 @@
/**
 * The five knobs (#10461): Speed, Weekly budget, Polish share, Autonomy per
 * The knobs (#10461): Speed, Weekly budget, Polish share, Autonomy per
 * repository, Feedback first. Plain data out: one row each with its name, a
 * line on what it does, the value, a control kind and its live effect. The
 * crew page, the terminal and the MCP `knobs` tool print these same rows;
 * `actions/knobs.ts` is the one place that turns them. The pipeline's own
 * dials (small share, polish cap) stay on the
 * capacity page.
 * `actions/knobs.ts` is the one place that turns them. Pace floor and queue
 * depth ride along as derived rows: Speed sets them, nothing else does. The
 * reserve is not one of them: it is what Weekly budget leaves (100 minus it),
 * so it moves with that dial and not with Speed.
 */
import type { App } from "../app.ts";
import { capacityValue, followsSpeed, paceFloor, queueDepth } from "../core/capacity.ts";
import { capacityValue, paceFloor, queueDepth } from "../core/capacity.ts";
import { labelsForIssues } from "../core/issues.ts";
import { getRepoById, type Repo } from "../core/repos.ts";
import { listActive } from "../core/runs.ts";
import { waitingOnPeople } from "./people_first.ts";
import { POLISH_SHARE_DEFAULT, isPolish, polishSpend } from "./small_share.ts";
import { POLISH_SHARE_DEFAULT, isPolish, polishSpend } from "./polish_share.ts";
import { budgetEffect } from "./week_read.ts";
export type KnobId = "speed" | "budget" | "polish" | "autonomy" | "feedback";
export type KnobId = "speed" | "budget" | "polish" | "autonomy" | "feedback" | "floor" | "depth";
/** The dials Speed sets: shown on the panel with their value, never turned there. */
export const DERIVED_KNOBS: readonly string[] = ["floor", "depth", "pace.floor", "queue.depth"];
export type AutonomyWord = "off" | "ask" | "go";
export const AUTONOMY_WORDS: readonly AutonomyWord[] = ["off", "ask", "go"];
@@ -27,7 +30,7 @@
export interface KnobRow {
  readonly does: string;
  /** The value as typed back: a number, a percent's number, or one of the words. */
  readonly value: string;
  readonly control: "number" | "percent" | "words" | "fixed";
  readonly control: "number" | "percent" | "words" | "fixed" | "derived";
  readonly min?: number;
  readonly max?: number;
  readonly words?: readonly string[];
@@ -43,11 +46,6 @@
export function autonomyWord(repo: Repo): AutonomyWord {
  return !repo.plansNeedNod && repo.decisionsBy !== "me" ? "go" : "ask";
}
/** Whether a dial follows Speed, in the words the capacity page and the terminal use. */
function from(app: App, key: "pace.floor" | "queue.depth"): string {
  return followsSpeed(app.db, key) ? " (derived from Speed)" : " (set)";
}
function runsLine(app: App): string {
  const active = listActive(app.db, "agent");
  const running = active.filter((r) => r.state === "running").length;
@@ -91,7 +89,23 @@
export function readKnobs(app: App, now: Date = new Date()): KnobRow[] {
      control: "number",
      min: 1,
      max: 16,
      effect: `${runsLine(app)} · pace floor ${paceFloor(app.db)}${from(app, "pace.floor")} · queue depth ${queueDepth(app.db)}${from(app, "queue.depth")}`,
      effect: runsLine(app),
    },
    {
      id: "floor",
      name: "Pace floor",
      does: "The slots the pace always leaves reviews and assigned work. Derived from Speed: half of it, at least 1.",
      value: String(paceFloor(app.db)),
      control: "derived",
      effect: `${paceFloor(app.db)} slots`,
    },
    {
      id: "depth",
      name: "Queue depth",
      does: "How many merge-queue candidates of one repository gate at once. Derived from Speed: half of it rounded up, 1 to 4.",
      value: String(queueDepth(app.db)),
      control: "derived",
      effect: `${queueDepth(app.db)} candidates`,
    },
    {
      id: "budget",
@@ -17,7 +17,7 @@
import type { Repo } from "../core/repos.ts";
import { raisedAt } from "../core/thought_links.ts";
import type { Agent, CrewRole } from "../core/agents.ts";
import { mayPick } from "./bets.ts";
import { isPolish, polishSpend, smallIssues } from "./small_share.ts";
import { isPolish, polishSpend, smallIssues } from "./polish_share.ts";
import { shunnedBy } from "./stalls.ts";
/** Why the picker passes a startable issue over. */
@@ -1,68 +0,0 @@
/**
 * A polish issue is capped small (#8852): a builder run on an issue labelled
 * `polish` that has gone past `polish.capMinutes` of run time is stopped, not
 * extended, and the issue gets one comment with what is left in a line, as a
 * bet past its appetite does (#8713). Time is the run's own: `startedAt` to
 * now, so a fake clock decides it.
 */
import type { App } from "../app.ts";
import { addComment } from "../actions/issues.ts";
import { announceRun } from "../actions/runs.ts";
import { polishCapMinutes } from "../core/capacity.ts";
import { getIssueById, labelsForIssues } from "../core/issues.ts";
import { openPullFromHead } from "../core/pulls.ts";
import { cancelRun, listActive } from "../core/runs.ts";
import { getUserById } from "../core/users.ts";
import type { Repo } from "../core/repos.ts";
import { abortAgentRun } from "./running.ts";
/** Whether a run begun at `startedAt` has used `capMinutes` of run time by `now`. */
export function pastCap(startedAt: string | null, capMinutes: number, now: Date): boolean {
  if (startedAt === null) return false;
  const from = Date.parse(startedAt);
  return Number.isFinite(from) && now.getTime() - from >= capMinutes * 60_000;
}
/** What the run left: its open pull, or plainly that nothing landed. */
export function leftOf(pullNumber: number | undefined): string {
  return pullNumber === undefined ? "nothing landed, no pull open" : `pull #${pullNumber} is open, unmerged`;
}
/** The one line a stopped polish run leaves: the cap, and what is left. */
export function leftLine(capMinutes: number, left: string): string {
  return `Stopped at the ${capMinutes}-minute polish cap, not extended. Left: ${left}.`;
}
/** Stops this repository's polish runs past the cap; answers how many. */
export function tickPolish(app: App, repo: Repo, now = new Date()): number {
  const runs = listActive(app.db, "agent").filter(
    (r) => r.repoId === repo.id && r.state === "running" && r.issueId !== null,
  );
  if (runs.length === 0) return 0;
  const cap = polishCapMinutes(app.db);
  const late = runs.filter((r) => pastCap(r.startedAt, cap, now));
  if (late.length === 0) return 0;
  const labels = labelsForIssues(app.db, late.map((r) => r.issueId!));
  // The comment is the stop's one line, so it is never silent: the autonomy
  // author says it, else the user the run acted as.
  const speaker = (actorId: string | null) => {
    const id = repo.autonomyBy ?? actorId;
    return id === null ? undefined : getUserById(app.db, id);
  };
  let stopped = 0;
  for (const run of late) {
    if (!(labels.get(run.issueId!) ?? []).some((l) => l.name.toLowerCase() === "polish")) continue;
    const by = speaker(run.actorId);
    const issue = getIssueById(app.db, run.issueId!);
    if (by === undefined || issue === undefined) continue; // no one to say it: leave the run, never stop it silently
    const gone = cancelRun(app.db, run.id, `stopped at the ${cap}-minute polish cap`);
    if (gone === undefined) continue;
    abortAgentRun(run.id);
    announceRun(app, gone);
    stopped++;
    const pull = run.branch === "" ? undefined : openPullFromHead(app.db, repo.id, repo.id, run.branch);
    addComment(app, by, repo, issue, leftLine(cap, leftOf(pull?.number)));
  }
  return stopped;
}
@@ -1,19 +1,9 @@
/**
 * Builder slots serve the roadmap first (#7571). Cheap pulls — a test that
 * pins something, a small terminal or MCP addition — are quick to start and
 * quick to land, so left alone they fill every slot and the open-pull limit
 * while the roadmap waits. Two rules keep them in their place:
 *
 * - **Pick order:** the order Next up shows, ranked rows then the ready tail
 *   (`pickOrder` in core/next_up.ts); the picker has no order of its own.
 * - **A cap:** small issues hold at most `slots.smallShare` percent of the
 *   builder slots (rounded up, so one slot may still take one). At the cap a
 *   small issue is skipped, never waited on: the slot goes to other work or
 *   stays free.
 *
 * Small is read from the issue alone: a title like "A test pins …" or
 * "Tests: …", or a label `test`, `tests`, `tests-only`, `small` or `polish`. Plain data in,
 * plain data out; the reads are two grouped queries whatever the count.
 * Small work and polish. An issue is small when its title or labels say so
 * (a title like "A test pins …" or "Tests: …", or a label `test`, `tests`,
 * `tests-only`, `small` or `polish`); polish is spent against a share of the
 * week (`polishSpend`). Small work holds no slots of its own: Speed and the
 * pick order bound it like any other work. Plain data in, plain data out.
 */
import type { Database } from "bun:sqlite";
@@ -28,46 +18,6 @@
export function isSmall(title: string, labels: readonly string[]): boolean {
  return SMALL_TITLE.test(title.trim()) || labels.some((l) => SMALL_LABELS.has(l.toLowerCase()));
}
/** How many slots small issues may hold: `share` percent of `slots`, rounded up; 5 at 30% is 2. */
export function smallCap(slots: number, share: number): number {
  if (slots <= 0 || share <= 0) return 0;
  return Math.min(slots, Math.ceil((slots * Math.min(share, 100)) / 100));
}
/** `1/2`: small issues in flight of what they may hold; each door adds its own word around it. */
export function shareWords(running: number, cap: number): string {
  return `${running}/${cap}`;
}
/** `small issues: 1 of 2 slots`, for the app's row in Today on /boards. */
export function smallIssuesWords(share: { readonly running: number; readonly cap: number }): string {
  return `small issues: ${share.running} of ${share.cap} ${share.cap === 1 ? "slot" : "slots"}`;
}
export interface Classed {
  /** On the owner's ranked list (#8694): never held back by the cap, small or not. */
  readonly ranked?: boolean;
  readonly small: boolean;
}
/**
 * The order is not decided here: `ordered` arrives in the order Next up shows
 * (#8826) and keeps it. All this does is leave small work out — raised or
 * not, unless the owner ranked it — once `running` small issues fill `cap`.
 */
export function slotOrder<T>(
  ordered: readonly T[],
  classOf: (t: T) => Classed,
  running: number,
  cap: number,
): T[] {
  const open = running < cap;
  return ordered.filter((t) => {
    const c = classOf(t);
    return open || c.ranked === true || !c.small;
  });
}
/** Which of these issues are small, from their titles and labels. */
export function smallIssues(
  db: Database,
@@ -81,18 +31,6 @@
export function smallIssues(
  );
}
/** Of these issue ids, the small ones: what the slotted runs are working on. */
export function smallOfIds(db: Database, ids: readonly string[]): number {
  const unique = [...new Set(ids)];
  if (unique.length === 0) return 0;
  const rows = db
    .query<{ id: string; title: string }, string[]>(
      `SELECT id, title FROM issue WHERE id IN (${unique.map((_, n) => `?${n + 1}`).join(",")})`,
    )
    .all(...unique);
  return smallIssues(db, rows).size;
}
/** The week polish is counted over: the seven days before `now`, on the clock the caller passes. */
export const POLISH_WINDOW_MS = 7 * 24 * 60 * 60 * 1000;
@@ -10,7 +10,6 @@
import type { App } from "../app.ts";
import { listAutonomousRepos, type Repo } from "../core/repos.ts";
import { smallShareWords } from "../crew/autonomy.ts";
import { admits, heldCounts, heldNow, mapHolds, type Held, type HoldName } from "../crew/held.ts";
export interface HeldRow {
@@ -21,8 +20,6 @@
export interface HeldRow {
  readonly counts: Readonly<Record<HoldName, number>>;
  /** Issues a hot file holds, with the open pulls on that file, oldest first. */
  readonly hot: readonly { readonly number: number; readonly detail: string; readonly pulls: readonly number[] }[];
  /** `1/2`: small issues in flight of the builder slots they may hold (#7571). */
  readonly small: string;
}
/** The most hot-file holds a row lists. */
@@ -53,7 +50,6 @@
export function readHeld(app: App, owner: boolean, now = Date.now()): HeldRow[]
        public: repo.visibility === "public",
        startable: held.startable.length,
        counts: heldCounts(held),
        small: smallShareWords(app, repo),
        hot: [...holds].flatMap(([number, h]) =>
          h.by === "hot_file" && h.pulls !== undefined && h.pulls.length > 0
            ? [{ number, detail: h.detail, pulls: h.pulls }]
@@ -13,7 +13,7 @@
import { kpiProbe } from "../../web/studio/kpi_probe.ts";
import { MAX_SECONDS, sampleStacks } from "../../perf/sample.ts";
import { listAccounts, removeAccount, retireAndRemoveAccount, retirementPlan, suspendAccount, unsuspendAccount, verifyAccount } from "../../actions/accounts.ts";
import { ADMIN_WORDS } from "../../actions/admin_words.ts";
import { changeCapacity, edgeOffDryRun, listCapacity } from "../../actions/capacity.ts";
import { DERIVED_WORDS, changeCapacity, edgeOffDryRun, listCapacity } from "../../actions/capacity.ts";
import { changeShield, lastShieldChange, shieldState } from "../../actions/shield.ts";
import { inviteLink, list as listInviteLinks, mint as mintInviteLink, revoke as revokeInviteLink } from "../../actions/invites.ts";
import { changeLimit, listLimits } from "../../actions/limits.ts";
@@ -196,7 +196,9 @@
export function adminRoutes(router: Router<Handler>): void {
      422,
      changed.error === "no_such_setting"
        ? "no such capacity setting"
        : SETTING_WORDS.outOfRange,
        : changed.error === "derived"
          ? DERIVED_WORDS
          : SETTING_WORDS.outOfRange,
    );
  });
@@ -1,4 +1,4 @@
import { SETTABLE_CAPACITY, changeCapacity, listCapacity } from "../../../actions/capacity.ts";
import { DERIVED_WORDS, SETTABLE_CAPACITY, changeCapacity, listCapacity } from "../../../actions/capacity.ts";
import { SETTING_WORDS } from "../../../actions/setting_words.ts";
import { scopeAllows } from "../../../core/tokens.ts";
import { good, bad, type Tool } from "../shared.ts";
@@ -36,7 +36,7 @@
export const tool: Tool = {
    if (!scopeAllows(ctx.auth.scope ?? "ro", "admin"))
      return bad("forbidden", "changing the forge's capacity needs an admin-scope token");
    const changed = changeCapacity(ctx.app, user, key, value);
    if (!changed.ok) return bad(changed.error, SETTING_WORDS.outOfRange);
    if (!changed.ok) return bad(changed.error, changed.error === "derived" ? DERIVED_WORDS : SETTING_WORDS.outOfRange);
    return good({
      says: `${key}: ${changed.value.from || "auto"} → ${changed.value.to || "auto"}, from the next pick on.`,
      ...changed.value,
@@ -1,5 +1,5 @@
import { takeProposal } from "../../../actions/week.ts";
import { polishSpend, polishWords } from "../../../crew/small_share.ts";
import { polishSpend, polishWords } from "../../../crew/polish_share.ts";
import { latestRetro, takenOf } from "../../../flow/retro.ts";
import { bad, good, type Tool, APP_ARG, planRepo, isAnswer } from "../shared.ts";
@@ -15,7 +15,7 @@
 */
import { updateRepoSettings } from "../../actions/repos.ts";
import { POLISH_SHARE_MAX, validPolishShare } from "../../crew/small_share.ts";
import { POLISH_SHARE_MAX, validPolishShare } from "../../crew/polish_share.ts";
import { seatSlotsSaid, setSeatSlots } from "../../actions/seat_slots.ts";
import { checkSeatSlots, seatSlotsOf, seatSlotsWords } from "../../crew/seat_slots.ts";
import type { CrewRole } from "../../core/agents.ts";
@@ -6,7 +6,7 @@
 */
import type { SelfSwap } from "../../release/swap.ts";
import { changeCapacity, listCapacity, type CapacityRow } from "../../actions/capacity.ts";
import { DERIVED_WORDS, changeCapacity, listCapacity, type CapacityRow } from "../../actions/capacity.ts";
import { SETTING_WORDS } from "../../actions/setting_words.ts";
import { CAPACITY, belowCeiling, validCapacity, type CapacityKey } from "../../core/capacity.ts";
import type { Ctx, Screen } from "../app/app.ts";
@@ -28,8 +28,10 @@
export function boundsOf(key: CapacityKey): string {
}
/** What a refused change says, in its own words. */
const refused = (error: "not_found" | "no_such_setting" | "invalid_value" | "no_credential"): string =>
  error === "no_credential"
const refused = (error: "not_found" | "no_such_setting" | "invalid_value" | "no_credential" | "derived"): string =>
  error === "derived"
    ? DERIVED_WORDS
    : error === "no_credential"
    ? "Set a password or a passkey first: turning the edge off would lock you out"
    : error === "invalid_value"
      ? SETTING_WORDS.outOfRange
@@ -241,7 +241,7 @@
export function openerLines(rows: readonly Opener[], inner: number): string[] {
  return rows.length > 5 ? [...lines, `and ${rows.length - 5} more`] : lines;
}
/** One line per autonomous repository: its name, then `startable=N`, each filter holding any, and `small 1/2` (#7571). */
/** One line per autonomous repository: its name, then `startable=N`, each filter holding any. */
export function heldLines(rows: readonly HeldRow[], inner: number): string[] {
  if (rows.length === 0) return ["Ready, and why it waits: no repository runs on its own."];
  return [
@@ -252,7 +252,6 @@
export function heldLines(rows: readonly HeldRow[], inner: number): string[] {
          r.repo,
          `startable=${r.startable}`,
          ...HOLDS.filter((h) => r.counts[h] > 0).map((h) => `${h}=${r.counts[h]}`),
          `small ${r.small}`,
        ].join(" "),
        inner,
      ),
@@ -42,6 +42,7 @@
export function knobsScreen(f: Session, ctx: Ctx): Screen {
      if (e.key !== "e") return state.key(e, rows.length);
      const row = rows[state.index];
      if (row === undefined) return true;
      if (row.control === "derived") return ctx.toast(`${row.name} follows Speed.`, "success"), true;
      if (row.control === "fixed") return ctx.toast(`${row.name} is always on.`, "success"), true;
      later(ctx, () =>
        promptScreen(ctx, screen, {
@@ -11,7 +11,7 @@
import { takeProposal } from "../../actions/week.ts";
import { canRead, canWrite, getRepoById, type Repo } from "../../core/repos.ts";
import { polishSpend, polishWords } from "../../crew/small_share.ts";
import { polishSpend, polishWords } from "../../crew/polish_share.ts";
import { latestRetro, takenOf, type Retro } from "../../flow/retro.ts";
import type { Ctx, Screen } from "../app/app.ts";
import { binding } from "../app/keys.ts";
@@ -83,10 +83,8 @@
import {
  autonomyStatus,
  holdWords,
  plannerHold,
  smallShareOf,
  startOfTodayUtc,
} from "../../crew/autonomy.ts";
import { smallIssuesWords } from "../../crew/small_share.ts";
import { distinct, notesRegion, type Note } from "./board-notes.ts";
import type { Ctx } from "../../http/context.ts";
import { repoBase, signInFirst } from "../chrome.ts";
@@ -1043,8 +1041,6 @@
function today(ctx: Ctx, scope: BoardScope): Html {
            <span><b>${shipped}</b> shipped</span>`,
          `${perShippedWords(week.get(repo.id))} this week`,
          holdLine,
          // Small issues in flight of the slots they may hold (#7571).
          repo.autonomy === "off" ? null : smallIssuesWords(smallShareOf(ctx.app, repo, now)),
          review,
        ],
        under: meter(
@@ -6,7 +6,7 @@
 * and each one is listed below the settings: who, when, from what to what.
 */
import { changeCapacity, edgeOffDryRun, listCapacity, type CapacityRow } from "../../actions/capacity.ts";
import { DERIVED_WORDS, changeCapacity, edgeOffDryRun, listCapacity, type CapacityRow } from "../../actions/capacity.ts";
import { CAPACITY, belowCeiling, type CapacityKey } from "../../core/capacity.ts";
import { bytes } from "../../system/format.ts";
import { egressRowsFor } from "../../spawn/process_counters.ts";
@@ -102,10 +102,12 @@
export function capacityPage(ctx: Ctx): Response {
              <span class="mono">${s.default === "" ? "auto" : s.default}</span>
              (<span class="mono">${s.env}</span>).`
          : s.source === "derived"
            ? html`Derived from Speed (<span class="mono">crew.concurrency</span>); set it here to stop following.`
            ? html`Derived from Speed (<span class="mono">crew.concurrency</span>); read-only here: change Speed and it moves.`
            : html`The boot default, from <span class="mono">${s.env}</span>.`}
        ${awayLine(s, now)}`,
      trail: html`<form
      trail: s.source === "derived"
        ? html`<span class="mono" data-derived="${s.key}">${s.value}</span>`
        : html`<form
        class="row-fields"
        method="post"
        action="/settings/capacity"
@@ -240,6 +242,7 @@
export function capacityPage(ctx: Ctx): Response {
const ERRORS: Record<string, string> = {
  no_such_setting: "There is no such setting.",
  derived: DERIVED_WORDS,
  invalid_value: "That value is outside what this setting takes.",
  no_credential:
    "Add a passkey (or a password) to your own account first: with the edge off, you would be signed out for good.",
@@ -16,6 +16,7 @@
import { btn } from "../ui.ts";
function control(r: KnobRow): Html {
  if (r.control === "fixed") return html`<span class="badge">${r.value}</span>`;
  if (r.control === "derived") return html`<span class="mono" data-derived="${r.id}" title="Read-only: Speed sets it">${r.value}</span>`;
  const label = `${r.name}${r.repo === undefined ? "" : ` for ${r.repo}`}`;
  const input =
    r.control === "words"
@@ -35,7 +36,7 @@
export function knobsCard(ctx: Ctx): Html {
  const rows = readKnobs(ctx.app);
  return html`<section id="knobs">
    <h2 class="mb">Knobs</h2>
    <p class="muted small">Five dials for the crew; a change applies on the next pump.</p>
    <p class="muted small">Dials for the crew; a change applies on the next pump.</p>
    <dl class="status-rows">
      ${rows.map(
        (r) => html`<div class="status-row" data-knob="${r.id}">
@@ -62,6 +63,9 @@
export async function knobSet(ctx: Ctx): Promise<Response> {
    "/settings/crew",
    set.ok
      ? { message: `${knob}: ${set.value.value}, from the next pump on.` }
      : { tone: "danger", message: "That value is outside what this knob takes." },
      : {
          tone: "danger",
          message: set.error === "derived" ? "That dial follows Speed: turn Speed and it moves." : "That value is outside what this knob takes.",
        },
  );
}
@@ -8,7 +8,7 @@
 * same-origin POST and every one of them says what happened.
 */
import { POLISH_SHARE_DEFAULT, POLISH_SHARE_MAX } from "../../crew/small_share.ts";
import { POLISH_SHARE_DEFAULT, POLISH_SHARE_MAX } from "../../crew/polish_share.ts";
import { appLimitWords } from "../../actions/app_limit.ts";
import { showProvenance } from "../../actions/provenance.ts";
import { getProvenance, parentUrl, sourceLabel } from "../../core/provenance.ts";
@@ -5,7 +5,7 @@
 * and nothing else on the page changes anything.
 */
import { takeProposal } from "../../actions/week.ts";
import { polishSpend } from "../../crew/small_share.ts";
import { polishSpend } from "../../crew/polish_share.ts";
import { canWrite, type Repo } from "../../core/repos.ts";
import { notePhase, takeSessionTime } from "../../core/route_timing.ts";
import { latestRetro, takenOf, type Line, type Retro } from "../../flow/retro.ts";
@@ -31,7 +31,7 @@
import { getAppByRepo } from "../../core/apps.ts";
import { canAdmin, canSeeOwnerFacts, type Repo } from "../../core/repos.ts";
import { seatsOf, type Seat } from "../../crew/seats.ts";
import { crewHasCredential } from "../../core/subscriptions.ts";
import { autonomyStatus, smallShareWords } from "../../crew/autonomy.ts";
import { autonomyStatus } from "../../crew/autonomy.ts";
import { governorSeen } from "../../crew/governed.ts";
import { crewOffInPreview } from "../../crew/preview.ts";
import type { Ctx } from "../../http/context.ts";
@@ -298,8 +298,6 @@
function autonomyCard(ctx: Ctx, repo: Repo, base: string, admin: boolean): Html
          </dd>
          <dt>Slots</dt>
          <dd>${status.active} of ${status.slots} in use</dd>
          <dt>Small issues</dt>
          <dd>${smallShareWords(ctx.app, repo)} slots</dd>
          ${governor === undefined
            ? null
            : html`<dt>Governor</dt>
@@ -1,7 +1,7 @@
/**
 * Builder slots serve the roadmap first (#7571): small issues — tests-only
 * or small additions — hold at most `slots.smallShare` of the slots, and an
 * issue under an open epic starts before a small one.
 * The pick order (#7571, #10622): small issues — tests-only or small
 * additions — hold no slots of their own now; Speed and the Next up order bound
 * them like any work. An old `slots.smallShare` is ignored.
 */
import { quietWeek } from "./helpers/week-quiet.ts";
import { afterAll, beforeAll, describe, expect, test } from "bun:test";
@@ -14,7 +14,6 @@
import { addToCrew, createAgent } from "../src/actions/crew.ts";
import { linkIssue } from "../src/actions/dependencies.ts";
import { openIssue } from "../src/actions/issues.ts";
import { commitToBranch, createRepo, updateRepoSettings } from "../src/actions/repos.ts";
import { smallShare } from "../src/core/capacity.ts";
import { readyNow, repoGraph } from "../src/core/dependencies.ts";
import { nextUp } from "../src/core/next_up.ts";
import { putFirst } from "../src/core/first.ts";
@@ -22,8 +21,8 @@
import { getIssueById, type Issue } from "../src/core/issues.ts";
import { getRepoById, type Repo } from "../src/core/repos.ts";
import { createRun } from "../src/core/runs.ts";
import { createUser, type User } from "../src/core/users.ts";
import { driveRepo, inSlotOrder, smallShareWords } from "../src/crew/autonomy.ts";
import { isSmall, shareWords, slotOrder, smallCap, smallIssuesWords } from "../src/crew/small_share.ts";
import { driveRepo, inSlotOrder } from "../src/crew/autonomy.ts";
import { isSmall } from "../src/crew/polish_share.ts";
import { readHeld } from "../src/flow/held.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { heldLines } from "../src/tui/screens/flow.ts";
@@ -36,23 +35,8 @@
describe("the rules", () => {
    expect(isSmall("Search notes by word", ["feature"])).toBe(false);
  });
  test("5 slots at 30% hold 2 small; 1 slot still holds 1; 0% holds none", () => {
    expect(smallCap(5, 30)).toBe(2);
    expect(smallCap(1, 30)).toBe(1);
    expect(smallCap(5, 0)).toBe(0);
    expect(smallCap(5, 100)).toBe(5);
  });
  test("the order given is kept, and small work is left out at the cap unless ranked", () => {
    const c = (t: string) => ({ ranked: t.endsWith("^"), small: t.startsWith("s") });
    expect(slotOrder(["s1", "o1", "r1", "s2"], c, 0, 2)).toEqual(["s1", "o1", "r1", "s2"]);
    expect(slotOrder(["s1", "o1", "s2^", "r1"], c, 2, 2)).toEqual(["o1", "s2^", "r1"]);
  });
  test("each label the docs name is small, and the words read as the doors print them", () => {
  test("each label the docs name is small", () => {
    for (const label of ["test", "tests", "tests-only", "small"]) expect(isSmall("Anything", [label])).toBe(true);
    expect(shareWords(1, 2)).toBe("1/2");
    expect(smallIssuesWords({ running: 1, cap: 2 })).toBe("small issues: 1 of 2 slots");
  });
});
@@ -66,15 +50,6 @@
let cookie: string;
const get = (path: string) =>
  fetch(`${servers.url}${path}`, { headers: { cookie: `${cookie}; forge_mode=studio` }, redirect: "manual" });
/** Sets `slots.smallShare` as an admin does, on /settings/capacity. */
const setShare = (value: string) =>
  fetch(`${servers.url}/settings/capacity`, {
    method: "POST",
    redirect: "manual",
    headers: { cookie, "content-type": "application/x-www-form-urlencoded", origin: servers.url },
    body: new URLSearchParams({ key: "slots.smallShare", value }),
  });
const fresh = () => getRepoById(app.db, repo.id)!;
/** Every issue opened here, for a drive that may pick any of them. */
@@ -150,34 +125,25 @@
afterAll(async () => {
  await rm(dataDir, { recursive: true, force: true });
});
test("with 5 slots and only small issues ready, at most 2 start; then an epic's issue starts before a small one", async () => {
  expect(smallShare(app.db)).toBe(30);
test("no cap holds small issues back: with 5 slots and four small issues ready, all four start, whatever an old slots.smallShare says", async () => {
  // A value stored by the knob that used to be here: ignored, not an error.
  app.db.query("INSERT INTO forge_setting (key, value, updated_by, updated_at) VALUES ('slots.smallShare', '0', ?1, ?2)").run(alice.id, new Date().toISOString());
  const small = ["A test pins the title", "A test pins the body", "A test pins the date", "A test pins the tags"].map(open);
  const started: Issue[] = [];
  for (let n = 0; n < 5; n++) {
    started.push(...(await drive(small)));
  }
  expect(started.length).toBe(2);
  expect(smallShareWords(app, fresh())).toBe("2/2");
  // Room is made for one more small one, and an epic's issue arrives beside it.
  const epic = open("Notes search");
  const child = open("Search notes by word");
  expect(linkIssue(app, alice, fresh(), epic, child).ok).toBe(true);
  app.db.query("UPDATE run SET state = 'ok' WHERE issue_id = ?1").run(started[0]!.id);
  const next = await drive([...small, child]);
  expect(next.map((i) => i.id)).toContain(child.id);
  for (let n = 0; n < 5; n++) started.push(...(await drive(small)));
  expect(started.length).toBe(4);
  // Those runs end, so the slots are free for the tests below.
  app.db.query("UPDATE run SET state = 'ok' WHERE repo_id = ?1 AND state IN ('queued','running')").run(repo.id);
});
test("one small issue of two slots shows on /board's Today, the studio's crew panel and the terminal's Flow", async () => {
  expect(smallShareWords(app, fresh())).toBe("2/2");
test("small issues in flight show nowhere: not on /board's Today, the studio's crew panel or the terminal's Flow", async () => {
  const board = await (await get("/board")).text();
  const today = board.slice(board.indexOf('id="today"'));
  expect(today).toContain("small issues: 2 of 2 slots");
  expect(board).not.toContain("small issues:");
  const studio = await (await get("/alice/notes/settings")).text();
  expect(studio).toMatch(/<dt>Small issues<\/dt>\s*<dd>2\/2 slots<\/dd>/);
  expect(studio).not.toContain("<dt>Small issues</dt>");
  const flow = heldLines(readHeld(app, true), 200).join("\n");
  expect(flow).toMatch(/^alice\/notes startable=\d+.* small 2\/2$/m);
  expect(flow).toMatch(/^alice\/notes startable=\d+/m);
  expect(flow).not.toContain(" small ");
});
test("what the owner raised again is first in the page's order and in the picker's, ahead of an older epic issue", async () => {
@@ -188,7 +154,7 @@
test("what the owner raised again is first in the page's order and in the picker
  app.db.query("INSERT INTO issue_raise (issue_id, raised_at) VALUES (?1, ?2)").run(plain.id, new Date().toISOString());
  const mine = new Set([plain.id, child.id]);
  const ready = readyNow(repoGraph(app.db, repo.id, { sealed: true }));
  const picker = inSlotOrder(app, fresh(), ready, [], 5).map((r) => r.issue.id).filter((id) => mine.has(id));
  const picker = inSlotOrder(app, fresh(), ready).map((r) => r.issue.id).filter((id) => mine.has(id));
  const page = nextUp(app.db, fresh()).rows.map((r) => r.issue.id).filter((id) => mine.has(id));
  expect(picker).toEqual([plain.id, child.id]);
  expect(page).toEqual(picker);
@@ -204,7 +170,7 @@
test("an epic's issue leads older plain work only as the page's ready order has
  const order = () => {
    const mine = new Set([older.id, child.id]);
    const ready = readyNow(repoGraph(app.db, repo.id, { sealed: true }));
    const picker = inSlotOrder(app, fresh(), ready, [], 5).map((r) => r.issue.id).filter((id) => mine.has(id));
    const picker = inSlotOrder(app, fresh(), ready).map((r) => r.issue.id).filter((id) => mine.has(id));
    const page = nextUp(app.db, fresh()).rows.map((r) => r.issue.id).filter((id) => mine.has(id));
    expect(page).toEqual(picker);
    return picker;
@@ -217,22 +183,3 @@
test("an epic's issue leads older plain work only as the page's ready order has
  for (const i of [older, epic, child]) app.db.query("UPDATE issue SET state = 'closed' WHERE id = ?1").run(i.id);
  opened.splice(opened.length - 3, 3);
});
test("slots.smallShare set on /settings/capacity changes the pick: 0 starts no small issue, 100 does; out of range is refused", async () => {
  // The earlier ticks filled the slots; those runs end so this pick has room.
  app.db.query("UPDATE run SET state = 'ok' WHERE repo_id = ?1 AND state IN ('queued','running')").run(repo.id);
  const small = open("A test pins the colour");
  expect((await setShare("0")).status).toBe(303);
  expect(smallShare(app.db)).toBe(0);
  expect(await drive(opened)).toEqual([]);
  expect(getIssueById(app.db, small.id)!.assigneeId).toBeNull();
  expect((await setShare("100")).status).toBe(303);
  expect(smallShare(app.db)).toBe(100);
  const picked = await drive(opened);
  expect(picked.length).toBeGreaterThan(0);
  for (const i of picked) expect(isSmall(i.title, [])).toBe(true);
  for (const value of ["101", "-1", "half"]) {
    await setShare(value);
    expect(smallShare(app.db)).toBe(100);
  }
});
@@ -7,11 +7,12 @@
import { afterAll, afterEach, beforeAll, expect, test } from "bun:test";
import { mkdtemp, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { changeCapacity } from "../src/actions/capacity.ts";
import { createRepo } from "../src/actions/repos.ts";
import { setKnob } from "../src/actions/knobs.ts";
import { createApp, type App } from "../src/app.ts";
import { listCapacity } from "../src/actions/capacity.ts";
import { CAPACITY_KEYS, capacityCount, followsSpeed, paceFloor, queueDepth, setCapacity, weekUse } from "../src/core/capacity.ts";
import { CAPACITY_KEYS, capacityCount, paceFloor, queueDepth, setCapacity, weekUse } from "../src/core/capacity.ts";
import { listEvents } from "../src/core/events.ts";
import { getRepoById } from "../src/core/repos.ts";
import { createUser, type User } from "../src/core/users.ts";
@@ -47,16 +48,16 @@
afterAll(async () => {
  await rm(dir, { recursive: true, force: true });
});
test("the panel has Speed, Weekly budget, Polish share, Autonomy per repository and Feedback first, each with an effect", () => {
test("the panel has Speed, the derived pace floor and queue depth, Weekly budget, Polish share, Autonomy per repository and Feedback first, each with an effect", () => {
  const rows = readKnobs(app);
  expect(rows.map((r) => r.id)).toEqual(["speed", "budget", "polish", "autonomy", "feedback"]);
  expect(rows.map((r) => r.id)).toEqual(["speed", "floor", "depth", "budget", "polish", "autonomy", "feedback"]);
  for (const r of rows) {
    expect(r.does.length).toBeGreaterThan(0);
    expect(r.effect.length).toBeGreaterThan(0);
  }
  expect(rows[0]!.effect).toMatch(/\d+ running · \d+ queued/);
  expect(rows[4]!.effect).toBe("nothing from a person waiting");
  expect(knobLines(rows)).toHaveLength(5);
  expect(rows[6]!.effect).toBe("nothing from a person waiting");
  expect(knobLines(rows)).toHaveLength(7);
});
test("Speed 4 → 2 is read by the next pump", async () => {
@@ -69,9 +70,24 @@
test("Speed 4 → 2 is read by the next pump", async () => {
  expect(listEvents(app.db, {}).some((e) => e.kind === "capacity.changed")).toBe(true);
});
test("the pipeline's dials stay on capacity and no knob reaches them", async () => {
  for (const key of ["slots.smallShare", "polish.capMinutes", "pace.floor", "queue.depth"]) expect(CAPACITY_KEYS as string[]).toContain(key);
  for (const knob of ["queue.depth", "pace.floor", "slots.smallShare"]) expect((await setKnob(app, admin, knob, "1")).ok).toBe(false);
test("the small share and the polish cap are gone from capacity; a stored old value is ignored", () => {
  for (const key of ["slots.smallShare", "polish.capMinutes"]) expect(CAPACITY_KEYS as string[]).not.toContain(key);
  app.db.query("INSERT OR REPLACE INTO forge_setting (key, value, updated_by, updated_at) VALUES ('slots.smallShare', '5', ?1, ?2)").run(admin.id, new Date().toISOString());
  const listed = listCapacity(app, admin);
  if (!listed.ok) throw new Error("not admin");
  expect(listed.value.settings.map((r) => r.key)).not.toContain("slots.smallShare");
  expect(readKnobs(app).length).toBeGreaterThan(0);
});
test("no knob or capacity POST sets the pace floor or the queue depth: a plain line, nothing stored", async () => {
  for (const knob of ["queue.depth", "pace.floor", "floor", "depth", "slots.smallShare"]) expect((await setKnob(app, admin, knob, "1")).ok).toBe(false);
  const knob = await setKnob(app, admin, "pace.floor", "1");
  expect(!knob.ok && knob.error).toBe("derived");
  for (const key of ["pace.floor", "queue.depth"]) {
    const changed = changeCapacity(app, admin, key, "3");
    expect(!changed.ok && changed.error).toBe("derived");
    expect(app.db.query("SELECT 1 FROM forge_setting WHERE key = ?1").get(key)).toBeNull();
  }
});
test("Weekly budget sets the reserve the pacer holds back", () => {
@@ -131,30 +147,50 @@
test("pace floor and queue depth follow Speed, and the next pump reads the new f
  expect(queueDepth(app.db)).toBe(1);
});
test("a stored pace floor or queue depth wins over Speed", () => {
test("a stored pace floor or queue depth is ignored: Speed decides", () => {
  setCapacity(app.db, "crew.concurrency", "6", admin.id);
  setCapacity(app.db, "pace.floor", "2", admin.id);
  setCapacity(app.db, "queue.depth", "4", admin.id);
  expect(paceFloor(app.db)).toBe(2);
  expect(queueDepth(app.db)).toBe(4);
  expect(followsSpeed(app.db, "queue.depth")).toBe(false);
  expect(paceFloor(app.db)).toBe(3);
  expect(queueDepth(app.db)).toBe(3);
});
test("derived rows are labelled on the capacity page, the terminal's lines and the knobs", async () => {
test("the derivation at the lowest, middle and highest Speed", () => {
  const at = (speed: string) => {
    setCapacity(app.db, "crew.concurrency", speed, admin.id);
    return [paceFloor(app.db), queueDepth(app.db)];
  };
  expect(at("1")).toEqual([1, 1]);
  expect(at("8")).toEqual([4, 4]);
  expect(at("16")).toEqual([8, 4]);
});
test("the capacity page and the knobs list the derived dials with their value, read-only", async () => {
  setCapacity(app.db, "crew.concurrency", "6", admin.id);
  const rows = listCapacity(app, admin);
  if (!rows.ok) throw new Error("not admin");
  const floor = rows.value.settings.find((r) => r.key === "pace.floor")!;
  expect(floor.source).toBe("derived");
  expect(floor.value).toBe("3");
  setCapacity(app.db, "queue.depth", "2", admin.id);
  const set = listCapacity(app, admin);
  if (!set.ok) throw new Error("not admin");
  expect(set.value.settings.find((r) => r.key === "queue.depth")!.source).toBe("setting");
  const effect = readKnobs(app)[0]!.effect;
  expect(effect).toContain("pace floor 3 (derived from Speed)");
  expect(effect).toContain("queue depth 2 (set)");
  for (const key of ["pace.floor", "queue.depth"]) {
    const r = rows.value.settings.find((x) => x.key === key)!;
    expect(r.source).toBe("derived");
    expect(r.value).toBe("3");
  }
  const knobs = readKnobs(app);
  for (const [id, unit] of [["floor", "slots"], ["depth", "candidates"]]) {
    const r = knobs.find((x) => x.id === id)!;
    expect([r.control, r.value, r.effect]).toEqual(["derived", "3", `3 ${unit}`]);
  }
  // The MCP tool prints the same rows, in the same words.
  const ctx = { app, auth: { scope: "admin" } } as never;
  expect(JSON.stringify(await tool.run(ctx, admin, {}))).toContain("pace floor 3 (derived from Speed)");
  expect(JSON.stringify(await tool.run(ctx, admin, {}))).toContain("Pace floor: 3 — 3 slots");
});
test("the knobs card renders the derived dials as plain values with no form", async () => {
  const { knobsCard } = await import("../src/web/pages/knobs.ts");
  const out = String(knobsCard({ app } as never));
  for (const id of ["floor", "depth"]) {
    const row = out.slice(out.indexOf(`data-knob="${id}"`), out.indexOf("</div>", out.indexOf(`data-knob="${id}"`)));
    expect(row).toContain(`data-derived="${id}"`);
    expect(row).not.toContain("<form");
    expect(row).not.toContain("<input");
  }
});
@@ -106,7 +106,7 @@
describe("next_up over MCP", () => {
  };
  const picked = (repo: Repo, slots: number): number[] =>
    inSlotOrder(app, repo, readyNow(repoGraph(app.db, repo.id, { sealed: true })), [], slots).map((r) => r.issue.number);
    inSlotOrder(app, repo, readyNow(repoGraph(app.db, repo.id, { sealed: true }))).map((r) => r.issue.number);
  test("the list lists the order the picker starts in, ranked first and then the rest, and a ranked small issue survives a full small share", async () => {
    const { repo, numbers } = await orderRepo();
@@ -116,11 +116,11 @@
describe("next_up over MCP", () => {
    const before = await listed();
    expect(before.slice(0, 2)).toEqual([numbers[3]!, numbers[2]!]);
    expect(picked(repo, 5)).toEqual(before);
    // With no small slot at all, the unranked small issue is dropped; ranking it keeps it, in its place.
    expect(picked(repo, 0)).toEqual(before.filter((n) => n !== numbers[4]));
    // No cap holds a small issue back; ranking it moves it to the top.
    await tool(rw, { app: "alice/order", issue: numbers[4], to: "top" });
    const after = await listed();
    expect(after[0]).toBe(numbers[4]!);
    expect(picked(repo, 0)).toEqual(after);
    expect(after).toContain(numbers[4]!);
  });
});
@@ -261,19 +261,6 @@
describe("the ranked list is bounded", () => {
  });
});
describe("the picker's order", () => {
  test("at the small cap a ranked small issue survives and keeps its place; an unranked one is left out", async () => {
    const { slotOrder } = await import("../src/crew/small_share.ts");
    const items = [
      { id: "a", small: false },
      { id: "ranked-small", ranked: true, small: true },
      { id: "b", small: true },
    ];
    const picks = slotOrder(items, (t) => t, 1, 1).map((t) => t.id);
    expect(picks).toEqual(["a", "ranked-small"]);
  });
});
describe("the picker follows the page (#8826)", () => {
  test("with two ranked and three unranked issues, five ticks start the page's rows top to bottom", async () => {
    const { inSlotOrder } = await import("../src/crew/autonomy.ts");
@@ -305,7 +292,7 @@
describe("the picker follows the page (#8826)", () => {
        const ready = readyNow(repoGraph(app.db, repo.id, { sealed: true })).filter(
          (x) => !started.includes(x.issue.number),
        );
        const next = inSlotOrder(app, repo, ready, [], 5)[0]!;
        const next = inSlotOrder(app, repo, ready)[0]!;
        started.push(next.issue.number);
      }
      expect(started).toEqual(page);
@@ -4,13 +4,13 @@
 * pace sentence, and at the reserve's wall everything waits (#8962).
 */
import { afterAll, beforeAll, expect, test } from "bun:test";
import { afterAll, afterEach, beforeAll, expect, test } from "bun:test";
import { addToCrew } from "../src/actions/crew.ts";
import { assignIssue, openIssue } from "../src/actions/issues.ts";
import { commitToBranch, createRepo, updateRepoSettings } from "../src/actions/repos.ts";
import { paceFloor, setCapacity } from "../src/core/capacity.ts";
import { getRepoById, type Repo } from "../src/core/repos.ts";
import { claimRun, createRun, getRun, listActive } from "../src/core/runs.ts";
import { cancelRun, claimRun, createRun, getRun, listActive } from "../src/core/runs.ts";
import { noteMeasure } from "../src/core/measure.ts";
import { setHeadroom } from "../src/core/standing.ts";
import { addSubscription } from "../src/core/subscriptions.ts";
@@ -23,10 +23,13 @@
let standIn: StandInCrew;
beforeAll(async () => {
  standIn = await startStandInCrew({ tickMs: 50 });
  setCapacity(standIn.app.db, "pace.floor", "2", standIn.alice.id);
  setCapacity(standIn.app.db, "crew.concurrency", "10", standIn.alice.id);
  setCapacity(standIn.app.db, "crew.concurrency", "4", standIn.alice.id);
}, 30_000);
afterAll(() => stopStandInCrew(standIn));
// Speed bounds every run at once: each test starts with no run left over from the one before.
afterEach(() => {
  for (const r of listActive(standIn.app.db, "agent")) cancelRun(standIn.app.db, r.id);
});
async function until(done: () => boolean, what: string, ms = 20_000): Promise<void> {
  const deadline = Date.now() + ms;
@@ -72,7 +75,7 @@
function assigned(repo: Repo, title: string, pick: boolean): string {
  return run.id;
}
test("the floor is a config value, 2 by default", () => {
test("the floor follows Speed: half of 4 is 2", () => {
  expect(paceFloor(standIn.app.db)).toBe(2);
});
@@ -1,131 +0,0 @@
/**
 * A polish issue is capped small (#8852): past the cap its run is stopped
 * with one comment; under it, or on any other issue, nothing happens. The
 * clock is a Date handed in, never the wall's.
 */
import { afterAll, beforeAll, describe, expect, test } from "bun:test";
import { mkdtemp, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { openIssue, setIssueLabels } from "../src/actions/issues.ts";
import { createLabel, createRepo } from "../src/actions/repos.ts";
import { listComments, type Issue } from "../src/core/issues.ts";
import { getRepoById, type Repo } from "../src/core/repos.ts";
import { claimRun, createRun, getRun } from "../src/core/runs.ts";
import { createUser, type User } from "../src/core/users.ts";
import { isSmall } from "../src/crew/small_share.ts";
import { leftLine, leftOf, pastCap, tickPolish } from "../src/crew/polish_cap.ts";
let dataDir: string;
let app: App;
let alice: User;
let repo: Repo;
function runOn(title: string, labels: string[]) {
  const made = openIssue(app, alice, getRepoById(app.db, repo.id)!, { title });
  if (!made.ok) throw new Error(String(made.error));
  const issue: Issue = made.value;
  if (labels.length > 0) expect(setIssueLabels(app, alice, repo, issue, labels).ok).toBe(true);
  const run = createRun(app.db, { repoId: repo.id, kind: "agent", issueId: issue.id, actorId: alice.id, reason: "assigned" });
  claimRun(app.db, run.id);
  return { issue, run };
}
const startedAt = (id: string) => Date.parse(getRun(app.db, id)!.startedAt!);
const comments = (issue: Issue) => listComments(app.db, issue.id).filter((c) => c.body.includes("polish cap"));
beforeAll(async () => {
  dataDir = await mkdtemp(join(tmpdir(), "forge-polish-"));
  app = createApp({ dataDir, port: 0 });
  const a = await createUser(app.db, {
    origin: "seed", trusted: true, username: "alice", email: "[email protected]",
    password: "a-good-passphrase", adminIfFirst: true,
  });
  if (!a.ok) throw new Error(a.error);
  alice = a.value;
  const made = await createRepo(app, alice, { name: "notes", visibility: "private" });
  if (!made.ok) throw new Error(String(made.error));
  repo = made.value;
  for (const [n, c] of [["polish", "aabbcc"], ["feature", "112233"]] as const) {
    const l = createLabel(app, alice, repo, n, c);
    if (!l.ok && l.error !== "taken") throw new Error(String(l.error));
  }
  // The drive reads the repository as stored, with its autonomy author.
  repo = { ...getRepoById(app.db, repo.id)!, autonomyBy: alice.id };
});
afterAll(async () => {
  await app.close?.();
  await rm(dataDir, { recursive: true, force: true });
});
describe("the rules", () => {
  test("polish counts as small-fixes work", () => {
    expect(isSmall("Round the corners", ["polish"])).toBe(true);
    expect(isSmall("Round the corners", ["Polish"])).toBe(true);
  });
  test("a run is past the cap at exactly 60 minutes, not at 59", () => {
    const at = "2026-11-02T10:00:00.000Z";
    expect(pastCap(at, 60, new Date("2026-11-02T10:59:59.000Z"))).toBe(false);
    expect(pastCap(at, 60, new Date("2026-11-02T11:00:00.000Z"))).toBe(true);
    expect(pastCap(null, 60, new Date("2030-01-01T00:00:00Z"))).toBe(false);
  });
  test("the line names the cap and what is left, plainly", () => {
    expect(leftLine(60, leftOf(undefined))).toBe(
      "Stopped at the 60-minute polish cap, not extended. Left: nothing landed, no pull open.",
    );
    expect(leftLine(45, leftOf(12))).toBe(
      "Stopped at the 45-minute polish cap, not extended. Left: pull #12 is open, unmerged.",
    );
  });
});
describe("the tick", () => {
  test("a polish run under the cap is left running", () => {
    const { issue, run } = runOn("Under: nudge the margin", ["polish"]);
    expect(tickPolish(app, repo, new Date(startedAt(run.id) + 59 * 60_000))).toBe(0);
    expect(getRun(app.db, run.id)!.state).toBe("running");
    expect(comments(issue)).toHaveLength(0);
  });
  test("past the cap it stops with one comment, however often the tick runs; a non-polish issue is untouched", () => {
    const polish = runOn("Past: nudge the padding", ["polish"]);
    const other = runOn("Past: a feature", ["feature"]);
    const unlabelled = runOn("Past: no label", []);
    const late = new Date(startedAt(polish.run.id) + 61 * 60_000);
    // Earlier tests' runs may also be past by now; this run is the one under test.
    expect(tickPolish(app, repo, late)).toBeGreaterThanOrEqual(1);
    expect(tickPolish(app, repo, late)).toBe(0);
    expect(getRun(app.db, polish.run.id)!.state).toBe("cancelled");
    expect(getRun(app.db, polish.run.id)!.summary).toBe("stopped at the 60-minute polish cap");
    const said = comments(polish.issue);
    expect(said).toHaveLength(1);
    expect(said[0]!.body).toContain("Left: nothing landed, no pull open.");
    expect(getRun(app.db, other.run.id)!.state).toBe("running");
    expect(getRun(app.db, unlabelled.run.id)!.state).toBe("running");
    expect(comments(other.issue)).toHaveLength(0);
  });
});
describe("who says it", () => {
  test("with no autonomy author the run's actor says it: the stop is never silent", () => {
    const { issue, run } = runOn("Silent: nudge the gap", ["polish"]);
    const bare = { ...repo, autonomyBy: null };
    tickPolish(app, bare, new Date(startedAt(run.id) + 61 * 60_000));
    expect(getRun(app.db, run.id)!.state).toBe("cancelled");
    const said = comments(issue);
    expect(said).toHaveLength(1);
    expect(said[0]!.authorId).toBe(alice.id);
  });
  test("with no one to say it the run is left, not stopped silently", () => {
    const { issue, run } = runOn("Mute: nudge the gap", ["polish"]);
    app.db.query("UPDATE run SET actor_id = NULL WHERE id = ?1").run(run.id);
    tickPolish(app, { ...repo, autonomyBy: null }, new Date(startedAt(run.id) + 61 * 60_000));
    expect(getRun(app.db, run.id)!.state).toBe("running");
    expect(comments(issue)).toHaveLength(0);
  });
});
@@ -17,7 +17,7 @@
import { getRepoById, type Repo } from "../src/core/repos.ts";
import { createRun } from "../src/core/runs.ts";
import { createUser, type User } from "../src/core/users.ts";
import { driveRepo } from "../src/crew/autonomy.ts";
import { isPolish, polishPosition, polishSpend, polishWords, validPolishShare } from "../src/crew/small_share.ts";
import { isPolish, polishPosition, polishSpend, polishWords, validPolishShare } from "../src/crew/polish_share.ts";
import { serve, type Servers } from "../src/http/server.ts";
describe("the rules", () => {
@@ -80,10 +80,12 @@
test("every capacity row shows its value and control, hover-free", async () => {
  const listed = listCapacity(app, admin);
  if (!listed.ok) throw new Error("no capacity");
  for (const s of listed.value.settings) {
    const row = rowsOf(page).find((r) => r.includes(`name="key" value="${s.key}"`));
    // a row derived from Speed is read-only: its value, no form
    const mark = s.source === "derived" ? `data-derived="${s.key}"` : `name="key" value="${s.key}"`;
    const row = rowsOf(page).find((r) => r.includes(mark));
    expect(row, s.key).toBeDefined();
    expect(row).toContain(s.label);
    expect(row).toContain("Now <span");
    if (s.source !== "derived") expect(row).toContain("Now <span");
    expect(row).not.toContain("row-actions");
  }
});
@@ -134,14 +134,15 @@
describe("tui capacity", () => {
    h.stop();
  });
  test("queue.depth, which the page sets, changes after a confirm", async () => {
  test("queue.depth follows Speed: an edit there changes nothing", async () => {
    const before = capacityValue(app.db, "queue.depth");
    const h = boot(carol);
    for (let i = 0; i < CAPACITY_KEYS.indexOf("queue.depth"); i++) await h.press("j");
    await h.press("e");
    for (let i = 0; i < 4; i++) await h.press("backspace");
    await h.press("4", "enter");
    await h.press("9", "enter");
    await h.press("left", "enter");
    expect(capacityValue(app.db, "queue.depth")).toBe("4");
    expect(capacityValue(app.db, "queue.depth")).toBe(before);
    h.stop();
  });
@@ -78,11 +78,10 @@
test("builds fill the pace slots, yet a review or assigned run still starts; a t
  if (!sub.ok) throw new Error(sub.error);
  setHeadroom(app.db, sub.value.id, 0);
  app.db.query("INSERT INTO subscription_grant (scope_id, agent_id, subscription_id) VALUES (?1, '', ?2)").run(made.value.id, sub.value.id);
  setCapacity(app.db, "crew.concurrency", "10", alice.id);
  setCapacity(app.db, "pace.floor", "2", alice.id);
  setCapacity(app.db, "crew.concurrency", "7", alice.id); // the pace floor follows: half of 7 is 3
  const now = Date.now();
  noteMeasure(app.db, sub.value.id, { window: "week", usedPct: 70, resetsAt: new Date(now + 3.5 * DAY).toISOString(), observedAt: new Date(now).toISOString() });
  // 30% free now, 36% an hour ago: 6 points an hour, far over what is allowed, so the pace is the floor of 2 slots.
  // 30% free now, 36% an hour ago: 6 points an hour, far over what is allowed, so the pace is the floor of 3 slots.
  app.db.query("INSERT INTO week_reading (scope, at, free_pct) VALUES (?1, ?2, 36)").run(sub.value.id, new Date(now - 3_600_000).toISOString());
  const on = await updateRepoSettings(app, alice, made.value, { autonomy: "autonomous", autonomyDirection: "Ship.", autonomyCeilingUsd: 1000, autonomySlots: 4, autonomyBy: alice.id });
  expect(on.ok).toBe(true);
@@ -100,15 +99,15 @@
test("builds fill the pace slots, yet a review or assigned run still starts; a t
  };
  const stateOf = (id: string) => getRun(app.db, id)!.state;
  const logOf = (id: string) => readRunLog(app.config.dataDir, id).lines.join("\n");
  // Two builds fill the pace; one review and one assigned run are going in their own lane.
  run("push", true);
  run("push", true);
  // Three builds fill the pace; one review and one assigned run are going in their own lane.
  for (let i = 0; i < 3; i++) run("push", true);
  run("review", true);
  run("review", true);
  run("assigned", true);
  const build = run("push", false);
  const review = run("review", false);
  await until(() => logOf(build).includes("queued, not started: Ahead of pace"), "the build to be held");
  await until(() => logOf(review).includes("2 of 2 places for reviews and assigned work are taken"), "the third priority run to be held");
  await until(() => logOf(review).includes("3 of 3 places for reviews and assigned work are taken"), "the third priority run to be held");
  expect(stateOf(build)).toBe("queued");
  expect(stateOf(review)).toBe("queued");
  // One priority run ends: the lane has room and the review starts, the build still waits.
@@ -83,7 +83,7 @@
beforeAll(async () => {
  const a = await seedAdmin(app, { username: "alice", email: "[email protected]", password: "a-long-passphrase" });
  if (!a.ok) throw new Error("signup failed");
  alice = a.value;
  setCapacity(app.db, "pace.floor", "2", alice.id);
  setCapacity(app.db, "crew.concurrency", "4", alice.id); // pace floor follows Speed: half of 4 is 2
  const made = await createRepo(app, alice, { name: "svc", visibility: "private" });
  if (!made.ok) throw new Error(String(made.error));
  repo = made.value;
@@ -120,7 +120,7 @@
afterAll(async () => {
beforeEach(() => forgetWeek());
// A failed expectation must not leave the lowered crew concurrency for later tests.
afterEach(() => {
  changeCapacity(app, alice, "crew.concurrency", null);
  changeCapacity(app, alice, "crew.concurrency", "4");
});
test("behind pace, with an idle slot and nothing startable, the tick releases the gated issue and says why", async () => {
@@ -196,6 +196,8 @@
test("Usage → Spend carries the same sentence, so pacing is not mistaken for t
    });
    const cookie = (signin.headers.get("set-cookie") ?? "").split(";")[0] ?? "";
    const spend = () => fetch(`${servers.url}/settings/spend`, { headers: { cookie } }).then((r) => r.text());
    expect(changeCapacity(app, alice, "crew.concurrency", String(Number(capacityDefault("crew.concurrency")))).ok).toBe(true);
    forgetWeek();
    expect(await spend()).not.toContain("below its ceiling");
    expect(changeCapacity(app, alice, "crew.concurrency", "1").ok).toBe(true);
    forgetWeek();
		@@ -216,7 +216,8 @@ while the suspect is judged. A pull in two red batches is never in a third:
216	216	it waits for a gate of its own. Red alone, it is handed back (`[queue] red
217	217	alone`); green alone, it rides at the tail of a later batch, never its head.
218	218	While a candidate gates, the next one gates on top of it (`queue.depth`
219		under Settings → Capacity, `FORGE_QUEUE_DEPTH`, default 2): when the first
	219	derived from Speed: half of it rounded up, 1 to 4, shown read-only under Settings → Capacity
	220	and on the knobs panel): when the first
220	221	lands whole the next lands right after it, on the tree it was gated on; when
221	222	it does not, the next is formed again on main. A gate beyond a line's first
222	223	starts only on a free check slot and holds it, and two slots are always kept
		@@ -296,13 +297,12 @@ bar, and the terminal's Flow command prints it as a line per app
296	297	(`flow/held.ts`, kept 5 s). Of the startable, the picker takes the order Next up shows
297	298	(#8826, `pickOrder` in `core/next_up.ts`): the owner's ranked issues by place,
298	299	then the ready order, what the owner raised again first. Small issues — a title like "A test pins …" or
299		"Tests: …", or a label `test`, `tests`, `tests-only` or `small` (#7571, `crew/small_share.ts`) — hold
300		at most `slots.smallShare` percent of the builder slots (default 30, rounded up:
301		2 of 5; an admin sets it on `/settings/capacity`). At the cap a small issue is
302		skipped, not waited on, unless the owner ranked it. The tick line's `small: 1/2`, the
303		Flow command's `small 1/2`, the app's row in Today on `/boards` (`small
304		issues: 1 of 2 slots`) and the studio's crew panel show small issues in
305		flight of what they may hold. An issue labelled `polish` is a small issue too, and its run is stopped past `polish.capMinutes` (default 60) with one comment saying what is left (`crew/polish_cap.ts`, `docs/features/polish-cap.md`). When nothing is startable while builder slots are free and some of the
	300	"Tests: …", or a label `test`, `tests`, `tests-only`, `small` or `polish`
	301	(`crew/polish_share.ts`) — hold no slots of
	302	their own: Speed and that order bound them like any work (the small share and the polish run
	303	cap are gone; a stored old value is ignored). Polish is held to its share of the week
	304	(`docs/features/polish-share.md`). When nothing is startable while builder slots are free
	305	and some of the
306	306	held are stalled, capped or parked twice, the planner is owed one pass with
307	307	that breakdown in its brief, to re-plan them into smaller, fresh issues; a
308	308	full plate and its own unanswered decline do not hold that pass, and the
		@@ -500,8 +500,8 @@ each subscription's `week 38%, 5h 80%` line, and the forge usage block
500	500	The week's pace (`src/crew/week.ts`) limits only the crew's own picks: the
501	501	builds the tick assigns under the operator's name (marked `pick` on the
502	502	`issue.assigned` event). Reviews and issues a person assigned are not slowed
503		by it: while the pace allows any slots at all, up to `pace.floor` of them (a
504		capacity setting, env `FORGE_PACE_FLOOR`, default 2, 1 to 16, read on every
	503	by it: while the pace allows any slots at all, up to `pace.floor` of them (derived from Speed:
	504	half of it, at least 1, read-only on the capacity page and the knobs panel, read on every
505	505	pump) run at once, apart from the picks; it is also the fewest slots a fast burn
506	506	slows a repository to. At the reserve's wall (no slots) everything waits for the
507	507	reset. Not covered: feedback, check and conflict runs still count with the picks.
		@@ -6,7 +6,7 @@ A bet is a name, an appetite (a share of the week), what done looks like in a fe
6	6	- Propose. "Ask the planner to propose bets" groups open issues in no live bet: by first label; else by the pillar an unlabelled issue holds up (later and structural issues are skipped); else by the title word most unlabelled issues share. A group of two or more becomes a proposal at 20% of the week. At most five proposals a pass; no model, so the same state gives the same proposals.
7	7	- Notes. Only notes written by the repo's owner or an admin count (a visitor's never join or appear). Such a note joins a proposal when its issue is held there, it names one of the group's issues as `#N`, or it shares two words with the group's name and its issues' titles; it is quoted in the journeys as "The owner's note".
8	8	- Back. The owner (a person who administers the repo, never an agent) backs one with a share. At most 5 run, and their shares stay within 100%.
9		- Picks. Once a repository has ever had a bet backed, builders pick only scopes of a running bet, issues the owner asked for or raised, and small fixes, polish included (held to `slots.smallShare`, #7571; a polish run is capped, see polish-cap.md). An issue in no bet does not start by itself. A repository with no bet picks as before.
	9	- Picks. Once a repository has ever had a bet backed, builders pick only scopes of a running bet, issues the owner asked for or raised, and small fixes, polish included (polish held to its share of the week, see polish-share.md). An issue in no bet does not start by itself. A repository with no bet picks as before.
10	10	- Appetite. The budget is share × builder slots × one week of builder time, counted from the runs on the bet's scopes since it was backed. At the budget the bet stops: no extension. Its left line defaults to the open scopes; the lead rewrites it in one line; the owner re-backs, cuts or ends it (ending as done is for a stopped bet only; a running bet finishes when every scope closes).
11	11	- Scopes read figuring out (no run yet), executing, or raised hand (nothing moved for two days), or done.
12	12	- Finishing. When every scope is closed the bet is finished and its page says "This is done. Try it." with a link; the owner taps Feels done or Not yet, because… (the bet returns to stopped with that reason). `/changelog` marks each landing with its bet and filters by it (`?bet=`).
		@@ -12,6 +12,12 @@ A change applies on the next pump and leaves the event the setting's own page le
12	12
13	13	## Derived from Speed
14	14
15		`pace.floor` (half of Speed, at least 1) and `queue.depth` (half of Speed rounded up, 1 to 4) follow Speed until someone sets them on Settings › Capacity; a stored value always wins and nothing stored is dropped. While they follow, the Speed row (page, terminal, MCP) says `(derived from Speed)` beside each, and the capacity page and its terminal screen mark the row `derived`. Because the floor was a fixed 2 before, an install with no stored floor now gets half its Speed (Speed 10: 5). That is a deliberate move of the default pace; set `pace.floor` to keep the old number.
	15	`pace.floor` (half of Speed, at least 1) and `queue.depth` (half of Speed rounded up, 1 to 4)
	16	are computed from Speed every time they are read. They show with their value, read-only, on
	17	the knobs panel and under Settings › Capacity; a POST that tries to set one is refused with
	18	a plain line, and `FORGE_PACE_FLOOR`, `FORGE_QUEUE_DEPTH` and any stored value are ignored.
	19	The reserve is not one of them: it is what Weekly budget leaves (100 minus `week.use`), so it
	20	moves with that dial, not with Speed. The small share and the polish run cap are gone; a
	21	stored old value is ignored.
16	22
17	23	`week.use` is new; a stored or `FORGE_WEEK_USE` value is read as the budget.
		@@ -1,10 +0,0 @@
1		# Polish cap
2
3		An issue labelled `polish` is small work, and it is capped small (#8852). A builder run on it that has gone `polish.capMinutes` of run time (default 60) is stopped, not extended. The crew's tick checks every minute, from the run's own start time.
4
5		- Set it. An admin changes Run time a polish issue may take (minutes) on `/settings/capacity`. It is read on every tick.
6		- What you see. The run ends cancelled with the summary "stopped at the N-minute polish cap", and the issue gets one comment: `Stopped at the 60-minute polish cap, not extended. Left: pull #M is open, unmerged.` or `Left: nothing landed, no pull open.` It is the run's open pull that says what is left; a polish run never produces a second comment.
7		- Who says it. The person who turned autonomy on, else the user the run acted as. If neither exists the run is left running rather than stopped silently.
8		- Other work. Only the label `polish` (any case) is capped; polish also counts as a small fix against `slots.smallShare`.
9
10		Left out: stopping a polish issue before its run starts, and reading the run's last summary into the line (a running run has none yet).
		@@ -1,6 +1,6 @@
1	1	# The polish share
2	2
3		The percent of the last seven days' agent spend that polish may take: issues labelled `polish`, or in the small-fixes lane (`isSmall`, `src/crew/small_share.ts`). 10 to start; a whole number 0 to 50. At 0 no polish starts.
	3	The percent of the last seven days' agent spend that polish may take: issues labelled `polish`, or in the small-fixes lane (`isSmall`, `src/crew/polish_share.ts`). 10 to start; a whole number 0 to 50. At 0 no polish starts.
4	4
5	5	- Set it. Web: Settings → Branch and gates → Polish share. Terminal: Autonomy, key `o`. Both go through `updateRepoSettings`, refuse anything but 0–50, and are on the settings trail, so an open week page or screen updates.
6	6	- See it. `/:owner/:name/week` ("Polish this week"), the terminal's week screen (last line) and the `week` MCP tool (`polish: { share, percent, polishUsd, totalUsd, under, says }`) print the same `polishWords`.
		@@ -37,6 +37,9 @@ import { signinReach, signsInWithoutEdge } from "../core/accounts.ts";
37	37	import type { User } from "../core/users.ts";
38	38	import { err, ok, type Result } from "../kernel/result.ts";
39	39
	40	/** What a refused change to a dial that follows Speed says, on every door. */
	41	export const DERIVED_WORDS = "The pace floor and the queue depth follow Speed: change Speed (crew.concurrency) and they move with it.";
	42
40	43	/** The six guards a caller may set by `key`: the MCP tool's enum and the terminal's `e`. */
41	44	export const SETTABLE_CAPACITY = [
42	45	"crew.concurrency",
		@@ -122,7 +125,7 @@ export function listCapacity(
122	125	label: CAPACITY[key].label,
123	126	help: CAPACITY[key].help,
124	127	value: effectiveCapacity(app.db, key),
125		source: followsSpeed(app.db, key) ? "derived" : storedCapacity(app.db, key) === undefined ? "default" : "setting",
	128	source: followsSpeed(key) ? "derived" : storedCapacity(app.db, key) === undefined ? "default" : "setting",
126	129	default: bootDefault(app.db, key),
127	130	env: CAPACITY[key].env,
128	131	...changedOf(app.db, key),
		@@ -166,11 +169,12 @@ export function changeCapacity(
166	169	value: string \| null,
167	170	): Result<
168	171	{ key: CapacityKey; from: string; to: string },
169		"not_found" \| "no_such_setting" \| "invalid_value" \| "no_credential"
	172	"not_found" \| "no_such_setting" \| "invalid_value" \| "no_credential" \| "derived"
170	173	> {
171	174	const who = admin(actor);
172	175	if (!who.ok) return who;
173	176	if (!isCapacityKey(key)) return err("no_such_setting");
	177	if (followsSpeed(key)) return err("derived");
174	178	const next = value === null ? null : value.trim();
175	179	if (next !== null && next !== "" && !validCapacity(key, next))
176	180	return err("invalid_value");
		@@ -9,12 +9,12 @@ import type { App } from "../app.ts";
9	9	import { changeCapacity } from "./capacity.ts";
10	10	import { updateRepoSettings } from "./repos.ts";
11	11	import { getRepo } from "../core/repos.ts";
12		import { AUTONOMY_WORDS, knobRepos, type AutonomyWord, type KnobId } from "../crew/knobs.ts";
13		import { validPolishShare } from "../crew/small_share.ts";
	12	import { AUTONOMY_WORDS, DERIVED_KNOBS, knobRepos, type AutonomyWord, type KnobId } from "../crew/knobs.ts";
	13	import { validPolishShare } from "../crew/polish_share.ts";
14	14	import { err, ok, type Result } from "../kernel/result.ts";
15	15	import type { User } from "../core/users.ts";
16	16
17		export type KnobError = "not_found" \| "no_such_knob" \| "invalid_value";
	17	export type KnobError = "not_found" \| "no_such_knob" \| "invalid_value" \| "derived";
18	18
19	19	const WORDS: Record<AutonomyWord, { autonomy: "off" \| "autonomous"; plansNeedNod: boolean; decisionsBy: "me" \| "decider" }> = {
20	20	off: { autonomy: "off", plansNeedNod: true, decisionsBy: "me" },
		@@ -31,6 +31,7 @@ export async function setKnob(
31	31	): Promise<Result<{ knob: KnobId; value: string }, KnobError>> {
32	32	if (actor?.isAdmin !== true \|\| actor.kind === "agent") return err("not_found");
33	33	const v = value.trim();
	34	if (DERIVED_KNOBS.includes(knob)) return err("derived");
34	35	if (knob === "speed" \|\| knob === "budget") {
35	36	const changed = changeCapacity(app, actor, knob === "speed" ? "crew.concurrency" : "week.use", v);
36	37	if (!changed.ok) return err(changed.error === "not_found" ? "not_found" : "invalid_value");
		@@ -74,7 +74,7 @@ import {
74	74	requireWriter,
75	75	type AccessError,
76	76	} from "./access.ts";
77		import { validPolishShare } from "../crew/small_share.ts";
	77	import { validPolishShare } from "../crew/polish_share.ts";
78	78	import { removeInstallCache } from "../crew/workdir.ts";
79	79	import type { SettingsChanged } from "../core/settings_changed.ts";
80	80
		@@ -10,6 +10,7 @@ export const route: Route = {
10	10	refusals: {
11	11	not_found: "the token is not a person who administers the forge (404)",
12	12	no_such_setting: "{key} is not a capacity setting (422)",
	13	derived: "{key} is pace.floor or queue.depth, which follow Speed and are not set directly (422)",
13	14	invalid_value: "the value is outside what this setting takes (422)",
14	15	no_credential: "the setting needs a credential the forge does not hold (422)",
15	16	},
		@@ -28,8 +28,6 @@ export type CapacityKey =
28	28	\| "children.registryEgress"
29	29	\| "guard_new_accounts"
30	30	\| "signin.edge"
31		\| "slots.smallShare"
32		\| "polish.capMinutes"
33	31	\| "pace.floor";
34	32
35	33	interface Definition {
		@@ -77,7 +75,7 @@ export const CAPACITY: Record<CapacityKey, Definition> = {
77	75	env: "FORGE_QUEUE_DEPTH",
78	76	kind: { type: "count", min: 1, max: 4 },
79	77	fallback: "2",
80		help: "How many merge-queue candidates of one repository gate at once, each on top of the one before: while one gates on main the next gates on it, and lands right after it if both are green. 1 gates one candidate at a time. A gate beyond the first takes a free check slot only, never one of the two kept for pull checks.",
	78	help: "How many merge-queue candidates of one repository gate at once, each on top of the one before: while one gates on main the next gates on it, and lands right after it if both are green. Derived from Speed (half of it rounded up, 1 to 4), read-only; FORGE_QUEUE_DEPTH is ignored. A gate beyond the first takes a free check slot only, never one of the two kept for pull checks.",
81	79	},
82	80	"queue.batch": {
83	81	label: "Merge queue batch size",
		@@ -135,26 +133,12 @@ export const CAPACITY: Record<CapacityKey, Definition> = {
135	133	fallback: "on",
136	134	help: "on reads the platform edge's identity headers (when the forge has an edge secret) and offers its sign-in; off ignores them on every door, so people sign in with the forge's own methods — password and passkey. Accounts the edge made keep their names but have no password until they set one. Takes effect on the next request.",
137	135	},
138		"slots.smallShare": {
139		label: "Builder slots small issues may hold (%)",
140		env: "FORGE_SLOTS_SMALL_SHARE",
141		kind: { type: "count", min: 0, max: 100 },
142		fallback: "30",
143		help: "The most of a repository's builder slots that tests-only and small-addition issues (\"A test pins …\", or a label test, tests, tests-only or small) hold at once, as a percent rounded up: 30 lets 2 of 5 slots go to them. At the cap a small issue is skipped and the slot goes to the next issue in the Next up order; a ranked small issue is still taken. 100 lifts the cap; 0 starts none. Read on every pick.",
144		},
145		"polish.capMinutes": {
146		label: "Run time a polish issue may take (minutes)",
147		env: "FORGE_POLISH_CAP_MINUTES",
148		kind: { type: "count", min: 1, max: 1440 },
149		fallback: "60",
150		help: "An issue labelled polish is small work: a builder run on it that has gone this many minutes is stopped, not extended, and the issue gets one comment saying what is left. Read on every tick.",
151		},
152	136	"pace.floor": {
153	137	label: "Slots the pace always leaves reviews and assigned work",
154	138	env: "FORGE_PACE_FLOOR",
155	139	kind: { type: "count", min: 1, max: 16 },
156	140	fallback: "2",
157		help: "While the week's pace allows any slots, this many reviews and issues a person assigned may run at once, apart from the crew's own picks, however hard the pace slows them; also the fewest slots a fast burn slows a repository to. At the reserve's wall everything waits. Read on every pump.",
	141	help: "While the week's pace allows any slots, this many reviews and issues a person assigned may run at once, apart from the crew's own picks, however hard the pace slows them; also the fewest slots a fast burn slows a repository to. At the reserve's wall everything waits. Derived from Speed (half of it, at least 1), read-only; FORGE_PACE_FLOOR is ignored; read on every pump.",
158	142	},
159	143	};
160	144
		@@ -378,11 +362,11 @@ export function paceFloor(db: Database): number {
378	362	return Number(effectiveCapacity(db, "pace.floor"));
379	363	}
380	364
381		/** The dials that follow Speed (`crew.concurrency`) until set on their own. */
	365	/** The dials Speed (`crew.concurrency`) sets: always derived, never stored. */
382	366	export type SpeedDerivedKey = "pace.floor" \| "queue.depth";
383	367
384		export function followsSpeed(db: Database, key: CapacityKey): key is SpeedDerivedKey {
385		return (key === "pace.floor" \|\| key === "queue.depth") && storedCapacity(db, key) === undefined;
	368	export function followsSpeed(key: CapacityKey): key is SpeedDerivedKey {
		sentinelcrew 2d ago outdated Unused `_db` parameter and a function that is now a constant check. Drop `_db`, and fix the comments above it ("until set on their own").
	369	return key === "pace.floor" \|\| key === "queue.depth";
386	370	}
387	371
388	372	/** What Speed implies for a dial that follows it: half of Speed, at least 1 for the floor; half rounded up, 1 to 4, for the depth. */
		@@ -392,9 +376,9 @@ export function derivedFromSpeed(db: Database, key: SpeedDerivedKey): number {
392	376	return Math.min(4, Math.max(1, Math.ceil(speed / 2)));
393	377	}
394	378
395		/** A capacity's value as the crew reads it: derived from Speed while a following dial is unset. */
	379	/** A capacity's value as the crew reads it: derived from Speed for the dials that follow it. */
396	380	export function effectiveCapacity(db: Database, key: CapacityKey): string {
397		return followsSpeed(db, key) ? String(derivedFromSpeed(db, key)) : capacityValue(db, key);
	381	return followsSpeed(key) ? String(derivedFromSpeed(db, key)) : capacityValue(db, key);
398	382	}
399	383
400	384	/** The share of the week the crew may use, in percent (`week.use`); the rest is the reserve. */
		@@ -456,16 +440,6 @@ export function queueBatch(db: Database): number {
456	440	return Number(capacityValue(db, "queue.batch"));
457	441	}
458	442
459		/** The percent of builder slots small issues may hold (#7571). */
460		export function smallShare(db: Database): number {
461		return Number(capacityValue(db, "slots.smallShare"));
462		}
463
464		/** The minutes of run time a polish issue may take before its run is stopped (#8852). */
465		export function polishCapMinutes(db: Database): number {
466		return Number(capacityValue(db, "polish.capMinutes"));
467		}
468
469	443	/** Whether the platform edge's identity is read at all; on every request. */
470	444	export function edgeSigninOn(db: Database): boolean {
471	445	return capacityValue(db, "signin.edge") !== "off";