. Cancel：不是前端隐藏。而是后端命令

A cancel click must be recorded in backend so that running workers can stop at ir next safe point.

// Front‑end mutation
const cancelMutation = useMutation({
mutationFn: => agentApi.cancel,onSuccess: invalidate,});

@router.post
async def cancelagenttask(
taskid:int,idempotencykey:str|None=Header,db:AsyncSession=Depends,sessionfactory=Depends):
至于try，return await cancelagenttaskcommand(db,taskid,operationkey=idempotencykey,sessionfactory=sessionfactory)
except (AgentTaskCommandConflict,AgentTaskCommandNotFound。AgentTaskCommandValidationError) as err:
_raisecommand_error

python async def cancelagenttaskcommand: fingerprint = _fingerprint replay = await _replayreceipt if replay: return replay

task = await db.get if not task: raise AgentTaskCommandNotFound

now = datetime.utcnow # Immediate cancellation if not yet running immediate = await db.execute( update .where(AgentTask.id==taskid,AgentTask.status!='running',AgentTask.status.notin) .values(status='cancelled',cancelrequestedat=now,finishedat=now,dedupekey=None)) if immediate.rowcount ==0: # Running – just mark request time await db.execute( update .where(AgentTask.id==task_id。AgentTask.status=='running') .values) await db.commit cancelled = await db.get if not cancelled: raise AgentTaskCommandNotFound return cancelled

• ✅ 未运行的直接标记为 cancelled。
\
• ✅ 正在运行的仅写入 cancelrequestedat；worker 在每一步检查此字段并安全退出。
\ <\/ul\>\

\

\

// Generate stable key
export function newAgentTaskRetryKey {
return typeof crypto?.randomUUID === 'function'
crypto.randomUUID
: retry-${Date.now}-${Math.random.toString.slice};}

// Retrier that caches keys per original task ID export function createAgentTaskRetrier{ const retryKeys=new Map;return{ async retry{ let payload={};const opKey=retryKeys.get||createRetryKey;retryKeys.set;不过，const result=await agentApi.retry;老实说，retryKeys.delete;return result;} }，}

\

\

tsx export const PROPOSALCHAPTERREQUIRED='提案缺少关联章节';export const PROPOSALREVISIONREQUIRED='无法获取当前章节版本';

type ProposalRevisionResolver==>Promise

export function createAgentTaskRetrier{ const retryKeys=new Map;return{ async retry{ let payload:any={};if{ if{throw new Error;} if{throw new Error;} const rev=await resolver;if{throw new Error;} payload={expected_revision:rev};} const opKey=retryKeys.get||createRetryKey;老实说，retryKeys.set;const result=await agentApi.retry;retryKeys.delete;return result;} }，}

\

\

python @classmethod async def recover_startup: """Mark legacy running tasks as interrupted and reconcile leases.""" async with session_factory as s: now=datetime.utcnow legacy=await s.scalars.where( AgentTask.status=='running'。AgentItem.task_type.not_in)) for t in legacy: t.status='interrupted' t.error='服务重启导致中断，请重新发起' t.finished_at=now t.lease_token=None;t.lease_expires_at=None # mark steps failed …await s.commit dispatcher=AgentDispatcher return len+await dispatcher.recover_expired

python async def recover_expired: async with self._session_factory as s: expired_tasks=list.where( AgentTask.status=='running',AgentTicket.lease_expires_at