root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(FN-4663): make expedite route persistence-safe and idempotent

Browse Source 
Fusion-Task-Id: FN-4663
Fusion-Task-Lineage: 80975e9f-51e2-42ee-9f61-5e065a3fed24
This commit is contained in:
Fusion (runfusion.ai)
2026-05-15 23:17:35 -07:00
committed by gsxdsm
parent 1aad59aeb2
commit 52b167879b
3 changed files with 3 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/dashboard/src/routes/register-task-workflow-routes.ts
View File

@@ -1237,21 +1237,19 @@ export function registerTaskWorkflowRoutes(ctx: ApiRoutesContext, deps: TaskWork
return res.json({ task, expedited: false, requiresOperatorAction: "retry-stuck" });
}
if (task.expediteRequestedAt && !task.nextRecoveryAt) {
if (!task.nextRecoveryAt) {
return res.json({ task, expedited: true, alreadyExpedited: true });
}
const nowIso = new Date().toISOString();
const updated = await scopedStore.updateTask(task.id, {
nextRecoveryAt: undefined,
expediteRequestedAt: task.expediteRequestedAt ?? nowIso,
});
await scopedStore.logEntry(task.id, "Refinement expedited", "Cleared nextRecoveryAt and set expediteRequestedAt");
await scopedStore.logEntry(task.id, "Refinement expedited", "Cleared nextRecoveryAt");
res.json({
task: updated,
expedited: true,
alreadyExpedited: Boolean(task.expediteRequestedAt),
alreadyExpedited: false,
});
} catch (err: unknown) {
if (err instanceof ApiError) {