eidZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z n #e $rdZ ddl Z n #e $rdZ YnwxYwYnwxYwddl mZddlmZmZe jdeeejjddlmZddlmZddlmZejeZ de!d e!d e"edzfd Z#e$hd Z%d ddddddddddddddZ&ddiZ'ddl(m)Z)m*Z*m+Z+m,Z,dZ-eZ.e.dz Z/e/d z Z0de!d ee!fd!Z1d"ed efd#Z2de!d$ed ee!fd%Z3de!d ee!fd&Z4de!d ee!fd'Z5e$hd(Z6e$hd)Z7e$hd*Z8d+ed,e"d-e!dzde!d df d.Z9d?de!d/ed eefd0Z:d1Z;e;Zd3ed e?e@effd4ZAd5ed e@fd6ZBd@de!d7ee?d efd8ZCde!d e?e@eeeeffd9ZDdAd;e@d e=fd<ZEed=kreEd:>dSdS)Ba Cron job scheduler - executes due jobs. Provides tick() which checks for due jobs and runs them. The gateway calls this every 60 seconds from a background thread. Uses a file-based lock (~/.hermes/cron/.tick.lock) so only one tick runs at a time if multiple processes overlap. NPath)ListOptionalget_hermes_home) load_config)nowjobcfgreturnc|d}|r|S ddlm}t||pidS#t$r&}t d|Yd}~dSd}~wwxYw)u>Resolve the toolset list for a cron job. Precedence: 1. Per-job ``enabled_toolsets`` (set via ``cronjob`` tool on create/update). Keeps the agent's job-scoped toolset override intact — #6130. 2. Per-platform ``hermes tools`` config for the ``cron`` platform. Mirrors gateway behavior (``_get_platform_tools(cfg, platform_key)``) so users can gate cron toolsets globally without recreating every job. 3. ``None`` on any lookup failure — AIAgent loads the full default set (legacy behavior before this change, preserved as the safety net). _DEFAULT_OFF_TOOLSETS ({moa, homeassistant, rl}) are removed by ``_get_platform_tools`` for unconfigured platforms, so fresh installs get cron WITHOUT ``moa`` by default (issue reported by Norbert — surprise $4.63 run). enabled_toolsetsr)_get_platform_toolscronzHCron toolset resolution failed, falling back to full default toolset: %sN)gethermes_cli.tools_configrsorted Exceptionloggerwarning)r r per_jobrexcs 0/home/div/.hermes/hermes-agent/cron/scheduler.py_resolve_cron_enabled_toolsetsr,s"gg())G??????))#)V<<===  V    ttttt s < A,A''A,>smsemailqqbotslackwecomfeishumatrixsignalweixindiscordwebhookdingtalktelegramwhatsapp mattermost bluebubbles homeassistantwecom_callbackMATRIX_HOME_ROOMTELEGRAM_HOME_CHANNELDISCORD_HOME_CHANNELSLACK_HOME_CHANNELSIGNAL_HOME_CHANNELMATTERMOST_HOME_CHANNELSMS_HOME_CHANNELEMAIL_HOME_ADDRESSDINGTALK_HOME_CHANNELFEISHU_HOME_CHANNELWECOM_HOME_CHANNELWEIXIN_HOME_CHANNELBLUEBUBBLES_HOME_CHANNELQQBOT_HOME_CHANNEL)r"r(r%rr#r*rrr'r!r r$r+rQQ_HOME_CHANNEL) get_due_jobs mark_job_runsave_job_outputadvance_next_runz[SILENT]rz .tick.lockc|d}|sdS|d}|d}|r|r|SdS)zFExtract origin info from a job, preserving any extra routing metadata.originNplatformchat_id)r)r rBrCrDs r_resolve_originrE}s[ WWX  F tzz*%%Hjj##GG 4 platform_namect|}|sdStj|d}|s1t |}|rtj|d}|S)zGReturn the configured home target chat/room ID for a delivery platform.)_HOME_TARGET_ENV_VARSrlowerosgetenv_LEGACY_HOME_TARGET_ENV_VARS)rGenv_varvaluelegacys r_get_home_target_chat_idrRsx#'' (;(;(=(=>>G r Igr " "E *-11'::  *Ifb))E LrF deliver_valuec t|}|dkrdS|dkr|r2|dt|d|ddStD]_}t |}|rLt d|d |d d |||ddcS`dSd |vr|d d \}}|}ddl m }|||\}} } | r|| } }n|d} } ddl m } | ||} | r||| \}} }|r|| } }n| }n#t$rYnwxYw||| dS|}|rE|d|kr,|t|d|ddS|tvrdSt |}|sdS||ddS)z9Resolve one concrete auto-delivery target for a cron job.localNrBrCrD thread_id)rCrDrVzJJob '%s' has deliver=origin but no origin; falling back to %s home channelnameid?:r)_parse_target_ref)resolve_channel_name)rEstrrrJrRrinfosplitrKtools.send_message_toolr\gateway.channel_directoryr]r_KNOWN_DELIVERY_PLATFORMS)r rSrBrGrDrest platform_keyr\parsed_chat_idparsed_thread_id is_explicitrVr]resolvedresolved_is_explicits r_resolve_single_delivery_targetrksS ! !Ft   ":.vi011#ZZ 44 3  M.}==G  `GGFCGGD#$6$677! !.&!% t m+11#q99 t$**,, ======8I8I,X\8]8]5(+  ,!/1AYGG!%tYG  F F F F F F++L'BBH 'IZIZ[giqIrIrF 02F'')79IYGG&G    D &"   "M  &**Z((M99%6),--K00   $===t&}55G t"  s-D<< E E c|dd}|dkrgSdt|dD}t}g}|D]}t ||}|rq|dt|d|df}||vr*|||||S)z]Resolve all concrete auto-delivery targets for a cron job (supports comma-separated deliver).deliverrUc^g|]*}||+Sstrip).0ps r z-_resolve_delivery_targets..s- E E E117799 EQWWYY E E ErF,rCrDrV)rr^r`setrkrKaddappend)r rmpartsseentargetsparttargetkeys r_resolve_delivery_targetsrsggi))G' E EG 2 23 7 7 E E EE 55DG''0d;;  '*%++--s6)3D/E/EvzzR]G^G^_C$ v&&& NrFc8t|}|r|dndS)zAResolve the concrete auto-delivery target for a cron job, if any.rN)r)r r{s r_resolve_delivery_targetrs"',,G *71::d*rF>.m4a.mp3.ogg.wav.opus>.3gp.avi.mkv.mov.mp4.webm>.gif.jpg.png.jpeg.webprD media_filesmetadatac @ddlm}|D]\}} ||j} | tvr||||} n\| t vr||||} n:| tvr| |||} n| |||} tj | |} | d} n##t$r| wxYw| rQt!| d d s@t"d |d d |t!| ddL#t($r<} t"d|d d || Yd} ~ d} ~ wwxYwdS)u;Send extracted MEDIA files as native platform attachments via a live adapter. Routes each file to the appropriate adapter method (send_voice, send_image_file, send_video, send_document) based on file extension — mirroring the routing logic in ``BasePlatformAdapter._process_message_background``. rr)rD audio_pathr)rD video_pathr)rD image_pathr)rD file_pathrtimeoutsuccessTz&Job '%s': media send failed for %s: %srXrYerrorunknownz%Job '%s': failed to send media %s: %sN)pathlibrsuffixrK _AUDIO_EXTS send_voice _VIDEO_EXTS send_video _IMAGE_EXTSsend_image_file send_documentasynciorun_coroutine_threadsaferesult TimeoutErrorcancelgetattrrrrr)adapterrDrrloopr r media_path _is_voiceextcorofutureres r_send_media_via_adapterrs!,gg I g$z"")//11Ck!!))'j[c)dd ##))'j[c)dd ##..w:`h.ii,,W ]e,ff5dDAAF r22      gfi>> <GGD#&& GFGY4W4W g g g NNBCGGDRUDVDVXbde f f f f f f f f g/ggs1B5ECE C==AE F1FFcontentc t|}|sY|dddkr=d|dd}td|d||SdSddlm}dd lm}m}id |j d |j d |j d |j d|j d|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|jd|j} d} t5} | didd} n#t6$rYnwxYw| rB|d|d} |dd} d | d!| d"|d#| d$ }n|}dd%lm}||\}} |}n@#t6$r3}d&|}td|d||cYd}~Sd}~wwxYwg}|D]}|d'}|d(}|d)}|d*pi}|d)}|r;|s9td+|d||dd|n&|r$t d,|d|||| |!}|s?d-|d.}td|d||"||pi|}d/}|j|gtG|d0d1rL|rd)|ind} |$}d} |rtKj&|'|||2|}! |!(d34}"n##tR$r|!*wxYw|"rHtG|"d5ds7tG|"d6d7}#td8|d|||#d/} | r|rtW||||||| r%t,d9|d||d}n;#t6$r.}td:|d|||Yd}~nd}~wwxYw|s|j-|}$|$r|$j.s?d;|d<}td|d||"| |||$||||=}% tKj/|%}&n#t`$r|%1tdj34d>?5}'|'5tJj/|||$||||=}!|!(d@4}&dddn #1swxYwYYnYt6$rM}dA|dB|dC|}td|d||"|Yd}~d}~wwxYw|&rY|&d6rDdD|&d6}td|d||"|t,dE|d|||rdF6|SdS)Gu Deliver job output to the configured target(s) (origin chat, specific platform, etc.). When ``adapters`` and ``loop`` are provided (gateway is running), tries to use the live adapter first — this supports E2EE rooms (e.g. Matrix) where the standalone HTTP path cannot encrypt. Falls back to standalone send if the adapter path fails or is unavailable. Returns None on success, or an error string on failure. rmrUz(no delivery target resolved for deliver=z Job '%s': %srXNr)_send_to_platform)load_gateway_configPlatformr(r%rr)r#r"r*r,r'r!r r-r$rrr+rTr wrap_responserWrIzCronjob Response: z (job_id: z) ------------- zI To stop or manage this job, send me a new message (e.g. "stop reminder z").)BasePlatformAdapterzfailed to load gateway config: rCrDrVrBzUJob '%s': origin has thread_id=%s but delivery target lost it (deliver=%s, target=%s)z*Job '%s': delivering to %s:%s thread_id=%szunknown platform ''F is_runningcdS)NFrororFrz!_deliver_result..sdirF)r<rrrrzLJob '%s': live adapter send to %s:%s failed (%s), falling back to standalonez-Job '%s': delivered to %s:%s via live adapterzPJob '%s': live adapter delivery to %s:%s failed (%s), falling back to standalonez platform 'z' not configured/enabled)rVrr[ max_workersrz delivery to rZz failed: zdelivery error: zJob '%s': delivered to %s:%sz; )7rrrrrargateway.configrrTELEGRAMDISCORDSLACKWHATSAPPSIGNALMATRIX MATTERMOST HOMEASSISTANTDINGTALKFEISHUWECOMWECOM_CALLBACKWEIXINEMAILSMS BLUEBUBBLESQQBOTr rgateway.platforms.baser extract_mediardebugrKrxrrqrrsendrrrrr_ platformsenabledrun RuntimeErrorclose concurrentfuturesThreadPoolExecutorsubmitjoin)(r radaptersrr{msgrrr platform_mapruser_cfg task_namejob_iddelivery_contentrrcleaned_delivery_contentconfigrdelivery_errorsr}rGrDrVrB origin_threadrCruntime_adapter delivered send_metadata text_to_send adapter_okr send_resulterrpconfigrrpools( r_deliver_resultr,s# (,,G  779g & &' 1 1ZSWWYPW=X=XZZC NN>3t9c : : :Jt999999<<<<<<<<H%8#  H%  (/  (/  h) / H% (/  (1 (/  x| x+!" #L.M == VR0044_dKK       #GGFCI.. r"" g g g g g g gXa  g g g #;:::::,?,M,MN^,_,_)K)$$&& 333 ^SY444  Oe[e[z* #JJ{++ ""(b ;//    NN*D =#'')W*E*Ev       LL<D ='9     ##M$7$7$9$9:: 7}777C NN>3t9c : : :  " "3 ' ' ' $>r..x88  &4+;@jl\i\i@j@j@l@l+;8AK[)44tM! 7==?? ! +$=',,Wl],[[F&,mmBm&?&? ' #+7; 4+P+P+%k7IFFjI}gs&+ m+m+OWkS`bfhklll%KK OQTUYQZ\ikrsss $I   fI}gq  ! [&**844G '/ J=JJJ~s4y#>>>&&s+++%$XwAYen}HIIID  T** 7 7 7  '::q:II7T![[6G6GRY[bd|IR`k7l7l7lmmF#]]2]66F777777777777777   J]JJWJJqJJ ^SY<<<&&s+++    &**W-- ::: ^SY<<<&&s+++ KK6D =RY Z Z Z*yy))) 4s8D?? E  E 4 F?? G< (G71G<7G<%AQ-)O?Q- O  B Q-- R%7$R  R%T44>X'2AW8 X'W X' W X' X'AX""X'xc2ttkr[ ttt}|dkr|Sn0#t$r#t dtYnwxYwtjdd }|rQ tt|}|dkr|Sn+#t$rt d|YnwxYw tpi}t|tr| dini}| d}|$tt|}|dkr|Sn2#t$r%}t d |Yd}~nd}~wwxYwtS) zOResolve cron pre-run script timeout from module/env/config with a safe default.rz>;:D::::(**N 8 ^SYY '"DK     -%2,,..-%2,,..  : : : : : :**622F**622FF    D    ! !C0ACCDE 3 111222 3 111222$))E*** *V|  $JJJIII4IIIIII 8887#7777777778sb!B77C CA:H#F.-H#. F;8H#:F;;A#H#H##I> II II script_outputcF|sdSd|D}|sdS|d} tj|}n#tjt f$rYdSwxYwt |tsdS|ddduS)uParse the last non-empty stdout line of a cron job's pre-check script as a wake gate. The convention (ported from nanoclaw #1232): if the last stdout line is JSON like ``{"wakeAgent": false}``, the agent is skipped entirely — no LLM run, no delivery. Any other output (non-JSON, missing flag, gate absent, or ``wakeAgent: true``) means wake the agent normally. Returns True if the agent should wake, False to skip. Tc:g|]}||Srorp)rrlines rrtz$_parse_wake_gate..js%RRRtTZZ\\RdRRRrF wakeAgentF) splitlinesrqjsonloadsJSONDecodeErrorrrrr)r+stripped_lines last_linegates r_parse_wake_gater8]s tRR}'?'?'A'ARRRN tr"((**Iz)$$  * -tt dD ! !t 88K & &e 33sAA10A1 prerun_scriptc ,|dd}|d}|d}|r5||\}}nt|\}}|r|r d|d|}nd|}nd |d|}|d }|r9d d lm}t |t r|g}|D]} | rt d | Dstd| : || z } | sUt| ddd} | s~| d  d } d} t| | kr | d| dz} | r d| d| d|}n݌#tt f$r'}td| |Yd}~d}~wwxYwd}||z}||d}|r|gng}d|D}|s|Sd dlm}g}g}|D]}t'j||}|dst|dpd |d!}td"|d#|d$|||t |d%pd }|r|d|d&|d'd|g|rEd(d)|d*d)|d+}|d ||r|dd,|gd-|S).aBuild the effective prompt for a cron job, optionally loading one or more skills first. Args: job: The cron job dict. prerun_script: Optional ``(success, stdout)`` from a script that has already been executed by the caller (e.g. for a wake-gate check). When provided, the script is not re-executed and the cached result is used for prompt injection. When omitted, the script (if any) runs inline as before. promptrIskillsscriptNzq## Script Output The following data was collected by a pre-run script. Use it as context for your analysis. ``` z ``` z3[Script ran successfully but produced no output.] zQ## Script Error The data-collection script failed. Report this to the user. ``` context_fromr) OUTPUT_DIRc3K|]}|dvV dS)0123456789abcdefNro)rrcs r z$_build_job_prompt..s(+[+[A1C,C+[+[+[+[+[+[rFz(context_from: skipping invalid job_id %rz*.mdc4|jSN)statst_mtime)fs rrz#_build_job_prompt..s!&&(("3rFT)r~reverseutf-8encodingi@z [... output truncated ...]z## Output from job 'zo' The following is the most recent output from a preceding cron job. Use it as context for your analysis. ``` z2context_from: failed to read output for job %r: %su[IMPORTANT: You are running as a scheduled cron job. DELIVERY: Your final response will be automatically delivered to the user — do NOT use send_message or try to deliver the output yourself. Just produce your report/output as your final response and the system handles the rest. SILENT: If there is genuinely nothing new to report, respond with exactly "[SILENT]" (nothing else) to suppress delivery. Never combine [SILENT] with content — either report your findings normally, or say [SILENT] and nothing more.] skillcg|]D}t|#t|ESro)r^rq)rrrWs rrtz%_build_job_prompt..s=MMM3t99??;L;LM3t99??$$MMMrF) skill_viewrrzFailed to load skill 'ru/Cron job '%s': skill not found, skipping — %srWrXrz&[IMPORTANT: The user has invoked the "zf" skill, indicating they want you to follow its instructions. The full skill content is loaded below.]ze[IMPORTANT: The following skill(s) were listed for this job but could not be found and were skipped: z, un. Start your response with a brief notice so the user is aware, e.g.: '⚠️ Skill(s) not found and skipped: z']zPThe user has provided the following instruction alongside the skill invocation: r)rr* cron.jobsr?rr^allrrrrglob read_textrqlenOSErrorPermissionErrortools.skills_toolrOr2r3rxextendrinsert)r r9r;r<rrr+r>r? source_job_idjob_output_dir output_files latest_output_MAX_CONTEXT_CHARSr cron_hintrQ skill_namesrOryskipped skill_nameloadedrrnotices r_build_job_promptrewsWWXr " "F WWX  F''(##K  $%2 "G]]%4[%A%A "G]    *         % 77>**L$g(((((( lC ( ( *(>L) g gM  +[+[]+[+[+[([([ I=YYY g!+m!;%,,..%"''//33     $ ,Q 9 97 9 K K Q Q S S %)"}%%(:::$12E3E2E$FIi$iM $}$$!.$$" $$F_- g g gSUbdeffffffff g D F ~!!#+&MMMMMK  ,,,,,, EG!  JJz2233zz)$$ JJw''Q+QJ+Q+Q+QE NNLcggV\^a^e^efj^k^kNlNlns t t t NN: & & & fjj++1r2288::   LL    llll       N!%7!3!3 N N8||$|d}"Yd}~nd}~wwxYw|d8id?p|d?pd@}&|dAi}'ddBl1m2}(m3})ddCl4m5}* dD|dEpt!j!dFi}+|dGr|dG|+dH<|(di|+},n#|*$r}}-t dI||-|dJp|dK}.|.rtO|.t`r|.n|.gng}/d},|/D]}0tO|0tPs dD|0dEi}1|0dGr |0dG|1dH<|0dLr |0dL|1dM<|(di|1},t dN||,dEnG#t$r:}2t dO||0dE|2Yd}2~2d}2~2wwxYw|,tm|)|-|-Yd}-~-n0d}-~-wt$r }3|)|3}4tm|4|3d}3~3wwxYw|dJp|dKpd}5d}6t-|,dEpd7}7|7r ddPl8m9}8|8|7}9|9:r>|9}6t dQ||7tw|9<n4#t$r'}t dR||7|Yd}~nd}~wwxYw|did.|dL|,dLdG|,dGdE|,dEdS|,dSdT|,dUdV|,dWdX|&dY|!dZ|"dK|5d[|6d\|'d]d^|'d_d`|'dadb|'dcddt{||degdfdgddht}| didddjdk|dl|}:tt!j!dmdn};|;dkr|;nd}tjD}?|>E|?jF|:jG| }@dr}A |<|@H}Bnd}B tjAI|@h|=s\}C}D|Cr|@H}BnXdt}Et|:dur< |:K}F|Fdvdt}En#t$rYnwxYw|E|LdrdwwxYw|>Ldrdwn#|>LdrdwwxYw|Ar"i}Gt|:dur& |:K}Gn#t$rYnwxYw|Gdxdy}H|Gdvd}I|Gdz}J|Gd{d}K|GdXd}Lt Md|||I|<|H|K|L|Jpd}t|:d~r|:Ndtd|dt|Idt|<d|HtO|BtPs'tmdt|BjRd|B|Bddpd}M|Mdkrd}M|Mr|Mnd}Nd |d |d t dd|ddd| d|Nd }Ot d|d|O|Mdf|r6|d#kr!t jSd"dn|t jd"<|||r |T|dn:#ttf$r&}t d||Yd}~nd}~wwxYw |VS#ttf$r&}t d||Yd}~Sd}~wwxYwS#t$r}t|jRdt-|}Pt Wd||Pd |d|d t dd|ddd| d|Pd }Odr|Od|PfcYd}~|r6|d#kr!t jSd"dn|t jd"<|||r |T|dn:#ttf$r&}t d||Yd}~nd}~wwxYw |VS#ttf$r&}t d||Yd}~Sd}~wwxYwSd}~wwxYw#|r6|d#kr!t jSd"dn|t jd"<|||r |T|dn:#ttf$r&}t d||Yd}~nd}~wwxYw |Vw#ttf$r&}t d||Yd}~wd}~wwxYwwxYw)z Execute a single cron job. Returns: Tuple of (success, full_output_doc, final_response, error_message) r)AIAgentN) SessionDBz0Job '%s': SQLite session store not available: %srXrYrWr=z6Job '%s' (ID: %s): wakeAgent=false, skipping agent runz # Cron Job: z **Job ID:** z **Run Time:** z%Y-%m-%d %H:%M:%Su< Script gate returned `wakeAgent=false` — agent skipped. T)r9cron__z %Y%m%d_%H%M%SzRunning job '%s' (ID: %s)z Prompt: %sd1HERMES_CRON_SESSION)set_session_varsclear_session_vars_VAR_MAPrCrIrD chat_name)rCrDrqworkdiruGJob '%s': configured workdir %r no longer exists — running without it TERMINAL_CWD_UNSET_zJob '%s': using workdir %s) load_dotenvz.envrJ)overriderLzlatin-1!HERMES_CRON_AUTO_DELIVER_PLATFORM HERMES_CRON_AUTO_DELIVER_CHAT_IDrV"HERMES_CRON_AUTO_DELIVER_THREAD_IDmodel HERMES_MODELz config.yamldefaultz8Job '%s': failed to load config.yaml, using defaults: %s)apply_ipv4_preferencenetwork force_ipv4)force)parse_reasoning_effortagentreasoning_effortHERMES_PREFILL_MESSAGES_FILEprefill_messages_filerrKz8Job '%s': failed to parse prefill messages file '%s': %s max_turnsZprovider_routing)resolve_runtime_providerformat_runtime_provider_error) AuthError requestedproviderHERMES_INFERENCE_PROVIDERbase_urlexplicit_base_urlz3Job '%s': primary auth failed (%s), trying fallbackfallback_providersfallback_modelapi_keyexplicit_api_keyz!Job '%s': fallback resolved to %sz Job '%s': fallback %s failed: %s) load_poolz@Job '%s': loaded credential pool for provider %s with %d entriesz3Job '%s': failed to load credential pool for %s: %sapi_mode acp_commandcommandacp_argsargsmax_iterationsreasoning_configprefill_messagescredential_poolproviders_allowedonlyproviders_ignoredignoreproviders_orderorder provider_sortsortrdisabled_toolsets)cronjob messagingclarify quiet_modeskip_context_files skip_memoryr session_id session_dbHERMES_CRON_TIMEOUTiXg@r[rFrgget_activity_summaryseconds_since_activity)waitcancel_futureslast_activity_descr current_toolapi_call_countz_Job '%s' idle for %.0fs (inactivity limit %.0fs) | last_activity=%s | iteration=%s/%s | tool=%snone interruptzCron job timed out (inactivity)z Cron job 'z ' idle for z s (limit us) — last activity: z agent.run_conversation returned z instead of dict: final_responsez(No response generated)z **Schedule:** schedule_displayzN/Az ## Prompt z ## Response rzJob '%s' completed successfully cron_completez#Job '%s': failed to end session: %sz2Job '%s': failed to close SQLite session store: %sz: zJob '%s' failed: %sz (FAILED) **Job ID:** z ## Error ``` z ``` ro)X run_agentrg hermes_staterhrrrrr*r8r_ _hermes_nowstrftime SILENT_MARKERrerErLenvirongateway.session_contextrnrorpr^rqris_dirrdotenvru _hermes_homeUnicodeDecodeErrorrrvrMyamlr(ropen safe_loadrrrr}rrrr2loadlisthermes_cli.runtime_providerrrhermes_cli.authrrrKagent.credential_poolrhas_credentialsrTentriesrboolrrrr contextvars copy_contextrrrun_conversationrrhasattrrshutdownrrrrtype__name__pop end_sessionKeyboardInterruptr exception)Qr rg _session_dbrhrrjob_namer9r_ran_ok_script_output silent_docr;rB_cron_session_idrnrorp _ctx_tokens _job_workdir_prior_terminal_cwdrudelivery_targetrz_cfgr _cfg_path_f _model_cfgr}_net_cfgreffortrr prefill_filepfpath_pfrprrrrruntime_kwargsruntimeauth_excfbfb_listentry fb_kwargsfb_excrmessagerrruntime_providerrrr _cron_timeout_cron_inactivity_limit_POLL_INTERVAL _cron_pool _cron_context _cron_future_inactivity_timeoutrdonerj _idle_secs_act _activity _last_desc _secs_ago _cur_tool_iter_n _iter_maxrlogged_responseoutput error_msgsQ rrun_jobrss"!!!!!K`******ikk ``` GQUWZI[I[]^________`YF6{H M''(##K9' 44 "/  9+N;; 9 KKH&    NxNN%NN!,!7!78K!L!LNNN  ]D8 8 s- @ @ @F S ! !FQvQQ (>(>(O(OQQ KK+Xv>>> KK fTcTl+++ ),BJ$%WVVVVVVVVV""'-5 ##2*08F9%&&&b17?&**["---RK GGI&&,"3355=LD..5577  U L    *..CCH%1 >" 0&,GGGt^ '&&&&& W KL6122TG T T T T T! W W W KL6122TI V V V V V V W3377  f 8 9 = =oj>Y Z Z Z 7 8 < BB3WbGcCdCdeee  CBIn$=$=C b KKKL=899Iw~~i(( A)__4>>"--3D444444444444444!XXgr22 www''A!*c22A *#J55A *y% @ @ b b b NNUW]_` a a a a a a a a b  > > > > > >xx 2..H(D)) 2hll<.H.H 2%%D1111    D  <;;;;;TXXgr**../A2FFGGMMOO11&99 y!?DDmQhjlHmHm  ,,''2244F%%'' /%.}} ,,fcG<<<:+/9S>>(:::::::::::::::%&6==0+/( ,,,NN#]_egmopqqq'+$$$$$$, '2..22;??^488KCXCX^\^XX(" - -         .----- 1SWWZ00ZBI>Y4Z4ZNwwz"" J69ggj6I6I23..@@@@GG Z Z Z NNPRXZb c c c.//M488z9J "56yy++I8=i8H "4566CCCCGKK CVW[[YcMdMdeeeE lllLL!CVUYYWaMbMbdjkkkkkkkkl"#@#@#J#JKKQYY 1 1 133C88Gw''S 0 1"677]488DT;U;U]Y]w{{:66<"==CCEEKKMM  q q;;;;;; y!122''))&*OKKZ(DLLNN++   q q q RTZ\lnopppppppp q   % KK *** [[,,, [[,,,  [[,,,   I...  [[((( *> .- .- *> ,O !ffVnnn !ffX... FF7OOO &&...! "BBI! n55Imm$4a88G! &6::I LLA)%;GY#V    uk** C ABBB3X33y>>33,/0F,G,G33&033 &$'' f4<<3Hff\bff  $4b99?R    ! !%> > >N-;Y..@Y (     }}%%&9::  ww)511         5x@@@V^T18  A"i// ~t4444-@ >*;'''  ^ O''(8/JJJJ01 O O O BFANNNNNNNN O ^!!####01 ^ ^ ^ QSY[\]]]]]]]] ^ ^C ,,,Aww'333q6633 .)DDD( }}%%&9::ww)511   fb)++++++  A"i// ~t4444-@ >*;'''  ^ O''(8/JJJJ01 O O O BFANNNNNNNN O ^!!####01 ^ ^ ^ QSY[\]]]]]]]] ^ ^C,4  A"i// ~t4444-@ >*;'''  ^ O''(8/JJJJ01 O O O BFANNNNNNNN O ^!!####01 ^ ^ ^ QSY[\]]]]]]]] ^ ^s  A0AA")#K  -K=:<K==CA R8P>2 R8>QR8QA1R878 S(S##S((,AT?>? U   U  C,Z>Y ZY##Z&Y#'Z Z5 Z0+0Z55A'A ]?=?d*Bc=Bbc= c 0cc=cc=8= d* d%%d**A;&A#h  h;h616h;;F1-A(r*rr r r r rs#r??ss33 t! ! t.+-t..G =}~ %~~ ~$$5 AE+*BAE&A9AE+A:AE.CACCADC,AD D ADDAD+D+AE"D<AEEAE"E&AE+E+AE.E.AAIF5AG G AIG AHGAG>G9AIG>AHHAIHAHHAIHAIH-AII AIIAIIAITverbosec  tddd} ttd}tr-t j|tjtjzn9tr2tj | tj dnH#ttf$r4td||YdSwxYw t#}r|stdt'd  tr t j|tjnRtrK tj | tjdn#ttf$rYnwxYw|dSrHtd t'd t/||D]}t1|d d} t3jd d }|rt9|pd}n1#t:t<f$rtdYnwxYw|u tApi}tC|tDr|#dini#d} | t9| pd}n#tH$rYnwxYwr-tdt/||r|nddtDdtJffd } d|D} d|D} g} | D]>}tMj'}| (|)| |?| rtTj+,|5}g}| D]D}tMj'}|(|-|j)| |E| .d|Ddddn #1swxYwYt_| tr t j|tjnRtrK tj | tjdn#ttf$rYnwxYw|S#tr t j|tjnRtrK tj | tjdn#ttf$rYnwxYw|wxYw)u Check and run all due jobs. Uses a file lock so only one tick runs at a time, even if the gateway's in-process ticker and a standalone daemon or manual tick overlap. Args: verbose: Whether to print status messages adapters: Optional dict mapping Platform → live adapter (from gateway) loop: Optional asyncio event loop (from gateway) for live adapter sends Returns: Number of jobs executed (0 if another tick is already running) Tr Nwr[u0Tick skipped — another instance holds the lockrz%s - No jobs duez%H:%M:%Sz%s - %s job(s) duerXHERMES_CRON_MAX_PARALLELrIz?Invalid HERMES_CRON_MAX_PARALLEL value; defaulting to unboundedrmax_parallel_jobsz.Running %d job(s) in parallel (max_workers=%s) unboundedr r cv t|\}}}}t|d|} rtd||r|n!d|d|dd|}t |}|rX|rVt |vr)td|dt d}d}|r] t|| }nH#t$r;} t| }t d |d| Yd} ~ nd} ~ wwxYw|r|sd}d }t|d||| d S#t$rQ} t d|d| t|ddt| Yd} ~ dSd} ~ wwxYw)z9Run one due job end-to-end: execute, save, deliver, mark.rXzOutput saved to: %su⚠️ Cron job 'rWz ' failed: u1Job '%s': agent returned %s — skipping deliveryFN)rrzDelivery failed for job %s: %szWAgent completed but produced empty response (model error, timeout, or misconfiguration))delivery_errorTzError processing job %s: %s)rr?rr_rrrrqupperrrr^rr>)r rrrr output_filedeliver_contentshould_deliverrderrrrs r _process_jobztick.._process_jobs,% 9@6-c$i@@ DKK 5{CCC 5<#D..BDUXU\U\]cehimenUoUoBDBD}BBDBD!%o!6!6!+g+-?CXCXCZCZC`C`CbCb2b2bKK SUXY]U^`mnnn%*N!%!VV)8oX`gk)l)l)l$VVV),R %Es4yRTUUUUUUUUVv>v#GuESY~VVVVt    :CIqIIISYs1vv666uuuuu sCCEC21E2 D7<1D2-E2D77$E F8'AF33F8cdg|]-}|dpd+|.SrrrIrrqrrjs rrtztick.. s:PPPai0@0@0FB/M/M/O/OPPPPrFcdg|]-}|dpd+|.Sr r!r"s rrtztick.. s:UUUqQUU95E5E5K4R4R4T4TUUUUrFrc3>K|]}|VdSrE)r)rrrHs rrCztick..s*==q ======rF)0 _LOCK_DIRrr _LOCK_FILEfcntlflockLOCK_EXLOCK_NBmsvcrtlockingfilenoLK_NBLCKrUIOErrorrrrr=r_rrLOCK_UNLK_UNLCKrTr@rLrMrqrr TypeErrorrr rrrrrrrrxrrrrrrXsum)rrrlock_fddue_jobsr _max_workers_env_par_ucfg_cfg_parr workdir_jobs parallel_jobs_results_ctx _tick_pool_futuress``` rtickrAsOOD4O000G z3''  A K!> ? ? ? ?  A N7>>++V_a @ @ @ W  GHHH   MMOOOqq  s>>  8  KK*KMM,B,B:,N,N O O ON   K / / / /   w~~//!DDDDW%     Y  a KK,kmm.D.DZ.P.PRUV^R_R_ ` ` ` ( (C SY ' ' ' ''+  ^y!;R@@FFHHH 5"8}}4 I& ^ ^ ^ NN\ ] ] ] ] ] ^   # +-7t-D-DLEIIfb)))"#)**'#&x==#8DL       KK@H ,= +    ' d' t' ' ' ' ' ' ' ' ZQP8PPP UUHUUU   9 9C+--D OODHH\377 8 8 8 8  >#66<6PP >T^(TTC&355DOOJ$5$5dh c$R$RSSSS==H======  > > > > > > > > > > > > > > >8}}   K / / / /   w~~//!DDDDW%        K / / / /   w~~//!DDDDW%     sBB&&AC+*C+/A S3+2FF21F2 A&S32:I-,S3-+JS3JS3!A#LS3 LS3LCS3A)Q  S3 QS3QS32SSS3/V#2UVU*'V)U**V__main__)r)NNrE)TNN)F__doc__rconcurrent.futuresrrr2loggingrLrrr( ImportErrorr,rrtypingrrr(rYr^__file__rrrhermes_cli.configr hermes_timer r getLoggerrrrrr frozensetrcrJrNrPr=r>r?r@rrr&r'rErRrkrrrrrrrrrrrtuplerr*r8rerrArorFrrNsG   LLLL E   !!!!!!!! 33ttH~~,344555,,,,,,))))))******  8 $ $4DI++++iAAABB iIIIJJ iBBBCC !gc!g!gPTW[P[!ghl!gqu!g!g!g!gHwwww(SV-wwwwt)#S####BN8N8tSy)9N8N8N8N8b4C4D44444LL4LL3LLLL^M^M^%c3 =>M^M^M^M^` RR$RCRRRRj zDs-)A6AAAAAA