ihdZddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZmZmZejeZddlmZ ddlmZd Zn #e$rd ZYnwxYwe Zed z Zed z Zed z Z dZ!dDdee"deedee"fdZ#dee"efdee"effdZ$de fdZ%de fdZ&dZ'de"de(fdZ)de"dee"effdZ*dedefdZ+dddee"efd ed!ee"dee"fd"Z,de-de(fd#Z.dEdee"efd!ee"dee"fd$Z/deee"effd%Z0d&eee"effd'Z1 dFd(e"de"d)ee"d*ee(d+ee"d,eee"efdee"deee"d-ee"d.ee"d/ee"d0ee"dee"effd1Z2d2e"deee"effd3Z3dGd4e4deee"effd5Z5d2e"d6ee"efdeee"effd7Z6dEd2e"d8ee"deee"effd9Z7d2e"deee"effd:Z8d2e"deee"effd;Z9d2e"de4fd<Z: dDd2e"d=e4d>ee"d?ee"fd@Z;d2e"de4fdAZdS)Hz 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)OptionalDictListAny)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 1/home/agentuser/.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)dictrget)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:rDvalueunit multiplierss rparse_durationrK`s  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)rCrD).0ps r z!parse_schedule..s@*+!1%%r zOCron expressions require 'croniter' package. Install with: pip install croniterzInvalid cron expression 'z': r )rPexprrRTz^\d{4}-\d{2}-\d{2}Zz+00:00oncezonce at z%Y-%m-%d %H:%M)rPrun_atrRzInvalid timestamp 'rQzonce 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))rrB startswithrKsplitlenall HAS_CRONITERrEr ExceptionrCrDr fromisoformatreplacetzinfo astimezone isoformatstrftime _hermes_nowr) rLoriginalschedule_lower duration_strrQpartsedtr\s rparse_schedulerqus$~~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 HHrpctj}|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)rf)rjrfrr rgre)rp target_tzlocal_tzs r _ensure_awarerusf $I y<>>,,..5zzz**55i@@@ == # ##r  last_run_atr rwc|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. rPr[Nr\)seconds)r$rurrdrONESHOT_GRACE_SECONDS)rLr rwr\ 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 rPrOrQr<r>r=r rX) r$maxminrbrjr get_nextrrF total_secondsrc) rL MIN_GRACE MAX_GRACErPperiod_secondsgracer r firstseconds 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. rPr[rvrOrQr]r NrX) rjr|rurrdrrhrbr r)rLrwr rQlastnext_runr s rcompute_next_runrs --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: )r9 JOBS_FILEr/openjsonloadr$JSONDecodeErrorloadsread save_jobsloggerwarningrcerror RuntimeErrorIOError)fdatarros r load_jobsr@scMMM      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)r9tempfilemkstemprrparentr(fdopenrdumprjrhflushfsyncfilenorer0 BaseExceptionunlinkr*)rfdtmp_pathrs rrr]ssMMM#I,<(=(=fU]^^^LB  Yr3 1 1 1 !Q It;==3J3J3L3LMMqYZ [ [ [ [ GGIII HQXXZZ  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! 8Y'''Y   Ih        D  sUDA3C DCDC1D ED21E2 D?<E>D??Epromptnamerepeatdeliveroriginmodelproviderbase_urlscriptc 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}|p |r|dndpd }id | d |p|dd  d|d|d|r|dndd|d|d|d|d| d| d|d|ddddddddddd |t| dddd||d!}t}||t||S)"a2 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. Returns: The created job dict NrrPr[r<rlocal /zcron jobidr2rrrrrrrrLschedule_displayrRr)times completedenabledTstate scheduled paused_at paused_reason created_at) next_run_atrw last_status last_errorlast_delivery_errorrr)rquuiduuid4hexrjrhrrrrrstripr$rrrr)rrLrrrrrrrrrrparsed_schedulejob_idr normalized_skillsnormalized_modelnormalized_providernormalized_base_urlnormalized_script label_sourcer!rs r create_jobrpsH%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)1TS7HR033dbXbL  f 1 SbS)//11  &  #   ):D"1%%   !   '  '  #  O  O// 8DD      4! " # $ T% & ' ( c) *(88#9   C> ;;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|Sr8r%rUjs r zlist_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_jobsrs9 8 8IKK 8 8 8D ;::4::: Kr updatesc t}t|D]\}}|d|krti||}d|v}d|vsd|vrJt|d|d}||d<|r|dnd|d<|r|d}t |t rt|}||d<|d|d|d|d<|d d krt||d <|d d rF|d d kr-|d st|d|d <|||<t|t||cSdS)zCUpdate a job by ID, refreshing derived schedule fields when needed.rrLrrrNrrRrpausedrrT) r enumerater%rr$rrrqrr) rrrir!updatedschedule_changedrupdated_schedules r update_jobrs ;;DD// , ,3 t9   %&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 .Cs' 1 1 1!qw&00A000r TF)rr`r)rr original_lens` r remove_jobr?sV ;;Dt99L 1 1 1 1t 1 1 1D 4yy<$t 5r successrdelivery_errorct}t|D]F\}}|d|kr3t}||d<|rdnd|d<|s|nd|d<||d<|d r|d d d d z|d d <|d d }|d d } |3|d kr-| |kr'||t |dSt|d||d<|d d|d<d |d<n|ddkrd|d<t |dSHt d|dS)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). rrwokrrNrrrrrr<rrLrFrrrrz0mark_job_run: job_id %s not found, skipping save) rrrjrhr$poprrrr) rrrrrrr!r rrs r mark_job_runrJs ;;DD//!!3 t9  --))++C!$C )0!=gC -4 >$C )7C% &wwx  -0]->->{A-N-NQR-RH k*H ))'22M+6 $yE7I7IHHQKKKdOOOFF"2#j/3!G!GC =!)!&I*G !!X--*G dOOO FFA D NNEvNNNNNr czt}|D]}|d|kr|did}|dvrdSt}t |d|}|r0||dkr||d<t |dSdSdS)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. rrLrPr rOFrT)rr$rjrhrr)rrr!rPr new_nexts radvance_next_runr |s ;;D   t9  77:r**..v66D///uu--))++C'J==H H (>(>>>%-M"$tt55  5r c 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|Sr8rrs rrz get_due_jobs..s! D D Dq  " " D D Dr FrTrrLrwrvz:Job '%s' had no next_run_at; recovering one-shot run at %srrrPr zSJob '%s' missed its scheduled time (%s, grace=%ds). Fast-forwarding to next run: %s)rjrcopydeepcopyr$r|rinforurrdrrrrhrr)r raw_jobsrdue needs_saver!rrecovered_nextrj next_run_dtrLrPrr s r get_due_jobsrs --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.Tr2z%Y-%m-%d_%H-%M-%Sz.mdrz.output_rrrrN)r9r7r6r-rjrirrrr(rwriterrrrer0rrr*)rrjob_output_dir timestamp output_filerrrs rsave_job_outputrsMMM&(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) NNNNNNNNNN)F)?__doc__rrloggingrr(rCrrrpathlibrhermes_constantsrtypingrrr r getLogger__name__r hermes_timer rjr rb ImportErrorresolve HERMES_DIRr5rr7rzrrr%r-r0r9rFrKrqrur|r#rrrrrrboolrrrrrrrr rrr8r rr*s  ((((((((,,,,,,,,,,,,,,,,,,  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(, !'+"&"" cc cc 3-c SM c c] c T#s(^ $ c C=c T#Y c C=csmcsmc SMc #s(^ccccLCHT#s(^4d38n1E$s$T#s(^$c3h8P$$$$N  c 8C= HT#s(^*LLLL^CsAA)(A)