website/docs/developer-guide/cron-internals.md
The cron subsystem provides scheduled task execution — from simple one-shot delays to recurring cron-expression jobs with skill injection and cross-platform delivery.
| File | Purpose |
|---|---|
cron/jobs.py | Job model, storage, atomic read/write to jobs.json |
cron/scheduler.py | Scheduler loop — due-job detection, execution, repeat tracking |
tools/cronjob_tools.py | Model-facing cronjob tool registration and handler |
gateway/run.py | Gateway integration — cron ticking in the long-running loop |
hermes_cli/cron.py | CLI hermes cron subcommands |
Four schedule formats are supported:
| Format | Example | Behavior |
|---|---|---|
| Relative delay | 30m, 2h, 1d | One-shot, fires after the specified duration |
| Interval | every 2h, every 30m | Recurring, fires at regular intervals |
| Cron expression | 0 9 * * * | Standard 5-field cron syntax (minute, hour, day, month, weekday) |
| ISO timestamp | 2025-01-15T09:00:00 | One-shot, fires at the exact time |
The model-facing surface is a single cronjob tool with action-style operations: create, list, update, pause, resume, run, remove.
Jobs are stored in ~/.hermes/cron/jobs.json with atomic write semantics (write to temp file, then rename). Each job record contains:
{
"id": "a1b2c3d4e5f6",
"name": "Daily briefing",
"prompt": "Summarize today's AI news and funding rounds",
"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
}
| State | Meaning |
|---|---|
scheduled | Active, will fire at next scheduled time |
paused | Suspended — won't fire until resumed |
completed | Repeat count exhausted or one-shot that has fired |
running | Currently executing (transient state) |
Older jobs may have a single skill field instead of the skills array. The scheduler normalizes this at load time — single skill is promoted to skills: [skill].
The scheduler runs on a periodic tick (default: every 60 seconds):
tick()
1. Acquire scheduler lock (prevents overlapping ticks)
2. Load all jobs from jobs.json
3. Filter to due jobs (next_run <= now AND state == "scheduled")
4. For each due job:
a. Set state to "running"
b. Create fresh AIAgent session (no conversation history)
c. Load attached skills in order (injected as user messages)
d. Run the job prompt through the agent
e. Deliver the response to the configured target
f. Update run_count, compute next_run
g. If repeat count exhausted → state = "completed"
h. Otherwise → state = "scheduled"
5. Write updated jobs back to jobs.json
6. Release scheduler lock
In gateway mode, the cron trigger (the part that decides when a due job
fires — "Axis B") is selected through a pluggable CronScheduler provider. The
gateway calls resolve_cron_scheduler() (cron/scheduler_provider.py) and runs
the resolved provider's start() in a dedicated background thread, alongside a
separate gateway-housekeeping thread.
The active provider is chosen by the cron.provider config key:
InProcessCronScheduler, which runs the
historical in-process loop calling scheduler.tick() every 60 seconds. This
is byte-identical to the pre-provider behavior.chronos, a managed-cron provider for
scale-to-zero deployments) → discovered from plugins/cron/<name>/ or
$HERMES_HOME/plugins/<name>/.If a named provider is missing, fails to load, or reports is_available() == False, the resolver falls back to the built-in with a warning — cron is
never left without a trigger. The built-in provider lives in core
(cron/scheduler_provider.py), not in plugins/, so the fallback can't be
accidentally removed.
What "firing" means (job execution + delivery) is unchanged and shared by all
providers — it stays in scheduler.run_job() / scheduler._deliver_result().
A provider only controls the trigger, never execution.
In CLI mode, cron jobs only fire when hermes cron commands are run or during active CLI sessions.
Hosted gateways can run the Chronos provider (cron.provider: chronos)
instead of the built-in ticker. Chronos lets an idle gateway scale to zero
and still fire cron jobs: rather than a 60-second in-process loop (which would
keep the process awake), it asks Nous infrastructure to arm exactly one
managed one-shot per job at that job's real next-fire time. At fire time Nous
calls the gateway back over an authenticated webhook (POST /api/cron/fire);
the gateway runs the job through the same run_one_job path as the built-in,
then re-arms the next one-shot. Between fires the process can be fully stopped —
it wakes only on a genuine fire, never on a periodic timer.
The flow (the managed scheduler is provided by Nous; the agent holds no scheduler credentials):
create/update a cron job
→ Chronos asks Nous to arm a one-shot at the job's next_run_at
(authenticated with the agent's existing Nous token)
→ at fire time Nous calls the gateway: POST {callback_url}/api/cron/fire
(authenticated with a short-lived, purpose-scoped Nous-minted JWT)
→ the gateway verifies the token, claims the job (store compare-and-set so
multi-replica deployments fire at-most-once), runs it, and re-arms the next
one-shot
Config (all non-secret; on hosted agents Nous sets these at provision time):
| key | meaning |
|---|---|
cron.provider | chronos to activate (empty = built-in ticker) |
cron.chronos.portal_url | Nous base URL (arming + the fire-token issuer) |
cron.chronos.callback_url | the gateway's own public base URL for inbound fires |
cron.chronos.expected_audience | this agent's fire-token audience |
cron.chronos.nas_jwks_url | key set for verifying the inbound fire token |
If Chronos is misconfigured or the agent isn't logged into Nous,
resolve_cron_scheduler() falls back to the built-in ticker (logged warning) —
cron never loses its trigger. Recurring jobs re-arm after each fire; repeat-N
jobs stop cleanly when the count is exhausted (no orphaned one-shot). The full
agent↔Nous wire contract lives in docs/chronos-managed-cron-contract.md.
Each cron job runs in a completely fresh agent session:
cronjob toolset is disabled (recursion guard)A cron job can attach one or more skills via the skills field. At execution time:
This enables reusable, tested workflows without pasting full instructions into cron prompts. For example:
Create a daily funding report → attach "ai-funding-daily-report" skill
Jobs can also attach a Python script via the script field. The script runs before each agent turn, and its stdout is injected into the prompt as context. This enables data collection and change detection patterns:
# ~/.hermes/scripts/check_competitors.py
import requests, json
# Fetch competitor release notes, diff against last run
# Print summary to stdout — agent analyzes and reports
The script timeout defaults to 120 seconds. _get_script_timeout() resolves the limit through a three-layer chain:
_SCRIPT_TIMEOUT (for tests/monkeypatching). Only used when it differs from the default.HERMES_CRON_SCRIPT_TIMEOUTcron.script_timeout_seconds in config.yaml (read via load_config())run_job() passes the user's configured fallback providers and credential pool into the AIAgent instance:
fallback_providers (list) or fallback_model (legacy dict) from config.yaml, matching the gateway's _load_fallback_model() pattern. Passed as fallback_model= to AIAgent.__init__, which normalizes both formats into a fallback chain.load_pool(provider) from agent.credential_pool using the resolved runtime provider name. Only passed when the pool has credentials (pool.has_credentials()). Enables same-provider key rotation on 429/rate-limit errors.This mirrors the gateway's behavior — without it, cron agents would fail on rate limits without attempting recovery.
Cron job results can be delivered to any supported platform:
| Target | Syntax | Example |
|---|---|---|
| Origin chat | origin | Deliver to the chat where the job was created |
| Local file | local | Save to ~/.hermes/cron/output/ |
| Telegram | telegram or telegram:<chat_id> | telegram:-1001234567890 |
| Discord | discord or discord:#channel | discord:#engineering |
| Slack | slack | Deliver to Slack home channel |
whatsapp | Deliver to WhatsApp home | |
| Signal | signal | Deliver to Signal |
| Matrix | matrix | Deliver to Matrix home room |
| Mattermost | mattermost | Deliver to Mattermost home |
email | Deliver via email | |
| SMS | sms | Deliver via SMS |
| Home Assistant | homeassistant | Deliver to HA conversation |
| DingTalk | dingtalk | Deliver to DingTalk |
| Feishu | feishu | Deliver to Feishu |
| WeCom | wecom | Deliver to WeCom |
| Weixin | weixin | Deliver to Weixin (WeChat) |
| BlueBubbles | bluebubbles | Deliver to iMessage via BlueBubbles |
| QQ Bot | qqbot | Deliver to QQ (Tencent) via Official API v2 |
For Telegram topics, use the format telegram:<chat_id>:<thread_id> (e.g., telegram:-1001234567890:17585).
By default (cron.wrap_response: true), cron deliveries are wrapped with:
The [SILENT] prefix in a cron response suppresses delivery entirely — useful for jobs that only need to write to files or perform side effects.
Cron deliveries are NOT mirrored into gateway session conversation history. They exist only in the cron job's own session. This prevents message alternation violations in the target chat's conversation.
Cron-run sessions have the cronjob toolset disabled. This prevents:
The scheduler uses cross-process file-based locking (fcntl.flock on Unix, msvcrt.locking on Windows) to prevent overlapping ticks from executing the same due-job batch twice — even between the gateway's in-process ticker and a standalone hermes cron / manual tick() call. If the lock cannot be acquired, tick() returns 0 immediately.
The hermes cron CLI provides direct job management:
hermes cron list # Show all jobs
hermes cron create # Interactive job creation (alias: add)
hermes cron edit <job_id> # Edit job configuration
hermes cron pause <job_id> # Pause a running job
hermes cron resume <job_id> # Resume a paused job
hermes cron run <job_id> # Trigger immediate execution
hermes cron remove <job_id> # Delete a job