+ jHj~<a0t$Rt^RIHt^RIt^RIt^RIt^RIHt^RI H t ^RI t ^RI H t HtHt^RIHt^RIHtHtHt^RIHtR tR tR tREtRFtRRlt^ t]P>!R4t RGRRllt!RRlt"]#!4t$R]%R&RRlt&]#!4t'R]%R &R!R"lt(R#R$lt)R%R&lt*!R'R(4t+R)R*lt,R+R,lt-R-R.lt.R/t/R0R1lt0R2R3lt1R4R5lt2R6R7lt3R8R9lt4R:R;lt5R<R=lt6R ]1R R>R]5RR?R]6RR@R]2R]3R]4/ t7RA]%RB&!RCRD4t8R#)HaKanban notifier: claim terminal task events per subscription and deliver them. ``GatewayKanbanWatchersMixin._kanban_notifier_watcher`` owns the loop and the GC cadence; the per-tick claim (``_notifier_collect``) and the per-subscription delivery (``_KanbanNotification``) live here. ) annotationsN)partial)Path)AnyCallableOptional)t) _list_boards_to_thread_process_servicelogger)session_owned_by_profilec^RIHpV#)kanban_db_connect) hermes_clirrs E/home/ubuntu/.hermes/hermes-agent/gateway/kanban_watchers_notifier.py_kbcrs , c^RIHpV#)rkanban_db_notify)rrrs r_kbnrs + rc.^RIHpVP4#)u>Machine-flow board resolution: env pins outrank the enumerated slug. The slug here came from ``list_boards()``, not from a user — on a box whose env pins ``HERMES_KANBAN_DB`` every board must resolve to the pinned file or the notifier reads per-slug DBs nobody writes (see ``kanban_db.pin_first_board_resolution``). kanban_db)rrpin_first_board_resolutionrs r _pin_firstr"s%  / / 11r completedblockedgave_upcrashed timed_outstatusblock_loop_detectedreview_requestedchanges_requestedcV^8dQhRR/#returnbool)formats"r __annotate__r.5s]]D]rcVPR9dR#VPR9d)VP;'g/PR4R8g#VPR8H;'d)VP;'g/PR4R9#)zEInfrastructure attention is distinct from an explicit owner decision.Tkind needs_inputr#>r!r r">rr$>triager)r0payloadget)evs&rdiagnostic_eventr65su ww55 ww44   b%%f->> 77h  \ \BJJ$4$4"#9#9(#CG\#\\rzY(?z4kanban notifier: scope lookup failed for chat %s: %sT)exc_info)scope_idguild_id slack_team_idteam_id) r4 isinstancerMr;getattrcallable Exceptionr debug)rLrE delivery_metakeyr8resolverresolvedexcs&& r_wake_scope_idrb[sGG/0M-&&GC!%%c*Eu5z!Hw 3T:H H  C 2 8 8b9: %3x=.$.  KSWWU^M_adosts8B7 B77 C6)C11C6z set[tuple]_ANCHORLESS_WARNEDc$V^8dQhRRRRRR/#)r)rErMplatformr;r*Noner,)r-s"rr.r.ys!$#$rcDVPR4;'g/p\VPR44;'g.VPR4;'gVPR4R 9pV'dVPR4'dR#VPR4YPR4VPR4;'gR3pV\9dR#\PV4\P !R VPR4WPR44R#) uA thread-shaped subscription without ``parent_chat_id`` cannot match a channel-level ``profile_routes`` entry, so the fail-closed route gate skips it on every tick. Say so ONCE per row at WARNING — a subscription that can never deliver was invisible below DEBUG (#110919).rP thread_id chat_typeparent_chat_idNtask_idrRr>zkanban notifier: subscription for %s on %s thread %s has no parent_chat_id anchor and matched no profile route; it will not be delivered. Re-subscribe with `hermes kanban notify-subscribe ... --parent-chat-id [--guild-id ]`.>forumtopicthread forum_post forum-post)r4r+rcaddr warning)rEremetadata thread_liker^s&& r _warn_anchorless_thread_sub_onceruysww*+11rHsww{+,@@1E1b1bVaIbh@1@K (,,'788 779 x);SWW[=Q=W=WUW XC   3 NN B  Hggi&8 r_UNROUTABLE_WARNEDc ,V^8dQhRRRRRRRRRR /#) r)rErMrermessager; extra_argsr*rfr,)r-s"rr.r.s1 4 44 43 4 4SV 4[_ 4rc HVPR4YPR4VPR4;'gR3pV\9dR#\PV4\P!W PR4\ VRV4VPR4.VO5!R#)zA routed subscription the credential gate fail-closes is a permanent dead-end: delivery rewinds every tick with only a DEBUG line. Say so ONCE per row at WARNING, mirroring ``_warn_anchorless_thread_sub_once`` (#115460).rkrRrhr>Nr8)r4rvrqr rrrY)rErerxryr^s&&&* r_warn_unroutable_sub_oncer{s 779 x);SWW[=Q=W=WUW XC   3 NN7GGI.'80T779%4(24rc V^8dQhRRRR/#)r)mappingrr*zset[str]r,)r-s"rr.r.sWWSWXWrc tVUu0uF'p\VR\V44P4kK) up#uupi)zNLower-cased platform names of an adapters mapping (Platform enums or strings).r8)rYr;lower)r}res& r_platform_namesrs0NU Vg(GHgs8} 5 ; ; =g VV Vs-5c ,V^8dQhRRRRRRRRRR/#) r)runnerrrerErM owner_profilerNr*r,)r-s"rr.r.s1:;:;c:;S:;t:;Ta:;fi:;rc tVPW4p\VRR4p\VRR4'gV#VPPV4pVeWFJdV#T;'g\VRR4p\VRR4;'gVP 4pT;'gTp\VR/4;'g/PV4;'g/p \VR\ V44P 4\V 49dR#VPR 4;'g/p V PR 4;'gV PR 4p V PR 4p VPR 4VPR4;'gRrVPR4;'gRp\V4;'g.VPR4;'gV PR4R9p\VRR4;'g.EFpVPVPWWVR7'diVPV8wd'\W!RVVPVP4R#^RI HpV!V4UUu0uFwppVkK pppVV9dVu#Ru#TPVPT ;'g VPT Y;'gV'd VP MRT;'g VP"R7'gEKR# Wx8wd'\VRV4R8Xd\%WWV 4'dV#Wx8XdV#R#uuppi)zWResolve a durable route without turning a missing secondary bot into primary authority.configNmultiplex_profilesF_kanban_notifier_profile_primary_profile_name_profile_adaptersr8rPrTrUrjrRrhuser_idriprofile_routes)rUrRrhrjrzkanban notifier: subscription for %s on %s chat %s is stamped with profile %s but a profile_routes entry pins that chat to profile %s; it will not be delivered. Re-subscribe with `hermes kanban notify-subscribe ... --notifier-profile %s`.)_multiplex_profile_homes api_server>rlrmrnrorp)_authorization_adapterrYadaptersr4_active_profile_namer;rrr+matchesr8profiler{ gateway.runrrUrRrr )rrerErrLrprimaryrprimary_profile own_adaptersrsguildparentchatrnrrtroutername_homeserveds&&&& r_adapter_for_subscriptionrs++HDG VXt ,F 6/ 7 7oo!!(+Gw5PPwv/I4PGf&=tDeeHcHcHeO((G F$7<BBGGPVVTVLx#h-0668OL>B> ==%#)'  S S}}')dU]]EMM ;  <.Fv.NO.N{tUd.NFO%/7 9T 9 ==%2I2I5>>SW#):l:lVaU]]gk!(!9!9EMM  ; ;#?0!gh&Jl&Z($??07:d:Ps*L4cb]tRt^tRtRRltRRltRRltRR ltR R lt R R lt Rt R#) _CollectorzUOne tick's claim state: which profiles/platforms this gateway serves and the GC gate.c 0V^8dQhRRRRRRRRRR R R /#) r)rrkbnotifier_profilerNgc_duer+gc_retention_daysr:r*rfr,)r-s"rr._Collector.__annotate__sAKKsKK-KY]KruKz~Krc 6aSVnW nW0nW@nWPn.VnSP 4Vn\SR/4Vn V0Vn VPPRVP44\SRR4p\VRR4'd0VPPV3RlVP44\SP4P!RVPP!44!VnR#)rc3"TF?p\V4P4'gK$\V4P4xKA R#5iN)r;strip).0ps& r &_Collector.__init__..s2%f>SWZ[\W]WcWcWenc!fllnn>Ss !A !A rNrFc3<"TFKpVP'gKVP\SP49gK=VPxKM R#5ir)enabledrerrr)rrrs& rrrs?*+@%==%*^^v7W%W +@sA!AAc38"TFp\V4xK R#5ir)r)rms& rrrs I*HQoa  *Hs)rrrrr deliveries_owns_kanban_dispatcher_lockinclude_unownedrYprofile_adaptersnotifier_profilesupdaterrrunionvaluesactive_platforms)selfrrrrrrs&f&$$$ r__init___Collector.__init__s  0 !2&(%BBD '0CR H"2!3 %%%fd>S>S%ff40 6/ 7 7  " " ) )*+1+@+@* !0 @ F F I$*?*?*F*F*H I!KrcV^8dQhRR/#)r)r* list[dict]r,)r-s"rr.rsrc VP'g#\P!R4VP#VPp\ 4;_uu_4\ 4p\V4FpVPR4;'g VPpVPR4pV'd1\\V4P4P44M'\VPV4P44pWb9d\P!RWF4KVP!V4VP#V4K RRR4VP# \d RT 2pLki;i +'giTP#;i)z5kanban notifier: no connected adapters; skipping tickslugdb_pathzslug:z;kanban notifier: skipping duplicate board slug %s for DB %sN)rr r\rrrsetr r4 DEFAULT_BOARDr;r expanduserresolvekanban_db_pathr[rq collect_board)rr seen_db_paths board_metarrresolved_db_paths& rcollect_Collector.collectsG$$$ LLP Q?? " WW \\&)eM*2. !~~f-AA1A1A$..36T[s4=+C+C+E+M+M+O'Padegevevw{e|fEfEfGbH$$4LL!^`dw!!"23""4(/!6).tf~$6\s>0E2E2#E+AEAE2E/ ,E2.E/ /E22 F c V^8dQhRRRR/#)r)rr;r*r+r,)r-s"rr.rs  C D rc 0\4PWPVPR7pT^8Xd,\ P !RT\TP44T^8g# \d#p\ P !RY4Rp?R#Rp?ii;i)zCheap read-only probe before the writable connect() (schema init, WAL sidecars, checkpoints); a probe failure falls back to the writable open.)boardrrzekanban notifier: read-only subscription probe failed for board %s (%s); falling back to writable openNTzIkanban notifier: board %s has no subscriptions owned by %s; skipping open)rcount_notify_subsrrr[r r\sorted)rrcountras&& r_board_has_subs_Collector._board_has_subss F,,.D.DVZVjVj-lE A: LLdvd&<&<= ?z  LLLMQ X s/A(( B3BBc$V^8dQhRRRRRR/#)r)connrrr;r*rfr,)r-s"rr.r$s&aa3acadarc \4PWPR7pV'd%\P!RW2VP4R#R# \ d#p\P !RY$4Rp?R#Rp?ii;i)z`Best-effort stale-sub sweep: a failed sweep never blocks delivery; the next hourly gate retries.) max_age_daysz^kanban notifier: purged %d stale done/blocked-task subscription(s) on board %s (retention %dd)z5kanban notifier: stale-sub GC failed for board %s: %sN)rpurge_stale_done_notify_subsrr infor[r\)rrr_purged_gc_excs&&& r_gc_stale_subs_Collector._gc_stale_subs$sm af99$McMc9dG |#4+A+AC a LLPRV ` ` asAA BA<<Bc(V^8dQhRRRRRRRR/#) r)rrrr;rErMr*zOptional[dict]r,)r-s"rr.r.s.ww3wcwwwrc  VPR4;'gRpVPR4;'gRP4pWPP9d4\P!RVPR4T;'gR4R#^RIHp\VPV!V4Y4;'g VP4f\W54R#\4PYR,VR,VR ,VPR 4;'gR\R 7wrxp V 'gR#VPPWR,4p \P!R \!V 4VR,W'V4R VRVRVRV RV RV/#)zIClaim one subscription's unseen events; None when skipped or nothing new.rNrer>zIkanban notifier: subscription for %s on %s skipped; adapter not connectedrkz )PlatformrRrh)rkrerRrhkindsuFkanban notifier: claimed %d event(s) for %s on board %s cursor %s→%srE old_cursorcursoreventstaskr)r4rrr r\gateway.configrrrrrurclaim_unseen_events_for_subTERMINAL_KINDSrget_taskrG) rrrrErrerrrrrs &&&& r_claim_for_sub_Collector._claim_for_sub.sN 23;;t GGJ'--2446 00 0 LLd+X-D-D F+ $T[[(82DcKqKq\`\q\q r z ,S ;%)V%G%G i.3z?CPYNggk*00b&H& " Fww)n5 ][#i.$F LsL*hRXZ`bfhoquvvrc V^8dQhRRRR/#)r)rr;r*rfr,)r-s"rr.rEs#$rc VPV4'gR#\4PVR7pTP 'dTPY!4\4PY PTPR7pT'g\P !RT4TF7pTPY!T4pTeTPPT4K7K9 TP#4R# \d#p\P !RY4Rp?R#Rp?ii;i \d3p\P!RTP!R4Y4Rp?KRp?ii;i TP#4i;i)zFClaim events on one board, appending delivery dicts to ``deliveries``.Nrz)kanban notifier: cannot open board %s: %s)rrz.kanban notifier: board %s has no subscriptionsz;kanban notifier: subscription for %s on board %s failed: %srk)rrconnectr[r r\rrrlist_notify_subsrrrrappendrrr4close)rrrrasubsrEclaimedsub_excs&& rr_Collector.collect_boardEs5##D))  6>>>-D {{{##D/6**4CYCYkokk*AD MtTF"11$cBG*..w7+ JJL-  LLDd P  "!FNN#`#&779#5tFFF JJLsSC6E&A$E&-1D&E&6 D#DD#& E#1'EE&E##E&&E8) rrrrrrrrrrN) __name__ __module__ __qualname____firstlineno____doc__rrrrrr__static_attributes__r,rrrrs+_K.2 aw.rrc 0V^8dQhRRRRRRRRRR R R /#) r)rrrrrNrr+rr:r*rr,)r-s"rr.r.ds=  c s  X\ qt zD rc:\WW#VR7P4#)aClaim unseen terminal events for every owned subscription on every board. Each gateway polls only subscriptions owned by profiles whose adapters it hosts; legacy rows without a profile stamp are visible only to the process holding the singleton dispatcher lock. )rrr)rr)rrrrrs&&$$$r_notifier_collectrds! %5Xi  girc$V^8dQhRRRRRR/#)r)r5rr^r;r*r,)r-s"rr.r.ts&OOO3O3OrcVP'd=VPPV4'dVPPV4#R#)z)Shared "payload present and truthy" read.N)r3r4)r5r^s&&r_payloadrts4"$***1D1D2::>># N$Nrc ,V^8dQhRRRRRRRRRR/#) r)r5rr^r;msg_keyr9r:r*r,)r-s"rr.r.ys6AAcAAcA#A#Arc^\W4pV'd\V\V4RVR7#R#)zwCatalog message ``msg_key`` (``{value}`` placeholder) rendered with the truncated payload value, or ``""`` when absent.N)r8r>)rrr;)r5r^rr9r8s&&&& r_clipr ys- R E381WCJv. /@b@rz {}c$V^8dQhRRRRRR/#)r)textr;r9r:r*r,)r-s"rr.r.s!77c7#7#7rcpVP4P4pV'd V^,RV#VRV#)rN)r splitlines)r r9liness&& r _first_liners4 JJL # # %E$58FU 6$v,6rcV^8dQhRR/#r)r*tupler,)r-s"rr.r.s o oU orcXRp\VR4pV'd\\V4^4pMNVP'd=VPP'd!\VPP^4pVeRV 2MRp\ RVP VPVR7VR3#)Nsummary r>zgateway.kanban.ping.completedheadtitlehandoff)rrr;rresultrrr)r5n wake_handoffpayload_summaryrs&& r_fmt_completedrsLr9-O"3#7= AFFMMM"166==#6 %1%=<.!2G ,166RY Z\hjn nnrcV^8dQhRR/#rr,)r-s"rr.r.s v vE vrcRpRp\VR4pV'd$\V4pRVR, 2p\V^4p\RVPVP VR7VR3#)r>Nrr:NNz$gateway.kanban.ping.review_requestedr)rr;rrrr)r5rrrrs&& r_fmt_review_requestedr"sfGLr9%Gg,wt}o&"7C0 3!&&Y` acoqu uurcV^8dQhRR/#rr,)r-s"rr.r.s " "U "rcVP;'g/p\VPR44p\VPR4^04p\VPR4^04pT;'g \R4pV'd\RVR7MRpV'dV\RVR7, p\R VPVP WgR 7pVR V3#) rIreviewer implementerz*gateway.kanban.ping.changes_default_reasonz#gateway.kanban.ping.reviewer_suffix)r%r>z&gateway.kanban.ping.implementer_suffix)r&z%gateway.kanban.ping.changes_requested) board_tagrkrI provenanceN)r3rJr4rr'rk) r5rr3rIr%r& reason_textr(msgs && r_fmt_changes_requestedr+sjjBG X!6 7F"7;;z#:B?H%gkk-&@"EKKKAJKKPX88L^`Ja@kZZ 3kk199[ aC k !!rcV^8dQhRR/#rr,)r-s"rr.r.surc \VR4pVR8Hp\RVP\V'dRMR4\VRR^4\VRR ^4R 7pVR R 3#) aRe-blocked for the same cause past the limit and routed to `triage`. It emits no blocked/status event, so ping loudly here. A repeated-block circuit breaker establishes that orchestration attention is needed; it does NOT establish that a human decision or owner input exists. Use neutral orchestration wording unless the block was typed as a genuine owner-input request (`needs_input`, the only kind that carries a concrete question for the owner). r0r1zgateway.kanban.ping.triagez#gateway.kanban.ping.triage_decisionz$gateway.kanban.ping.triage_attention recurrencesz&gateway.kanban.ping.triage_recurrencesrI!gateway.kanban.ping.reason_suffix)rwhyr.rIN)rrrr )r5rr0decisionr*s&& r_fmt_block_loop_detectedr2sh B D}$H $166 x3Ek l"m-UWZ[R#FL  C d?rcV^8dQhRR/#rr,)r-s"rr.r.spp5prc\VR4pV'd\R\V4R7M \R4p\VRR^4p\RVPW4VP R7RR3#) failuresz"gateway.kanban.ping.failed_n_times)rz gateway.kanban.ping.kept_failingerrorzgateway.kanban.ping.last_errorzgateway.kanban.ping.gave_up)rrlastrkN)rrr:r rrk)r5rr5rr7s&& r _fmt_gave_upr8sfJ'HMUQ33x= I67 W> DD *uYZYbYb ceiko oorcV^8dQhRR/#rr,)r-s"rr.r.sRRURrc\\VR4;'g^4pV'd\^\V^<, 44M^pV'd\ RVR7M \ R4p\ RVP VR7RR3#) limit_secondsz!gateway.kanban.ping.limit_minutes)minutesz!gateway.kanban.ping.limit_genericzgateway.kanban.ping.timed_out)rspanN)r:rmaxroundrr)r5rr9r<r=s&& r_fmt_timed_outr@sg _-22 3E+0c!U52:&'aGFM1 0' BSTUxSyD ,166 EtT QQrc P\RVP\VRR^4R7RR3#)zgateway.kanban.ping.blockedrIr/)rrIN)rrr r5rs&&rrCs* 'affU2xQtvy=z{ drc6\RVPR7RR3#)zgateway.kanban.ping.crashed)rN)rrrBs&&rrCrCsa =AFFKTSWXrc`\RVP\VR4;'gRR7RR3#)zgateway.kanban.ping.statusr#r>)rr#N)rrrrBs&&rrCrCs.Q;!&&QYZ\^fQgQmQmkmnptvz{rz6dict[str, Callable[[Any, _KanbanNotification], tuple]]_EVENT_FORMATTERSc]tRtRtRtRRltRRltRRltR R ltR R lt R Rlt RRlt RRlt RRlt RRltRRltRtRRltRRltRRltR R!ltR"tR##)$_KanbanNotificationiaDeliver one subscription's claimed events, then settle the cursor. Both legs of notify+wake must succeed before settling. Sent pings have a separate durable checkpoint so wake retries do not resend them. Admission is at-least-once queueing, not an execution or final-response receipt. c ,V^8dQhRRRRRRRRRR/#) r)rrdrM platform_clssub_fail_countsr*rfr,)r-s"rr. _KanbanNotification.__annotate__s1%%s%t%c%TX%]a%rc WnW nW0nW@nVR,;VnpVR,;VnpVP R4VnVR,;'gRP4Vn VR,Vn VP R4;'gRVn V'd VPMVR,R,Vn VP'd\RVPR 7MRVnV'd*VP'd\R VPR 7MRp\R VPWpPR 7VnVR,VR,VR,VP R4;'gR3VnVP R4;'gRpVR9VnVR8gVnR;Vn;Vn;VnVnRVnRVnRVn\74VnR#)rErrrer>rkr:NxNzgateway.kanban.ping.board_tagrz gateway.kanban.ping.assignee_tag)assigneezgateway.kanban.ping.head)r' assignee_tagrkrRrh delivery_modenotifywakeNT)z notify+wakerT)rrJrKrLrErr4 board_slugr platform_strrk sub_profilerrr'rPrsub_key wake_agent send_passiverwake_review_detail session_keysynthplatrLis_push_adapterr wake_kinds) rrrJrKrLrErtagmodes &&&$$ rr_KanbanNotification.__init__s (.5!3V9$ D%%. _2299;9~ 77#56<<"$(djjc)ndC VZVeVeVe:$//RkmOSX\XeXeXea2T]]Kkm0DNNY\frfrs IJYQ\I]IcIcacd ww'338"99 FNWYXXD3Xd6F   #"urcV^8dQhRR/#r)r*rfr,)r-s"rr.rMs  d rc "\VPPVPVPR,VPP R^4VP 4GRjxL R#L5i)rrN)r r_kanban_rewindrErJr4rUrs&rrewind_KanbanNotification.rewindsP( KK & &$&&2BDFFJJ|]^D_aeapap   sA&A1(A/)A1cV^8dQhRR/#rer,)r-s"rr.rMssstsrc "\VPPVPVPR,VP 4GRjxL R#L5i)rN)r r_kanban_advancerErJrUrhs&radvance_KanbanNotification.advances;()D)DdhhPTPVPVW_P`bfbqbqrrrsA A AAcV^8dQhRR/#rer,)r-s"rr.rMs__T_rc "\VPPVPVP4GRjxL R#L5ir)r r _kanban_unsubrErUrhs&runsub_KanbanNotification.unsubs)()B)BDHHdoo^^^s9AAAcV^8dQhRR/#rer,)r-s"rr.rMs555rc RVPPVPR4R#r)rLpoprXrhs&rclear_failures"_KanbanNotification.clear_failuress   t4rc 0V^8dQhRRRRRRRRRR R R /#) r)fmtr;prefixrdrop_fmtrar[rSr+r*rfr,)r-s"rr.rM s9     e  s  QZ  fj  os  rc "VPPVP^4^,pW`PVP&\P!V.VOVN\ NVN5RV/V\ 8dW\P!W0P VPV4VP4GRjxL VP4R#VP4GRjxL R#L0L5i)zfBump the failure counter; drop the sub past the limit, else rewind the claim so the next tick retries.rSN) rLr4rXr rrMAX_SEND_FAILURESrkrVrsrxri)rr{r|r}rarSfailss&&&&&& rdelivery_failed#_KanbanNotification.delivery_failed s$$((q9A=-2T\\*sVVVUV,=VsVXV % % NN8\\43D3De L**,      !++-    s$B4C+6C'7)C+ C)!C+)C+c$V^8dQhRRRRRR/#)r)r{r;rar[r*rfr,)r-s"rr.rM,s&NNcN NdNrc b"RpVPWP3W2R4GRjxL R#L5i)zRkanban notifier: dropping subscription %s on %s after %d consecutive wake failuresTN)rrk)rr{rar}s&&& r _wake_failed _KanbanNotification._wake_failed,s(g""3MMMs $/-/c V^8dQhRRRR/#)r)r5rr*rNr,)r-s"rr.rM2s  s } rc \PVP4pVfR#V!W4wr4pVeW@nVeWPnV#)uORender one event; accumulates wake handoff/review detail. None → silent kind.N)rFr4r0rr[)rr5 formatterr*r review_details&& r format_event _KanbanNotification.format_event2sK%))"''2  &/&9#m   '   $&3 # rcV^8dQhRR/#rer,)r-s"rr.rM>sHHHrc  aSPSPr!SP'dDSPR,Uu0uF%q3P\ 9gKVPkK' upM \ 4Sn\;QJd0V3RlSPR,4F 'dK RM% RM!!V3RlSPR,44Sn SP'gR#SP'd\VRR4;'gRSn M-VR,;'g\VRR4;'gRSn \ Uu.uF#qDSP9gK\R V 24NK% pp\R 4PV4;'g \R 4p\R VR ,TSPV'd VP MRSP"R7pSP$'d&VR\RSP$R7,, pSP&'d&VR\RSP&R7,, pVR,\R4,SnR#uupiuupi)zDSet ``wake_kinds`` / ``session_key`` / ``synth`` for the wake paths.rc3r<"TF,qPSP9gK\V4xK. R#5ir)r0r`r6)rr5rs& rr6_KanbanNotification.build_wake_text..Bs1"qBRBV]V]aeapapVp#7#3B#7#7BRs77FTN session_idr>rRzgateway.kanban.wake.z!gateway.kanban.wake.status_joinerz"gateway.kanban.wake.status_defaultzgateway.kanban.wake.messagerk)rkr#rrPrrzgateway.kanban.wake.handoff)rz!gateway.kanban.wake.review_detail)rIz zgateway.kanban.wake.guidance)rrErYrJr0 _WAKE_KINDSrr`allwake_diagnosticr_rYr\rrCrrPrUrr[r])rrrEr5k_parts_statusr]sf rbuild_wake_text#_KanbanNotification.build_wake_text>sIItxxc\`\k\k\kTVVH-=X-=rKAW7277-=Xqtqv"s"q$&&BR"qsss"q$&&BR"qq     &t\4@FFBD  #9~XX|T1RXXVXD 9D]AT__H\/!*1#./]78==fEppKoIp ) N7$**&*T]]$//      TA;TEVEVWW WE  " " " TAA$JaJabb bEV^a(F&GG 3Y^sI<I<J-JcV^8dQhRR/#rer,)r-s"rr.rM\szz4zrc \P!RVPVPVPR,VP ;'gRVP 4R#)z@kanban notifier: woke agent for %s on %s/%s profile=%s events=%srRdefaultN)r rrkrVrErWr`rhs&r _log_woke_KanbanNotification._log_woke\sF VLL$"3"3TXXi5H$JZJZJgJg^gimixix zrcV^8dQhRR/#)r)r*rNr,)r-s"rr.rM`s   m  rc VP'gR#\\VPRR4RR4'gR#VP#)zThe subscription's profile when THIS gateway is a multiplexer serving it, else ``None``. ``None`` keeps the historical path: a standalone ``hermes -p `` gateway owns its own listener and key, so its api_server wakes keep using the HTTP self-post. NrrF)rWrYrrhs&r_served_wake_profile(_KanbanNotification._served_wake_profile`s@ wt{{Hd;=QSXYYrc VPpVP4pV'g\P!4#^RIHp^RIHpV!VPVPR,VR7pV!VPV44#)zRRuntime scope of the subscription's profile under multiplex, else a no-op context._async_profile_runtime_scope SessionSourcerR)rerRr) rr contextlib nullcontextrrgateway.sessionrr^rE _resolve_profile_home_for_source)rrserved_profilerrsources& r _owner_scope _KanbanNotification._owner_scopelsd224))+ +<1 488I;NXfg+F,S,STZ,[\\rcV^8dQhRR/#rer,)r-s"rr.rMws**D*rc "^RIHpVPpVP'gVP 4;_uu_4GRjxL T!VP VP VPVP4VP'dRMRR7GRjxL RRR4GRjxL VP4R#^RI H pVPR4;'g/p\VPR4;'gVPR4;'gR 4P4pT!VP VR ,T;'gR VPR 4;'gRVPR 4VPR4VP";'gR\%VP V4VPR4R7 p\&P(!VP 4Vn^RIHpVP"'da\1\1VP2RR4RR4'd9^RIHpV!VP"4'g\9RVP": R24hV!VP2P;V44;_uu_4GRjxL T!VP VP VPTVP'dRMRR7GRjxL RRR4GRjxL VP4R#ELELhEL[ +GRjxL 'giELs;iLLNL@ +GRjxL 'giLW;i5i)zoWake the creator session (raises on failure): push adapters get a full SessionSource, non-push a raw self-post.) deliver_wakeN diagnosticr)r rrnotification_categoryrrPrir>rRgrouprhr user_id_altrj) rerRrirhrrrrTrjrrrF)profile_existszKanban wake profile z no longer exists)r rrr) gateway.wakerrEr_rrLr]r\rrrrrr4r;rr^rWrbweakrefref_transport_adapter_refrrrYrhermes_cli.profilesr RuntimeErrorr) rrrEr_delivery_meta _chat_type_sourcerrs & rrT_KanbanNotification.wakewsz-hh### ((***"4<?   *1T\\)B&<     Xt(LNbdi j j :!$"2"233"%9$:J:J9MM^#_``/ 0\0\]d0effft||$**IYIYbiEIEYEYEY\_gi i igf C+m+***<g igfffsAMK=MALLL M(L)3MM=M2M M#4MB/MAML#MAL)L%L) M&L''MLML L L L  M%L)'M)M /L20 M ;M =Mc$V^8dQhRRRRRR/#)r)r5rr*r;r*r+r,)r-s"rr.rMs!""C"c"d"rc aaaa a "^RIHpVPVPuo oS P R4p\ V\ 4'd \ V4M/o S P R4'd$S P R4'g S R,S R&RoVVV VV 3RlpV!WPP\V4R7GRjxL 'gR#\SRR 4RJd$\R \SR R4;'gR 24h\P!R VPVPVPS R,VP4VPR9dHVP P#SS R,S \VRR4VP$R7GRjxL R #R #LL \&d.p\P!RTPT4Rp?R #Rp?ii;i5i)zMSend one text ping; raises on adapter exception or SendResult(success=False).)present_notificationrPrhNcZ<"SPSR,SSR7GRjxL oR#L5i)rR)rsN)send) _send_resrLrsr*rEsr send_ping2_KanbanNotification._send_event..send_pings$%ll3y>3lRRIRs +)+)rerFsuccessTz!adapter send() reported failure: r6z unknown errorz?kanban notifier: delivered %s event for %s to %s/%s on board %srRr3)rLrRrs event_payloadrz4kanban notifier: artifact delivery for %s failed: %s)rr%)gateway.warning_notificationsrrErLr4rXrMrVr6rYrr r\r0rkrUr_deliver_kanban_artifactsrr[) rr5r*rrPrart_excrrLrsrEs &&f @@@@r _send_event_KanbanNotification._send_eventsFxx WGG$78>HIZ\`>a>a4(9#:gi 77;   [(A(A$' $4H[ !  S S*)>O>O\lmo\pqqq 9i .% 7!B79V]_cCdCwCwhwBxyz z VWWdllD,=,=s9~t ` 777 7 lkk;;#S^h")"i">TYY< -r  l SUYUaUacjkk lsgA*G%2G% 8G%F& G% ,G%9A$G%?F*F(F*"G%(F** G"5"GG%G""G%cV^8dQhRR/#r(r,)r-s"rr.rMs##4#rc D"VPR,EF1pVPV4pVfKVP'gAVP'd/\P !RVP VP4KmVP'gKVPVPPR^48:dKVPW4GRjxL RJdK\\VPP VP"RVPVPR74GRjxL VP%4EK4 R #LtL \&dApTP)RTPTP 3R TR4GRjxL Rp?R#Rp?ii;i5i) zOSend every text ping; False when a send failed (claim already rewound/dropped).rNzmkanban notifier: adapter %s has no push channel; skipping text ping for %s, relying on wake self-post insteadlast_ping_event_idFrecord_notify_ping)event_idz=kanban notifier: send failed for %s on %s (attempt %d/%d): %szRkanban notifier: dropping subscription %s on %s after %d consecutive send failuresT)rJrr_rYr r\rVrkrZidrEr4rr rr_kanban_sub_oprUrxr[r)rr5r*ras& r _send_pings_KanbanNotification._send_pingssf&&""B##B'C{ '''DOOO 0151B1BDLL$$$uu %91== ))"22e;0KK..AUW[W_W_UU2##%5#B3  **SVZVbVbdhduduUvhjmot  sAF F ?F /F EEE"F $AE2E3EF EE F.F F FF FF cV^8dQhRR/#rer,)r-s"rr.rMsIItIrc \"VPVP4Vn\ P !\TPTPTPTP;'gR4GRjxL pTfG\P!RTPTP4TP4GRjxL R#Yn^RIHpT!T4TnTP'4;_uu_4GRjxL TP)4GRjxL 'gRRR4GRjxL R#TP*R,p^RIHpT!TP4'*pT'gT.MITUu.uFp\1T4'gKTNK upTUu.uFp\1T4'dKTNK up.p.pTFp T 'gK /TP*CRT /CTnR;TnTnT FpTP7T4K TP94TP:'gKpTP=TP>TP@TP:34K /TP*CRT/CTnRRR4GRjxL TP$p ^RIH!p X'dFTF.wTnTn TnTPE4GRjxL K0 TPG4TP 4GRjxL T 'gTPG4TPL'd8TPLPNR 8XdTPQ4GRjxL R#R#R# \dTP 4GRjxL R#i;iELELELELELnuupiuupiEL# +GRjxL 'giEL;;iL T dTP4GRjxL R#\Hd1p TPKT 'dRMRT 4GRjxL Rp ? R#Rp ? ii;iEL.L5i) NzPkanban notifier: adapter %s disconnected before delivery for %s; rewinding claim)adapter_supports_pushr)warning_notifications_enabledr>)WakeNotAcceptedzEkanban notifier: wake-only delivery failed for %s (attempt %d/%d): %szAkanban notifier: wake self-post failed for %s (attempt %d/%d): %sarchived))rKrVr^ ValueErrorrnasyncio to_threadrrrErWr r\rkrirLrrr_rrrJrrr6rr[rrr`rr]rrrTrxr[rrr#rs) rrLroriginal_eventsrrFr5 wake_groups wake_payloadsris_pushr_wk_errs & rdeliver_KanbanNotification.deliversS ))$*;*;@@!D$; B%%b)!$$&???!(($**d6J6JDOO)\]&;:/:DF-'&.&&0  IVEDJ 4do))+%%JW##%lln    ! 999))Z7**,  89K ,,.   c '+'GJ'&&&<&" kkm## ''_f[\     sP, M!AP,- P,7N 8AP,?N;P,;N<P,?N(N N(N( P,*N+P,17N()N(0NNN(N ,N 2A3N(*A N(7 P,N%P,"+O OO&P,9P': P,!P,(.P,P* P,!N ?NN P,N  P,P,P,N(P, N(%P,(O .N1/ O :O < P,OP$!O$"P$'P,*P$3P$4PPPP,P$$P,*P,)rLrUr'rJrr_r^rKrVrrZr\rErLrXrWr]rrkrrYrrr`r[N)rrrrrrrirnrsrxrrrrrrrrTrrrrr,rrrHrHsg%> s_5  N H<z   ]*X"H#JIIrrH) rrr r!r"r#r unblockedr$r%r&)rr r!r"rr%r&r$))9__conditional_annotations__r __future__rrrre functoolsrpathlibrrtypingrrr agent.i18nrgateway.kanban_watchers_commonr r r rr rrrrrr6rcompilerDrJrbrrc__annotations__rurvr{rrrrrr _NLrrr"r+r2r8r@rFrH)rs@rrsP# **[[1  2pJ ],|}/6"%J&*"%J& 4W :;@D  O A 7 o v "*pR | X {-/3 MI &JJr