feat(tasks): add conditional claimability

MoltNet-Diary: c96a5197-c20c-40f9-91c4-88d505d4db36
Task-Group: conditional-task-claimability
Task-Family: feature

Author: legreffier[bot]

apps/agent-daemon/README.md

@@ -250,7 +250,7 @@ Leave it running. It idles until a task lands in its queue.
 
 In another terminal, with `.moltnet/local-dev/env` sourced. Pick the CLI
 form (recommended — schema-validates locally, no Node dependency in the
-imposer path) or the template-driven TS form (legacy path that supports
+proposer path) or the template-driven TS form (legacy path that supports
 `{{placeholder}}` substitution via `--set`).
 
 ::: code-group
@@ -325,7 +325,7 @@ pnpm exec tsx tools/src/tasks/create-pr-review.ts \
   --repo <owner/repo>
 ```
 
-This helper stays imposer-only. It reads PR metadata, ensures the PR
+This helper stays proposer-only. It reads PR metadata, ensures the PR
 correlation marker exists, loads the binary rubric, and creates the
 `pr_review` task. The daemon-claimed LLM attempt remains responsible for
 the review itself and for any requested outward action such as `gh pr comment`.

apps/agent-daemon/e2e/daemon.e2e.test.ts

@@ -69,7 +69,7 @@ function buildProducerVerification(inputCid: string) {
 
 /**
  * The realistic local-daemon scenario is "one agent, one team, one
- * daemon" — the same agent imposes a task and runs the daemon that
+ * daemon" — the same agent proposes a task and runs the daemon that
  * claims it. Cross-agent claiming requires team membership (canAccessTeam
  * on /tasks list); a diary grant alone is not sufficient for the list
  * endpoint, only for individual claim/heartbeat/complete by id.
@@ -103,7 +103,7 @@ describe('Agent daemon (e2e)', () => {
     await harness?.teardown();
   });
 
-  function imposeCuratePackTask() {
+  function proposeCuratePackTask() {
     return agent.tasks.create({
       taskType: 'curate_pack',
       teamId,
@@ -115,7 +115,7 @@ describe('Agent daemon (e2e)', () => {
     });
   }
 
-  function imposeFulfillBriefTask(correlationId: string) {
+  function proposeFulfillBriefTask(correlationId: string) {
     return agent.tasks.create({
       taskType: 'fulfill_brief',
       teamId,
@@ -129,7 +129,10 @@ describe('Agent daemon (e2e)', () => {
     });
   }
 
-  function imposeRunEvalTask(correlationId: string, variantLabel = 'baseline') {
+  function proposeRunEvalTask(
+    correlationId: string,
+    variantLabel = 'baseline',
+  ) {
     return agent.tasks.create({
       taskType: 'run_eval',
       teamId,
@@ -145,7 +148,7 @@ describe('Agent daemon (e2e)', () => {
     });
   }
 
-  function imposeJudgeEvalAttemptTask(
+  function proposeJudgeEvalAttemptTask(
     correlationId: string,
     targetTaskId: string,
   ) {
@@ -177,7 +180,7 @@ describe('Agent daemon (e2e)', () => {
     });
   }
 
-  function imposePrReviewTask() {
+  function proposePrReviewTask() {
     return agent.tasks.create({
       taskType: 'pr_review',
       teamId,
@@ -218,7 +221,7 @@ describe('Agent daemon (e2e)', () => {
   }
 
   it('PollingApiTaskSource claims a queued task and exits drain mode when empty', async () => {
-    const created = await imposeCuratePackTask();
+    const created = await proposeCuratePackTask();
 
     const source = new PollingApiTaskSource({
       agent: agent,
@@ -249,7 +252,7 @@ describe('Agent daemon (e2e)', () => {
   });
 
   it('two parallel claim() calls race on the same task — server CAS picks one winner', async () => {
-    const created = await imposeCuratePackTask();
+    const created = await proposeCuratePackTask();
 
     const sourceA = new PollingApiTaskSource({
       agent: agent,
@@ -285,7 +288,7 @@ describe('Agent daemon (e2e)', () => {
   });
 
   it('runtime.start() drives a full claim → execute → complete loop', async () => {
-    const created = await imposeCuratePackTask();
+    const created = await proposeCuratePackTask();
 
     const runtime = new AgentRuntime({
       source: new PollingApiTaskSource({
@@ -367,7 +370,7 @@ describe('Agent daemon (e2e)', () => {
   }, 60_000);
 
   it('runtime.start() can drive a full pr_review judgment loop with a stub executor', async () => {
-    const created = await imposePrReviewTask();
+    const created = await proposePrReviewTask();
 
     const runtime = new AgentRuntime({
       source: new PollingApiTaskSource({
@@ -435,7 +438,7 @@ describe('Agent daemon (e2e)', () => {
   }, 60_000);
 
   it('fails a claimed attempt when executor throws before reporter.open()', async () => {
-    const created = await imposeCuratePackTask();
+    const created = await proposeCuratePackTask();
 
     const runtime = new AgentRuntime({
       source: new PollingApiTaskSource({
@@ -469,15 +472,15 @@ describe('Agent daemon (e2e)', () => {
     expect(final.status).toBe('failed');
   }, 60_000);
 
-  it('honors imposer-side cancel — reporter heartbeat trips cancelSignal, runtime returns cancelled', async () => {
-    // The full cancel contract from #938: imposer cancels the task while
+  it('honors proposer-side cancel — reporter heartbeat trips cancelSignal, runtime returns cancelled', async () => {
+    // The full cancel contract from #938: proposer cancels the task while
     // the executor is running. The reporter's periodic heartbeat (250ms)
     // observes cancelled:true on the next tick, aborts cancelSignal, and
     // the executor (which awaits the signal) returns status:'cancelled'
     // promptly. The runtime ensures the final output is 'cancelled' even
     // if the executor returned anything else. finalizeTask is a no-op
     // because the row is already terminal.
-    const created = await imposeCuratePackTask();
+    const created = await proposeCuratePackTask();
 
     const runtime = new AgentRuntime({
       source: new PollingApiTaskSource({
@@ -500,7 +503,7 @@ describe('Agent daemon (e2e)', () => {
           attemptN: claimedTask.attemptN,
         });
 
-        // Cancel from the imposer side after the first heartbeat.
+        // Cancel from the proposer side after the first heartbeat.
         setTimeout(() => {
           void agent.tasks.cancel(claimedTask.task.id, {
             reason: 'e2e test cancellation',
@@ -540,7 +543,8 @@ describe('Agent daemon (e2e)', () => {
           durationMs: 0,
           error: {
             code: 'task_cancelled',
-            message: reporter.cancelReason ?? 'cancelled by imposer during e2e',
+            message:
+              reporter.cancelReason ?? 'cancelled by proposer during e2e',
             retryable: false,
           },
         };
@@ -580,7 +584,7 @@ describe('Agent daemon (e2e)', () => {
     const warmSessionTtlSec = 60;
 
     try {
-      const first = await imposeFulfillBriefTask(correlationId);
+      const first = await proposeFulfillBriefTask(correlationId);
       const firstOutput = await runStubbedSlotAwareTask({
         agent,
         taskId: first.id,
@@ -610,7 +614,7 @@ describe('Agent daemon (e2e)', () => {
       expect(existsSync(firstSessionPath!)).toBe(true);
       expect(existsSync(firstWorktreePath!)).toBe(true);
 
-      const second = await imposeFulfillBriefTask(correlationId);
+      const second = await proposeFulfillBriefTask(correlationId);
       const secondOutput = await runStubbedSlotAwareTask({
         agent,
         taskId: second.id,
@@ -670,7 +674,7 @@ describe('Agent daemon (e2e)', () => {
     const correlationId = randomUUID();
     const warmSessionTtlSec = 60;
     try {
-      const producer = await imposeRunEvalTask(correlationId);
+      const producer = await proposeRunEvalTask(correlationId);
       const producerRun = await runStubbedSlotAwareTask({
         agent,
         taskId: producer.id,
@@ -699,7 +703,7 @@ describe('Agent daemon (e2e)', () => {
       expect(existsSync(producerSessionPath!)).toBe(false);
       expect(existsSync(producerWorkspacePath!)).toBe(false);
 
-      const judge = await imposeJudgeEvalAttemptTask(
+      const judge = await proposeJudgeEvalAttemptTask(
         correlationId,
         producer.id,
       );
@@ -731,7 +735,7 @@ describe('Agent daemon (e2e)', () => {
     // `--task-types`: server filters at SQL level, daemon also pre-
     // filters at the source level. No claim-time rejection.
 
-    function imposePinnedCuratePackTask(
+    function proposePinnedCuratePackTask(
       allowed: {
         provider: string;
         model: string;
@@ -747,7 +751,7 @@ describe('Agent daemon (e2e)', () => {
     }
 
     it('persists allowedExecutors with lowercased provider/model', async () => {
-      const created = await imposePinnedCuratePackTask([
+      const created = await proposePinnedCuratePackTask([
         { provider: 'Anthropic', model: 'Claude-Sonnet-4-5' },
       ]);
       try {
@@ -760,7 +764,7 @@ describe('Agent daemon (e2e)', () => {
     });
 
     it('filters out pinned tasks for a non-matching daemon', async () => {
-      const pinned = await imposePinnedCuratePackTask([
+      const pinned = await proposePinnedCuratePackTask([
         { provider: 'anthropic', model: 'claude-opus-4-7' },
       ]);
       try {
@@ -778,7 +782,7 @@ describe('Agent daemon (e2e)', () => {
     });
 
     it('returns pinned tasks to a matching daemon', async () => {
-      const pinned = await imposePinnedCuratePackTask([
+      const pinned = await proposePinnedCuratePackTask([
         { provider: 'anthropic', model: 'claude-sonnet-4-5' },
       ]);
       try {
@@ -796,7 +800,7 @@ describe('Agent daemon (e2e)', () => {
     });
 
     it('returns unrestricted tasks regardless of daemon executor', async () => {
-      const unrestricted = await imposeCuratePackTask();
+      const unrestricted = await proposeCuratePackTask();
       try {
         const result = await agent.tasks.list({
           teamId,

apps/agent-daemon/src/cli/poll-shared.ts

@@ -338,7 +338,7 @@ export async function runPolling(opts: PollSharedArgs): Promise<number> {
         }
         // Pre-execute cancel check. The reporter's first heartbeat
         // (fired by `open()`) may already have observed `cancelled:true`
-        // from the server — e.g. the imposer cancelled between claim and
+        // from the server — e.g. the proposer cancelled between claim and
         // executor entry. Don't burn a VM on work that's already
         // terminal. The runtime would override our output anyway via the
         // post-execute cancelSignal check, but bailing here saves the

apps/agent-daemon/src/lib/finalize.ts

@@ -60,7 +60,7 @@ export async function finalizeTask(
       // we get here, so doing nothing would let the lease expire silently
       // and the attempt would surface as `lease_expired` with no signal
       // of the real cause. Convert into a terminal `tasks.fail` so the
-      // attempt carries the actual server-side reason — the next imposer
+      // attempt carries the actual server-side reason — the next proposer
       // (retry, judge, etc.) can read the failure code and act.
       const reason = errorToFailReason(err);
       ctx.log?.('complete-rejected-falling-back-to-fail', err);
@@ -106,7 +106,7 @@ function errorToFailReason(
         `${err.detail ?? err.message}${fields}`,
       // The model produced output that violated a server-side rule. A
       // bare retry of the same attempt would hit the same rejection.
-      // Mark non-retryable so the next attempt (or imposer) has a clean
+      // Mark non-retryable so the next attempt (or proposer) has a clean
       // signal that this isn't a transient transport failure.
       retryable: false,
     };

apps/console/src/pages/TaskDetailPage.tsx

@@ -25,7 +25,9 @@ export function TaskDetailPage({ id }: { id: string }) {
     }),
     refetchInterval: (query) =>
       query.state.data &&
-      ['queued', 'dispatched', 'running'].includes(query.state.data.status)
+      ['waiting', 'queued', 'dispatched', 'running'].includes(
+        query.state.data.status,
+      )
         ? 5_000
         : false,
   });

apps/console/src/pages/TasksPage.tsx

@@ -43,7 +43,7 @@ export function TasksPage() {
     refetchInterval: (query) => {
       const hasActive = query.state.data?.pages.some((page) =>
         page.items.some((task) =>
-          ['queued', 'dispatched', 'running'].includes(task.status),
+          ['waiting', 'queued', 'dispatched', 'running'].includes(task.status),
         ),
       );
       return hasActive ? 5_000 : false;
@@ -70,8 +70,8 @@ export function TasksPage() {
         <Stack gap={1}>
           <Text variant="h2">Tasks</Text>
           <Text color="muted">
-            Track queued, running, failed, and completed work in the active
-            team.
+            Track waiting, queued, running, failed, and completed work in the
+            active team.
           </Text>
         </Stack>
         <Button

apps/console/src/tasks/status.ts

@@ -1,6 +1,7 @@
 import type { TaskStatus } from '@moltnet/api-client';
 
 export const TASK_STATUS_FILTERS: TaskStatus[] = [
+  'waiting',
   'queued',
   'dispatched',
   'running',

apps/mcp-server/__tests__/task-tools.test.ts

@@ -62,8 +62,8 @@ const mockTask = {
   inputCid: 'bafy-input',
   references: [],
   correlationId: null,
-  imposedByAgentId: '330e8400-e29b-41d4-a716-446655440091',
-  imposedByHumanId: null,
+  proposedByAgentId: '330e8400-e29b-41d4-a716-446655440091',
+  proposedByHumanId: null,
   acceptedAttemptN: null,
   requiredExecutorTrustLevel: 'selfDeclared',
   allowedExecutors: [],
@@ -190,7 +190,7 @@ describe('Task tools', () => {
           error: 'Forbidden',
           message: 'Forbidden',
           statusCode: 403,
-          detail: 'Not authorized to impose tasks on this diary',
+          detail: 'Not authorized to propose tasks on this diary',
         }) as never,
       );
 
@@ -207,7 +207,7 @@ describe('Task tools', () => {
 
       expect(result.isError).toBe(true);
       expect(getTextContent(result)).toContain(
-        'Not authorized to impose tasks on this diary',
+        'Not authorized to propose tasks on this diary',
       );
     });
 
@@ -314,8 +314,8 @@ describe('Task tools', () => {
           status: 'queued',
           task_type: 'curate_pack',
           diary_id: DIARY_ID,
-          imposed_by_agent_id: '330e8400-e29b-41d4-a716-446655440091',
-          imposed_by_human_id: '330e8400-e29b-41d4-a716-446655440093',
+          proposed_by_agent_id: '330e8400-e29b-41d4-a716-446655440091',
+          proposed_by_human_id: '330e8400-e29b-41d4-a716-446655440093',
           claimed_by_agent_id: '330e8400-e29b-41d4-a716-446655440092',
           has_attempts: true,
           queued_after: '2026-04-28T10:00:00.000Z',
@@ -335,8 +335,8 @@ describe('Task tools', () => {
             status: 'queued',
             taskTypes: ['curate_pack'],
             diaryId: DIARY_ID,
-            imposedByAgentId: '330e8400-e29b-41d4-a716-446655440091',
-            imposedByHumanId: '330e8400-e29b-41d4-a716-446655440093',
+            proposedByAgentId: '330e8400-e29b-41d4-a716-446655440091',
+            proposedByHumanId: '330e8400-e29b-41d4-a716-446655440093',
             claimedByAgentId: '330e8400-e29b-41d4-a716-446655440092',
             hasAttempts: true,
             queuedAfter: '2026-04-28T10:00:00.000Z',