i7#dZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddl mZddlmZmZmZmZmZejeZddlmZddlmZ dd lmZd Zn #e$rd ZYnwxYwe Z!e!d z Z"e"d z Z#ej$Z%e"dz Z&dZ'dLdee(deedee(fdZ)dee(efdee(effdZ*de fdZ+de fdZ,dZ-de(de.fdZ/de(dee(effdZ0de de fdZ1dd dee(efd!e d"ee(dee(fd#Z2de3de.fd$Z4dMdee(efd"ee(dee(fd%Z5deee(effd&Z6d'eee(effd(Z7d)ee(dee(fd*Z8 dNd+e(de(d,ee(d-ee.d.ee(d/eee(efdee(deee(d0ee(d1ee(d2ee(d3ee(d4eee(ee(fd5eee(d)ee(dee(eff d6Z9d7e(deee(effd8Z:dOd9e;deee(effd:ZZ>d7e(deee(effd?Z?d7e(deee(effd@Z@d7e(de;fdAZA dLd7e(dBe;dCee(dDee(fdEZBd7e(de;fdFZCdeee(effdGZDd7e(de(fdHZE dLdIeee(e(fdJeee(dee(effdKZFdS)Pz Cron job storage and management. Jobs are stored in ~/.hermes/cron/jobs.json Output is saved to ~/.hermes/cron/output/{job_id}/{timestamp}.md N)datetime timedelta)Path)get_hermes_home)OptionalDictListAnyUnion)now)atomic_replace)croniterTFcronz jobs.jsonoutputxskillskillsreturnc||r|gng}n(t|tr|g}nt|}g}|D]@}t|pd}|r||vr||A|S)zPNormalize legacy/single-skill and multi-skill inputs into a unique ordered list.N) isinstancestrliststripappend)rr raw_items normalizeditemtexts ./home/ubuntu/.hermes/hermes-agent/cron/jobs.py_normalize_skill_listr!0s ~$,UGG" FC !H LL J$$4:2$$&&  $D **   d # # # jobct|}t|d|d}||d<|r|dnd|d<|S)zLReturn a job dict with canonical `skills` and legacy `skill` fields aligned.rrrN)dictr!get)r#rrs r _apply_skill_fieldsr'As[cJ ":>>'#:#:JNN8|}tjd|}|st d|dt |d}|dd}dddd }|||zS) u Parse duration string into minutes. Examples: "30m" → 30 "2h" → 120 "1d" → 1440 zD^(\d+)\s*(m|min|mins|minute|minutes|h|hr|hrs|hour|hours|d|day|days)$zInvalid duration: 'z''. Use format like '30m', '2h', or '1d'r<i)mhd)rlowerrematch ValueErrorintgroup)r<rFvalueunit multiplierss r parse_durationrMgs  A H\^_ ` `E [YqYYYZZZ  A  E ;;q>>! D..K ;t$ $$r"schedulec`|}|}|}|dr5|dd}t|}d|d|ddS|}t |dkrut d|ddDrTtstd  t|n'#t$r}td |d |d}~wwxYwd ||d Sd|vstj d|r tj|dd}|j|}d|d|ddS#t$r}td|d |d}~wwxYw t|}t)t+|z}d|d|dS#t$rYnwxYwtd|d)uM Parse schedule string into structured format. Returns dict with: - kind: "once" | "interval" | "cron" - For "once": "run_at" (ISO timestamp) - For "interval": "minutes" (int) - For "cron": "expr" (cron expression) Examples: "30m" → once in 30 minutes "2h" → once in 2 hours "every 30m" → recurring every 30 minutes "every 2h" → recurring every 2 hours "0 9 * * *" → cron expression "2026-02-03T14:00" → once at timestamp zevery NintervalrA)kindminutesdisplayc3@K|]}tjd|VdS)z ^[\d\*\-,/]+$N)rErF).0ps r z!parse_schedule..s@*+!1%%r"zOCron expressions require 'croniter' package. Install with: pip install croniterzInvalid cron expression 'z': r)rRexprrTTz^\d{4}-\d{2}-\d{2}Zz+00:00oncezonce at z%Y-%m-%d %H:%M)rRrun_atrTzInvalid timestamp 'rSzonce in zInvalid schedule 'z'. Use: - Duration: '30m', '2h', '1d' (one-shot) - Interval: 'every 30m', 'every 2h' (recurring) - Cron: '0 9 * * *' (cron expression) - Timestamp: '2026-02-03T14:00:00' (one-shot at time))rrD startswithrMsplitlenall HAS_CRONITERrGr ExceptionrErFr fromisoformatreplacetzinfo astimezone isoformatstrftime _hermes_nowr) rNoriginalschedule_lower duration_strrSpartsedtr^s r parse_schedulers|s$~~HH^^%%N  ** |))++  ..****    NN  E 5zzQ3/4RaRy pnoo o K X     K K KIIIaIIJJ J K    h"(#8(CC E'(8(8h(G(GHHBy ]]__,,..Ebkk2B&C&CEE   E E EC8CCCCDD D E   **7!;!;!;;&&((,(,,          CX C C C  sDC$$ D.DD+A0F G&F;;GAH HHrrctj}|jStjj}|||S||S)aReturn a timezone-aware datetime in Hermes configured timezone. Backward compatibility: - Older stored timestamps may be naive. - Naive values are interpreted as *system-local wall time* (the timezone `datetime.now()` used when they were created), then converted to the configured Hermes timezone. This preserves relative ordering for legacy naive timestamps across timezone changes and avoids false not-due results. N)rh)rlrhrr rirg)rr target_tzlocal_tzs r _ensure_awarerwsf $I y<>>,,..5zzz**55i@@@ == # ##r" last_run_atr ryc|ddkrdS|rdS|d}|sdSttj|}||t t z kr|SdS)aReturn a one-shot run time if it is still eligible to fire. One-shot jobs get a small grace window so jobs created a few seconds after their requested minute still run on the next tick. Once a one-shot has already run, it is never eligible again. rRr]Nr^)seconds)r&rwrrfrONESHOT_GRACE_SECONDS)rNr ryr^ run_at_dts r _recoverable_oneshot_run_atr~s||Fv%%tt \\( # #F th4V<<==IC),ABBBBBB 4r"c6d}d}|d}|dkr<|dddz}|dz}t|t||S|d krtr t }t |d |}|t}|t} t| |z }|dz}t|t||S#t$rYnwxYw|S) a(Compute how late a job can be and still catch up instead of fast-forwarding. Uses half the schedule period, clamped between 120 seconds and 2 hours. This ensures daily jobs can catch up if missed by up to 2 hours, while frequent jobs (every 5-10 min) still fast-forward quickly. ri rRrQrSr>r@r?rrZ) r&maxminrdrlrget_nextrrH total_secondsre) rN MIN_GRACE MAX_GRACErRperiod_secondsgracer rfirstseconds r _compute_grace_secondsrs II <<  D z!i33b8!#9c%33444 v~~,~ --CHV,c22DMM(++E]]8,,F &5.!?!?!A!ABBN"a'Ey#eY"7"788 8    D  s*BD DDct}|ddkrt|||S|ddkrf|d}|r5ttj|}|t |z}n|t |z}|S|ddkrts0t d| d d S|}|r!ttj|}t|d |}| t}|Sd S) zo Compute the next run time for a schedule. Returns ISO timestamp string, or None if no more runs. rRr]rxrQrSr_rzCannot compute next run for cron schedule %r: 'croniter' is not installed. croniter is a core dependency as of v0.9.x; reinstall hermes-agent or run 'pip install croniter' in your runtime env.rZN) rlr~rwrrfrrjrdloggerwarningr&rr)rNryr rSlastnext_run base_timers r compute_next_runr#s[ --C6!!*8SkRRRR & Z ' '9%  8 !7 !D!DEEDi8888HHYw7777H!!### & V # #  NN V$$    4   K%h&<[&I&IJJI()44==**!!### 4r"chttsgS ttdd5}t j|}|dgcdddS#1swxYwYdS#tj$r ttdd5}t j| d}|dg}|r)t|t d|cdddcYS#1swxYwYYdS#t$r3}td |td ||d}~wwxYwt $r3}td |td ||d}~wwxYw) zLoad all jobs from storage.rutf-8encodingjobsNF)strictz8Auto-repaired jobs.json (had invalid control characters)z#Failed to auto-repair jobs.json: %sz*Cron database corrupted and unrepairable: zIOError reading jobs.json: %szFailed to read cron database: )r; JOBS_FILEr1openjsonloadr&JSONDecodeErrorloadsread save_jobsrrreerror RuntimeErrorIOError)fdatarrqs r load_jobsrUscMMM      H )S7 3 3 3 (q9Q< B B BOAOOPPVW W X HHH 4a888?A??@@aGHsB*A9, B9A==BA=BF1D5-A+D' D5$F1'D+ +D5.D+ /D55 E2?.E--E22 F1>.F,,F1rcttjttjdd\}} t j|dd5}tj |t d|d | t j |d d d n #1swxYwYt|tt!td S#t"$r( t j|n#t&$rYnwxYwwxYw) zSave all jobs to storage..tmpz.jobs_dirsuffixprefixwrr)r updated_atr?)indentN)r;tempfilemkstemprrparentr*fdopenrdumprlrjflushfsyncfilenor r2 BaseExceptionunlinkr,)rfdtmp_pathrs r rrrsqMMM#I,<(=(=fU]^^^LB  Yr3 1 1 1 !Q It;==3J3J3L3LMMqYZ [ [ [ [ GGIII HQXXZZ  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! x+++Y   Ih        D  sUD A3C D CD C,D D?D-,D?- D:7D?9D::D?workdirc|dSt|}|sdSt|}|st d|d|}|st d||st d|t|S)uhNormalize and validate a cron job workdir. Rules: - Empty / None → None (feature off, preserves old behaviour). - ``~`` is expanded. Relative paths are rejected — cron jobs run detached from any shell cwd, so relative paths have no stable meaning. - The path must exist and be a directory at create/update time. We do NOT re-check at run time (a user might briefly unmount the dir; the scheduler will just fall back to old behaviour with a logged warning). Returns the absolute path string, or None when disabled. Raises ValueError on invalid input. Nz+Cron workdir must be an absolute path (got zN). Cron jobs run detached from any shell cwd, so relative paths are ambiguous.zCron workdir does not exist: z!Cron workdir is not a directory: ) rrr expanduser is_absoluterGresolver1is_dir)rrawexpandedresolveds r _normalize_workdirrst g,,    C tCyy##%%H    ! !  [# [ [ [   !!H ??  ECCCDDD ??  IGXGGHHH x==r"promptnamerepeatdeliveroriginmodelproviderbase_urlscript context_fromenabled_toolsetsc t|}||dkrd}|ddkr|d}||rdnd}tjjdd}t }t ||}t|tr!t| nd}t| tr!t|  nd}t| tr4t|  d nd}|pd}|pd}|pd}t| tr!t|  nd}|pd}| r d | Dnd}|pd}t|}t| tr,| r| gnd} n&t| trd | Dpd} nd} |p |r|dndpd }id |d|p|dd d|d|d|r|dndd|d|d|d|d| d|d| d|d|dddddd d!dd"d|t|dddd||||d# }t}||t#||S)$a Create a new cron job. Args: prompt: The prompt to run (must be self-contained, or a task instruction when skill is set) schedule: Schedule string (see parse_schedule) name: Optional friendly name repeat: How many times to run (None = forever, 1 = once) deliver: Where to deliver output ("origin", "local", "telegram", etc.) origin: Source info where job was created (for "origin" delivery) skill: Optional legacy single skill name to load before running the prompt skills: Optional ordered list of skills to load before running the prompt model: Optional per-job model override provider: Optional per-job provider override base_url: Optional per-job base URL override script: Optional path to a Python script whose stdout is injected into the prompt each run. The script runs before the agent turn, and its output is prepended as context. Useful for data collection / change detection. context_from: Optional job ID (or list of job IDs) whose most recent output is injected into the prompt as context before each run. Useful for chaining cron jobs: job A finds data, job B processes it. enabled_toolsets: Optional list of toolset names to restrict the agent to. When set, only tools from these toolsets are loaded, reducing token overhead. When omitted, all default tools are loaded. workdir: Optional absolute path. When set, the job runs as if launched from that directory: AGENTS.md / CLAUDE.md / .cursorrules from that directory are injected into the system prompt, and the terminal/file/code_exec tools use it as their working directory (via TERMINAL_CWD). When unset, the old behaviour is preserved (no context files injected, tools use the scheduler's cwd). Returns: The created job dict NrrRr]r>rlocal /cg|]D}t|#t|ESr:rr)rWts r zcreate_job..s9VVVas1vv||~~V3q66<<>>VVVr"cg|]D}t|#t|ESr:rrWjs r rzcreate_job..s9OOO1A OA OOOr"zcron jobidr2rrrrrrrrrNschedule_displayrTr)times completedenabledTstate scheduled paused_at paused_reason) created_at next_run_atry last_status last_errorlast_delivery_errorrrrr)rsuuiduuid4hexrlrjr!rrrrstriprrr&rrrr)rrNrrrrrrrrrrrrrparsed_schedulejob_idr normalized_skillsnormalized_modelnormalized_providernormalized_base_urlnormalized_scriptnormalized_toolsetsnormalized_workdir label_sourcer#rs r create_jobrsf%X..Ofkkv&((V^$1((' Z\\ crc "F -- ! ! # #C-eV<<-7s-C-CMs5zz'')))3=h3L3LV#h----///RV?I(TW?X?Xb#h----//66s;;;^b'/4-5-5/9&#/F/FPF ))+++D)1TZjtVV3CVVVVpt-5+G44,$$1=1C1C1E1EO **,,--4 L$ ' 'OO OOOWSW  S7HR033dbXbL  f 1 SbS)//11  &  #  ):D"1%%  !  '  '  #     O  O// 8DD     " 4# $ % & T' ( ) *'88#/%?   CD ;;DKK dOOO Jr"rcft}|D]}|d|krt|cS dS)zGet a job by ID.rN)rr')rrr#s r get_jobr)sG ;;D,, t9  &s++ + + +  4r"include_disabledcRdtD}|s d|D}|S)z2List all jobs, optionally including disabled ones.c,g|]}t|Sr:r'rs r rzlist_jobs..4s! 8 8 8q  " " 8 8 8r"c>g|]}|dd|S)rT)r&rs r rzlist_jobs..6s+:::a155D#9#9::::r")r)rrs r list_jobsr2s9 8 8IKK 8 8 8D ;::4::: Kr"updatesc t}t|D]\}}|d|krd|vr$|d}|dvrd|d<nt||d<ti||}d|v}d|vsd|vrJt |d|d}||d<|r|dnd|d<|r|d} t | trt| } | |d<|d | d |d |d <|d d krt| |d <|ddrF|d d kr-|d st|d|d <|||<t|t||cSdS)zCUpdate a job by ID, refreshing derived schedule fields when needed.rr)NrFNrNrrrrrTrpausedrrT) r enumeraterr'r!r&rrrsrr) rrrir#_wdupdatedschedule_changedrupdated_schedules r update_jobr :s1 ;;DD//),),3 t9      )$C'''%) ""%7%<%< "%&8&8&899%0 w  'W"4"4 5gkk'6J6JGKKX`LaLa b b  1GH 7HR033dGG   L&z2 *C00 7#12B#C#C &6 #*1++" $$Y .s' 1 1 1!qw&00A000r"TF)rrbr)rr original_lens` r remove_jobrsV ;;Dt99L 1 1 1 1t 1 1 1D 4yy<$t 5r"successrdelivery_errorc xt5t}t|D]\}}|d|krt}||d<|rdnd|d<|s|nd|d<||d<|d r|d d d d z|d d <|d d }|d d } |>|d kr8| |kr2||t|ddddSt|d||d<|d|did} | dvrVd|d<|dsd|d<t d|d|d| n)d|d<d |d<n|ddkrd|d<t|ddddSt d|ddddS#1swxYwYdS)uK Mark a job as having been run. Updates last_run_at, last_status, increments completed count, computes next_run_at, and auto-deletes if repeat limit reached. ``delivery_error`` is tracked separately from the agent error — a job can succeed (agent produced output) but fail delivery (platform down). rryokrrNrrrrrr>rrNrrRrrQrztFailed to compute next run for recurring schedule (is the 'croniter' package installed in the gateway's Python env?)zyJob '%s' (%s) could not compute next_run_at; leaving enabled and marking state=error so the job is not silently disabled.rFrrrz0mark_job_run: job_id %s not found, skipping save) _jobs_file_lockrrrlrjr&poprrrrr) rrrrrrr#r rrrRs r mark_job_runrs ;S;S{{oo7 7 FAs4yF""!mm--//%(M"-4%ATT'M"18$BEEdL!-;)*778$$ 14X1B1B;PQ1R1RUV1VCM+. M--g66E #H k :I(UQYY9;M;M !$-;S;S;S;S;S;S;S;S2&6c*os%K%KM"}%-77:r2266v>>D333'.G "ww|44!J -  < GGFCI66 */I'2G WWW%%11#.CL$s;S;S;S;S;S;S;S;S#p I6RRRw;S;S;S;S;S;S;S;S;S;S;S;S;S;S;S;S;S;SsDH/CH/H//H36H3ct5t}|D]}|d|kr|did}|dvrddddSt}t |d|}|r;||dkr"||d<t |ddddSddddS ddddS#1swxYwYdS) uPreemptively advance next_run_at for a recurring job before execution. Call this BEFORE run_job() so that if the process crashes mid-execution, the job won't re-fire on the next gateway restart. This converts the scheduler from at-least-once to at-most-once for recurring jobs — missing one run is far better than firing dozens of times in a crash loop. One-shot jobs are left unchanged so they can still retry on restart. Returns True if next_run_at was advanced, False otherwise. rrNrRrNFrT)rrr&rlrjrr)rrr#rRr new_nexts r advance_next_runr"s {{  C4yF""wwz2..226::333 "mm--//+C OSAA CGGM,B,B B B)1C &dOOO#s%A C2"A&C2C2#C22C69C6c ft}t}dtj|D}g}d}|D]}|dds|d}|st |di||d}|sm||d<|}t d |d |d ||D]}|d |d kr ||d<d}nttj |} | |kr|di} | d } t| } | d vr|| z | kr~t| |} | rZt d|d |d || | |D]}|d |d kr | |d<d}n|||rt!||S)aOGet all jobs that are due to run now. For recurring jobs (cron/interval), if the scheduled time is stale (more than one period in the past, e.g. because the gateway was down), the job is fast-forwarded to the next future run instead of firing immediately. This prevents a burst of missed jobs on gateway restart. c,g|]}t|Sr:rrs r rz get_due_jobs..s! D D Dq  " " D D Dr"FrTrrNryrxz:Job '%s' had no next_run_at; recovering one-shot run at %srrrRrzSJob '%s' missed its scheduled time (%s, grace=%ds). Fast-forwarding to next run: %s)rlrcopydeepcopyr&r~rinforwrrfrrrrjrr)r raw_jobsrdue needs_saver#rrecovered_nextrj next_run_dtrNrRrr!s r get_due_jobsr. s --C{{H D DDM(,C,C D D DD CJ99wwy$''  77=)) 8 B''GGM22N " !/C %H KKLD **      d8s4y(((6B}%!%JE) $H$:8$D$DEE #  wwz2..H<<''D +844E+++{1B0Q0Q0S0SV[0[0[,HcmmooFFKK:D 22  '""d8s4y0008B}-)-J!E1 JJsOOO( Jr"ctt|z }|ddt|t d}||dz }t jt|dd\}} tj |dd 5}| || tj |d d d n #1swxYwYt||t!|n5#t"$r( tj|n#t&$rYnwxYwwxYw|S) zSave job output to file.Tr4z%Y-%m-%d_%H-%M-%Sz.mdrz.output_rrrrN)r;r9r8r/rlrkrrrr*rwriterrrr r2rrr,)rrjob_output_dir timestamp output_filerrrs r save_job_outputr4[sMMM&(N555 &&':;;I i#4#4#44K#N(;(;FS]^^^LB  Yr3 1 1 1 !Q GGFOOO GGIII HQXXZZ  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! x---[!!!!   Ih        D   sUD.'AD7 D.DD. D "D.. E 9E E  EE EE  consolidatedprunedc (t|pi}t|pg}|t|z}|s|sgdddSt5t }g}d}|D]3}t |d|d}|s umbrella_skill_name``. pruned: list of skill names that were archived with no forwarding target. Returns a report dict:: { "rewrites": [ { "job_id": ..., "job_name": ..., "before": [...], "after": [...], "mapped": {"old": "new", ...}, "dropped": ["old", ...], }, ... ], "jobs_updated": N, "jobs_scanned": M, } Best-effort: exceptions from loading/saving propagate to the caller so tests can assert behaviour; the curator invocation site wraps this call in a try/except so a failure here never breaks the curator. r)rewrites jobs_updated jobs_scannedFrrNTrr)rjob_namebeforeaftermappeddroppedz2Curator rewrote skill references in %d cron job(s)) r%setkeysrrr!r&rrrrr'rb) r5r6 pruned_setrr8changedr# skills_beforer>r? new_skillsrtargets r rewrite_skill_refsrG{sd *++LV\r""J#l''))***J F F1EEE 4 4 {{)+# # C1#'''2B2BCGGHDUDUVVM  %'F!#G$&J% 0 0<'')$/F#)F4L2& ":":"))&111Z''NN4((((:--"))$/// ' &CM,6@:a==DCLG OO''$--GGFOOrVs  ((((((((,,,,,,33333333333333  8 $ $****** !!!!!!LLLLL_   & & ( (   { " !).""  #x}X\]`Xa"T#s(^S#X d     t    %c%c%%%%*VSVT#s(^VVVVr$h$8$$$$."& 38n #  c] 6Tc@++tCH~+HSM+U]^aUb++++dH4S#X'HHHH:Dc3h(& (3-H !'+"&"" 48,0!@@ @@ 3-@ SM @ c] @ T#s(^ $ @ C=@ T#Y @ C=@sm@sm@ SM@5d3i01@tCy)@c]@  #s(^!@@@@FCHT#s(^4d38n1E-s-T#s(^-c3h8P----`  c 8C= HT#s(^*LLLL^CB.2"&o o 4S>*o T#Y o  #s(^o o o o o o s"A++A54A5