feat: auto-transition task statuses based on agent idle detection and chief reports

Three-layer auto-transition: chief reports completion via [任务完成] section,
idle detection (10min → completed, 30min+low progress → failed), and global
sweep on startup for historical stale tasks. Covers all non-terminal states
(in_progress, rework, assigned, review) so every task eventually reaches
completed or failed.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: shuanbao

scripts/autopilot/constants.cjs

@@ -48,6 +48,10 @@ const MAX_DOMAIN_KNOWLEDGE_CHARS = 3000      // Max chars for domain knowledge f
 const SESSION_RESET_INPUT_TOKENS = 80000     // Reset session when inputTokens exceeds this
 const SESSION_FORCE_COMPACT_TOKENS = 50000   // Force compact when inputTokens exceeds this
 
+// Task auto-transition thresholds
+const IDLE_COMPLETE_MINS = 10               // Agent idle N minutes → in_progress task auto-completed
+const STALE_TASK_MINS = 30                  // Agent idle N minutes + low progress → task failed
+
 // Chief response validation
 const MIN_EFFECTIVE_RESPONSE_LENGTH = 50    // Below this char count = ineffective response
 const MAX_CONSECUTIVE_FAILURES = 3           // Trigger fallback dispatch after N consecutive failures
@@ -86,6 +90,8 @@ module.exports = {
   MAX_DOMAIN_KNOWLEDGE_CHARS,
   SESSION_RESET_INPUT_TOKENS,
   SESSION_FORCE_COMPACT_TOKENS,
+  IDLE_COMPLETE_MINS,
+  STALE_TASK_MINS,
   MIN_EFFECTIVE_RESPONSE_LENGTH,
   MAX_CONSECUTIVE_FAILURES,
 }

scripts/autopilot/department-loop.cjs

@@ -14,8 +14,9 @@ const {
   COMPACT_TOKEN_RATIO, DEFAULT_CONTEXT_TOKENS, HEALTH_CHECK_INTERVAL,
   SESSIONS_DIR, SESSION_RESET_INPUT_TOKENS, SESSION_FORCE_COMPACT_TOKENS,
   MIN_EFFECTIVE_RESPONSE_LENGTH, MAX_CONSECUTIVE_FAILURES,
+  IDLE_COMPLETE_MINS, STALE_TASK_MINS,
 } = require('./constants.cjs')
-const { loadDeptConfig, loadDeptState, saveDeptState, getSessionTokenInfo, readAgentActivity } = require('./readers.cjs')
+const { loadDeptConfig, loadDeptState, saveDeptState, getSessionTokenInfo, readAgentActivity, readProjectTasks, readStandaloneTasks } = require('./readers.cjs')
 const { sendToAgent, compactSession, killSession } = require('./gateway.cjs')
 const { buildDepartmentDirective } = require('./dept-directive.cjs')
 const { compressMemoryByRole } = require('./memory.cjs')
@@ -56,6 +57,136 @@ function parseTaskAssignments(text) {
   return assignments
 }
 
