+ jHjRt^RIHt^RIt^RIt^RIt^RIHt^RIH t ^RI H t H t H t ]P!R4tRRltR R ltR R ltR RltRRltRRltRRltRRltRRltRRltR#)zPlumbing shared by the kanban notifier and dispatcher loops. Thread offload, board enumeration, live-config coercers and the singleton dispatcher lock live here so the notifier, dispatcher and mixin modules read them from one place. ) annotationsN)Context)Path)AnyCallableOptionalz gateway.runc$V^8dQhRRRRRR/#funczCallable[..., Any]argsrreturn)formats"C/home/ubuntu/.hermes/hermes-agent/gateway/kanban_watchers_common.py __annotate__rs"&& 2&c&c&c:\4P!V.VO5!#)aSRun *func* in an empty ``Context`` so request-local ContextVars stay behind. ``asyncio.to_thread`` copies the caller's context; a lingering ``delegate_task`` child marker would make ``write_txn`` false-trip for these process-owned writers. An empty Context keeps the DB guard intact for real children without exempting dispatcher writes. )rrunr r s"*r_run_in_fresh_contextrs 9== % %%rc$V^8dQhRRRRRR/#r r)rs"rrr s(GG+=GGQTGrcX"\P!\V.VO5!GRjxL #L5i)zMOffload blocking process-service work without inheriting request ContextVars.N)asyncio to_threadrrs"*r_to_thread_process_servicer s$""#8$FF FF Fs !*(*c V^8dQhRRRR/#r kbrr listr)rs"rrr%s::S:T:rcVPRR7# \d TPTP4.u#i;i)zIEnumerate live boards; fall back to the default board when listing fails.F)include_archived) list_boards Exceptionread_board_metadata DEFAULT_BOARD)rs&r _list_boardsr&%sA:~~u~55 :&&r'7'7899:s '>>c V^8dQhRRRR/#rr)rs"rrr-sIISITIrc\V4Uu.uF'qPR4;'g VPNK) up#uupi)slug)r&getr%)rbs& r _board_slugsr,-s87CB7G H7G!EE&M - -R-- -7G HH Hs>>c$V^8dQhRRRRRR/#)r kanban_cfgdictkeystrr z Optional[int]r)rs"rrr1s!drcVPV4pVfR#\V4pT^8d\P RY4R#\P RY4T# \\3d\P RY4R#i;i)zXParse an optional ``kanban.`` int cap; None when unset or invalid (< 1 is invalid).Nz1kanban dispatcher: invalid kanban.%s=%r; ignoringz4kanban dispatcher: kanban.%s=%r is below 1; ignoringzkanban dispatcher: %s=%d)r*int TypeError ValueErrorloggerwarninginfo)r.r0rawvalues&& r_positive_int_settingr;1s} .. C {C qyMsX KK*C7 L z "JCUs A'BBc V^8dQhRRRR/#)r load_configzCallable[[], Any]r ztuple[bool, int]r)rs"rrrBs DD2CDHXDrcXV!4p\T\4'dTPR/4M/p\ TPR^4;'g^4p\TPRR44\T^43# \dRu#i;i \ \ 3d^pLOi;i)uLive (enabled, per_tick) auto-decompose settings, re-read every dispatcher tick. Fails safe: a config read error returns ``(False, 3)`` rather than re-enabling a feature the user turned off. ``per_tick`` is clamped to ``>= 1``. Read fresh from config on every dispatcher tick (#49638) so that flipping ``kanban.auto_decompose: false`` to STOP runaway fan-out takes effect on the next tick instead of requiring a gateway restart. Auto-decompose is a safety toggle — a user who sees it create and launch tasks they didn't intend reaches for this flag to halt it, and a stale boot-captured value silently ignoring that change is the bug reported in #49638. kanbanauto_decompose_per_tickauto_decomposeT)F) r# isinstancer/r*r3r4r5boolmax)r=cfgkcfgper_ticks& r _resolve_auto_decompose_settingsrIBsm%/sD$9$93778R rDtxx 91=BBC )40 13x3C CC  z "s(BBB BBB)(B)cV^8dQhRR/#)r r r3r)rs"rrrZsCrc^RIHp\V!4;'g/PR4;'g/PR^44# \d^#i;i)za``kanban.done_sub_retention_days`` (default 30; 0 disables), re-read per sweep; fails safe to 30.r=r?done_sub_retention_days)hermes_cli.configr=r3r*r#rLs r_gc_retention_daysrOZsS1[]((b--h7==2BBC\^`abb sA A A AAcV^8dQhRR/#)r r rDr)rs"rrrds . .$ .rcX^RIHpT!R\4'*# \dR#i;i)zFalse while the global emergency stop (`hermes pause`) is engaged. Checked every tick before spawning, so a pause applies on the next tick; in-flight workers are never touched. Fails open if estop is unimportable.  check_pausedTr?) agent.estoprS ImportErrorr6rRs r_kanban_dispatch_allowedrVds0 ,Hf- -- s  ))cV^8dQhRR/#)r r ztuple[Optional[object], str]r)rs"rrrqs*Frc ^RIHp\T4PP RRR7\ \T4RRR7pT!T4'gTP4R #TR3# \dRu#i;i \dRu#i;i) amTake the exclusive, non-blocking advisory lock for the sole dispatcher. Only one gateway machine-wide may run the embedded dispatcher: concurrent dispatchers double reclaim frequency and claim events, and with ``wal_autocheckpoint=0`` concurrent manual checkpoints can corrupt index pages. ``dispatch_in_gateway`` is the primary control; this is the backstop. Returns ``(handle, "held")`` (release via :func:`_release_singleton_lock`), ``(None, "contended")`` when another process holds it (caller must NOT dispatch), or ``(None, "unavailable")`` when locking cannot be performed (caller falls back to config control). )_try_acquire_file_lockT)parentsexist_okza+zutf-8)encodingheld)N unavailable)N contended) gateway.statusrYrUrparentmkdiropenr1OSErrorclose) lock_pathrYhandles& r_acquire_singleton_lockrhqs#9# Y$$TD$Ac)ndW= "& ) )   6> #""# #""#s"A*=A=* A:9A:= B  B cV^8dQhRR/#)r r Noner)rs"rrrs  t rcHVfR#\P!\4;_uu_4^RIHpV!V4RRR4\P!\4;_uu_4VP 4RRR4R# +'giLM;i +'giR#;i)zrwsk#**   = )&G :I"D0 .8 r