oq'j3dZddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z ej dZGddZdS) uKanban board watcher methods for GatewayRunner. Extracted verbatim from ``gateway/run.py`` (god-file decomposition Phase 3). These are the background-loop methods that subscribe to kanban boards, deliver notifications/artifacts, and drive the multi-agent dispatcher. They use only ``self`` state, so they live on a mixin that ``GatewayRunner`` inherits — the ``self._kanban_*`` call sites resolve identically via the MRO, making this a behavior-neutral move that lifts ~1,000 LOC out of run.py. ) annotationsNPath)AnyOptionalz gateway.runcNeZdZdZdddZ dddZdddZ dd dZd!dZd"dZ dS)#GatewayKanbanWatchersMixinz?Kanban watcher / notifier / dispatcher loops for GatewayRunner.@intervalfloatreturnNonec '()K ddlm}n+#t$rtdYdSwxYwt jdd }|dvrt ddS |}n3#t$r&}td |Yd}~dSd}~wwxYwt|tr|d ini}|d d st d dSddl m} ddlm(n+#t$rtdYdSwxYwd'd}t#di} | _t#dd))s))_t+jdd{Vjr '()fd} t+j| d{V} | D]} | d} | d}| d}| dpd } ||}n8#t2$r+t+jj| | d|d{VYwxYwj|}|atd|| dt+jj| | d| dd|d{V|r|jn| ddd}| d D]v}|j}|r|j r|j nd}|rd!|d"nd}|d#krd}d}|j!r4|j!d$rtE|j!d$}|rH|#}|r|ddd%n |dd%}d&|}nZ|rX|j$rQ|j$#}|r|ddd'n|j$dd'}d&|}d(|d)| dd*||}n.|d+krZd}|j!r?|j!d,r%d-tE|j!d,dd'}d.|d)| dd/|}n|d0krZd}|j!r?|j!d1r%d&tE|j!d1dd%}d2|d)| dd3|}nn|d4krd2|d)| dd5}nX|d6krPd} |j!r4|j!d7rtK|j!d7} d8|d)| dd9| d:}nRi}!| d;r | d;|!d;<| d| d| d<| d;pdf}" |&| d<||!=d{Vtd>|| d|| d<||d#krp '|| d<|!t#|d?d|@d{Vn9#t$r,}#tdA| d|#Yd}#~#nd}#~#wwxYw| (|"d#t$r}| |"ddBz}$|$| |"<tdC| d||$|||$|kr[tdD| d||$t+jj)| |d{V| (|"dn=t+jj| | d| dd|d{VYd}~n^d}~wwxYwt+jj| | d|d{V|o|j*dEv}%|%r!t+jj)| |d{Vn2#t$r%}tdF|Yd}~nd}~wwxYwtWtKtYdB|D]&}&jsdSt+jdBd{V'jdSdS)GuPoll ``kanban_notify_subs`` and deliver terminal events to users. For each subscription row, fetches ``task_events`` newer than the stored cursor with kind in the terminal set (``completed``, ``blocked``, ``gave_up``, ``crashed``, ``timed_out``). Sends one message per new event to ``(platform, chat_id, thread_id)``, then advances the cursor. When a task reaches a terminal state (``completed`` / ``archived``), the subscription is removed. Runs in the gateway event loop; all SQLite work is pushed to a thread via ``asyncio.to_thread`` so the loop never blocks on the WAL lock. Failures in one tick don't stop subsequent ticks. **Multi-board:** iterates every board discovered on disk per tick. Subscriptions live inside each board's own DB and cannot cross boards, so delivery semantics are unchanged — this is purely a fan-out of the single-DB poll. r load_configz4kanban notifier: config loader unavailable; disabledN!HERMES_KANBAN_DISPATCH_IN_GATEWAY>0noofffalsezCkanban notifier: disabled via HERMES_KANBAN_DISPATCH_IN_GATEWAY envz2kanban notifier: cannot load config (%s); disabledkanbandispatch_in_gatewayTzEkanban notifier: disabled via config kanban.dispatch_in_gateway=false)Platform kanban_dbzzXGatewayKanbanWatchersMixin._kanban_notifier_watcher.._collect..qsF((($ '3x==AAGGII(((z5kanban notifier: no connected adapters; skipping tickFinclude_archivedslugdb_pathzslug:z;kanban notifier: skipping duplicate board slug %s for DB %sboardz)kanban notifier: cannot open board %s: %sz.kanban notifier: board %s has no subscriptionsnotifier_profilezUkanban notifier: subscription for %s owned by profile %s; current profile %s skippingtask_idr-rzIkanban notifier: subscription for %s on %s skipped; adapter not connectedz chat_id thread_id)r8r-r9r:kindsuFkanban notifier: claimed %d event(s) for %s on board %s cursor %s→%s)sub old_cursorcursoreventstaskr6)adapterskeysloggerdebug list_boards Exceptionread_board_metadata DEFAULT_BOARDsetgetr*r expanduserresolvekanban_db_pathaddconnectlist_notify_subsr+claim_unseen_events_for_subget_tasklenappendclose) deliveriesactive_platformsboards seen_db_paths board_metar3r4resolved_db_pathconnexcsubsr< owner_profiler-r=r>r?r@TERMINAL_KINDS_kbr7selfs r._collectzEGatewayKanbanWatchersMixin._kanban_notifier_watcher.._collectos_-/J(((, (:(:(<(<((($,* %\]]]))N!$%!H!H$NNN"%"9"9#:K"L"L!MN.1eeM&,J)J) )~~f55J9J",..";";>\c0Qs4==3K3K3M3M3U3U3W3W/X/X/XilmpmmAEnFnFnNnNnPnPjQjQ,,(>>>/=t~~,,,>+}<<"LL ] $&6%%))*:;;;%#&;;T;#:#:DD(%%%"LL)TVZ\_```$HHHH%7)$'#7#7#=#=D#'e & -]_c d d d'+%#%#038J0K0K0St #0!-]FV5V5V$*LL((+ (:(:MK[%&%&%&%-,/GGJ,?,?,E2+L+L+N+N#+3C#C#C$*LL(s(+ (:(:H]>">" : FF(.!-$,'*||D#i.'I'I & $l$'KKYzSY!"!"!"!+ 1 1+.2<.4.4,0-1 3"3"!#!#!#!#=%#N!JJLLLLDJJLLLL%%sJA%BB A6EEEF'' G1GGFNN$r<r@r6r-r>zPkanban notifier: adapter %s disconnected before delivery for %s; rewinding claimr8r=xr?@ rsummary u✔ zKanban u done — rreasonz: u⏸ z blockedrerroru✖ z& gave up after repeated spawn failuresr z1 worker crashed (pid gone); dispatcher will retryr! limit_secondsu⏱ z timed out (max_runtime=zs); will retryr:r9)metadataz?kanban notifier: delivered %s event for %s to %s/%s on board %spayload)adapterr9rn event_payloadr@z4kanban notifier: artifact delivery for %s failed: %sz=kanban notifier: send failed for %s on %s (attempt %d/%d): %szRkanban notifier: dropping subscription %s on %s after %d consecutive send failures>donearchivedzkanban notifier tick failed: %s)-hermes_cli.configrrFrCwarningosenvironrJstripr+info isinstancedictgateway.configr hermes_clirr)r#_active_profile_namer$asynciosleep_running to_thread ValueError_kanban_advancerArD_kanban_rewindtitlekindassigneeror* splitlinesresultintsend_deliver_kanban_artifactspop _kanban_unsubstatusrangemax)*rbr _load_config env_overridecfgr] kanban_cfg _PlatformMAX_SEND_FAILURESsub_fail_countsrcrVdr<r@ board_slug platform_strplatrprevrwhotaghandoffpayload_summarylineshrmsgrkerrlimitrnsub_keyart_excfails task_terminal_r`rar7s*` @@@r._kanban_notifier_watcherz3GatewayKanbanWatchersMixin._kanban_notifier_watchers .  E E E E E E E    NNQ R R R FF z~~&I2NNTTVV\\^^ 6 6 6 KK] ^ ^ ^ F ,..CC    NNOQT U U U FFFFF /9d.C.CKSWWXr*** ~~3T::  KKW    F888888  3 3 3 3 3 3 3    NNY Z Z Z FF U",3 +R- - (7$"4)CTJJ =#88:: ,#>>>>>>> #mmAE(CV9D!"wJ$' O$9r#@#@#B#BL!(y66%!!!&/ 0#q{J! !#m//55G n(#i.&/ /hKEE,22& !+/CTZZS^TcTJEkPP!w15PPt}}D,/7j#jjjjR;.. ')G.2O!zMbjnnY.G.GM25bj6K2L2L.3(7(=(=(?(?(J(J(L(L6;$VE!HTcTNNQURUQUAV*2q((!%3$+3(, (9(9(;(;(F(F(H(H6;$RE!HTcTNNTcTAR*2q((!9s!9!93y>!9!9(-!9/6!9!9 C"Y..%'F!zPbjnnX.F.FP)Oc"*X2F.G.G.M)O)O"U"U"US^"U"UV"U"UCC!Y.."$C!zLbjnnW.E.EL&K3rz'/B+C+CDSD+I&K&K!Fs!F!F3y>!F!F@C!F!F C"Y..!Es!E!E3y>!E!E!E C"[00$%E!zIbjnn_.M.MI(+BJ,G(H(H!Fs!F!F3y>!F!F05!F!F!F C %3577;//E47 4DH[1 NC O NCGGK,@,@,FB#=""),, #Ih#/###LL a $c)nlC NT^ ${22 !&*.*H*H0703I196=b)T6R6R-1 +I+&+&%&%&%&%&%&%&%&%&(1!&!&!&$*LL(^(+I%&%&%&%&%&%&%&%&!& ,//>>>>("""$3$7$7$C$Ca$GE7 I_>2J  _> J  M_>AZ,%5YZ, Z%"Z Z, ZZ,*_>, ^"6C!^_>^""A_>> `-`((`-Nr<r|r>rr6 Optional[str]c ddlm}||} |||d|d|d|dpd| |d S#|wxYw) zSync helper: advance a subscription's cursor. Runs in to_thread. ``board`` scopes the DB connection to the board that owns this subscription. Unsub cursors in one board can't touch another's. rrr5r8r-r9r:r)r8r-r9r: new_cursorN)r~rrOadvance_notify_cursorrJrU)rbr<r>r6rar\s r.rz*GatewayKanbanWatchersMixin._kanban_advances 0/////{{{''   % %IZI''+..4"! &    JJLLLLLDJJLLLLs AA66B c ddlm}||} |||d|d|d|dpd |dS#|wxYw) Nrrr5r8r-r9r:r)r8r-r9r:)r~rrOremove_notify_subrJrU)rbr<r6rar\s r.rz(GatewayKanbanWatchersMixin._kanban_unsubs//////{{{''   ! !IZI''+..4" "    JJLLLLLDJJLLLLs AA55B claimed_cursorr=c  ddlm}||} |||d|d|d|dpd|| |d S#|wxYw) zCSync helper: undo a claimed notification cursor after send failure.rrr5r8r-r9r:r)r8r-r9r:rr=N)r~rrOrewind_notify_cursorrJrU)rbr<rr=r6rar\s r.rz)GatewayKanbanWatchersMixin._kanban_rewinds 0/////{{{''   $ $IZI''+..4"-% %    JJLLLLLDJJLLLLs AA77B r9r*rnrqOptional[dict]cKddlmgtdfd }t|tr|d}t|t tfr%|D]"}t|tr ||#|d } t| tr*| r(| | \} } | D] } || |Mt|d d r._adds| w))$//H47>>(++  HHX      h ' ' ' ' 'r0 artifactsrgNr)BasePlatformAdapter>.gif.jpg.png.jpeg.webp>.3gp.avi.mkv.mov.mp4.webm)quotec\g|](}|jv&|)Ssuffixr+r,p _IMAGE_EXTS_Paths r. zHGatewayKanbanWatchersMixin._deliver_kanban_artifacts..s9WWWQa0E0E0G0G;0V0Vq0V0V0Vr0c\g|](}|jv&|)Srrrs r.rzHGatewayKanbanWatchersMixin._deliver_kanban_artifacts..s9[[[Qa0E0E0G0G{0Z0Zq0Z0Z0Zr0c0g|]}d|dfS)zfile://rr)r,r_quotes r.rzHGatewayKanbanWatchersMixin._deliver_kanban_artifacts..s/JJJ/FF1II//4JJJr0)r9imagesrnz.kanban notifier: image batch upload failed: %s)r9 video_pathrn)r9 file_pathrnz0kanban notifier: artifact upload (%s) failed: %s)rr*r r)pathlibrrIr{r|rJlisttupler*extract_local_filesr)rgateway.platforms.baserfilter_local_delivery_paths urllib.parsersend_multiple_imagesrFrCrvrr+ send_video send_document)rbrpr9rnrqr@rrawitemrgpathsrr result_textr _VIDEO_EXTS image_paths other_pathsbatchr]rextrrrrrs @@@@@r.rz4GatewayKanbanWatchersMixin._deliver_kanban_artifactss 2 *))))) "  ( ( ( ( ( ( ( mT * * ##K00C#e}-- ###D!$,,#T $'' 22G'3'' G "66w??qADGGGG  h = = dk**K22;??HE1  Q  F>>>>>>(DDZPP   F@@@ GGG 000000XWWWW*WWW [[[[[*[[[   JJJJkJJJ22#EH3   Dc     D%++$**,,C +%%!,, 'D8-"// '4(0   F#   s1,F22 G!<GG! AI  I=I88I=cZ !"#$%&K ddlm}n+#t$rtdYdSwxYwt jdd }|dvrt ddS |}n3#t$r&}td |Yd}~dSd}~wwxYwt|tr|d ini}|d d st d dS ddl mn+#t$rtdYdSwxYw t|ddpd}nG#t t"f$r3td|dd}YnwxYwt%|d}|dd%%t d%|dd}d#| t'|##dkrtd|d#nRt d#n4#t"t f$r td|d#YnwxYw|dj} t'|"n?#t"t f$r+td|jj"YnwxYw"dkr(td|jj"|dd} t'| pd&n4#t"t f$r td | d&YnwxYw|d!pdpd rt d" |d#d} d$| t'| $$dkrtd$| d$nPt d%$n4#t"t f$r td&| d$YnwxYwt+jd'd{Vd(} d} d} d)i!dHfd. dIfd2 dJ !"#$%&f d4 dKfd6 }dLfd7 }t/|d8d } t'|d9d:pd:n#t"t f$rd:YnwxYwdkrddMfd< }t d=||jr t+jjd{V}|r)t d>t7||n*#t$rtd?YnwxYw |rt+j|d{Vt+j|d{V}d@}|pgD]\}}|t;|dAdrd }t dB|t7|j|jtA|j!dCrt7|j!ndtA|j"dCrt7|j"nd|j#tA|j$dCrt7|j$ndt+j|d{V}|r|s| dz } nd} | | krFt'tKj%}|| z d)krtdD| |} nS#t*j&$rt'dEt$rtdFYnwxYwdG}||krD|jr=t+jtQd||z d{V|dz }||kr|j=|jdSdS)NuEmbedded kanban dispatcher — one tick every `dispatch_interval_seconds`. Gated by `kanban.dispatch_in_gateway` in config.yaml (default True). When true, the gateway hosts the single dispatcher for this profile: no separate `hermes kanban daemon` process needed. When false, the loop exits immediately and an external daemon is expected. Each tick calls :func:`kanban_db.dispatch_once` inside ``asyncio.to_thread`` so the SQLite WAL lock never blocks the event loop. Failures in one tick don't stop subsequent ticks — same pattern as `_kanban_notifier_watcher`. Shutdown: the loop checks ``self._running`` between ticks; gateway stop() flips it to False and cancels pending tasks, and the in-flight ``to_thread`` returns on its own after the current ``dispatch_once`` call finishes (typically <1ms on an idle board). rrz6kanban dispatcher: config loader unavailable; disabledNrr>rrrrzEkanban dispatcher: disabled via HERMES_KANBAN_DISPATCH_IN_GATEWAY envz4kanban dispatcher: cannot load config (%s); disabledrrTzGkanban dispatcher: disabled via config kanban.dispatch_in_gateway=falserz@kanban dispatcher: kanban_db not importable; dispatcher disableddispatch_interval_seconds<zIkanban dispatcher: invalid dispatch_interval_seconds=%r, using default 60gN@g? max_spawnzkanban dispatcher: max_spawn=max_in_progressrrzAkanban dispatcher: kanban.max_in_progress=%r is below 1; ignoringz#kanban dispatcher: max_in_progress=z>kanban dispatcher: invalid kanban.max_in_progress=%r; ignoring failure_limitzDkanban dispatcher: invalid kanban.failure_limit=%r; using default %dzGkanban dispatcher: kanban.failure_limit=%r is below 1; using default %ddispatch_stale_timeout_secondsz^kanban dispatcher: invalid kanban.dispatch_stale_timeout_seconds=%r; disabling stale detectiondefault_assigneezZkanban dispatcher: default_assignee=%r (unassigned ready tasks will route to this profile)max_in_progress_per_profilezMkanban dispatcher: kanban.max_in_progress_per_profile=%r is below 1; ignoringz1kanban dispatcher: max_in_progress_per_profile=%dzJkanban dispatcher: invalid kanban.max_in_progress_per_profile=%r; ignoringr%i,r3r*r "tuple[str, int | None, int | None]cJ|} t|}n#t$rt|}YnwxYw |}n#t $r|ddfcYSwxYw||j|jfSr) rMr*rKrLrFstatOSError st_mtime_nsst_size)r3rresolvedrras r._board_db_fingerprintzTGatewayKanbanWatchersMixin._kanban_dispatcher_watcher.._board_db_fingerprints%%d++D %t0088::;; % % %t99 % .yy{{ . . . $---- .d. = =s#3A A('A(,BBBr]rFboolctdd}|t||rdSt|tjsdSt |}d|vpd|vS)NKanbanDbCorruptErrorTFzfile is not a databasez database disk image is malformed)r)r{sqlite3 DatabaseErrorr*r+)r]corrupt_guard_errorrras r._is_corrupt_board_db_errorzYGatewayKanbanWatchersMixin._kanban_dispatcher_watcher.._is_corrupt_board_db_errorsz")#/Et"L"L ".:cCV3W3W.tc7#899 uc((..""C(C/=5< r0'Optional[object]'c  d} |} |}|}|\}}tj|z }||kr|krdS||krtd||ntd| |d |} || |& |S#t$rYSwxYwS#tj $r} |rj|tjf |<t d||dYd}~|( |dS#t$rYdSwxYwdSt d|Yd}~|( |dS#t$rYdSwxYwdSd}~wt$r} |rj|tjf |<t d||dYd}~|( |dS#t$rYdSwxYwdSt d|Yd}~|( |dS#t$rYdSwxYwdSd}~wwxYw#|& |w#t$rYwwxYwwxYw) aRun one dispatch_once for a specific board. Runs in a worker thread via `asyncio.to_thread`. `board=slug` is passed through `dispatch_once` so `resolve_workspace` and `_default_spawn` see the right paths. The per-board DB is opened explicitly so concurrent boards never share a connection handle or accidentally claim across each other. Nzdkanban dispatcher: board %s database fingerprint unchanged after %.0fs quarantine; retrying dispatchz?kanban dispatcher: board %s database changed; retrying dispatchr5)r6rrrstale_timeout_secondsrra kanban dispatcher: board %s database %s is not a valid SQLite database; pausing dispatch for this board until the file changes, the gateway restarts, or the quarantine timer expires. Move or restore the file, then run `hermes kanban init` if you need a fresh board.rz*kanban dispatcher: tick failed on board %s)rJtime monotonicrCrzrrO dispatch_oncerUrFrr rl exception)r3r\ fingerprintdisabled_entrydisabled_fingerprint disabled_atager]!CORRUPT_BOARD_RETRY_AFTER_SECONDSrr rardisabled_corrupt_boardsrrrrrs r._tick_once_for_boardzSGatewayKanbanWatchersMixin._kanban_dispatcher_watcher.._tick_once_for_boardsD//55K488>>N)4B1$kn&&4(K77???4';66KKD KKY(++D$7775 {{{..(('$3"/*?%50K)  R# $$?(   --c22  5@$.BRBR4S+D1LLS #A 444&# $$#%  !MtTTTttt"# $$#!   --c22  5@$.BRBR4S+D1LLS #A 444# $$#  !MtTTTttt# $$#!  # $$s$2C?C.. C;:C;?J AGJ#E00 E>=E>GJ#%F;; G G  J AJ J#'H== I  I J+J#2J JJJ  J##K 'J<;K < K K K  K $'list[tuple[str, Optional[object]]]'c d}n+#t$rjg}YnwxYwg}|D]>}|dpj}|||f?|S)aRun one dispatch_once per board. Returns (slug, result) pairs. Enumerating boards on every tick keeps the dispatcher honest when users create a new board mid-run: no restart required, the next tick picks it up automatically. Fr1r3)rErFrGrHrJrT)rXoutbr3rars r. _tick_oncezIGatewayKanbanWatchersMixin._kanban_dispatcher_watcher.._tick_onceUs F%@@ F F F11#2CDDE F8:C ? ?uuV}}9(9 D"6"6t"<"<=>>>>Js%AAc< d}n+#t$rjg}YnwxYw|D]S}|dpj}d} |}|r0 |* |dS#t$rYdSwxYwdS|r0 |* |dS#t$rYdSwxYwdSn8#t$r+Y|& |#t$rYwxYwwxYw |( |#t$rY"wxYw(#|& |w#t$rYwwxYwwxYwdS)a~Cheap probe: is there at least one ready+assigned+unclaimed task on ANY board whose assignee maps to a real Hermes profile (i.e. one the dispatcher would actually spawn for)? Tasks assigned to control-plane lanes (e.g. ``orion-cc``, ``orion-research``) are pulled by terminals via ``claim_task`` directly and never spawnable, so a queue full of those is "correctly idle", not "stuck". Filtering them out here keeps the stuck-warn fire only on real failures (broken PATH, missing venv, credential loss for a real Hermes profile). Fr1r3Nr5T) rErFrGrHrJrOhas_spawnable_readyrUhas_spawnable_review)rXrr3r\ras r._ready_nonemptyzNGatewayKanbanWatchersMixin._kanban_dispatcher_watcher.._ready_nonemptyfs` F%@@ F F F11#2CDDE F ! !uuV}}9(9 !;;T;22D..t44$# '! JJLLLLLL(!!! DDD!('' //55$#'! JJLLLLLL(!!! DDD!('' $ '! JJLLLL(!!! D!($ '! JJLLLL(!!! D!(t'! JJLLLL(!!! D!( 5s%AA)+D B// B>=B>D C44 DD E/ D?E/D-- D:9D:>D??E/E E*)E*/F3FF F FF Fauto_decomposeauto_decompose_per_tickr"rc  ddlm}n3#t$r&}td|Yd}~dSd}~wwxYw d}n+#t$r  jg}YnwxYwd}d}|D]}|dp j}| krntj d} |tj d< | }n5#t$r(}t d ||g}Yd}~nd}~wwxYw|D]} | krn|d z } | | d } n+#t$rtd | YOwxYw| jr`|d z }| jr7| jr0td|| t'| jtd|| t d|| | j|"tj dd|tj d<#|!tj ddn|tj d<wxYw|S)zRun the auto-decomposer for up to N triage tasks across all boards. Returns the number of triage tasks that were successfully decomposed or specified this tick. r)kanban_decomposez3kanban auto-decompose: import failed (%s); skippingNFr1r3HERMES_KANBAN_BOARDz>kanban auto-decompose: list_triage_ids failed on board %s (%s)rrzauto-decomposer)authorz3kanban auto-decompose: decompose_task crashed on %su.kanban auto-decompose [%s]: %s → %d childrenu:kanban auto-decompose [%s]: %s → single task (no fanout)z*kanban auto-decompose [%s]: %s skipped: %s)r~r'rFrCrvrErGrHrJrwrxlist_triage_idsrDdecompose_taskrokfanout child_idsrzrSrkr) _decompr]rX attempted successesrr3prev_env triage_idstidoutcomerar%s r._auto_decompose_tickzSGatewayKanbanWatchersMixin._kanban_dispatcher_watcher.._auto_decompose_ticks>  BBBBBBB   I3qqqqq    F%@@ F F F11#2CDDE FII8 E8 EuuV}}9(9 777E :>>*?@@/E8%> $((( \ #&( ( *  $(???!E!Q  %&-&<&< #,='=''GG )%%%",, U #%H % #:%NI&~ "'2C " & $T$(#s73D/E/E!"!"!"!" !' $`$(#!"!"!"!"#LL L $c7>  ' 'EE  * Y"%&9":":#Q&&NN[+'+OOKK Wo W WXXXXz* ' ' 'T'#'  ' 'NN?C>D"KKMMUQU   KK.    %..)FMM&*#  & .1/.B.B+/22NNg'37//KKK3z* 3 3 3`#/3+++  3,mA    -0)   > > > > > >      V V V V V V V V V V V V V V V V p       "! ! ! ! ! ! R"&jnn5Et&L&L!M!M (&)8!<<A'' # #:& ( ( (&' # # # ( "Q & &&' #K K K K K K K Z  Ex   m?  L%.s/FGGGGGGGGKKPD   L L L  !JKKKKK L* P)B!+,@AAAAAAAAA ' 1* = =======# ")-RID#73 4+H+H&*  R  ,,M07 Y0O0OVC ,,,UV29#-2S2SZC ...YZL5$>????????? (""t}"{m? ? ? ? ? s$AA( B33 C#=CC#E $E54E59%FAG#"G#J.KK'K779L32L3;N .N>=N>$Q33.R$#R$%T>>UU A W$W<;W<F^A __)r )r r r rr)r<r|r>rr6rr r)r<r|r6rr r) r<r|rrr=rr6rr r)r9r*rnr|rqrr r)r r) __name__ __module__ __qualname____doc__rrrrrrQrr0r.r r sIIh'h'h'h'h'V >B,     & $ .kkkkZyyyyyyr0r )rU __future__rrloggingrwrrrrtypingrr getLoggerrCr rr0r.rZs#"""""     = ) )NNNNNNNNNNr0