iԚ%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'dNdee(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$Z4dOdee(efd"ee(dee(fd%Z5deee(effd&Z6d'eee(effd(Z7d)ee(dee(fd*Z8 dPd+ee(de(d,ee(d-ee.d.ee(d/eee(efdee(deee(d0ee(d1ee(d2ee(d3ee(d4eee(ee(fd5eee(d)ee(d6e9dee(eff"d7Z:d8e(deee(effd9Z;dQd:e9deee(effd;Zee(deee(effd?Z>d8e(deee(effd@Z?d8e(deee(effdAZ@d8e(de9fdBZA dNd8e(dCe9dDee(dEee(fdFZBd8e(de9fdGZCdeee(effdHZDdeee(effdIZEd8e(de(fdJZF dNdKeee(e(fdLeee(dee(effdMZGdS)Rz 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/piyush/.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_toolsetsno_agentc 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|}|r|std t| tr,| r| gnd} n&t| trd | Dpd} nd} |p|r|dndp|r|ndpd }id|d|p|dd d|d|d|r|dndd|d|d|d|d|d| d|d|d|d|dddd d!d"d#dd|t!|dddd||||d$ }t#}||t'||S)%uX Create a new cron job. Args: prompt: The prompt to run (must be self-contained, or a task instruction when skill is set). Ignored when ``no_agent=True`` except as an optional name hint. 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 script whose stdout feeds the job. With ``no_agent=True`` the script IS the job — its stdout is delivered verbatim. Without ``no_agent``, its stdout is injected into the agent's prompt as context (data-collection / change-detection pattern). Paths resolve under ~/.hermes/scripts/; ``.sh`` / ``.bash`` files run via bash, anything else via Python. 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. Ignored when ``no_agent=True``. 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). With ``no_agent=True``, ``workdir`` is still applied as the script's cwd so relative paths inside the script behave predictably. no_agent: When True, skip the agent entirely — run ``script`` on schedule and deliver its stdout directly. Empty stdout = silent (no delivery). Requires ``script`` to be set. Ideal for classic watchdogs and periodic alerts that don't need LLM reasoning. Returns: The created job dict NrrRr]r>rlocal /cg|]D}t|#t|ESr:rr)rWts r zcreate_job..s9VVVas1vv||~~V3q66<<>>VVVr"udno_agent=True requires a script — with no agent and no script there is nothing for the job to run.cg|]D}t|#t|ESr:rrWjs r rzcreate_job..s9OOO1A OA OOOr"zcron jobidr2rrrrrrrrrrNschedule_displayrTr)times completedenabledTstate scheduled paused_at) paused_reason created_at next_run_atry last_status last_errorlast_delivery_errorrrrr)rsuuiduuid4hexrlrjr!rrrrstriprboolrGrr&rrrr)rrNrrrrrrrrrrrrrrparsed_schedulejob_idr normalized_skillsnormalized_modelnormalized_providernormalized_base_urlnormalized_scriptnormalized_toolsetsnormalized_workdirnormalized_no_agent label_sourcer#rs r create_jobrs4B%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+G44x..  #4  3   ,$$1=1C1C1E1EO **,,--4 L$ ' 'OO OOOWSW  L7HR033dLnAYKXiXiGK[Q[L!  f! 1 SbS)//11!  &!  # !  ):D"1%% !  ! !  '!  '!  #!  '!   !  O!  O// 8DD!    ! $ 4%! & '! ( T)! *'88#/%A! ! ! CF ;;DKK dOOO Jr"rcft}|D]}|d|krt|cS dS)zGet a job by ID.rN)rr')rrr#s r get_jobrBsG ;;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..Ms! 8 8 8q  " " 8 8 8r"c>g|]}|dd|S)rT)r&rs r rzlist_jobs..Os+:::a155D#9#9::::r")r)rrs r list_jobsrKs9 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_jobrSs1 ;;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) rrrrrr r#r rrrRs r mark_job_runr"s ;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)r rr&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`t5tcdddS#1swxYwYdS)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. N)r _get_due_jobs_lockedr:r"r get_due_jobsr(%sw &&#%%&&&&&&&&&&&&&&&&&&s #''c t}t}dtj|D}g}d}|D]'}|dds|d}|s|di}|d}t |||d } | rd nd } | s*|d vr&t ||} | r|} | s| |d<| }t d |d|d| | |D]} | d|dkr | | d<d}nttj |} | |kr|di}|d}t|} |d vr|| z | kr~t ||}|rZt d|d|d|| ||D]} | d|dkr || d<d}n||)|rt!||S)zQInner implementation of get_due_jobs(); must be called with _jobs_file_lock held.c,g|]}t|Sr:rrs r rz(_get_due_jobs_locked..5s! D D Dq  " " D D Dr"FrTrrNrRryrxzone-shotNrz4Job '%s' had no next_run_at; recovering %s run at %srrzSJob '%s' missed its scheduled time (%s, grace=%ds). Fast-forwarding to next run: %s)rlrcopydeepcopyr&r~rrjrinforwrrfrrrr)r raw_jobsrdue needs_saver#rrNrRrecovered_next recovery_kindrj next_run_dtrr$s r r'r'1s --C{{H D DDM(,C,C D D DD CJJJwwy$''  77=))% wwz2..H<<''D9GGM22N +9BJJdM" )d.B&B&B!1(CMMOO!L!L!)$(M! !/C %H KKFD **       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_outputr: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%setkeysr rr!r&rrrrr-rb) r;r< pruned_setrr>changedr# skills_beforerDrE new_skillsrtargets r rewrite_skill_refsrMsd *++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''$--GGFOOr[s  ((((((((,,,,,,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!!YY SMYY 3-Y SM Y c] Y T#s(^ $ Y C=Y T#Y Y C=YsmYsmY SMY5d3i01YtCy)Yc]Y !Y" #s(^#YYYYxCHT#s(^4d38n1E-s-T#s(^-c3h8P----`  c 8C= HT#s(^* & & & &Wd4S>2WWWWtCB.2"&o o 4S>*o T#Y o  #s(^o o o o o o s"A++A54A5