+/**
+ * Parse task completions from the chief's structured response.
+ * Extracts [任务完成] section (priority) and [进展汇报] section,
+ * looking for task IDs with completion keywords.
+ *
+ * @param {string} text - Chief's response text
+ * @returns {string[]} - Deduplicated list of completed task IDs
+ */
+function parseTaskCompletions(text) {
+  if (!text) return []
+
+  const completedIds = new Set()
+  const completionKeywords = /完成|已完成|已交付|done|finished|completed|100%/i
+
+  // Parse [任务完成] section (priority)
+  const completionMatch = text.match(/\[任务完成\]\s*\n([\s\S]*?)(?=\n\[|$)/)
+  if (completionMatch) {
+    const lines = completionMatch[1].split('\n')
+    for (const line of lines) {
+      const m = line.match(/(task-[a-z0-9-]+)/i)
+      if (m && !/无/.test(line.trim())) {
+        completedIds.add(m[1])
+      }
+    }
+  }
+
+  // Parse [进展汇报] section for completion keywords
+  const progressMatch = text.match(/\[进展汇报\]\s*\n([\s\S]*?)(?=\n\[|$)/)
+  if (progressMatch) {
+    const lines = progressMatch[1].split('\n')
+    for (const line of lines) {
+      const m = line.match(/(task-[a-z0-9-]+)/i)
+      if (m && completionKeywords.test(line)) {
+        completedIds.add(m[1])
+      }
+    }
+  }
+
+  return [...completedIds]
+}
+
+/**
+ * Auto-transition tasks based on agent activity and chief reports.
+ *
+ * Rules:
+ * - Chief reports task completed → completed
+ * - in_progress/rework + agent idle >= IDLE_COMPLETE_MINS → completed
+ * - in_progress/rework + agent idle >= STALE_TASK_MINS + progress < 50 → failed
+ * - assigned + agent active (idle < 5) → in_progress
+ * - assigned + agent idle >= STALE_TASK_MINS → failed (never picked up)
+ * - review + idle >= IDLE_COMPLETE_MINS → completed (auto-approve)
+ *
+ * @param {string} deptId
+ * @param {object} config - Department config
+ * @param {string} chiefResponseText - Chief's response text
+ */
+async function autoTransitionTasks(deptId, config, chiefResponseText) {
+  const agentActivity = readAgentActivity()
+  const agents = config.agents || []
+
+  // Collect all tasks assigned to department agents
+  const projects = readProjectTasks()
+  const allTasks = []
+  for (const proj of projects) {
+    for (const t of (proj.tasks || [])) {
+      const assignees = [t.assignedAgent, ...(t.assignees || [])]
+      if (assignees.some(a => agents.includes(a))) {
+        allTasks.push(t)
+      }
+    }
+  }
+  const standalone = readStandaloneTasks()
+  for (const t of standalone) {
+    const assignees = [t.assignedAgent, ...(t.assignees || [])]
+    if (assignees.some(a => agents.includes(a))) {
+      allTasks.push(t)
+    }
+  }
+
+  if (allTasks.length === 0) return
+
+  // 1. Chief-reported completions
+  const chiefCompletions = parseTaskCompletions(chiefResponseText)
+  for (const taskId of chiefCompletions) {
+    const task = allTasks.find(t => t.id === taskId)
+    if (task && (task.status === 'in_progress' || task.status === 'rework')) {
+      const assignee = task.assignedAgent || (task.assignees && task.assignees[0])
+      if (assignee) updateTaskStatus(assignee, taskId, 'completed')
+      logger.info('dept-loop', `Chief reported task ${taskId} completed in ${deptId}`)
+    }
+  }
+
+  // 2. Idle-based auto-complete / stale cleanup
+  for (const task of allTasks) {
+    if (!['in_progress', 'rework', 'assigned', 'review'].includes(task.status)) continue
+    if (chiefCompletions.includes(task.id)) continue
+
+    const assignee = task.assignedAgent || (task.assignees && task.assignees[0])
+    if (!assignee) continue
+    const activity = agentActivity[assignee]
+    const idleMins = activity ? activity.idleMins : 9999
+
+    if (task.status === 'assigned') {
+      if (idleMins < 5) {
+        // Agent active → promote to in_progress
+        updateTaskStatus(assignee, task.id, 'in_progress')
+        logger.debug('dept-loop', `Auto-promoted assigned task ${task.id} to in_progress`)
+      } else if (idleMins >= STALE_TASK_MINS) {
+        // Agent never picked it up → failed
+        updateTaskStatus(assignee, task.id, 'failed')
+        logger.warn('dept-loop', `Assigned task ${task.id} never started, marked failed (agent ${assignee} idle ${idleMins}m)`)
+      }
+    } else if (task.status === 'review') {
+      if (idleMins >= IDLE_COMPLETE_MINS) {
+        // No one reviewed → auto-approve
+        updateTaskStatus(assignee, task.id, 'completed')
+        logger.info('dept-loop', `Review task ${task.id} auto-approved (idle ${idleMins}m)`)
+      }
+    } else if (task.status === 'in_progress' || task.status === 'rework') {
+      if (idleMins >= STALE_TASK_MINS && (task.progress || 0) < 50) {
+        updateTaskStatus(assignee, task.id, 'failed')
+        logger.warn('dept-loop', `Stale task ${task.id} marked failed (idle ${idleMins}m, progress ${task.progress || 0}%)`)
+      } else if (idleMins >= IDLE_COMPLETE_MINS) {
+        updateTaskStatus(assignee, task.id, 'completed')
+        logger.info('dept-loop', `Auto-completed task ${task.id} (agent ${assignee} idle ${idleMins}m)`)
+      }
+    }
+  }
+}
+
 /**
  * Run a single department cycle.
  *
@@ -139,6 +270,11 @@ async function runDepartmentCycle(deptId) {
         })
       }
 
+      // ── Auto-transition stale tasks ──
+      autoTransitionTasks(deptId, config, result.text).catch(e =>
+        logger.debug('dept-loop', `Auto-transition error for ${deptId}`, e)
+      )
+
       // ── Response validation: token check ──
       const responseLength = (result.text || '').trim().length
       const isEffective = responseLength >= MIN_EFFECTIVE_RESPONSE_LENGTH
@@ -234,6 +370,10 @@ async function runDepartmentCycle(deptId) {
       return { ok: true, text: result.text }
     } else {
       logger.error('dept-loop', `Department ${deptId} cycle failed: ${result.error}`)
+      // Still run idle-based auto-transition even when chief fails
+      autoTransitionTasks(deptId, config, '').catch(e =>
+        logger.debug('dept-loop', `Auto-transition error for ${deptId} (on failure path)`, e)
+      )
       state.consecutiveFailures = (state.consecutiveFailures || 0) + 1
       state.status = 'error'
       state.lastCycleResult = `Error: ${result.error}`
@@ -243,6 +383,8 @@ async function runDepartmentCycle(deptId) {
     }
   } catch (err) {
     logger.error('dept-loop', `Department ${deptId} cycle error`, err)
+    // Still run idle-based auto-transition even on exception
+    autoTransitionTasks(deptId, config, '').catch(() => {})
     state.consecutiveFailures = (state.consecutiveFailures || 0) + 1
     state.status = 'error'
     state.lastCycleResult = `Error: ${err.message}`
@@ -584,4 +726,4 @@ if (require.main === module) {
   })
 }
 
-module.exports = { runDepartmentCycle, generateDepartmentReport, ensureSessionHealth, fallbackDispatch, parseTaskAssignments }
+module.exports = { runDepartmentCycle, generateDepartmentReport, ensureSessionHealth, fallbackDispatch, parseTaskAssignments, parseTaskCompletions, autoTransitionTasks }

scripts/autopilot/dept-directive.cjs

@@ -204,9 +204,10 @@ peer-send 消息中引用任务 ID：\`[Task: task-xxx] 具体指令...\`
 
 ### 其他行动
 1. **检查进行中任务的产出质量** — 确保输出符合标准
-2. **向 CEO 汇报关键进展** — 将重要信息写入部门报告
-3. **更新你的 MEMORY.md** — 记录本轮做了什么
-4. **如果部门方向、工作重点发生变化，更新部门使命文件** — 写入 config/departments/${deptId}/mission.md
+2. **检查已完成的任务** — 如果有 agent 已经完成了某个任务，在输出的 \`[任务完成]\` section 中明确列出 task ID
+3. **向 CEO 汇报关键进展** — 将重要信息写入部门报告
+4. **更新你的 MEMORY.md** — 记录本轮做了什么
+5. **如果部门方向、工作重点发生变化，更新部门使命文件** — 写入 config/departments/${deptId}/mission.md
 
 ## 行动原则
 - **空闲 agent 必须有事做** — 发现空闲 agent 不分配任务是严重失职
@@ -219,6 +220,8 @@ peer-send 消息中引用任务 ID：\`[Task: task-xxx] 具体指令...\`
 \`\`\`
 [任务分配]
 - <agent-id>: <分配的任务摘要> (peer-send 已发送/无需分配)
+[任务完成]
+- <task-id>: <完成情况> 或 "无"
 [进展汇报]
 - <关键进展>
 [阻塞项]

scripts/autopilot/index.cjs

@@ -15,15 +15,16 @@ const {
   DEFAULT_INTERVAL_SEC, MAX_HISTORY_ENTRIES, MAX_CYCLE_RESULT_LENGTH, MAX_HISTORY_RESULT_LENGTH,
   DEPARTMENTS_DIR, AGENTS_DIR,
   CEO_COORDINATION_INTERVAL_SEC, CEO_STRATEGY_INTERVAL_SEC, DEFAULT_DEPT_INTERVAL_SEC,
+  IDLE_COMPLETE_MINS, STALE_TASK_MINS,
 } = require('./constants.cjs')
 const { loadState, saveState } = require('./state.cjs')
 const { sendToCeo } = require('./gateway.cjs')
-const { fetchSessionTokens } = require('./readers.cjs')
+const { fetchSessionTokens, readProjectTasks, readStandaloneTasks, readAgentActivity } = require('./readers.cjs')
 const { buildDirective } = require('./directive.cjs')
 const { syncProjects } = require('./sync.cjs')
 const { buildMemoryContext, compressMemory } = require('./memory.cjs')
-const { runDepartmentCycle } = require('./department-loop.cjs')
-const { createCycleTask, completeCycleTask } = require('./task-bridge.cjs')
+const { runDepartmentCycle, autoTransitionTasks } = require('./department-loop.cjs')
+const { createCycleTask, completeCycleTask, updateTaskStatus } = require('./task-bridge.cjs')
 const logger = require('./logger.cjs')
 
 const MAX_HISTORY = 50
@@ -334,6 +335,51 @@ async function runCeoCycleForAll(cycleType = 'coordination') {
   }
 }
 
+// ── Global task sweep: clean up stale tasks across ALL agents ────
+async function sweepStaleTasks() {
+  const agentActivity = readAgentActivity()
+
+  // Gather all non-terminal tasks from projects + standalone
+  const allTasks = []
+  for (const proj of readProjectTasks()) {
+    for (const t of (proj.tasks || [])) allTasks.push(t)
+  }
+  for (const t of readStandaloneTasks()) allTasks.push(t)
+
+  const activeStatuses = ['in_progress', 'rework', 'assigned', 'review']
+  const staleTasks = allTasks.filter(t => activeStatuses.includes(t.status))
+  if (staleTasks.length === 0) return
+
+  let transitioned = 0
+  for (const task of staleTasks) {
+    const assignee = task.assignedAgent || (task.assignees && task.assignees[0])
+    if (!assignee) continue
+    const activity = agentActivity[assignee]
+    const idleMins = activity ? activity.idleMins : 9999
+
+    let newStatus = null
+    if (task.status === 'assigned' && idleMins >= STALE_TASK_MINS) {
+      newStatus = 'failed'
+    } else if (task.status === 'review' && idleMins >= IDLE_COMPLETE_MINS) {
+      newStatus = 'completed'
+    } else if ((task.status === 'in_progress' || task.status === 'rework') && idleMins >= STALE_TASK_MINS && (task.progress || 0) < 50) {
+      newStatus = 'failed'
+    } else if ((task.status === 'in_progress' || task.status === 'rework') && idleMins >= IDLE_COMPLETE_MINS) {
+      newStatus = 'completed'
+    }
+
+    if (newStatus) {
+      updateTaskStatus(assignee, task.id, newStatus)
+      transitioned++
+      logger.info('main', `Sweep: task ${task.id} (${task.status}) → ${newStatus} (agent ${assignee} idle ${idleMins}m)`)
+    }
+  }
+
+  if (transitioned > 0) {
+    logger.info('main', `Sweep completed: ${transitioned} stale tasks transitioned`)
+  }
+}
+
 // ── Start all: CEO cycles + department cycles ───────────────────
 async function startAll() {
   await killExistingAutopilot()
@@ -358,6 +404,11 @@ async function startAll() {
   process.on('SIGTERM', shutdown)
   process.on('SIGINT', shutdown)
 
+  // 0. Sweep stale tasks from previous runs
+  await sweepStaleTasks().catch(e =>
+    logger.warn('main', 'Stale task sweep failed', e)
+  )
+
   // 1. Run initial CEO coordination cycle
   await runCeoCycleForAll('coordination')