JizbLdZddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZmZmZejeZddlmZ ddlmZd Zn #e$rd ZYnwxYwe Zed z Zed z Zed z ZdZ dBdee!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-dCdee!efd!ee!dee!fd$Z.deee!effd%Z/d&eee!effd'Z0 dDd(e!de!d)ee!d*ee'd+ee!d,eee!efdee!deee!d-ee!d.ee!d/ee!dee!effd0Z1d1e!deee!effd2Z2dEd3e3deee!effd4Z4d1e!d5ee!efdeee!effd6Z5dCd1e!d7ee!deee!effd8Z6d1e!deee!effd9Z7d1e!deee!effd:Z8d1e!de3fd;Z9dCd1e!dZ:d1e!de3fd?Z;deee!effd@Z>'#:#: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 cttsgS ttdd5}t j|}|dgcdddS#1swxYwYdS#tj$r ttdd5}t j| d}|dg}|r)t|t d|cdddcYS#1swxYwYYdS#t$rgcYcYSwxYwt$rgcYSwxYw) zLoad all jobs from storage.rutf-8encodingjobsNF)strictz8Auto-repaired jobs.json (had invalid control characters))r9 JOBS_FILEr/openjsonloadr$JSONDecodeErrorloadsread save_jobsloggerwarningrcIOError)fdatars r load_jobsr@sMMM       )S7 3 3 3 (q9Q<D??Epromptnamerepeatdeliveroriginmodelproviderbase_urlc (t|} ||dkrd}| ddkr|d}||rdnd}tjjdd} t } t ||}t|tr!t| nd}t| tr!t|  nd}t| tr4t|  d nd}|pd}|pd}|pd}|p |r|dndpd }id | d |p|dd  d|d|d|r|dndd|d|d|d| d| d|d|ddddddddddd| d t| ddd||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 Returns: The created job dict NrrPr[r<rlocal /zcron jobidr2rrrrrrrLschedule_displayrRr)times completedenabledTstate scheduled paused_at paused_reason created_at next_run_at)rw last_status last_errorrr)rquuiduuid4hexrjrhrrrrrstripr$rrrr)rrLrrrrrrrrrparsed_schedulejob_idr normalized_skillsnormalized_modelnormalized_providernormalized_base_url label_sourcer!rs r create_jobrns@%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-5S7HR033dbXbL  f 1 SbS)//11  &  #   ):D"1%%   !   '  '  O  O// 8DD      4  ! " T# $ % & c' ( '88) *5   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 0t}t|D]v\}}|d|krti||}d|v}d|vsd|vrJt|d|d}||d<|r|dnd|d<|rs|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$rr) 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 *1++" $$Y .3s' 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 successerrorct}t|D]A\}}|d|kr.t}||d<|rdnd|d<|s|nd|d<|dr|dd d d z|dd <|dd }|dd }|3|d kr-||kr'||t |dSt|d ||d<|d d|d<d |d<n|ddkrd|d<t |dSCt |dS)z 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. rrwokrrNrrrrr<rrLrFrrrr)rrrjrhr$poprr) rrrrrr!r rrs r mark_job_runr:s ;;DD//3 t9  --))++C!$C )0!=gC -4 >$C wwx  -0]->->{A-N-NQR-RH k*H ))'22M+6 $yE7I7IHHQKKKdOOOFF"2#j/3!G!GC =!)!&I*G !!X--*G dOOO FF= @dOOOOOr 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_runrfs ;;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 %srrrPrzSJob '%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_dtrLrPrrs 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) NNNNNNNNN)F)>__doc__r rloggingrr(rCrrrpathlibrhermes_constantsrtypingrrr r getLogger__name__r hermes_timer rjr rb ImportError HERMES_DIRr5rr7rzrrr%r-r0r9rFrKrqrur|r#rrrrrrboolrrrrrrrrrrr8r 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]^aUbH4S#X'6Dc3h(, !'+"&""[[ [[ 3-[ SM [ c] [ T#s(^ $ [ C=[ T#Y [ C=[sm[sm[ #s(^[[[[|CHT#s(^4d38n1EsT#s(^c3h8PB  c 8C= HT#s(^*LLLL^CsAA)(A)