闲社服务运行正常AI智能体自动化平台
工作流并发控制复核工作流

工作流并发控制复核工作流

把工作流并发策略、重叠执行证据和锁 TTL 风险整理成可复核的人工放行门禁。

AI智能体与自动化
立即购买
技能数量
4
22,919
下载量
¥185.00
参考价 · 登录确认
17,179
销量

购买前,先确认这些

我的已购工作流

以下摘录自发布者现有说明,不代表平台已完成运行验证。完整交付范围、限制与验收要求请继续阅读原文。

交付内容

四个独立技能目录,每个包含 _meta.json、SKILL.md、agents/openai.yaml、README、Python 执行器、文档和脱敏样例。 四步可重复运行:策略归一、重叠证据审计、锁 TTL 检查、人工放行门禁。 缺策略引用、时间窗、TTL、最长时长、审批、变更或回滚引用时均有明确 REVIEW/QUARANTINE/BLOCKED 分支。 完整样例产生 READY、CLEAR、PASS 和 READY_FOR_HUMAN_REVIEW,并固定输出 enforcement_executed=false。

需要准备

已脱敏的工作流并发策略、触发类型、锁键、TTL、排队模式和负责人引用 脱敏运行记录的开始时间、结束时间、工作流引用和执行引用 最长运行时长、安全余量、陈旧锁记录、变更单、回滚和审批引用

运行与安装说明

使用 Python 3.10 或更高版本,把主机、密钥、客户数据和内部路径替换为占位符。 依次运行四个脚本,也可以单独运行某一步检查字段和状态分支。 先在测试环境复核输出,再由有权限的管理员决定是否修改真实并发、锁或队列配置。

费用、服务与边界

脚本只处理买家有权使用且已脱敏的本地 JSON,不连接 Redis、RabbitMQ、n8n、Dify、Coze、GitHub 或数据库,不发送告警,不停止、不排队、不重放、不修改任何真实执行。审计结果不等于生产并发安全;实际配置必须由有权限人员在测试环境验证。套餐不包含接口接入、锁服务部署、队列实施、生产变更、合规认证、故障值守或结果保证。

安装准备与故障排查确认材料、运行环境与额外费用后再购买。阅读完整说明

工作流详情

包含技能

以下为套餐组成,实际执行顺序请按上方工作流说明。安装所需环境、账号与外部服务费用请在购买前确认。

并发人工放行门禁

# 并发人工放行门禁 ## 输入与输出 输入为 policy_result、overlap_result、ttl_result、owner_ref、change_ref、rollback_ref 和 approval_ref。输出 READY_FOR_HUMAN_REVIEW/QUARANTINE/REVIEW、decision=PENDING 和 enforcement_executed=false。 ## 执行 python scripts/handoff_gate.py examples/input.json ## 错误恢复 策略、重叠证据或 TTL 结果不合格,或审批、变更、回滚引用缺失时输出 REVIEW/QUARANTINE;补齐证据后再提交人工审核。 ## 权限与隐私边界 只生成审核队列,不改变并发配置、不获取权限、不执行队列或锁操作。 ## 验收 完整样例输出 READY_FOR_HUMAN_REVIEW、decision=PENDING 和 enforcement_executed=false;将任一上游状态改为 ESCALATE 或 QUARANTINE 可验证隔离

并发策略归一

# 并发策略归一 ## 输入与输出 输入为脱敏的 workflow_ref、trigger_kind、max_concurrency、lock_key、ttl_seconds、queue_mode 和 owner_ref。输出 READY/REVIEW/BLOCKED、规范策略、policy_hash 和 issues。 ## 执行 python scripts/normalize_policy.py examples/input.json ## 错误恢复 缺 workflow_ref、max_concurrency 或 owner_ref 输出 BLOCKED;并发值非正数、TTL 非正数或 queue_mode 不在允许集合时输出 REVIEW。修正 JSON 后重新运行。 ## 权限与隐私边界 只读取本地 JSON,不读取凭据、不连接 Redis、队列、工作流平台或网络。 ## 验收 完整样例输出 READY;可将 max_concurrency 改为 0 或删除 lock_key 验证分支。

锁 TTL 安全检查

# 锁 TTL 安全检查 ## 输入与输出 输入为 max_duration_seconds、ttl_seconds、safety_margin_seconds、lock_key 和 stale_locks。输出 PASS/REVIEW/QUARANTINE、TTL 缺口、陈旧锁记录和 ttl_hash。 ## 执行 python scripts/check_lock_ttl.py examples/input.json ## 错误恢复 缺 lock_key 或 TTL 小于预计最长运行时间加安全余量输出 QUARANTINE;陈旧锁或时间字段缺失输出 REVIEW。先在策略文件中修正,再重新检查。 ## 权限与隐私边界 只比较数字和脱敏锁引用;不写入、删除或续租任何真实锁,不连接 Redis 或其他存储。 ## 验收 完整样例输出 PASS;把 ttl_seconds 改小或加入 stale_locks 可验证 QUARANTINE/REVIEW。

重叠执行证据审计

# 重叠执行证据审计 ## 输入与输出 输入为 executions 数组,每条包含 execution_ref、workflow_ref、trigger_ref、started_at、finished_at 和 status。输出 CLEAR/REVIEW/ESCALATE、重叠窗口、缺失证据和 evidence_hash。 ## 执行 python scripts/audit_overlap.py examples/input.json ## 错误恢复 时间格式错误、结束时间早于开始时间或缺 execution_ref 输出 REVIEW;同一 workflow 的时间区间相交输出 ESCALATE。补齐脱敏运行记录后重跑。 ## 权限与隐私边界 不读取运行日志正文,不调用 API,不发送告警,不终止或重放执行。 ## 验收 样例包含两个不同 workflow 的非重叠记录,应输出 CLEAR;让同一 workflow 的第二条 started_at 早于第一条 finished_at 可验证 ESCALATE。

返回顶部