长流程状态恢复工作流

长流程状态恢复工作流

4个可下载技能 · 4步自动化工作流 · 每个技能可单独运行

把长时间等待、异步回调和并行子流程在恢复前做一次本地状态审计：先整理执行状态，再检查检查点与队列阈值，核验重复恢复和未完成任务，最后形成由负责人决定恢复、暂停或回滚的交接包。套餐不连接平台、不调用恢复 URL、不重试、不清理队列。

4步自动化工作流

1 执行状态整理

对应技能： execution-state-normalizer

解决什么： 统一 execution、workflow、session、checkpoint、resume、job、状态和观察时间。

你会得到： READY/REVIEW 状态记录、缺失项和 state_hash。

流转到下一步： 规范化状态进入检查点超时审计。

2 检查点超时审计

对应技能： checkpoint-timeout-auditor

解决什么： 对比等待时长、队列阈值、心跳、时区契约和状态，发现可能的超时、队列重拾或时钟漂移风险。

你会得到： PASS/REVIEW/BLOCKED、风险项和人工问题。

流转到下一步： 超时结果与状态进入恢复重复执行核验。

3 恢复重复执行核验

对应技能： resume-duplication-checker

解决什么： 比较恢复事件、session、job、检查点和并行任务，标记重复回调或未汇齐的任务。

你会得到： CLEAR/POSSIBLE_DUPLICATE/REVIEW、命中事件、未完成任务和人工确认项。

流转到下一步： 重复核验与超时结果进入状态恢复交接包。

4 状态恢复人工交接包

对应技能： state-recovery-handoff-packet

解决什么： 汇总执行状态、检查点、超时风险、恢复事件、回滚引用和负责人政策。

你会得到： READY_FOR_HUMAN_RECOVERY/REVIEW、建议动作、decision=PENDING 和 executed=false。

流转到下一步： 形成最终恢复交接材料，由负责人决定恢复、暂停、回滚或继续观察。

实际示例

示例使用 [EXEC_A]、[SESSION_A]、[WAIT_01] 和 [SNAPSHOT_A] 等脱敏引用，等待45秒、队列阈值60秒、三套时区一致，两个并行任务均已完成。流程会输出 PASS、CLEAR 和待人工决定的恢复包。该结果是脱敏测试示例，不代表真实执行已恢复或系统故障已修复。

适合谁

使用 n8n 或类似编排器的开发者、自动化实施团队、运维、DevOps、异步任务和多步骤代理工作流负责人；尤其适合有 Wait、Webhook、轮询或并行子流程的系统。

买家只需提供

• 已脱敏的执行、工作流、session、检查点、job、恢复引用和观察状态

• 等待时长、队列/worker阈值、心跳、时区契约和并行任务状态

• 恢复政策、负责人引用、回滚快照引用和人工验收要求

使用方式

1. 使用 Python 3.10 或更高版本，删除真实 resume token、Webhook URL、数据库地址、日志正文和客户数据。

2. 依次运行状态整理、超时审计、恢复重复核验和人工交接包。

3. 用正常等待、超过阈值、重复回调、任务未齐和时区不一致样例验收，再由负责人执行真实恢复动作。

交付与验收

• 四个独立技能目录，每个包含 _meta.json、SKILL.md、agents/openai.yaml、README、Python 执行器、文档和脱敏样例。

• 四步可重复运行：状态整理、检查点超时审计、恢复重复核验、人工交接包。

• 缺 session、缺心跳、超过阈值、时区契约不完整、重复恢复、未完成任务和回滚引用缺失均有明确分支。

• 输出保留 state_hash、风险项、人工建议、PENDING 决策和 executed=false，不包含恢复、重试、取消、队列清理或平台写回动作。

服务说明

脚本只读买家有权使用且已脱敏的执行摘要和环境契约，不连接 n8n、队列、数据库、Webhook 或外部任务系统。检查结果不能证明平台缺陷、任务成功、业务完整性或零重复；负责人必须核对原始执行、版本、队列模式、时区和恢复策略。套餐不包含账号、密钥、平台接入、真实恢复、重试、回滚实施、数据库操作、环境变量修改、持续值守或结果保证。