eiyx#FdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddl mZddlmZmZmZmZmZejeZddlmZ ddlmZd Zn #e$rd ZYnwxYweZed z Z e d z Z!ej"Z#e d z Z$dZ%dHdee&deedee&fdZ'dee&efdee&effdZ(de fdZ)de fdZ*dZ+de&de,fdZ-de&dee&effdZ.de de fdZ/dddee&efd e d!ee&dee&fd"Z0de1de,fd#Z2dIdee&efd!ee&dee&fd$Z3deee&effd%Z4d&eee&effd'Z5d(ee&dee&fd)Z6 dJd*e&de&d+ee&d,ee,d-ee&d.eee&efdee&deee&d/ee&d0ee&d1ee&d2ee&d3eee&ee&fd4eee&d(ee&dee&eff d5Z7d6e&deee&effd7Z8dKd8e9deee&effd9Z:d6e&d:ee&efdeee&effd;Z;dId6e&dZ=d6e&deee&effd?Z>d6e&de9fd@Z? dHd6e&dAe9dBee&dCee&fdDZ@d6e&de9fdEZAdeee&effdFZBd6e&d e&fdGZCdS)Lz 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)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/div/.hermes/hermes-agent/cron/jobs.py_normalize_skill_listr /s ~$,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&@s[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;rEvalueunit multiplierss rparse_durationrLfs  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 Nintervalr@)kindminutesdisplayc3@K|]}tjd|VdS)z ^[\d\*\-,/]+$N)rDrE).0ps r z!parse_schedule..s@*+!1%%r!zOCron expressions require 'croniter' package. Install with: pip install croniterzInvalid cron expression 'z': r)rQexprrSTz^\d{4}-\d{2}-\d{2}Zz+00:00oncezonce at z%Y-%m-%d %H:%M)rQrun_atrSzInvalid timestamp 'rRzonce 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))rrC startswithrLsplitlenall HAS_CRONITERrFr ExceptionrDrEr fromisoformatreplacetzinfo astimezone isoformatstrftime _hermes_nowr) rMoriginalschedule_lower duration_strrRpartsedtr]s rparse_schedulerr{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 HHrqctj}|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)rg)rkrgrr rhrf)rq target_tzlocal_tzs r _ensure_awarervsf $I y<>>,,..5zzz**55i@@@ == # ##r! last_run_atr rxc|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. rQr\Nr])seconds)r%rvrrerONESHOT_GRACE_SECONDS)rMr rxr] 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 rQrPrRr=r?r>rrY) r%maxminrcrkr get_nextrrG total_secondsrd) rM MIN_GRACE MAX_GRACErQperiod_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|ddkrMtsdSt|d |}| t}|SdS) zo Compute the next run time for a schedule. Returns ISO timestamp string, or None if no more runs. rQr\rwrPrRr^rNrY) rkr}rvrrerrircr r)rMrxr rRlastnext_runrs rcompute_next_runr"s --C6!!*8SkRRRR & Z ' '9%  8 !7 !D!DEEDi8888HHYw7777H!!### & V # # 4(#..==**!!### 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_FILEr0openjsonloadr%JSONDecodeErrorloadsread save_jobsloggerwarningrderror RuntimeErrorIOError)fdatarrps r load_jobsrFscMMM      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 j|tt!td S#t"$r( t j|n#t&$rYnwxYwwxYw) zSave all jobs to storage..tmpz.jobs_dirsuffixprefixwrr)r updated_atr>)indentN)r:tempfilemkstemprrparentr)fdopenrdumprkriflushfsyncfilenorfr1 BaseExceptionunlinkr+)rfdtmp_pathrs rrrcssMMM#I,<(=(=fU]^^^LB  Yr3 1 1 1 !Q It;==3J3J3L3LMMqYZ [ [ [ [ GGIII HQXXZZ  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! 8Y'''Y   Ih        D  sUDA3C DCDC1D ED21E2 D?<E>D??Eworkdirc|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_absoluterFresolver0is_dir)rrawexpandedresolveds r_normalize_workdirrvst 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 NrrQr\r=rlocal /cg|]D}t|#t|ESr9rr)rVts r zcreate_job..s9VVVas1vv||~~V3q66<<>>VVVr!cg|]D}t|#t|ESr9rrVjs rrzcreate_job..s9OOO1A OA OOOr!zcron jobidr2rrrrrrrrrMschedule_displayrSr)times completedenabledTstate scheduled paused_at paused_reason) created_at next_run_atrx last_status last_errorlast_delivery_errorrrrr)rruuiduuid4hexrkrir rrrrstriprrr%rrrr)rrMrrrrrrrrrrrrrparsed_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 rget_jobrsG ;;D,, t9  &s++ + + +  4r!include_disabledcRdtD}|s d|D}|S)z2List all jobs, optionally including disabled ones.c,g|]}t|Sr9r&rs rrzlist_jobs..%s! 8 8 8q  " " 8 8 8r!c>g|]}|dd|S)rT)r%rs rrzlist_jobs..'s+:::a155D#9#9::::r!)r)rrs r list_jobsr#s9 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)NrFNrMrrrrrSrpausedrrT) r enumeraterr&r r%rrrrrr) 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)rrar)rr original_lens` r remove_jobrsV ;;Dt99L 1 1 1 1t 1 1 1D 4yy<$t 5r!successrdelivery_errorcrt5t}t|D]\\}}|d|krIt}||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 d|d<d |d<n|ddkrd|d<t|ddddS^t 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). rrxokrrNrrrrrr=rrMrFrrrrz0mark_job_run: job_id %s not found, skipping save) _jobs_file_lockrrrkrir%poprrrr) rrrrrrr"r rrs r mark_job_runrs %S%S{{oo! ! 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"}%-%*C N#.CLLWWW%%11#.CL$G%S%S%S%S%S%S%S%S#D I6RRRK%S%S%S%S%S%S%S%S%S%S%S%S%S%S%S%S%S%SsDF,AF,F,,F03F0ct5t}|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. rrMrQrrPNFrT)rrr%rkrirr)rrr"rQr new_nexts radvance_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|Sr9rrs rrz get_due_jobs..s! D D Dq  " " D D Dr!FrTrrMrxrwz:Job '%s' had no next_run_at; recovering one-shot run at %srrrQrzSJob '%s' missed its scheduled time (%s, grace=%ds). Fast-forwarding to next run: %s)rkrcopydeepcopyr%r}rinforvrrerrrrirr)r raw_jobsrdue needs_saver"rrecovered_nextrj next_run_dtrMrQrrs 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 #1swxYwYtj||t!|n5#t"$r( tj|n#t&$rYnwxYwwxYw|S) zSave job output to file.Tr3z%Y-%m-%d_%H-%M-%Sz.mdrz.output_rrrrN)r:r8r7r.rkrjrrrr)rwriterrrrfr1rrr+)rrjob_output_dir timestamp output_filerrrs rsave_job_outputr26sMMM&(N555 &&':;;I i#4#4#44K#N(;(;FS]^^^LB  Yr3 1 1 1 !Q GGFOOO GGIII HQXXZZ  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! 8[)))[!!!!   Ih        D   sUD3'AD7 D3DD3 D 'D33 E%>EE% E E%E  E%)NN)N) NNNNNNNNNNNNN)F)D__doc__r#rloggingr threadingr)rDrrrpathlibrhermes_constantsrtypingrrr r r getLogger__name__r hermes_timer rkr rc ImportErrorr HERMES_DIRr6rLockrr8r{rr r&r.r1r:rGrLrrrvr}r$rrrrrrrboolrr r rrrrr r,r2r9r!rr@s]  ((((((((,,,,,,33333333333333  8 $ $******!!!!!!LLLLL_   & & ( (   { " !).""  #x}X\]`Xa"T#s(^S#X d     t    %c%c%%%%*VSVT#s(^VVVVr$h$8$$$$."& 38n #  c] 6Tc@tCH~HSMU]^aUbHH4S#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^CsA%%A/.A/