+ jHj?Rt^RIHt^RIt^RIt^RIt^RIHt^RIH t H t ^RI H t H t HtHtHtHtHt^RIHtHt^RIHtHtHt0R mt0R mtRt^t!R R 4tR#) aKanban board watcher methods for GatewayRunner. Background loops that subscribe to kanban boards, deliver notifications and artifacts, and drive the multi-agent dispatcher. They use only ``self`` state, so they live on a mixin ``GatewayRunner`` inherits. Per-tick work lives in ``kanban_watchers_notifier`` / ``kanban_watchers_dispatcher``; shared plumbing in ``kanban_watchers_common``. ) annotationsN)Path)AnyOptional)_acquire_singleton_lock_kanban_dispatch_allowed_release_singleton_lock _resolve_auto_decompose_settings_gc_retention_days_to_thread_process_servicelogger)_KanbanNotification_notifier_collect)_KanbanDispatcher_log_spawn_results_resolve_dispatcher_settingsg @c]tRt^(tRtRRltRRltRRltRRR lltR R lt RR Rllt RRRllt RRRllt RRlt RRltRRltRtR #)GatewayKanbanWatchersMixinz?Kanban watcher / notifier / dispatcher loops for GatewayRunner.cV^8dQhRR/#)returnbool)formats"Clear notifier-visible ownership before releasing the OS lock.rN)r rr)r!handles& r_release_kanban_dispatcher_lock:GatewayKanbanWatchersMixin._release_kanban_dispatcher_lock.s!?F.2+'rc V^8dQhRRRR/#rintervalfloatrr&r)rs"rrr4s5Trc "\VR4pRpW!8dNVP'd:\P!\ RW, 44GRjxL VR, pKQR#R#L5i)zTSleep *interval* (floored to 1s) in 1s slices so stop() never waits a full interval.g?N)max_runningasynciosleepmin)r!r-slepts&& r_sleep_between_ticks/GatewayKanbanWatchersMixin._sleep_between_ticks4sTx%4===--C)9 :; ; ; SLE$1 ;s&A()A(A&A(c V^8dQhRRRR/#r,r)rs"rrr<s=6=6u=6t=6rc p"^RIHpV!4p\V\4'dVP R/4M/pVP RR4'g\ P!R4R#^RI H p^R I H p\TR /4pYn\TR R4;'gTP4p Yn\"P$!^4GRjxL R p TP&'d\(P*!4T 8p ^p T 'd+\(P*!4\,,p \/4p \"P0!\2YYT R7GRjxL p T F&p\5YYhR7P74GRjxL K( TP9T4GRjxL KR# \ d%p\ P!RT4/pRp?ELRp?ii;i \ d\ P!R 4R#i;iEL/LL \ d"p\ P!RT4Rp?LRp?ii;iL5i)u Poll ``kanban_notify_subs`` and deliver terminal events to users. Per subscription, claims ``task_events`` newer than the stored cursor (kinds in TERMINAL_KINDS), sends one message per event, then advances the cursor. The subscription is removed only when the task is ``archived``: ``done`` is reversible, so the cursor — not unsubscribing — is the dedup mechanism (unsub-on-terminal dropped users when the dispatcher respawned a crashed task). All SQLite work runs in a thread; one tick's failure never stops the next.  load_configkanbanzH6)!H A HH'H>H?HH6H4H6$ G/GH6GH6!G;7H6:G;;H6HH H1H,'H6,H11H6c ,V^8dQhRRRRRRRRR R /#) rboard Optional[str]opstrsubrKextrarrr&r)rs"rrr{s1MsPSX\rc ^RIHp^RIHp^RIHpVP 4;_uu_4VP VR7p\ Wr4!V3RVR,RVR,RVR,RVPR4;'gR /VBVP4R R R 4R # TP4i;i +'giR #;i) zbSync helper (runs in to_thread): call ``kanban_db_notify.`` for one subscription on its board.r@)kanban_db_connect)kanban_db_notify)rftask_idplatformchat_id thread_idN) rQrArmrnpin_first_board_resolutionconnectr rLclose) r!rfrhrjrkr]_kbc_kbnconns &&&&, r_kanban_sub_op)GatewayKanbanWatchersMixin._kanban_sub_op{s/87  + + - -<z?TWXaTb!ggk288b\PPV4'gKeV PV4Kx V 'gR#^RIHpVP#V 4p V 'gR#^RIHpV U u.uF3p \)V 4P*P-4\.9gK1V NK5 pp V U u.uF3p \)V 4P*P-4\.9gK1V NK5 pp V'd:VU u.uFp RV!V 4 2R3NK pp VP1VVVR 7GRjxL VFhp\)V4P*P-4\89dVP;W.VR 7GRjxL KMVP=W.VR 7GRjxL Kj R#uup iuup iuup iuup iuup iuup iL \2d"p\4P6!R T4Rp?LRp?ii;iLvL[ \2d$p\4P6!R TT4Rp?KRp?ii;i5i)a<Upload artifact files referenced by a completed kanban task. Sources, in priority order: ``event_payload['artifacts']``, ``event_payload['summary']``, then ``task.result`` (legacy). Paths are deduplicated, missing files are skipped (may be mentioned for reference only), and upload errors are logged, never raised. artifactssummaryNresultrs)BasePlatformAdapter)quotezfile://)rqimagesrz.kanban notifier: image batch upload failed: %s)rq video_pathr)rq file_pathrz0kanban notifier: artifact upload (%s) failed: %s)rJrKrLlisttupleriextract_local_filesr rospathbasename expanduserisfileappendgateway.platforms.baserfilter_local_delivery_paths urllib.parserrsuffixlower _IMAGE_EXTSsend_multiple_imagesrMr rN _VIDEO_EXTS send_video send_document)r!adapterrqrrtask raw_paths prose_pathsrawitemrp staged_names candidatesrexpandedr_quote image_paths other_pathsbatchr[s&$$$$$ r_deliver_kanban_artifacts4GatewayKanbanWatchersMixin._deliver_kanban_artifactss " !# mT * *##K0C#e}--sLstjs6KddsLL #'' 2G'3''G::7CAFF  h = = 66s4;;7GHK KK6??Y((+Y ?XA0@0@0C<0WaaXX " D37rww))$/RHxH6277>>(;S;S!!(+ >(DDZP  0#-V*QQ0D0D0F+0Uqq* V",Z*QQ0D0D0Fk0Yqq* Z  V>IJkGF1I;/4kJ2275[c2ddd D ^:$$**, ;!,,WX`,aaa!//Zb/ccc  GM@X"WZKd VOQTUU V bc ^QSWY\]] ^s"A OM+M17O)A*O(M;O&M#,M#2>O5O="O$O O" O..M(!M('O-.M- M-& O1M95M2 M9$M7%M9)O/AN,1N(2N,6O8N,N*N,O2M99 N%N O N%%O(N,*N,, O7OOOOcV^8dQhRR/#)rrzOptional[tuple]r)rs"rrrs.-.-.-rc ^RIHp\ P PRR4P4P4pTR9d\P!R4R#T!4p\T\4'dTPR/4M/pTPR R 4'g\P!R 4R#^R I HpRTnTP!4R, R, p\#T4wrT R8Xd\P!RT4R#T R8XdYn\P!RT4M\P!RT4YT3# \d\P!R4R#i;i \d#p\P!RT4Rp?R#Rp?ii;i \d\P!R 4R#i;i)aResolve config, kanban_db and the singleton lock; None when the dispatcher must not run. Config is read once at boot (restart to apply), except the auto-decompose toggle which is re-read every tick. The env var is an escape hatch to disable without editing YAML. r;z6kanban dispatcher: config loader unavailable; disabledN!HERMES_KANBAN_DISPATCH_IN_GATEWAYrszEkanban dispatcher: disabled via HERMES_KANBAN_DISPATCH_IN_GATEWAY envz4kanban dispatcher: cannot load config (%s); disabledr=dispatch_in_gatewayTzGkanban dispatcher: disabled via config kanban.dispatch_in_gateway=falser@z@kanban dispatcher: kanban_db not importable; dispatcher disabledz.dispatcher.lock contendedzjkanban dispatcher: another gateway already holds the dispatcher lock (%s); this gateway will NOT dispatch.heldz9kanban dispatcher: holding singleton dispatcher lock (%s)zWkanban dispatcher: advisory lock unavailable at %s; proceeding on config control alone.>0noofffalse)rIr<rMr rNrenvironrLstriprrOrJrKrQrAr kanban_homer) r!rX env_overriderYr[rZr] _lock_path _lock_handle _lock_states & r_kanban_dispatcher_boot2GatewayKanbanWatchersMixin._kanban_dispatcher_boots  Ezz~~&I2NTTV\\^ 6 6 KK_ ` .C/9d.C.CSWWXr* ~~3T:: KKa b  3/3+__&14FF $;J$G! + % KKEFP R & 2> / KKSU_ ` NN67A C*,,K  NNS T   NNQSV W   NN] ^ s;E$FF6!FF F3F..F36!GGcV^8dQhRR/#r%r)rs"rrrsK/K/$K/rc "VP4pVfR#Vwr#p\WC4pVPp\P!^4GRjxL ^p^pRp \ W54p \ P!RV4VP'Ed^RI H p \V P4GRjxL p V 'd"\ P!R\V 4V 4\!4'g^pM\#T4wrT 'd\T P$T4GRjxL \T P&4GRjxL p \)T 4p\T P*4GRjxL pT'dT'g T^,M^p\-\.P.!44pT\08dYTT, R8dKX P3RT ;'g.44p\ P4!RTT'dR T R 2MR 4TpTP=T4GRjxL EKVP;4R#ELEL \d\ P!R4ELi;iELBEL(EL \P6d)\ P8!R 4TP;4h\d\ P!R 4Li;iL5i)uEmbedded kanban dispatcher — one tick every `dispatch_interval_seconds`. Gated by `kanban.dispatch_in_gateway` (default True); when false the loop exits and an external `hermes kanban daemon` is expected. Each tick runs :func:`kanban_db_dispatch.dispatch_once` in a thread; one tick's failure never stops the next. Shutdown: ``self._running`` is checked between ticks and the in-flight ``to_thread`` returns on its own. Nz7kanban dispatcher: embedded in gateway (interval=%.1fs))kanban_db_dispatchz6kanban dispatcher: reaped %d zombie worker(s), pids=%sz'kanban dispatcher: zombie reaper failedi,c3*"TF wrVxK R#5iNr).0_slugress& r HGatewayKanbanWatchersMixin._kanban_dispatcher_watcher..:s4[MZUSMszkanban dispatcher stuck: ready queue non-empty for %d consecutive ticks but 0 workers spawned.%s Check profile health (venv, PATH, credentials) and `hermes kanban list --status ready`.z Last tick held back: .rszkanban dispatcher: cancelledz+kanban dispatcher: unexpected watcher error)rrr-r3r4rr rOr2rQrr reap_worker_zombieslenrM exceptionrr auto_decompose_tick tick_oncerready_nonemptyr~rS_HEALTH_WINDOWdescribe_suppressionrNCancelledErrordebugr)r7)r!bootrXr]rZsettingsr- bad_ticks last_warn_atresults dispatcher_kbdpids _ad_enabled _ad_per_tick any_spawned ready_pendingnowrs& r_kanban_dispatcher_watcher5GatewayKanbanWatchersMixin._kanban_dispatcher_watchers]++- < (,% :/ @$$mmA   "&&s5  MxXmmm LB78P8PQQKK XZ]^bZceij P011 !I1QQ]0^-K"89W9WYefff$>z?S?S$TTG"4W"=K*DZE^E^*_$_M1>{ A XYI$))+&.33E3L444[GMMWYM4[NN?"t%;D6#CQS $'L++H5 5 5 ,,.u  R L  !JK LgT$_))  ;<446 P  !NO P 6sA K H1>K H7-H4. H7:!H7AI(II(:I";'I("I%# I(/I(7AI(%I(5I(K K K 4H77!IK IK I("I(%I((AK-KK KK )rrCrB)g@r)__name__ __module__ __qualname____firstlineno____doc__r"r)r7rcrzrrrrrr__static_attributes__rrrrr(sJIQ( =6~&T=v7^r.-`K/K/rr>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4.webm)r __future__rr3rrSpathlibrtypingrrgateway.kanban_watchers_commonrrrr r r r gateway.kanban_watchers_notifierr r"gateway.kanban_watchers_dispatcherrrrrrrUrrrrrrs`#  T 9 ? d/d/r