fail job 支持删除 重试

Author: linyuan.yang

packages/admin/src/components/modals/MemoryListModal.vue

@@ -46,6 +46,7 @@ const consolidating = ref(false)
 const reconciling = ref(false)
 const deleting = ref(false)
 const retryingJobId = ref<number | null>(null)
+const deletingJobId = ref<number | null>(null)
 
 const rows = ref<MemorySummary[]>([])
 const jobs = ref<MemoryJob[]>([])
@@ -174,16 +175,12 @@ async function runReconcile() {
   }
 }
 
-function canRetryExtractJob(job: MemoryJob): boolean {
-  return job.type === 'extract' && job.status === 'failed'
-}
-
-async function retryExtractJob(job: MemoryJob) {
-  if (!memoryId.value || !canRetryExtractJob(job) || retryingJobId.value !== null) return
+async function retryFailedJob(job: MemoryJob) {
+  if (!memoryId.value || job.status !== 'failed' || retryingJobId.value !== null) return
   retryingJobId.value = job.id
   try {
-    await apiFetch(`/api/memories/${encodeURIComponent(memoryId.value)}/jobs/${job.id}/retry`, 'POST', {})
-    show(t('memory_profiles.retry_extract_done'))
+    await apiFetch(`/api/memories/${encodeURIComponent(memoryId.value)}/jobs/${job.id}/retry?${viewQuery.value}`, 'POST', {})
+    show(t('memory_profiles.retry_job_done'))
     await refresh()
   } catch (e: any) {
     show(e.message, 'error')
@@ -192,6 +189,21 @@ async function retryExtractJob(job: MemoryJob) {
   }
 }
 
+async function deleteFailedJob(job: MemoryJob) {
+  if (!memoryId.value || job.status !== 'failed' || deletingJobId.value !== null) return
+  if (!window.confirm(t('memory_profiles.confirm_delete_job', { id: job.id }))) return
+  deletingJobId.value = job.id
+  try {
+    await apiFetch(`/api/memories/${encodeURIComponent(memoryId.value)}/jobs/${job.id}?${viewQuery.value}`, 'DELETE')
+    show(t('memory_profiles.delete_job_done'))
+    await loadJobs()
+  } catch (e: any) {
+    show(e.message, 'error')
+  } finally {
+    deletingJobId.value = null
+  }
+}
+
 async function deleteMemory(memory: MemorySummary) {
   if (!memoryId.value || !memory.slug || deleting.value) return
   if (!window.confirm(t('memory_profiles.confirm_delete_memory', { slug: memory.slug }))) return
@@ -334,13 +346,22 @@ defineExpose({ openByMemoryId })
             <div class="memory-job-id">#{{ job.id }}</div>
             <div class="memory-job-actions">
               <SButton
-                v-if="canRetryExtractJob(job)"
+                v-if="job.status === 'failed'"
                 type="outline"
                 size="sm"
                 :loading="retryingJobId === job.id"
-                @click="retryExtractJob(job)"
+                @click="retryFailedJob(job)"
+              >
+                {{ t('memory_profiles.retry_job') }}
+              </SButton>
+              <SButton
+                v-if="job.status === 'failed'"
+                type="danger"
+                size="sm"
+                :loading="deletingJobId === job.id"
+                @click="deleteFailedJob(job)"
               >
-                {{ t('memory_profiles.retry_extract') }}
+                {{ t('memory_profiles.delete_job') }}
               </SButton>
               <SBadge :variant="jobVariant(job.status)" size="sm">{{ jobStatusLabel(job.status) }}</SBadge>
             </div>

packages/admin/src/i18n/en.ts

@@ -539,8 +539,11 @@ export default {
     consolidate_queued: 'Consolidation queued: #{id}',
     run_reconcile: 'Sync File Index',
     reconcile_queued: 'File index sync queued: #{id}',
-    retry_extract: 'Retry Extract',
-    retry_extract_done: 'Extraction retry queued',
+    retry_job: 'Retry',
+    retry_job_done: 'Job queued for retry',
+    delete_job: 'Delete Record',
+    confirm_delete_job: 'Delete failed job #{id}? This only removes the job record and does not affect saved memories.',
+    delete_job_done: 'Failed job record deleted',
     delete_memory: 'Delete',
     confirm_delete_memory: 'Delete memory "{slug}"? The file will be moved to .archive/ and can be recovered.',
     delete_memory_done: 'Deleted',

packages/admin/src/i18n/zh.ts

@@ -539,8 +539,11 @@ export default {
     consolidate_queued: '已加入整理队列：#{id}',
     run_reconcile: '同步文件索引',
     reconcile_queued: '已加入索引同步队列：#{id}',
-    retry_extract: '重新抽取',
-    retry_extract_done: '已重新加入抽取队列',
+    retry_job: '重试',
+    retry_job_done: '已重新加入任务队列',
+    delete_job: '删除记录',
+    confirm_delete_job: '确定删除失败任务 #{id} 吗？此操作只删除任务记录，不影响已保存的记忆。',
+    delete_job_done: '已删除失败任务记录',
     delete_memory: '删除此条',
     confirm_delete_memory: '确定删除记忆 "{slug}" 吗？文件将移到 .archive/ 目录可恢复。',
     delete_memory_done: '已删除',

packages/docs-site/guide/memory.md

@@ -38,7 +38,7 @@ A **Memory Profile** defines how memories are extracted and read. Sidebar → **
 | Writer Prompt | Controls **what** gets extracted |
 | Read Prompt | How retrieved memories are formatted back into the prompt |
 
-Then, in an agent → **Memory** section, toggle Memory on and pick the profile. From the Memory Profiles page you can **View Memories**, inspect pending/failed background jobs, retry failed extract jobs, queue **Clean Up Memories**, and use **Sync File Index** to rescan files and indexes.
+Then, in an agent → **Memory** section, toggle Memory on and pick the profile. From the Memory Profiles page you can **View Memories**, inspect pending/failed background jobs, retry or delete any failed job, queue **Clean Up Memories**, and use **Sync File Index** to rescan files and indexes.
 
 ## Memory vs Notes vs Wiki
 

packages/docs-site/zh/guide/memory.md

@@ -38,7 +38,7 @@ Memory 是 Agent 的自动长期记忆。后台 **MemoryLLM** 会在每次对话
 | Writer 提示词 | 控制 **提取什么** |
 | Read 提示词 | 召回的记忆如何回填进提示词 |
 
-随后在 Agent → **Memory** 区块开启 Memory 并选择 Profile。在 Memory Profiles 页面可以 **查看记忆**、检查 pending / failed 后台任务、对失败的抽取任务点 **重新抽取**，也可以用 **整理记忆** 排队合并/压缩现有记忆，用 **同步文件索引** 重新扫描文件与索引。
+随后在 Agent → **Memory** 区块开启 Memory 并选择 Profile。在 Memory Profiles 页面可以 **查看记忆**、检查 pending / failed 后台任务、重试或删除任意失败任务，也可以用 **整理记忆** 排队合并/压缩现有记忆，用 **同步文件索引** 重新扫描文件与索引。
 
 ## Memory vs Notes vs Wiki
 

packages/sbot/src/Server/routes/memories.ts

@@ -106,15 +106,38 @@ export class MemoryRoutes {
             }
         }));
 
-        /** 重试一条失败的抽取任务：把 failed extract job 放回 pending 队列并立即唤醒消费。 */
+        /** 重试一条失败任务：放回 pending 队列并立即唤醒消费。 */
         app.post('/api/memories/:id/jobs/:jobId/retry', api(async (req) => {
             const memoryId = requireMemoryId(req.params.id);
             const jobId = Number(req.params.jobId);
             if (!Number.isSafeInteger(jobId) || jobId <= 0) throwBad('Invalid jobId');
-            const retried = memoryServicePool.retryExtractJob(memoryId, jobId);
-            if (retried == null) throw new Error(`Failed to retry memory extract job #${jobId}`);
-            if (!retried) throwBad(`Job #${jobId} is not a failed extract job`);
-            return { memoryId, jobId };
+            const target = requireViewTarget(req.query.viewScope, req.query.workPath);
+            const service = acquireMemoryService(memoryId, target);
+            try {
+                if (!service.retryFailedJob(jobId)) {
+                    throwBad(`Job #${jobId} is not a failed job in the selected scope`);
+                }
+                return { memoryId, jobId };
+            } finally {
+                service.release();
+            }
+        }));
+
+        /** 删除一条失败任务记录；不允许删除仍在等待或处理中的任务。 */
+        app.delete('/api/memories/:id/jobs/:jobId', api(async (req) => {
+            const memoryId = requireMemoryId(req.params.id);
+            const jobId = Number(req.params.jobId);
+            if (!Number.isSafeInteger(jobId) || jobId <= 0) throwBad('Invalid jobId');
+            const target = requireViewTarget(req.query.viewScope, req.query.workPath);
+            const service = acquireMemoryService(memoryId, target);
+            try {
+                if (!service.deleteFailedJob(jobId)) {
+                    throwBad(`Job #${jobId} is not a failed job in the selected scope`);
+                }
+                return { memoryId, jobId };
+            } finally {
+                service.release();
+            }
         }));
 
         /** 单条 memory 全文。 */

packages/scorpio.ai/src/Memory/Service/IMemoryService.ts

@@ -74,6 +74,12 @@ export interface IMemoryService {
     /** admin 排障：列最近的 pending+failed job（按 id DESC）。 */
     listPending(limit?: number): PendingMemoryJobRow[];
 
+    /** admin 将一条 failed job 重新放回 pending 队列。 */
+    retryFailedJob(id: number): boolean;
+
+    /** admin 删除一条 failed job；pending/processing 不允许删除。 */
+    deleteFailedJob(id: number): boolean;
+
     /** admin 触发：把合并/压缩现有 memory 条目的 job 入队。 */
     enqueueConsolidate(): number;
 

packages/scorpio.ai/src/Memory/Service/MemoryService.ts

@@ -449,6 +449,10 @@ export class MemoryService {
         return this.store.listPendingJobs(limit ?? 50, target);
     }
 
+    deleteFailedJob(id: number, target: MemoryTarget): boolean {
+        return this.store.deleteFailedJob(id, target);
+    }
+
     processPending(): void {
         void this.checkJobs();
     }
@@ -465,8 +469,8 @@ export class MemoryService {
         return id;
     }
 
-    retryExtractJob(id: number): boolean {
-        const retried = this.store.retryFailedExtractJob(id, Date.now());
+    retryFailedJob(id: number, target: MemoryTarget): boolean {
+        const retried = this.store.retryFailedJob(id, Date.now(), target);
         if (retried) void this.checkJobs();
         return retried;
     }

packages/scorpio.ai/src/Memory/Service/MemoryServicePool.ts

@@ -171,20 +171,6 @@ export class MemoryServicePool {
         }
     }
 
-    /** 返回 null 表示触发失败，错误已在 pool 中记录；false 表示该 job 不可重试。 */
-    retryExtractJob(memoryId: string, jobId: number): boolean | null {
-        let service: MemoryService | undefined;
-        try {
-            service = this.acquireOwner(memoryId);
-            return service.retryExtractJob(jobId);
-        } catch (e: any) {
-            this.logActionFailed(`重试记忆抽取 #${jobId}`, memoryId, e);
-            return null;
-        } finally {
-            this.releaseQuietly(service, `重试记忆抽取 #${jobId}`, memoryId);
-        }
-    }
-
     listWorkspaceScopes(memoryId: string): MemoryWorkspaceScope[] {
         const service = this.acquireOwner(memoryId);
         try { return service.listWorkspaceScopes(); }

packages/scorpio.ai/src/Memory/Service/MemoryServiceView.ts

@@ -51,6 +51,14 @@ export abstract class MemoryServiceView implements IMemoryService {
         return this.owner.listPending(limit, this.target);
     }
 
+    retryFailedJob(id: number): boolean {
+        return this.owner.retryFailedJob(id, this.target);
+    }
+
+    deleteFailedJob(id: number): boolean {
+        return this.owner.deleteFailedJob(id, this.target);
+    }
+
     enqueueConsolidate(): number {
         return this.owner.enqueueConsolidate(this.target);
     }