原文链接:Cron Internals sidebar position: 11 title: "Cron Internals" description: "How Hermes stores, schedules, edits, pauses, skill-loads, and delivers cron jobs"
> 原文链接:Cron Internals
sidebar_position: 11 title: "Cron Internals" description: "How Hermes stores, schedules, edits, pauses, skill-loads, and delivers cron jobs"
Cron 内部机制
Cron 子系统提供计划任务执行——从简单的一次性延迟到带有技能注入和跨平台交付的循环 Cron 表达式任务。
关键文件
| 文件 | 用途 |
|---|---|
cron/jobs.py | 任务模型、存储、对 jobs.json 的原子读写 |
cron/scheduler.py | 调度器循环 — 到期任务检测、执行、重复跟踪 |
tools/cronjob_tools.py | 面向模型的 cronjob 工具注册和处理程序 |
gateway/run.py | 网关集成 — 在长运行循环中进行 cron 滴答 |
hermes_cli/cron.py | CLI hermes cron 子命令 |
调度模型
支持四种调度格式:
| 格式 | 示例 | 行为 |
|---|---|---|
| 相对延迟 | 30m、2h、1d | 一次性,在指定持续时间后触发 |
| 间隔 | every 2h、every 30m | 循环,按固定间隔触发 |
| Cron 表达式 | 0 9 * * * | 标准 5 字段 cron 语法(分钟、小时、日、月、星期) |
| ISO 时间戳 | 2025-01-15T09:00:00 | 一次性,在精确时间触发 |
面向模型的接口是单个 cronjob 工具,支持 action 风格的操作:create、list、update、pause、resume、run、remove。
任务存储
任务存储在 ~/.hermes/cron/jobs.json 中,具有原子写入语义(写入临时文件,然后重命名)。每个任务记录包含:
{
"id": "a1b2c3d4e5f6",
"name": "每日简报",
"prompt": "总结今天的 AI 新闻和融资轮次",
"schedule": {
"kind": "cron",
"expr": "0 9 * * *",
"display": "0 9 * * *"
},
"skills": ["ai-funding-daily-report"],
"deliver": "telegram:-1001234567890",
"repeat": {
"times": null,
"completed": 42
},
"state": "scheduled",
"enabled": true,
"next_run_at": "2025-01-16T09:00:00Z",
"last_run_at": "2025-01-15T09:00:00Z",
"last_status": "ok",
"created_at": "2025-01-01T00:00:00Z",
"model": null,
"provider": null,
"script": null
}
任务生命周期状态
| 状态 | 含义 |
|---|---|
scheduled | 活跃,将在下一个计划时间触发 |
paused | 暂停 — 恢复前不会触发 |
completed | 重复次数已用完或一次性任务已触发 |
running | 当前正在执行(瞬态) |
向后兼容
旧版任务可能有单个 skill 字段而不是 skills 数组。调度器在加载时标准化——单个 skill 被提升为 skills: [skill]。
调度器运行时
滴答周期
调度器按周期性滴答运行(默认:每 60 秒):
tick()
1. 获取调度器锁(防止重叠滴答)
2. 从 jobs.json 加载所有任务
3. 过滤到期任务(next_run <= now 且 state == "scheduled")
4. 对每个到期任务:
a. 设置状态为 "running"
b. 创建新的 AIAgent 会话(无对话历史)
c. 按顺序加载附加的技能(作为用户消息注入)
d. 通过 Agent 运行任务 prompt
e. 将响应投递到配置的目标
f. 更新 run_count,计算 next_run
g. 如果重复次数用完 → state = "completed"
h. 否则 → state = "scheduled"
5. 将更新的任务写回 jobs.json
6. 释放调度器锁
网关集成
在网关模式下,调度器滴答集成到网关的主事件循环中。网关在其周期性维护周期中调用 scheduler.tick(),与消息处理并行运行。
在 CLI 模式下,Cron 任务仅在运行 hermes cron 命令或活跃 CLI 会话期间触发。
新会话隔离
每个 Cron 任务在完全全新的 Agent 会话中运行:
- 没有之前运行的对话历史
- 没有之前 Cron 执行的记忆(除非持久化到记忆/文件)
- prompt 必须自包含 — Cron 任务无法提问澄清问题
cronjob工具集被禁用(递归保护)
技能支撑的任务
Cron 任务可以通过 skills 字段附加一个或多个技能。执行时:
- 技能按指定顺序加载
- 每个技能的 SKILL.md 内容作为上下文注入
- 任务的 prompt 附加为任务指令
- Agent 处理组合的技能上下文 + prompt
这实现了可复用的、经过测试的工作流,无需将完整指令粘贴到 Cron prompt 中。例如:
创建每日融资报告 → 附加 "ai-funding-daily-report" 技能
脚本支撑的任务
任务也可以通过 script 字段附加 Python 脚本。脚本在每次 Agent 轮次之前运行,其 stdout 作为上下文注入到 prompt 中。这实现了数据收集和变更检测模式:
# ~/.hermes/scripts/check_competitors.py
import requests, json
# 获取竞争对手的发布说明,与上次运行进行对比
# 将摘要打印到 stdout — Agent 分析并报告
脚本超时默认为 120 秒。_get_script_timeout() 通过三层链解析超时限制:
- 模块级覆盖 —
_SCRIPT_TIMEOUT(用于测试/monkeypatching)。仅在与默认值不同时使用。 - 环境变量 —
HERMES_CRON_SCRIPT_TIMEOUT - 配置 —
config.yaml中的cron.script_timeout_seconds(通过load_config()读取) - 默认值 — 120 秒
Provider 恢复
run_job() 将用户配置的回退 Provider 和凭据池传入 AIAgent 实例:
- 回退 Provider(Fallback Providers) — 从
config.yaml读取fallback_providers(列表)或fallback_model(旧版字典),匹配网关的_load_fallback_model()模式。作为fallback_model=传给AIAgent.__init__,后者将两种格式标准化为回退链。 - 凭据池(Credential Pool) — 通过
agent.credential_pool中的load_pool(provider)使用解析后的运行时 Provider 名称加载。仅在池有凭据时传递(pool.has_credentials())。启用同 Provider 密钥轮换以应对 429/速率限制错误。
这镜像了网关的行为——没有它,Cron Agent 在遇到速率限制时会失败而不尝试恢复。
投递模型
Cron 任务结果可以投递到任何支持的平台:
| 目标 | 语法 | 示例 |
|---|---|---|
| 原始聊天 | origin | 投递到创建任务的聊天 |
| 本地文件 | local | 保存到 ~/.hermes/cron/output/ |
| Telegram | telegram 或 telegram:<chat_id> | telegram:-1001234567890 |
| Discord | discord 或 discord:#channel | discord:#engineering |
| Slack | slack | 投递到 Slack 主频道 |
whatsapp | 投递到 WhatsApp 主页 | |
| Signal | signal | 投递到 Signal |
| Matrix | matrix | 投递到 Matrix 主房间 |
| Mattermost | mattermost | 投递到 Mattermost 主页 |
email | 通过邮件投递 | |
| SMS | sms | 通过 SMS 投递 |
| Home Assistant | homeassistant | 投递到 HA 对话 |
| DingTalk | dingtalk | 投递到钉钉 |
| Feishu | feishu | 投递到飞书 |
| WeCom | wecom | 投递到企业微信 |
| Weixin | weixin | 投递到微信 |
| BlueBubbles | bluebubbles | 通过 BlueBubbles 投递到 iMessage |
| QQ Bot | qqbot | 通过官方 API v2 投递到 QQ(腾讯) |
对于 Telegram 话题,使用格式 telegram:<chat_id>:<thread_id>(例如 telegram:-1001234567890:17585)。
响应包装
默认情况下(cron.wrap_response: true),Cron 投递会被包装:
- 标识 Cron 任务名称和任务的头部
- 注明 Agent 无法在对话中看到已投递消息的尾部
Cron 响应中的 [SILENT] 前缀会完全抑制投递——适用于只需要写入文件或执行副作用的任务。
会话隔离
Cron 投递不会镜像到网关会话的对话历史中。它们只存在于 Cron 任务自己的会话中。这防止目标聊天对话中的消息交替违规。
递归保护
Cron 运行的会话禁用了 cronjob 工具集。这防止:
- 计划任务创建新的 Cron 任务
- 可能导致 token 使用量爆炸的递归调度
- 从任务内部意外修改任务计划
锁定
调度器使用基于文件的锁定来防止重叠的滴答执行同一个到期任务批次两次。这在网关模式下很重要,因为如果前一个滴答花费的时间超过滴答间隔,多个维护周期可能重叠。
CLI 接口
hermes cron CLI 提供直接的任务管理:
hermes cron list # 显示所有任务
hermes cron create # 交互式任务创建(别名:add)
hermes cron edit <job_id> # 编辑任务配置
hermes cron pause <job_id> # 暂停运行中的任务
hermes cron resume <job_id> # 恢复暂停的任务
hermes cron run <job_id> # 触发立即执行
hermes cron remove <job_id> # 删除任务