`gjI%ldZddlmZddlZddlmZmZddlmZGddeZ d dZ Gd d e Z y) u"CronScheduler provider interface (Axis B — the trigger). ⚠️ EXPERIMENTAL — this interface is validated by exactly ONE consumer (the built-in) until an external provider (Chronos, Phase 4) shakes it out. Until then the module path, method signatures, and start() kwargs MAY change without a deprecation cycle. Once a second provider validates the shape it becomes stable. Any growth MUST be additive (new optional method with a default), never a changed signature on start() or a new abstractmethod. A CronScheduler decides *when* a due job fires. It does NOT decide what firing means: execution + delivery stay in cron.scheduler.run_job / _deliver_result, shared by all providers. Providers must never reimplement agent construction or delivery. The built-in InProcessCronScheduler runs the historical 60s daemon-thread ticker. Alternative providers (e.g. Chronos, a NAS-mediated managed-cron provider for scale-to-zero deployments) live under plugins/cron_providers// and are selected via the `cron.provider` config key (empty = built-in). ) annotationsN)ABCabstractmethod)AnyceZdZdZeeddZddZedddd ddZddZ dd Z dd Z ddd dd Z dd Z y) CronScheduleruAxis-B trigger provider. Decides WHEN a due cron job fires. Required surface is intentionally minimal: ``name`` + ``start``. ``stop`` and ``is_available`` carry safe defaults. The three Phase-4 hooks (``on_jobs_changed`` / ``fire_due`` / ``reconcile``) are added later as NON-abstract methods so the built-in keeps satisfying the ABC without overriding them — see ``test_abc_growth_stays_additive``. cy)z,Short identifier, e.g. 'builtin', 'chronos'.Nselfs J/root/.hermes/venv/lib/python3.12/site-packages/cron/scheduler_provider.pynamezCronScheduler.name%cy)a)Whether this provider can run in the current environment. MUST NOT make network calls. The built-in is always available; an external provider checks for configured endpoint/credentials. When a named provider returns False, the resolver falls back to the built-in. Tr r s r is_availablezCronScheduler.is_available*srN<)adaptersloopintervalcy)aPBegin firing due jobs. For the built-in this BLOCKS in the 60s loop until stop_event is set (it is run inside a daemon thread by the caller, exactly as today). An external provider may register a schedule/webhook and return immediately; in that case it must still honor stop_event for teardown. Nr )r stop_eventrrrs r startzCronScheduler.start3rrcy)zOptional eager teardown hook. Default no-op; setting the stop_event is the primary stop signal. Override for providers holding external resources (queue consumers, HTTP servers).Nr r s r stopzCronScheduler.stopDrcy)aCalled after a successful store mutation (create/update/remove/ pause/resume). External providers reconcile their registry here (e.g. Chronos re-provisions/cancels the affected one-shot via NAS). Built-in: no-op (it re-reads jobs.json on every tick).Nr r s r on_jobs_changedzCronScheduler.on_jobs_changedNs rcddlm}|S)z@Run profile-local attempt recovery for every provider lifecycle.r)recover_interrupted_executions)cron.executionsr )r r s r recover_interruptedz!CronScheduler.recover_interruptedUsB-//rrrcddlm}m}ddlm}ddlm}||sy||}|y|||jd|d<|||| S) aLRun a single job NOW via the shared orchestrator. Called by the inbound fire webhook when an external scheduler signals a job is due. The default claims the job with a store-level compare-and-set (multi-machine at-most-once), then runs it via the shared ``run_one_job`` body. Built-in never calls this (it has its own tick loop); an external provider routes its inbound fire here. Returns True if THIS caller claimed and ran the job, False if the claim was lost (another machine/retry won it) or the job no longer exists. r)claim_job_for_fireget_job)create_execution) run_one_jobF)sourceid execution_idr#) cron.jobsr%r&r!r'cron.schedulerr(r) r job_idrrr%r&r'r(jobs r fire_duezCronScheduler.fire_due[sR :4.!&)fo ;.vdiiHNN3==rcy)zConverge the external registry toward jobs.json (the desired state): arm missing one-shots, cancel orphaned ones, re-arm changed times. Built-in: no-op.Nr r s r reconcilezCronScheduler.reconcilesrrreturnstr)r4bool) rzthreading.Eventrrrrrintr4None)r4r8)r4r7)r.r5rrrrr4r6)__name__ __module__ __qualname____doc__propertyrrrrrrr"r0r2r rr rrs;;   #          0 8<>0rrcddl}|jd}d} ddlm}m}||dddxsdj }|r|d vr tS dd lm }||}||jd |tS|js|jd |tS|jd |j|S#t $rYwxYw#t $r'}|jd||tcYd}~Sd}~wwxYw)u1Return the active cron scheduler provider. Reads ``cron.provider`` from config. Empty/absent → built-in. A named provider that is missing, fails to load, or reports ``is_available() == False`` falls back to the built-in with a warning — cron must never be left without a trigger. rNcron.scheduler_provider)cfg_get load_configcronprovider)default)builtinz in-process inprocess)load_cron_schedulerz3cron.provider '%s' not found; using built-in tickerz7cron.provider '%s' not available; using built-in tickerz!Using cron scheduler provider: %sz=Failed to load cron.provider '%s' (%s); using built-in ticker)logging getLoggerhermes_cli.configrArBstrip ExceptionInProcessCronSchedulerplugins.cron_providersrHwarningrinfor)rIloggerrrArBrHrDes r resolve_cron_schedulerrTzs    8 9F D : vz2FL"SSU 4AA%''(>&t,   NNPRV W)+ +$$& NNTVZ [)+ + 7G!    " ( KTST &'' (s;+C +C+C-C CC D #D?D D c4eZdZdZeddZddddddZy)rNaDefault provider: the historical in-process 60s ticker. ``start()`` blocks in the tick loop until ``stop_event`` is set, identical to the pre-refactor ``_start_cron_ticker`` core loop. The caller runs it in a daemon thread. ``can_dispatch`` is an optional synchronous gate supplied by GatewayRunner during external drain; skipped ticks leave due jobs intact for the next allowed tick. cy)NrFr r s r rzInProcessCronScheduler.namesrNr)rrr can_dispatchcddl}ddlm}ddlm}|j d} | j d||j} | r| jd| ||jsYd} ||s| jdn |d||d| d } || |j||jsXyy#t$r} | jd | d Yd} ~ Od} ~ wwxYw)Nr)tick)record_ticker_heartbeatr?z0In-process cron scheduler started (interval=%ds)z=Marked %d interrupted cron execution(s) unknown after restartFz7Cron dispatch paused while gateway drains existing work)verboserrsyncrWTzCron tick error: %s)exc_info)success)rIr-rYr,rZrJrQr"rPis_setdebug BaseExceptionerrorwait) r rrrrrWrI cron_tickrZrR recoveredokrSs r rzInProcessCronScheduler.starts45""#<= FQ,,.  NNO  !##%B F+LNLL!Z[ %!)!"%1  $B / OOH %7##%! F 2A EE Fs2*C C0C++C0r3)r9r:r;r<r=rrr rr rNrNs,-1tbW[+&rrN)r4z'CronScheduler') r< __future__r threadingabcrrtypingrrrTrNr rr rks9&##\C\~%(P9&]9&r