yj7_dZddlZddlZddlmZddlmZmZmZee j j Z ej dee ddlmZmZddlmZddeeedeeefd Zd Zdefd Zdd Zd defdZdZd!deedefdZdZddZ dZ!dZ"dedededefdZ#defdZ$dZ%dS)"z Cron subcommand for hermes CLI. Handles standalone cron management commands like list, create, edit, pause/resume/run/remove, status, and tick. N)Path)IterableListOptional)Colorscolor)"contains_gateway_lifecycle_commandskillsreturnc||dS|g}nt|}g}|D]@}t|pd}|r||vr||A|S)N)liststrstripappend) single_skillr raw_items normalizeditemtexts 5/home/ragecks/.hermes/hermes-agent/hermes_cli/cron.py_normalize_skillsrs ~  4!N LL J$$4:2$$&&  $D **   d # # # c Bddlm}tj|di|S)Nr)cronjob)tools.cronjob_toolsrjsonloads)kwargs cronjob_tools r _cron_apir"-s4;;;;;; :ll,,V,, - --rcT ddlm}|jpdS#t$rYdSwxYw)u8Name of the resolved cron scheduler provider ('builtin', 'chronos', …). Best-effort + offline (``resolve_cron_scheduler`` reads config and the provider's ``is_available()`` contract forbids network). Returns 'builtin' on any failure so callers fall back to the historical ticker-based checks. rresolve_cron_schedulerbuiltin)cron.scheduler_providerr%name Exceptionr$s r_active_cron_provider_namer*3sRBBBBBB%%'',9 9 yys  ''c tdkrdSddlm}|rdSn#t$rYdSwxYwt t dt jt t dt jt t dt jt t dt jdS) uWarn that scheduled jobs won't fire unless the gateway is running. The cron ticker only runs inside the gateway (``_start_cron_ticker`` in gateway/run.py); there is no standalone cron daemon. Without a running gateway, ``next_run_at`` passes but jobs never fire and ``last_run_at`` stays null — the most common cron support report (#51038). Surfacing this at create/list time, when the user is right there, prevents it. An external provider (e.g. Chronos) fires jobs via a NAS-mediated webhook, NOT the in-process ticker, so a momentarily-absent gateway process does not mean jobs won't fire — the warning would be a false alarm. Stay quiet for any non-builtin provider; the gateway-process heuristic only speaks to the built-in ticker's trigger. r&Nrfind_gateway_pidsu@ ⚠ Gateway is not running — jobs won't fire automatically.z* Start it with: hermes gateway installzI sudo hermes gateway install --system # Linux serversz& Check status: hermes cron status) r*hermes_cli.gatewayr-r)printrrYELLOWDIMr,s r_warn_if_gateway_not_runningr2Bs  % ' '9 4 4 F888888      F   %RTZTa b bccc %|d?d tj}td@|d$||dA}|r=tdB|dCd d$|d d |dD}|r-tdEtdFtj d%|tt!dS)GzList all scheduled jobs.r list_jobsinclude_disabledzNo scheduled jobs.zFCreate one with 'hermes cron create ...' or the /cron command in chat.Nu┌─────────────────────────────────────────────────────────────────────────┐uO│ Scheduled Jobs │u└─────────────────────────────────────────────────────────────────────────┘)effective_job_stateid?r(z (unnamed)schedule_displayschedulevalue next_run_atrepeattimes completed/u∞deliverlocal, r skillpausedz[paused]z [completed]enabledTz[active]z [disabled]  z Name: z Schedule: z Repeat: z Next run: z Deliver: z Skills: scriptz Script: monitor_script monitor_urlz Monitor: # (agent runs only on output change) monitor_statelast_changed_atz Changed: no_agentz Mode: zno-agentz# (script stdout delivered directly)workdirz Workdir: last_status last_run_atokz: last_errorz Last run: latest_executionz Execution: statuslast_delivery_error u⚠ Delivery failed:) cron.jobsr6r/rrr1CYANr9get isinstancerjoinr0BLUEGREENREDr2)r3r6jobsr9jobjob_idr(r=statenext_run repeat_info repeat_timesrepeat_completed repeat_strrD deliver_strr rYrLmonitor_source mon_staterSrTlast_runstatus_displayrX delivery_errs r cron_listrscsO###### 9h / / /D  e(&*55666 e\^d^hiijjj GGG %tv|vA B BCCC %acicn o oppp %tv|vA B BCCC GGG------PPs##wwv{++77-swwz2/F/F/J/J7TW/X/XYY$#C((77=#.. ggh''-2 "w// &??;::=IT(99<999u '')$$1  gs # # iGii(( ""R9I9I'QG ~~r H  :v}55FF k ! !=&+66FF WWY % % 5:v|44FF<44F :5//::&::;;; &&&''' ***+++ , ,,--- ***+++ - --...  9 7DIIf$5$577 8 8 8""  . ,F,, - - -!122Lcggm6L6L  H WNWWW X X X006BI}}.// HF 2C(DFFGGG 77:   h fE*fj$A$Afff g g g'')$$  / -G-- . . .ggm,,  Bww}c22Hd""!&tV\!:!:!&+'U'Us9S9S'U'UW]Wa!b!b @H@@@@ A A A77#566   5"2"6"6x"E"E55#''c2255    ww455  X V5v}EEVV VV W W W  """""rc*ddlm}|ddS)zRun due jobs once and exit.rtickT)verboseN)cron.schedulerrvrus r cron_tickrys-######Drrflimitcddlm}|||}|stddS|D]}t|ddd|d dd d |d dd |ddd|dd |drtd|ddS)z,Show indexed durable cron execution history.r)list_executions)rfr{z$No cron execution attempts recorded.Nr:r;rJrYz<9z job=rfz source=source claimed_aterrorr[)cron.executionsr}r/r^)rfr{r}recordsrecords r cron_runsrs*//////oV5999G  4555,, zz$$$ / / 8S(A(A H / /::h,, / /7=zz(C7P7P / /zz,,, / /   ::g   , *** + + +,,rc ddlm}ddlm}t t }|dkrt t d|dtjt t dtj t t|d t d S|}|rdd lm }m }m }m}|d zd z}|} |} | | |krt t dt| dtjt ddt%t&|t dn| | | |krt t dt| dtjt ddt%t&||} | rUt t d| tjd| vr't t dtjt dnt t dtjt ddt%t&|| t dt| dnqt t dtjt t dt dt dt d t t|d t d S)!zShow cron execution status.rr5r,r&u✓ Cron provider: uD — jobs fire via the managed scheduler, not the in-process ticker.zq (No ticker heartbeat is expected for an external provider; due jobs are delivered by an authenticated webhook.)Fr7N)get_ticker_heartbeat_ageget_ticker_last_errorget_ticker_success_ageTICKER_INTERVAL_SECONDSrzuN⚠ Gateway is running but the cron ticker looks STALLED — no heartbeat for zs (expected every ~60s).z PID: rFz> Cron jobs may NOT be firing. Restart: hermes gateway restartuF⚠ Gateway and cron ticker are running, but no tick has succeeded in us — ticks may be failing.z Last tick error: zPermission deniedz Hint: jobs.json may be owned by another user (e.g. rewritten by a root `docker exec hermes hermes cron ...`). Fix ownership to match the gateway user, and prefer `docker exec -u :`.z. Check the gateway log for 'Cron tick error'.u<✓ Gateway is running — cron jobs will fire automaticallyz Ticker heartbeat: zs agou6✗ Gateway is not running — cron jobs will NOT firez To enable automatic execution:z9 hermes gateway install # Install as a user servicezS sudo hermes gateway install --system # Linux servers: boot-time system servicez4 hermes gateway # Or run in foreground)r\r6r.r-r/r*rrrbr1_print_active_jobs_summaryrrrrintr0r`maprrc) r6r-providerpidsrrrr STALE_AFTERhb_ageok_agerWs r cron_statusrs######444444 GGG)++H9 e )( ) ) ) L     e C J     "99e#D#D#DEEE     D @F             .1B6 ))++''))  &;"6"6 %J$'KKJJJ     7DIIc#tnn5577 8 8 8 R S S S S  F$66K;O;O %I #F III     7DIIc#tnn5577 8 8 8..00J e>*>> KKLLL&*44%Q  B C C C C %VX^Xdee f f f 7DIIc#tnn5577 8 8 8!?S[[???@@@ eLfjYYZZZ  0111 IJJJ cddd DEEE GGGyy%@@@AAA GGGGGrc|rQd|D}tdt|d|r!tdt|dSdStddS)zvPrint the ' active job(s)' + next-run line shared by every status path (built-in ticker AND external provider).cbg|],}|d|d-S)r?)r^).0js r z._print_active_jobs_summary..Ps5PPPa155;O;OPQUU=))PPPrrJz active job(s) Next run: z No active jobsN)r/lenmin)rd next_runss rrrLs "PP4PPP  ,3t99,,,---  3 1Y11 2 2 2 2 2 3 3  !!!!!rctd|j|jt|ddt|ddt|ddt|ddt t|ddt|ddt|ddt|ddt|d dt|d dt|d d pdt|d dt|dd}|ds@t td|ddtj dSt td|dtj t d|dt d|d|dr+t dd |d|di}|drt d|d|d rt d|d d|drt d|dd|d rt d |drt d!|dt d"|d#td$S)%Ncreater(rDr@rGr rLrSmodelmodel_providerrRFrMrN)actionr=promptr(rDr@rGr rLrSrrrRrMrNsuccesszFailed to create job: r unknown errorz Created job: rf Name: Schedule: r= Skills: rFre Script: Monitor: rO3 Mode: no-agent (script stdout delivered directly) Workdir: rr?r) r"r=rgetattrrr^r/rrrcrbr`r2)argsresultjob_datas r cron_createrXs{ T64 ( (i..tXt,,dGT** w!=!=wtXW[?\?\]]tXt,,i..dGT**/66z5119Tt%5t<<D-66F" ::i  eSVZZ-Q-QSSU[U_``aaaq %2x 022FL A ABBB %VF^ % %&&& - + - -... zz(: 8499VH%56688999zz%$$H||H1 /8H-//000||$%%] [H%56[[[\\\||M""Z XH]3XXXYYY||JE CDDD||I3 1HY/11222 0 . 0 0111 """ 1rcL ddlm}m} ||j}n#|$rx}t t t |tj|j D]1}t d|dd| dd2Yd}~dSd}~wwxYw|s1t t d |jtjdSt| d p,| d sgn| d g}tt|d dt|d d}tdt|d dpg}ttdt|d dpg d} t|ddrg} n5||} n0|s r, fd|D} |D]} | | vr| | t!d|jt|ddt|ddt|ddt|ddt|dd| t|ddt|ddt|ddt|ddt|ddt|ddt|dd} | ds@t t d| d d!tjdS| d"} t t d#| d$tjt d%| dt d&| d| d r,t d'd(| d nt d)| drt d*| d| drt d+| dd,| drt d+| dd,| drt d-| drt d.| ddS)/Nr)AmbiguousJobReferenceresolve_job_refrJr:z (name: r()rzJob not found: r rG add_skills remove_skills clear_skillsFcg|]}|v| Srr)rrGrs rrzcron_edit..s#YYY%e=>X>X>X>X>Xrupdater=rrDr@rLrSrrrRrMrN)rrfr=rr(rDr@r rLrSrrrRrMrNrzFailed to update job: rrrez Updated job: rfrrrrFz Skills: nonerrrOrr)r\rrrfr/rrrrcmatchesr^rrrsetrr"rbr`)rrrreexcmexisting_skillsreplacement_skillsr final_skillsrGrupdatedrs @r cron_editrs@@@@@@@@odk**  eCHHfj))*** = =A ;qw;;v;;; < < < <qqqqq   e3dk33VZ@@AAAq3778,,d3777;K;K1cRURYRYZaRbRbQceeO*74$+G+GQUW_aeIfIfgg"4|T)J)JKKQrJ)$ot0T0TUU[Y[\\MLt^U+++  ') +}+YYYY?YYY  + +EL((##E*** {z400tXt,, T64 ( (i..tXt,,tXt,,i..dGT**/66z400t%5t<<D-66F" ::i  eSVZZ-Q-QSSU[U_``aaaqUmG %3 133V\ B BCCC &WV_ & &''' ., . .///{{8  9499WX%67799:::: {{80 .78,..///{{#$$\ ZG$45ZZZ[[[{{=!!Y WGM2WWWXXX{{:E CDDD{{92 0GI.00111 1sBA-BBr success_verbc t||}|dsCttd|d|ddtjdS|dp|d pi}tt|d|d |d |d tj|d vrG|didrtd|dd|dkr|di}|dr-|drdnd}td|dn=|drtd|dntddS)N)rrfrz Failed to z job: rrrre removed_jobr(z (r>runresumer?rrexecutedexecution_success succeededfailedz Ran now: .execution_skippedrJz) It will run on the next scheduler tick.r)r"r^r/rrrcrb)rrfrrreoutcomes r _job_actionrs fV 4 4 4F ::i  eUUUvzz'?/S/SUUW]Wabbcccq **U   >vzz-88 >BC %<KKswwvv'>'>KK&KKKV\ Z Z[[[ """vzz%'<'<'@'@'O'O" ;VE]=9;;<<< jj## 77:   ?%(WW-@%A%AOkkxG **** + + + + WW( ) ) ? 1s./11 2 2 2 2 = > > > 1rc rddlm}tt|ddpd}t|ddpd}t|dd}t|d d}|s)t t d t jd S |d krt||)t t d t jd S||||t t d|d|dt j dS|dkr|)t t dt jd S| ||}|0t t d|d|dt j d St |dS|dkr|)t t dt jd S| ||r0t t d|d|dt j dSt t d|d|dt j d S| |}|s-t t d|dt jdS|D]{}t dt |dt j d|d t dt dt|dzt j|dS#t$r5} t t d| t jYd} ~ d Sd} ~ wwxYw)uUHandle ``hermes cron notepad [get|set|delete|list]``. The per-job durable KV scratchpad (``cron/notepad.py``). This CLI is the write path — a running cron agent updates its own notepad by invoking these commands via its terminal tool; the scheduler injects non-empty notepads into the job prompt on each run. r)notepadrfr notepad_actionNrkeyr>zA job ID is required.rrz5Usage: hermes cron notepad set zSet notepad key 'z ' for job rr^z-Usage: hermes cron notepad get zNo notepad key 'deletez0Usage: hermes cron notepad delete zDeleted notepad key 'zNotepad for job z is empty.rJz = r[z updated: updated_atzNotepad error: )cronrrrr/rrrcset_noterbget_noter0 delete_note list_notesr1 ValueError) rrrfrrr>storednotesnoters r cron_notepadrsl x,,2 3 3F T+T 2 2 K77 L6*L11L6ct|dd}||dkr"t|dd}t|dS|dkrtdS|dkrtdS|d vr0t t|d dt|d d dS|d krt |S|dvrt |S|dkrt|S|dkrtd|j dS|dkrtd|j dS|dkrtd|j dS|dvrtd|j dStd|tdtj ddS)zHandle cron subcommands. cron_commandNrallFrrYrv>runshistoryrfr{rzr>addreditpausePausedrResumedr Triggered>rmrremoverRemovedzUnknown cron command: zNUsage: hermes cron [list|create|edit|pause|resume|run|remove|status|runs|tick]r) rrsrryrrrrrrfr/sysexit)rsubcmdr3s rrr$s T>4 0 0F ~6))4..(q  q  q $$$'$$//w1K1KLLLq D!!! """4     7DK::: 8T[)<<< 5$+{;;; +++8T[)<<< +6 + +,,, Z[[[HQKKKKKr)NN)r N)F)Nrz)&__doc__rrpathlibrtypingrrr__file__parentresolve PROJECT_ROOTpathinsertrhermes_cli.colorsrrcron.lifecycle_guardr #_contains_gateway_lifecycle_commandrr"r*r2boolrsryrrrrrrrrrrrrrsX ++++++++++tH~~$+3355 33|$$%%%++++++++  (3-1H T\]abe]fTg     ... C    GGGGBe#e#e#e#e#e#P ,,hsm,3,,,,$f f f R " " " "- - - `E E E P  S      *<#<<<<~,,,,,r