+ ӃiHdpRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t ^RI H t ^RIHtHtHtHt]P&!]4t^RIHt^RIHtRt] !4t]R , t]R , t]R , t^xt R?R Rllt!RRlt"RRlt#RRlt$Rt%RRlt&RRlt'RRlt(RR/RRllt)RR lt*R@R!R"llt+R#R$lt,R%R&lt-RAR'R(llt.R)R*lt/RBR+R,llt0R-R.lt1R@R/R0llt2R1R2lt3R3R4lt4R5R6lt5R@R7R8llt6R9R:lt7R;R<lt8R=R>lt9R# ]dR tLi;i)Cz 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 timedeltaPath)get_hermes_home)OptionalDictListAny)now)croniterTFcronz jobs.jsonoutputc~V^8dQhR\\,R\\,R\\,/#)skillskillsreturn)rstrr r )formats"&/home/ubuntu/hermes-agent/cron/jobs.py __annotate__r)s0#x}X\]`XacVfV'dV.M.pM%\V\4'dV.pM \V4p.pVFIp\T;'gR4P4pV'gK0WS9gK8VP V4KK V#)zPNormalize legacy/single-skill and multi-skill inputs into a unique ordered list.) isinstancerliststripappend)rr raw_items normalizeditemtexts&& r_normalize_skill_listr#)sv ~$UG" FC H L J4::2$$& 4D*   d # rctV^8dQhR\\\3,R\\\3,/#)rjobr)rrr )rs"rrr:s*T#s(^S#Xrc\V4p\VPR4VPR44pW!R&V'd V^,MRVR&V#)zLReturn a job dict with canonical `skills` and legacy `skill` fields aligned.rrN)dictr#get)r%r rs& r_apply_skill_fieldsr):sIcJ ":>>'#:JNN8! D3C.K t$ $$rcRV^8dQhR\R\\\3,/#rscheduler)rrr )rs"rrrus&VVSVT#s(^Vrc hVP4pTpVP4pVPR4'd/VR,P4p\V4pRRRVRRV R2/#VP 4p\ V4^8dt\ ;QJd#RVR ,4F 'dK R M R M!RVR ,44'd,\'g \R 4h\V4RRRTRT/#RV9g\P!RV4'dn\P!VPRR44pVP fVP#4pRRRVP%4RRVP'R4 2/#\V4p\)4\+VR7,pRRRVP%4RRV 2/# \dp\R T RT 24hRp?ii;i \dp\RT RT 24hRp?ii;i \dMi;i\RT R24h)u  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 :NNkindintervalminutesdisplayrEc3P"TFp\P!RV4xK R#5i)z ^[\d\*\-,/]+$N)rIrJ).0ps& r !parse_schedule..s"/8!!1%%ys$&:NNFTzOCron expressions require 'croniter' package. Install with: pip install croniterzInvalid cron expression 'z': Nr exprTz^\d{4}-\d{2}-\d{2}Zz+00:00oncerun_atzonce at z%Y-%m-%d %H:%MzInvalid timestamp 'rXzonce 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))rrH startswithrPsplitlenall HAS_CRONITERrKr ExceptionrIrJr fromisoformatreplacetzinfo astimezone isoformatstrftime _hermes_nowr) rSoriginalschedule_lower duration_strrXpartsedtrds & rparse_scheduleryusY$~~HH^^%N  **|))+  . J w y*   NN E 5zQ33/4Ry333/4Ry|no o K X  F H x   h"((#8(CC E''(8(8h(GHByy ]]_",,.Xbkk2B&C%DE    *7!;; F f&&( (,  ; K8 #aSIJ J K, E28*CsCD D E      XJ'B C sC( G A+G0 >H G-G((G-0 H;H  H H"!H"c0V^8dQhR\R\/#)rrxr)r)rs"rrrs$$h$8$rc\4PpVPfO\P!4P 4PpVP VR7P V4#VP V4#)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. )rn)rrrnrr rorm)rx target_tzlocal_tzs& r _ensure_awarer~s` $$I yy<<>,,.55zzz*55i@@ == ##r last_run_atc V^8dQhR\\\3,R\R\\,R\\,/#)rrSr rr)rrr rr)rs"rrrs@38n #  c] rcVPR4R8wdR#V'dR#VPR4pV'gR#\\P!V44pWA\ \ R7, 8dV#R#)zReturn 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. rVrcNrd)seconds)r(r~rrlrONESHOT_GRACE_SECONDS)rSr rrd run_at_dts&&$ r_recoverable_oneshot_run_atrs`||Fv% \\( #F h44V<=I),ABBB rc0V^8dQhR\R\/#rR)r'rC)rs"rrrsTcrc^xpRpVPR4pVR8Xd8VPR^4^<,pV^,p\V\WR44#VR8Xd\'d\ 4p\ VR,V4pVP \4pVP \4p \W, P44pV^,p\V\WR44#V# \dT#i;i)aCompute 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. i rVrWrXr r`) r(maxminrjrrr get_nextrrC total_secondsrk) rS MIN_GRACE MAX_GRACErVperiod_secondsgracer r firstseconds & r_compute_grace_secondsrsII << D z!i3b8!#9c%344 v~,, -CHV,c2DMM(+E]]8,F &.!?!?!ABN"a'Ey#e"78 8     s(BC.. C=<C=cV^8dQhR\\\3,R\\,R\\,/#)rrSrr)rrr r)rs"rrrs4tCH~HSMU]^aUbrc\4pVR,R8Xd\WVR7#VR,R8XdwVR,pV'dC\\P!V44pV\ VR7,pVP 4#V\ VR7,pVP 4#VR,R8XdG\'gR#\VR ,V4pVP\4pVP 4#R#) zc Compute the next run time for a schedule. Returns ISO timestamp string, or None if no more runs. rVrcrrWrXrer Nr`) rrrr~rrlrrprjr r)rSrr rXlastnext_runr s&& rcompute_next_runrs -C6!*8kRR & Z '9%  !7!7 !DEDi88H!!##Yw77H!!## & V #|(#.==*!!## rc\V^8dQhR\\\\3,,/#rrr rrr )rs"rrr@s 4S#X'rc\4\P4'g.#\\RRR7;_uu_4p\P !V4pVP R.4uuRRR4# +'giR#;i \Pd\\RRR7;_uu_4p\P!TP4RR7pTP R.4pT'd!\T4\PR4TuuRRR4u# +'giR#;i \d.uu#i;i\d.u#i;i) zLoad all jobs from storage.rutf-8encodingjobsNF)strictz8Auto-repaired jobs.json (had invalid control characters))r@ JOBS_FILEr6openjsonloadr(JSONDecodeErrorloadsread save_jobsloggerwarningrkIOError)fdatars r load_jobsr@sM       )S7 3 3q99QD??EcV^8dQhR\R\R\\,R\\,R\\,R\\\\3,,R\\,R\\ \,,R \\,R \\,R \\,R \\,R \\\3,/ #)rpromptrSnamerepeatdeliveroriginrrmodelproviderbase_urlscriptr)rrrCrr r )rs"rrrnsbb bb 3-b SM b c] b T#s(^ $ b C=b T#Y b C=bsmbsmb SMb #s(^brc \V4p Ve V^8:dRpV R,R8XdVf^pVf V'dRMRp\P!4PR,p \ 4P 4p\ Wg4p\V\4'd\V4P4MRp\V \4'd\V 4P4MRp\V \4'd)\V 4P4PR4MRpT;'gRpT;'gRpT;'gRp\V \4'd\V 4P4MRpT;'gRpT;'gV'd V^,MR;'gRp/R V bR T;'gVR ,P4bR VbR VbRV'd V^,MRbRVbRVbRVbRVbRV bRV PRV4bRRVR^/bRRbRRbRRbRRbRVbR \V 4R!RR"RR#RR$VRV/Cp\4pVPV4\V4V#)%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. Returns: The created job dict NrVrcrlocal:N N/zcron jobidr:N2NrrrrrrrrSschedule_displayrYrtimes completedenabledTstate scheduled paused_at paused_reason created_at next_run_atr last_status last_errorr)ryuuiduuid4hexrrrpr#rrrrstripr(rrrr)rrSrrrrrrrrrrparsed_schedulejob_idr normalized_skillsnormalized_modelnormalized_providernormalized_base_urlnormalized_script label_sourcer%rs&&&&&&&&&&&& r create_jobrnsH%X.Ofkv&(V^$(' ZZ\  c "F - ! ! #C-e<-7s-C-Cs5z'')3=h3L3L#h---/RV?I(TW?X?X#h---/66s;^b'//4-55-55/9&#/F/FF ))+D)11TbS7H03dbbXbL  f 11 S)//1  &  #   ):"1%   !   '  '  #  O  O// 8D   V    4! " # $ T% & ' ( c) * '8ttd7&7 C< ;DKK dO JrchV^8dQhR\R\\\\3,,/#rrrrrrr )rs"rrrs'CHT#s(^4rcb\4pVFpVR,V8XgK\V4u# R#)zGet a job by ID.rN)rr))rrr%s& rget_jobrs/ ;D t9 &s+ + rchV^8dQhR\R\\\\3,,/#)rinclude_disabledr)boolr rrr )rs"rrrs'd38n1Erc\4Uu.uFp\V4NK ppV'g+VUu.uFqPRR4'gKVNK ppV#uupiuupi)z2List all jobs, optionally including disabled ones.rT)rr)r()rjrs& r list_jobsrsO,5K 8Kq  "KD 8 :4a55D#94: K 9:sAA Ac V^8dQhR\R\\\3,R\\\\3,,/#)rrupdatesr)rrr r)rs"rrrs6sT#s(^c3h8Prc \4p\V4EF^wr4VR,V8wdK\/VCVC4pRV9pRV9gRV9dE\VP R4VP R44pWuR&V'd V^,MRVR&V'dbVR,pVP RVP RVP R444VR&VP R4R 8wd\ V4VR &VP R R 4'dCVP R4R 8wd-VP R 4'g\ VR,4VR &WRV&\ V4\W#,4u# R#) zCUpdate a job by ID, refreshing derived schedule fields when needed.rrSrrNrrYrpausedrrT)r enumerater)r#r(rr) rrrir%updatedschedule_changedrupdated_schedules && r update_jobrs\ ;DD/ t9  %&8&8&89%0 w 'W"4 5gkk'6JGKKX`La b  1H 7H03dGG  &z2 *1++" $$Y ->{A-NQR-RH k*H ))'2M+6 $y7IHHQKdO"2#j/3!GC =!)!&I*G !X-*G dO ?"BdOrc0V^8dQhR\R\/#rr)rs"rrrmsSTrcX\4pVFpVR,V8XgKVPR/4PR4pVR9dR#\4P4p\ VR,V4pV'd(WRPR48wdWRR&\ V4R#R# R#)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. rrSrVFrTr rW)rr(rrrprr)rrr%rVr new_nexts& radvance_next_runrms ;D t9 77:r*..v6D//-))+C'J=HH (>>%-M"$ rc\V^8dQhR\\\\3,,/#rr)rs"rrrs#LLd4S>*Lrc d\4p\4p\P!V4Uu.uFp\ V4NK pp.pRpVEFpVP RR4'gKVP R4pV'g\ VP R/4VVP R4R7pV'gKnWR&Tp\PRVP R VR ,4V4VF p V R ,VR ,8XgKWR&RpM \\P!V44p W8:gKVP R/4p V P R 4p \V 4p V R 9dW , P4V 8d{\WP44pV'dZ\PR VP R VR ,4VV V4VF p V R ,VR ,8XgKWR&RpM EKVP!V4EK V'd \#V4V#uupi)a;Get 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. FrTrrSrrz:Job '%s' had no next_run_at; recovering one-shot run at %srrrVzSJob '%s' missed its scheduled time (%s, grace=%ds). Fast-forwarding to next run: %sr)rrrcopydeepcopyr)r(rrinfor~rrlrrrrprr)r raw_jobsrrdue needs_saver%rrecovered_nextrj next_run_dtrSrVrrs r get_due_jobsr+s -C{H,0MM(,C D,Cq  ",CD D CJwwy$'' 77=)8 B'GGM2N "!/ %H KKLD *  d8s4y((6}%!%J  $H$:$:8$DE  wwz2.H<<'D +84E++1B0Q0Q0SV[0[,HmmoFKK:D 2  'd8s4y008}-)-J! '  JJsOsv( JE EsH-c0V^8dQhR\R\/#)rrr)r)rs"rrrsCrc\4\V, pVPRRR7\V4\ 4P R4pW# R2, p\ P!\V4RRR7wrV\P!VRR R 7;_uu_4pVPV4VP4\P!VP44R R R 4\P!Wd4\!V4V# +'giL3;i \"d+\P$!T4h \&dhi;ii;i) zSave job output to file.Tr9z%Y-%m-%d_%H-%M-%Sz.mdrz.output_rrrrN)r@r>r=r3rrrqrrrr.rwriterrrrmr7rrr0)rrjob_output_dir timestamp output_filerrrs&& rsave_job_outputr2sM&(N5 &&':;I [#44K##N(;FS]^LB  YYr3 1 1Q GGFO GGI HHQXXZ 2 8)[! 2 1   IIh      sI?!D$ AD&)D$ D! D$$ E0EE EEEE)NN)N) NNNNNNNNNN)F):__doc__r"rloggingrr.rIrrrpathlibrhermes_constantsrtypingrrr r getLogger__name__r hermes_timer rrr rj ImportError HERMES_DIRr<rr>rr#r)r3r7r@rPryr~rrrrrrrrrrr rrrrr+r2r?rrr=s&  (,,,   8 $*!L    { "  "  %*Vr$&"& 6@H6&bJB &")X8L^{LsD)) D54D5