+ jHj}~Rt^RIHtHtHtHt^RIt]P !]4tRt Rt Rt Rt RRlt R R ltR#) zExact scheduled identities, independent of mutable jobs.json dispatch stamps, plus the profile-local stale-schedule catch-up counter marker.)datetime timedeltatimezoneUTCNc\V\4'gR#\P!V4pVPfR#VP \ 4P4# \dR#i;i)zMCanonicalize aware instants; legacy/ambiguous values carry no exact identity.N) isinstancestrr fromisoformattzinfo astimezoner isoformat ValueError)valueinstants& 5/home/ubuntu/.hermes/hermes-agent/cron/occurrences.pyscheduled_instantr s` eS ! !((/ >> !!!#&0022 s$A#"A## A21A2c ^RIHp^RIHp\ V4pVfR#\ P !V4\VR7, pV!4;_uu_4pVPR\VR,4V34P4pRRR4XFp\ VR,;'g VR ,4pVe\ P !V4V8gKG\PR VPR VPR44VPR4YR,VR,;'g VR ,4R # R# +'giL;i \d$\PR TR,R R7R#i;i)zKUnknown/failed/pruned attempts cannot prove completion: keep them eligible.)FIRE_CLAIM_SKEW_SECONDS) _transactionNF)secondszpSELECT id, finished_at, claimed_at FROM executions WHERE job_id=? AND scheduled_instant=? AND status='completed'id finished_at claimed_atzJob '%s' (%s): scheduled occurrence %s was already completed by execution %s (finished %s); skipping the due slot without a new runnameTz,Cannot check completed occurrence for job %s)exc_info)cron.constantsrcron.executionsrrrr rexecuterfetchallloggerwarningget Exception) jobrrr earliest_realconnrowsrow completed_ats && rcompleted_occurrencer)sF6,(G**73iH_6``M ^^t<<)+.s4y>7*Chj  C,S-?-T-T3|CTUL#x'='=l'K}'\PGGFCGGDM2CGGDM7PTI &;;#l*; = '^( Es4y[_`sCE3E!E**EAE1EE E E*FFcD^RIHpRVRVP4RV!4/#)zLStore value for a recurring occurrence about to be handed to the dispatcher.) _machine_id scheduled_atatby) cron.jobsr+r )next_runnowr+s&& rpending_slot_stampr2Gs % HdCMMOT;= QQc^RIHp^RIHpHpHpVP R4p\V\4'gR#VP R4pVP R/4P R4R 9g\V\4'gR#\P!V4T!\TP RR 444'dR#TP R 4T!48wdT!YaT4'dR#T# \dR#i;i) uStored instant of a slot the dispatcher never claimed, or None. None for non-recurring jobs and malformed stamps (never a fire) and for a job still in this process's running set (its queued worker will claim and clear the slot itself). A stamp by THIS process on a job not running here is orphaned (dispatch refused). A stamp by another process is honoured while that owner may still be alive within the fire-claim lease — a second live gateway on the same store is mid-dispatch, not dead.)FIRE_CLAIM_TTL_SECONDS)_claim_is_live_job_running_in_this_processr+ pending_slotNr,schedulekindrr.>croninterval) rr5r/r6r7r+r!rdictrrr r )r#r1r5r6r7r+pendingslots&& runclaimed_pending_slotrANs6SSggn%G gt $ $ ;;~ &D wwz2""6*2FFjY]_bNcNct$$Cb(9$:;;{{4KM)nWKa.b.b K s C77 DDc$V^8dQhR\/#)return)int)formats"r __annotate__rGjssr3c ^RIHpV!4PR, p\^\ VP RR7P 444# \\3d^#i;i)z7Return the profile-local stale-schedule catch-up count.)_current_cron_storecatch_up_occurrencesz utf-8-sig)encoding) r/rIcron_dirmaxrE read_textstripOSErrorr )rIpaths rget_catch_up_occurrence_countrRjs[-  ) ),B BD1c$..+.>DDFGHH Z s2AA('A(cV^8dQhRR/#)rCrDN)rFs"rrGrGus__D_r3cV^RIHpV!R\\4^,4R4R#)zIIncrement the profile-local stale-schedule catch-up counter, best effort. _write_markerrJz.count_N)r/rWrrRrVs rrecord_catch_up_occurrencerXus"'(#.K.MPQ.Q*RT]^r3)__doc__rrrrlogging getLogger__name__rrr)r2rArRrXrTr3rr]sD977   8 $ !bR8_r3