+ jHjx$aRt0tRt^RIt^RIt^RIt^RIt^RIHt^RI H t ]P!R4t Rt /s]^kRRltRRRR R /R R llltR tRRltRRltRRRR R /RRllltR#)zLIn-process tick admission and dispatch; job execution stays in scheduler.py.N) store_health) is_recurringzcron.schedulerg @c(V^8dQhR\RR/#)reasonreturnN)str)formats"8/home/ubuntu/.hermes/hermes-agent/cron/scheduler_tick.py __annotate__r s 4 4 4 4c\P!4p\PR4p\PRR4pW 8wgV\ V4, \ 8d\ PRV4RVRV/sR#)z?Log the yield at error level once per episode (skew signature).ratguCron tick yielded: this process is running stale code (%s) and a fresher gateway owns the runtime lock — jobs will fire from that process. Restart this one to reclaim its ticks.N)time monotonic_last_yield_loggetfloat_YIELD_LOG_INTERVAL_SECONDSloggererror)rnow last_reasonlast_ats& r _log_tick_yield_oncerso .. C!%%h/K!!$,GuW~!5:U U  >     s3Or can_dispatchheadlessFc$V^8dQhR\/#)rrbool)r s"r r r !s 1 1 1r c ^RIHpVP4;_uu_4pV'g RRR4^#\WW#VVR7uuRRR4# +'giR#;i)) retirementN)rr)hermes_cli.backend_retirementr"work_tick_admitted)verboseadaptersloopsyncrrr"admitteds&&&&$$ r tickr+!sF8   h  g,'/1    s A A  A c2VP4wrVPV4VPV4# \dVpTP\ P 9dh\ P!TRRTR7TP4Rp?R#Rp?ii;i)aThe tick lock fd, or None when this tick must not run: another ticker holds the lock, or the store cannot be written (read-only/full/denied: the lock file cannot even be created), in which case the store is marked degraded and the MCP orphan sweep still runs.ztick lock unavailablelock)cron_dirN) _get_lock_paths_ensure_cron_dir_acquire_tick_lockOSErrorerrnorUNWRITABLE_ERRNOSnote_unwritable_sweep_mcp_orphans)_schedlock_dir lock_fileexcs& r _acquire_tick_lock_or_degrader;.s!002H H%((33  99L:: : $$S*A6T\]!!# s6 BA BBc0V^8dQhR\R\/#)rdue_jobsr)list)r s"r r r >s < < <$  a crash mid-run would re-fire them, so skipping is the at-most-once side). One-shots still go through their own fire claim.idzskipped z recurring job(s)advanceN)advance_next_runsr2rrr5len)r7r=jobr:jskippeds&& r _advance_or_drop_recurringrG>s<  x!@xd))x!@A"A <&:h,q/11h::$$SHS\NBS*TV_ahi#;8a<?8;;p+p+r ch aaaa^RIHoSP4pVe@\RV^, RV^, 24SP V^,V^,4h\ S4pVf^#\ P!\4;_uu_4^RI H pV!RSP4'dRRR4SPV4^#RRR4Ve=V!4'g0SPPR4SPV4^#\SV4SP4SP#4p SP%V 4V'd^R IHp V !V 4p V 'g{S'd:SPP+R SP-4P/R 44\0P2!4SP54SPV4^#\0P6!V 4'd%SP54SPV4^#S'dDSPP+R SP-4P/R 4\9V 44\;SV 4p V 'g%SP54SPV4^#SP=4p S'd1SPP+R \9V 4V 'dT MR4RVVVV3Rllp .p.pSP?V 4pV FHpSPAVVV 4pVfKVPCV4V'dK7VPCR4KJ V'ds\DPFPIV4F#pVPCVPK44K% SP54\OV4SPV4#SPQV4\OV4SPV4# +'giELH;i \ d(p SPPRT 4Rp ? ELRp ? ii;i \ d:pSPPMRT4TPCR4Rp?EKRp?ii;i SPT4i;i)aCheck and run all due jobs. File-locked so only one tick runs at a time (gateway ticker vs standalone daemon / manual tick). ``can_dispatch``: optional gate; false leaves due jobs for the next allowed tick. ``headless``: the tick runs outside any gateway (system crontab, ``hermes cron tick``) and must refuse agent jobs rather than spawn one. Returns the number of jobs executed (0 if another tick holds the lock).) schedulerNzboot=z disk=) check_pausedcronz7Cron dispatch paused while gateway drains existing workz(Worktree maintenance dispatch failed: %s)!refuse_agent_jobs_without_gatewayz%s - No jobs duez%H:%M:%Sz%s - %s job(s) duez.Running %d job(s) in parallel (max_workers=%s) unboundedc0V^8dQhR\R\/#)rrDr)dictr)r s"r r $_tick_admitted..__annotate__s I Id It Ir c,<SPVSSS4#)N)_process_due_job)rDr7r'r(r&s&r _process_job$_tick_admitted.._process_jobs**3$H Hr TzCron job future failed: %sF))rYrW#_should_yield_tick_to_fresh_gatewayrCronTickYieldedr; contextlibsuppress ImportError agent.estoprXr_release_tick_lockdebugrT_maybe_run_worktree_maintenancerP get_due_jobs_sweep_stale_inflight_for_tickcron.scheduler_gateway_gaterZinfo _hermes_nowstrftimer recheck_idler6dispatch_blockedrCrG_resolve_max_parallel_workers_get_parallel_pool_submit_with_guardappend concurrentfutures as_completedresultrsum _sweep_mcp_orphans_when_all_done)r&r'r(r)rr_skewlock_fd_estop_check_paused_wt_excr=rZ _max_workersra_results _all_futurespoolrDfutfr:r7sfff&$$ @r r%r%\s)  6 6 8E uU1XJfU1XJ?@$$U1XuQx88+F3GZ+   - - G"66==99.p !!'*m:.  #LNN MM   Y Zb !!'*_ #684 U  2 2 4&&(--h7  U8BH  ""#5v7I7I7K7T7TU_7`a  % % '  % % 'n !!'*k  ( ( 2 2  % % 'b !!'*_  MM  3V5G5G5I5R5RS]5^`cdl`m n .fh?  % % 'L !!'*I;;=  MM  @H , + ?  I I  ((6C++C|DC{    $4%  ''44\B+OOAHHJ/C  % % 'x= !!'* // =8}!!'*q. - - U MM   JG T T UD!+MM''(DcJOOE**+ !!'*s0"R!P3RR(R R$P"4(RR3R;AR-R R-R5A'R0RBRR/"RQ1R!R P  R" Q-Q RQR R"-RRRRR1cbV^8dQh/^\9d\\\3,;R&#)rr)__conditional_annotations__r]robject)r s"r r r s$RR('c6k"'Sr )TNNT)r__doc__concurrent.futuresrxreloggingrrYrcron.constantsr getLoggerrrrrr+r;rGrTr%r )rs@r rsR '   + ,%%'' 4 1D 1 1 1  <%"p+W[p+p+p+r