`gjvLdZddlZddlZddlmZddlmZmZmZee jjjZ ejjdee ddlmZmZddlmZddeeedeeefd Zd Zdefd Zdd Zdd efdZdZddeedefdZdZddZ dZ!dZ"dedededefdZ#dZ$y)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||y|g}n t|}g}|D]8}t|xsdj}|s#||vs(|j|:|S)N)liststrstripappend) single_skillr raw_items normalizeditemtexts B/root/.hermes/venv/lib/python3.12/site-packages/hermes_cli/cron.py_normalize_skillsrsj ~  !N L J$4:2$$& D *   d #$ c Dddlm}tj|di|S)Nr)cronjob)tools.cronjob_toolsrjsonloads)kwargs cronjob_tools r _cron_apir"-s; ::l,V, --rcX ddlm}|jxsdS#t$rYywxYw)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*3s0B%',,9 9 s  ))cv tdk7ryddlm}|ry t t dt jt t dt jt t dt jt t dt jy#t$rYywxYw) 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 8      %RTZTaTa bc %}|r)td?td@tjd&|tty)AzList 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└─────────────────────────────────────────────────────────────────────────┘id?r(z (unnamed)schedule_displayschedulevaluestateenabledT scheduledpaused next_run_atrepeattimes completed/u∞deliverlocal, r skillz[paused]z [completed]z[active]z [disabled]  z Name: z Schedule: z Repeat: z Next run: z Deliver: z Skills: scriptz Script: 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/rrr1CYANget isinstancerjoinr0BLUEGREENREDr2)r3r6jobsjobjob_idr(r<r>next_run repeat_info repeat_timesrepeat_completed repeat_strrG deliver_strr rUrMrOrPlast_runstatus_displayrT delivery_errs r cron_listrlcsD# h /D  e(&**56 e\^d^h^hij G %tv|vAvA BC %acicncn op %tv|vAvA BC GHs#wwv{+77-swwz2/F/J/J7TW/XY 40HhW77=#. ggh'-2 "w/ &??;:=I()<.9u '')$1  gs #iGii( "R9IG ~r H :v}}5F k !=&++6F WWY %:v||4F<4F 5/0&:; v&' z*+  |,- z*+  }-.  ODIIf$5#67 8"  OF8, - 77:  OE*fjj$A#BBef g'')$  OG9- .ggm, ww}c2Hd"!&tV\\!:!&+bs9S8T'UW]WaWa!b OH:R/?@ A77#56  !"2"6"6x"E!Fb#''c235  ww45  D5v}}EFa ~V W QHT!"rc"ddlm}|dy)zRun due jobs once and exit.rtickT)verboseN)cron.schedulerrorns r cron_tickrrs #rrblimitchddlm}|||}|s tdy|D]}t|jddd|jd dd d |jd dd |jddd|jdd |jdstd|dy)z,Show indexed durable cron execution history.r)list_executions)rbrsz$No cron execution attempts recorded.Nr9r:rKrUz<9z job=rbz source=source claimed_aterrorrW)cron.executionsrur/rZ)rbrsrurecordsrecords r cron_runsr|s/V59G  45, zz$$%R 8S(A"'EF::h,-Yvzz(C7P6QQSzz,,- / ::g  D)* +,rc ddlm}ddlm}t t }|dk7rqt t d|dtjt t dtjt t|d t y |}|rhdd lm }m }m }|d zd z}|}|} |m||kDrht t dt|dtjt ddj!t#t$|t dn2|n| l| |kDrgt t dt| dtjt ddj!t#t$|t dnt t dtjt ddj!t#t$||rt dt|dnYt t dtj&t t dt dt dt dt t|d t y )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_success_ageTICKER_INTERVAL_SECONDSuN⚠ Gateway is running but the cron ticker looks STALLED — no heartbeat for zs (expected every ~60s).z PID: rIz> 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. 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)rXr6r.r-r/r*rrr^r1_print_active_jobs_summaryr~rrintr0r\maprr_) r6r-providerpidsr~rr STALE_AFTERhb_ageok_ages r cron_statusrs+#4 G)+H9 e!(,) ) LL  e C JJ  "9e#DE   D   .1B6 )+')  &;"6 %$$'K=0HJ   GDIIc#tn567 8 R S  F$66K;O % #F },GI   GDIIc#tn567 8 B C %VX^XdXde f GDIIc#tn567 8!,S[M?@ eLfjjYZ  01 IJ cd DE Gy%@A Grc|rc|Dcgc]%}|jds|jd'}}tdt|d|rtdt|yytdycc}w)zvPrint the ' active job(s)' + next-run line shared by every status path (built-in ticker AND external provider).rBrKz active job(s) Next run: z No active jobsN)rZr/lenmin)r`j next_runss rrr3sp 37Pa155;OQUU=)P P 3t9+^,-  LY 01 2   ! Qs A2A2ctd|j|jt|ddt|ddt|ddt|ddt t|ddt|ddt|ddt|ddt|d d xsd }|j d s7t td |j ddtjyt td|dtjt d|dt d|d|j dr t ddj|d|j di}|j drt d|d|j d r t d|j drt d|dt d|dty)Ncreater(rGrCrJr rMrOrNF) actionr<promptr(rGrCrJr rMrOrNsuccesszFailed to create job: rx unknown errorz Created job: rb Name: Schedule: r< Skills: rIra Script: 3 Mode: no-agent (script stdout delivered directly) Workdir: rrBr) r"r<rgetattrrrZr/rrr_r^r\r2)argsresultjob_datas r cron_creater?s{{ T64 (i.tXt,dGT* w!=wtXW[?\]tXt,i.z519T F ::i  e,VZZ-Q,RSU[U_U_`a %-x 012FLL AB HVF^$ %& L +, -. zz( 499VH%56789zz%$H||H 8H-./0||J CD||I HY/012 L ./ 01 " rcddlm}m} ||j}|s1t t d |jtjyt|jd xs%|jd sgn|jd g}tt|d dt|d d}tdt|d dxsg}ttdt|d dxsg} d} t|ddrg} n:||} n5|s| r1|D cgc] } | | vs|  } } |D]} | | vs| j| t!d|jt|ddt|ddt|ddt|ddt|dd| t|ddt|ddt|dd } | jds7t t d| jddtjy| d} t t d| dtj"t d | dt d!| d| jd r!t d"d#j%| d n t d$| jdrt d%| d| jdr t d&| jdrt d'| dy#|$rk}t t t |tj|jD]&}t d|dd|jdd(Yd}~yd}~wwxYwcc} w)(Nr)AmbiguousJobReferenceresolve_job_refrKr9z (name: r()rzJob not found: r rJ add_skills remove_skills clear_skillsFupdater<rrGrCrMrOrN) rrbr<rr(rGrCr rMrOrNrzFailed to update job: rxrraz Updated job: rbrrrrIz Skills: nonerrr)rXrrrbr/rrrr_matchesrZrrrsetrr"r^r\)rrrraexcmexisting_skillsreplacement_skillsrr final_skillsrJrupdateds r cron_editrgs1@dkk*  eodkk]3VZZ@A3778,d3777;KRURYRYZaRbQceO*74$+GQUW_aeIfg"4|T)JKQrJ)$ot0TU[Y[\MLt^U+  ') }+:Y%e=>XY Y +EL(##E* +{{z40tXt, T64 (i.tXt,tXt,i.z40 F ::i  e,VZZ-Q,RSU[U_U_`aUmG %- 123V\\ BC HWV_% &' L,- ./{{8 499WX%6789: {{8 78,-./{{: CD{{9 GI./01 q ! eCHfjj)* =A Bqwiyv(9; < = (Zs$K+ MM+M0A!MMr success_verbc t||}|jds:ttd|d|jddtj y|jdxs|jd xsi}tt|d|jd |d |d tj |d vr5|jdijdrtd|dd|dk(rv|jdi}|jdr%|jdrdnd}td|dy|jdrtd|dytdy)N)rrbrz Failed to z job: rxrrra removed_jobr(z (r>runresumerBrrexecutedexecution_success succeededfailedz Ran now: .execution_skippedrKz) It will run on the next scheduler tick.r)r"rZr/rrr_r^)rrbrrraoutcomes r _job_actionrs] fV 4F ::i  ejvzz'?/S.TUW]WaWabc **U  >vzz-8 >BC %<.swwvv'>&?r&KV\\ Z[ ""vzz%'<'@'@'O VE]=9:;< jj# 77: %(WW-@%AkxG Ky* + WW( ) Bs./01 2  = > rcdt|dd}||dk(rt|dd}t|y|dk(r ty|dk(r ty|d vr#t t|d dt|d d y|d vr t |S|dk(r t |S|dk(rtd|jdS|dk(rtd|jdS|dk(rtd|jdS|dvrtd|jdStd|tdtjdy)zHandle cron subcommands. cron_commandNrallFrrUro>runshistoryrbrsr>addreditpausePausedrResumedr Triggered>rmdeleteremoverRemovedzUnknown cron command: zNUsage: hermes cron [list|create|edit|pause|resume|run|remove|status|runs|tick]r) rrlrrrr|rrrrbr/sysexit)rsubcmdr3s rrrs3 T>4 0F ~6)4.(     $$'$$/w1KL ""4    7DKK:: 8T[[)<< 5$++{;; ++8T[[)<< "6( +, Z[HHQKr)NN)r N)F)Nr)%__doc__rrpathlibrtypingrrr__file__parentresolve PROJECT_ROOTpathinsertrhermes_cli.colorsrrcron.lifecycle_guardr #_contains_gateway_lifecycle_commandrr"r*r2boolrlrrrr|rrrrrrrrrrs ++H~$$++335 3|$%+ (3-1H T\]abe]fTg  . C GB[#[#| ,hsm,3,$W t "% P= @  S   *)r