fjc UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlmZddlmZddlmZdZded <d Zded <d Zded <dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZded<dZ ded<d Z!ded!<d"d#d$d%d&d'd(d)d*Z"ded+<ed,Z#d-Z$d.Z%ded/<d0Z&ded1<e jNd2Z(d3Z)d4Z*d5Z+hd6Z,Gd7d8e-Z.Gd9d:e.Z/ed;<Gd=d>Z0d`d?Z1dadbd@Z2dcdAZ3dddBZ4dedCZ5 dfdDZ6dgdEZ7dhdFZ8didGZ9djdHZ: dk dldIZ; dmdJZ dpdMZ? dqdNZ@drdOZAdsdPZB dtdQZCdudRZDdvdSZEdwdTZFdxdUZGdydVZHdzdWZId{dXZJd|dYZKGdZd[ZLd}d\ZMd~d]ZNd|d^ZOePd_k(r eQeOy)zNContinuous, event-first Task26 lifecycle observer and role-handoff controller.) annotationsN) dataclass)Path)Final@4e9962be49b72951c3b9ed7e1a4fe36d0ca03e757872ae03364c1ab7a790f32br SUCCESSOR@88caabf3dee923e720463d917d35b6dd32ecc31102ed3ab4df4c6a203df4a760CORE@33688875a0d1ce20955bd8272257ee34d84cb138f6a23a43e5d16682368ae5e5WHEEL@d816dbbd6a27d5826b251d279a9831de096ef7cd79b5fd131ceff7253b7369bePLAN@8416cd7c83cab5540af2e1e01dbcc5b1bdfd49a59d8ef21ea49512c28d749218GOLDEN@a2e15845764e7041957ae4518096fe73f87ec35b57021980cdd4df3ea18ac00dRECOVERY@5e3067fe3c865224fc73ff5a9a65058c87960f05d9af53bddccaf6f32dc83939CONSENTcb_PCczfFXoI4GjvCxLBs1oRASESSION@53b4f95b5b4db9a611128976a7b951bbe22d9619e05b2ff07fadf5b02f9a5380SID%task26_live_2e_r2_20260815_8527916639KEY 8527916639CUSTOMER 8693203710OWNER) date_of_birthequation_sex_basis height_cm weight_kgactivity_categoryactivity_rationale goal_typetarget_weight_kg target_date allergies intolerancesreligious_ethical_exclusionsdisliked_foodsdietary_preferences conditions medicationspregnancy_breastfeedingeating_disorder_riskcooking_access budget_band meal_countschedule_constraintsFIELDS@95637abce4742d583534cf406b038f7c862ad0a72d10a6bab24d2452dcb0f776@8c7065277d5d96ce1012ac0c098d53288bba66c44c0674704be4072fe0a63951@8ce2fe8770c2b480083e9d44237d80892ccddcaec06acca14db18576a2ee0088@b41060dea28eb3bbb83217068f5218d5df2c879dba00e73c9ca4e577a6049dad@8fb6ba6f855e7508c525447cdec482ceb240f8c0a5827b2ca0ce4268c6880bb0@8afb45c5cca082fd85cf07ab43dc5d1062c34678fd268a5722e313ce35cffd8b@3c24d49d656c623edfb95fcfbc7fb0f92365fc123420df66f733f9dbe39d704f@f04ea498ad12a257fb1322da4c8cfd2f91fc9403f0b978617fcc00df41729209)z1gateway/platforms/dualcoach_activation_cutover.pyz$gateway/platforms/dualcoach_admin.pyz0gateway/platforms/telegram_customer_bootstrap.pyzgateway/platforms/telegram.pyz8gateway/platforms/nutrition_onboarding_reconciliation.pyz7gateway/platforms/telegram_nutrition_onboarding_copy.pyz:gateway/platforms/telegram_nutrition_onboarding_runtime.pyzFgateway/platforms/telegram_nutrition_onboarding_runtime_publication.pyRUNTIMEzK/home/cube/projects/richard/hermes-agent/.venv/lib/python3.12/site-packagesz$task26-continuous-lifecycle-v3-finalu활동 수준: 보통. 주 3회, 회당 60분 정도의 중간 강도 근력운동을 희망합니다 . 평소 걷기·이동은 하루 약 6,000~8,000보 수준입니다.LEGACY_ACTIVITYu주 3회, 회당 60분 정도의 중간 강도 근력운동을 희망합니다 . 평소 걷기·이동은 하루 약 6,000~8,000보 수준입니다.DETAILED_RATIONALEiIIIii@i>recovery-auditsprofile-reset-archivesdualcoach-provider-authrehearsal-reset-archivespost-lifecycle-cleanup-archivesglobalc eZdZy)LifecycleErrorN__name__ __module__ __qualname__c.omo/evidence/task26/task26-continuous-lifecycle-observer-v3-final-4e9962be/continuous_lifecycle.pyrIrI\rOrIc eZdZy)LifecycleTimeoutNrJrNrOrPrSrS`rQrOrST)frozencneZdZUded<ded<ded<ded<ded<ded <d Zded <d Zded <dd Zy)Promptstrstatusroleactorztuple[str, str]route str | None message_idactioncommanddetailc |j|j|jt|j|j |j |j|jdS)N)rXrYrZr[r]r^r`ra) rXrYrZlistr[r]r^r`raselfs rPdocz Prompt.docosIkkIIZZ$**%//kk||kk  rON)returndict[str, object])rKrLrM__annotations__r`rarfrNrOrPrVrVds; K I J  KGSFC  rOrVcdtj|jjSN)hashlibsha256 read_bytes hexdigest)ps rPsharq|s >>!,,. ) 3 3 55rOc|js|S|jrtd||j}tj|j rC|j tjk7s"tj|j dzrtd| tj|jS#tj$r}td||d}~wwxYw)Nzsymlink authority: ?zunsafe authority: zinvalid JSON: )exists is_symlinkrIstatS_ISREGst_modest_uidosgetuidS_IMODEjsonloadsrnJSONDecodeError)rpdefaultses rPloadrs 88:||~21#677 A LL # 88ryy{ " << "U *1!566:zz!,,.))   :~aS129:s2"CC<(C77C<c4t|tr!|Dcgc]}t|ts|c}St|trLdD]G}t|j|ts#||Dcgc]}t|ts|c}cSgScc}wcc}w)N)records generationsitems) isinstancercdictget)vxks rProwsrs!T41a 1d 3144!T4A!%%(D)#$Q4?4a:a+>4??5 I 5@sBB.BBctjtjtj j d}d|d|d|S)N=znon2::)base64urlsafe_b64encodebytesfromhexrdecoderstrip)r^ generationhs rPcallbackrsH  s!34;;=DDSIA 6(!J' --bootstrap-session zg --expected-generation 5 --package-root /home/cube/.hermes/profiles/dualcoachtest/workspace/checkin_cli)rrrNrOrP exact_cutoverrs4 b   M N   t  trOc |Dcgc]#}t|j|d|k(s"|%}}t|dk(r|dSdScc}w)Nr_r)rWrlen)seqfieldvaluerrs rP_onersM:Cq3quuUB/0E9CA:q6Q;1Q4(D( ;s #AAct|dz i}ttt|tr|j dgngdt }t|dz i}ttt|tr|j dgngdt}|dz tz dz }t|d z dxst|d z d}t|d z i}ttt|tr|j dinidt }|[t|trKt|j dtr,|dj t } t| tr| nd}t|d z i} t|d z i} |dz tz dz } t| dz d} d}t| tr| j d}t| j dg}|rt|dt|nd}|rt| dz |dz dnd}t|tr||j d|j d|j dt|j dt|j dgt|tr|j dndd}t|dz g}t|dz i}t|dz i}t|dz i}g}|dz }|jrO|jjD cgc](} | jstj| *}} ||||t| t| |t|t|trt|j!n t|t|tr|nit|tr||d Si|d Scc} w)!Nz:data/onboarding/telegram-customer-bootstrap-v1/ledger.jsonsessions session_idzcustomers/registry.json customers customer_keyzdata/customersznutrition-onboardingz ready.jsonztransient/workflow.jsonz session.jsonz:data/onboarding/telegram-publication-outbox-v1/ledger.jsonzCdata/onboarding/telegram-publication-outbox-v1/owner-callbacks.jsonwizardztelegram-bindings.jsonactive_session_idbindingsdraftsz.jsonversionstepr]chat_idtopic_idfinalized_event_id)rrrr]r[rz)data/owner-actions/draft-generations.jsonz.data/owner-actions/draft-generation-cards.jsonzdata/owner-actions/drafts.jsonz(data/owner-actions/draft-deliveries.jsonz$data/customer-activation-audit.jsonl) bootstrapcustomerworkflow publicationoutboxowner_callbacksrrcardsr deliveries activation)rrrrrrrrrWrt read_text splitlinesstripr}r~rcvalues)rootbootbrregcrnrwfpubsprroutocwrbindractivebsbdraftgensrrrauditaps rPcapturers SSUW XD  D$)?TXXj" %RH B t// 4C  C)>SWW[" %BG  B  3 &)? ?B b< & T$r4M/Mt*TB ^#R (D  D$)?TXXj" %RH B  zjt,DHHZFdGGLJ E 6 6B yy{(* (A(A(CQ(C1qwwyA(CQs)8Dz)3E4)@elln%d5k&vt4&"$.z4$@j  GI  Rs 'O=Oc |jd}|jd}t|trV|jdtk7s>|jdtk7s&|jddvs|jddvr t d t|tr]|jd t t k7s@|jd ttd d dfvr*|jdttd gk7r t dt}|jdg}t|ts t d|D]}t|ts t d|jd|jdf}||vr t d|j||jd}|jd}|dk(r |td gk7s|dk(s|td gk7st d|jdi} t| trs| jDcgc]@}t|tr.|jd t k(r|jddk(r|B} }t| dkDr t dyycc}w)Nrrrsid_hashstate>ACTIVEAWAITING_ACTIVATIONr>zbootstrap authority driftrtelegram0user_idrrr[zcustomer route driftrzoutbox schema driftz duplicate publication generationrYownerzpublication role route driftrrX sent_auditedrzduplicate sent_audited delivery)rrrrrrIrrsetrcaddrrr) rrcseenrrrrYr[dterminals rPvalidate_snapshotrsH kA jA q$  55 ' ) 55  # 55>!B B 55 f ,899 q$  55 % , EE*  (X3OQUV Wg8Xs";;344 5D UU8R F fd #233 !T" !67 7 UU< !%% "5 6 9 !CD D  uuV}g J (C(w%% !?@ @ lBA!TXXZ !T"n%,h>1    x=1  !BC C  s)AJ ct||jd}|jd}t|trzt|trj|jddk(rV|jddk(rBt |jddt |jddkr t d|jd}|jd}t|trRt|trBt |jddt |jddkr t d |jd }|jd }t|trxt|trg|jd |jd k(rCt |jd dt |jd dkr t d yyyy)Nrr collectingcursorrzonboarding cursor regressedrrz publication generation regressedrrrzcheckin version regressed)rrrrintrI)arawbwrbpavbvs rPvalidate_transitionr0sa z B z B2t r4 FF7O| + FF7O| + x# $s266(A+>'? ?:;; } B } B2t r4 |Q' (3rvvlA/F+G G?@@ xB xB2t r4 FF< BFF<$8 8 y!$ %BFF9a,@(A A899 B 9 ! rOctj|ddddj}tj|j S)NFT,r) ensure_ascii sort_keys separators allow_nan)r}dumpsencoderlrmro)rencodeds rPcanonical_digestrOsEjj    fh   >>' " , , ..rOcv|jd}t|tr|jddk7ry|jd}|jd}|jd}t|tr,t|tus|dkst|tus|dkry|jd}t|t sy|Dcgc]}t|tr|jd t k(r|jddk(ry|jd|k(re|jd|k(rQ|jd|k(r=|jd |k(r)|jd |d k(rtd gntd gk(r|}}td|Dd} t|dk(r|| k(r|SdScc}w)Nrr COMMITTEDpayloadrr]rrrrYr[rrc3K|]n}t|tr\|jdtk(rD|jddk(r0t |jdt urt |dpyw)rrrrN)rrrrtyper).0records rP z(committed_publication..|sd  &$' <(G3 7#{2VZZ -.#5 |$ % sA4A6)rr) rrrrrrcrrrmaxr) rrYrrrr]rrmatcheslatests rPcommitted_publicationr Zs%% &K k4 (KOOG,D ,Sooi(G.J.J w %  3 & >  3 & ? UU8_F fd # F fd # JJ| $ / JJw ; . JJ| $ 2 JJ| $ 2 JJy !W , JJv $ & JJw #z1XsOs| E      Fg,!+ f0D;N$N1 s Bresolved clarifyinganswers_digestrr>kindr question_korr> ambiguity contradictionr)rrrrrrcrrrrWrr5rappend) rr rrrrrkeyrunsignedtypedritems rPreconciliation_authorityrsll9%G \\* +F gt $Jvt,D%g.NZZ 01NJJ/M ZZ !F-3\\^O^zsEshU ^HO 7#== ::& '> 9.$/  c )M8S%88  &#& H % / JJw < / C/ / 1%'EUD4&4y<<xx .xx D(xx'EEdhh}5s; & T']#$ T NE= 889Ps  H#Hc|jd}t|trddddj|nd}|jd}t|trddd d d d j|nd}|y |ydD]?}|j|}t|tr|jddvs8dd|fcS|jddury|jddurydd|d|dfS)Nr%감량유지증량lossmaintaingainr#좌식 가벼움보통매우 활동적 최고 활동 sedentarylightmoderate very_active extra_active)Fz$canonical Korean goal is unavailable)Fz(canonical Korean activity is unavailable)r(r)r*r+r,r-r.rX>noneprovidedFzstructured answer unavailable: r/)Fz#health review input requires reviewr0Tzgoal=z ; activity=z; health=no-review)rrrWr)r  goal_valuegoalactivity_valueactivityrrs rPsummary_qualityr8s-[)J j# &xBFFzR  [[!45N nc * "  -+  #n    |<@ E"%&%))H*=F + ;E7CC C{{,-U:;{{)*%7; 5k(3EF FFrOc d!d"fd }d#fd ddddjtjd}d d d d d djtjd}djfddD}djd|xsdd|xsdd|dd|ddd|dd|dd|dd|d fS)$N 미입력cj|}| |dk(s|gk(r|St|trdjd|Dxs|St |S)Nr_, c32K|]}t|ywrk)rWrrs rPrz7authoritative_summary..value..s734SY3s)rrrcjoinrW)rrrawr s rPrz$authoritative_summary..valuesTkk%  ;#)sbyN c4 997377B7 B3xrOcj|}t|tsy|jddk(ry|jd}|jddk7st|tsydj d|DxsdS) Nr:rXr2없음rr3r<c3HK|]}t|ts|s|ywrkrrWr>s rPrz.structured..sOut 40E$dus """)rrrrcr?)rr@rr s rP structuredz)authoritative_summary..structureds|kk% #t$ 778  &  778  **UD2I IIOuO O  rOr r!r"r#r%r'r(r)r*r+r,r#u · c3>K|]\}}|d|yw) NrN)rlabelrrEs rPrz(authoritative_summary..s2  LE5 ':e$%& s))u 알레르기r()u 불내증r))u종교·윤리 제한r*)u비선호 식품r+)u 식품 선호r, u - 목표: u - 활동: r$u- 식사: 하루 r3u끼u- 조리·예산: r1r2u- 식사 시간: r4u*- 알레르기·불내증·식품 제한: u=- 건강 관련 입력: 별도 검토 입력이 없습니다.)r:)rrWrrWrgrW)rrWrgrW)rrWr?)r rr5r7 restrictionsrEs` @rPauthoritative_summaryrKs  (H E I I GKK $% D)'   c#gkk-. /0  ;;    L 99,- .0[1eR=S T&< => ?8 G K   rOc|jd}t|tsy|jd}t|tsy|r t|n|jd}t|tr|sydd|g}dD]d\}}|rdn|j|} | st| t t frtd| Dsy|jd|gd | Df|jd d j|d zS) Nradvisory summary_kou 입력 내용을 정리했어요r_))u확인된 내용facts_ko)u안전 관련 참고사항safety_observations_korNc3<K|]}t|tywrkrDr>s rPrz-candidate_attestation_text..-s@28$ 4%&sc3&K|] }d| yw)z- NrNr>s rPrz-candidate_attestation_text..1s&FvtD6{vs)r_u\이 요약은 참고용이며 안전 판정·승인·활성화를 대신하지 않습니다.u=내용이 맞으면 아래 확인 버튼을 눌러 주세요.rIu 아래 버튼을 누르면 입력 확인이 저장되고 운영자 검토로 넘어갑니다. 이 단계에서 영양 코칭이 시작되거나 활성화되지는 않습니다.) rrrrKrWrctupleallextendr?) rr rrrMsummarylinestitlerrs rPcandidate_attestation_textrYs\\"23N nd +!!*-H h %*7g&X\\,=W  gs #7 /W =E s%(,,s*; ftUm4C@28@= LL"eG&Fv&FG H LL  % ] ]rOct|||}t|duxrC|jdtj|j j k(S)N body_digest)rYboolrrlrmrro)rr rrtexts rPcandidate_body_boundr^@sV &h GD  D T KK &'..*G*Q*Q*S S rOcRt|\}}t|xrt|ttk(xrp|j ddk(xrZ|j dt k(xr@|j ddk(xr*|j ddk(xr|j dd k(S) Nr#r/r$r%r%r4rBr3)r8r\rr5rr@)r  quality_ok_s rPbaseline_valid_answersrcMs#G,MJ  + LCK ' + KK+ , : + KK, -1C C + KK $ 2  + KK. /8 ;  + KK % * rOc|jd}tt|txrZt |t t ddk(xr:|jddk(xr$|jdt k(xr d|vxrd|vS)Nr rr#r/r$r4r)rr\rrrr5r@)rr s rPnormalized_rewindreZsll9%G 7D! - LCs , , - KK+ , : - KK, -1C C - #' 1  - H ,  rOct|||t||||syd}tfd|Dryddtdf}t fd|Dsy y ) N)Fz.publication body is not candidate-render-bound) {rrXr:u 수정 전u 실제 총활동량은 불명확u 위험 신호r%r/r-r0r1c3&K|]}|v ywrkrNrtokenr]s rPrz.publication_summary_quality..s 0iU5D=i)Fz5publication contains forbidden internal or stale copyu- 목표: 유지u- 활동: 보통u%별도 검토 입력이 없습니다.c3&K|]}|v ywrkrNris rPrz.publication_summary_quality..s3(u}(rk)Fz8publication lacks Korean goal/activity/no-review summary)Tz,candidate-render-bound Korean summary passed)rYr^anyr@rT)rr rr forbiddenrequiredr]s @rPpublication_summary_qualityrpfsr &h GD |/'='G I 0i 00M/ H 3(3 3P ?rOc |jd}t|}t|tr|jddk7s|yt |}|jd}|t|tsy|\}}}}t |\} } t d} |jd} |jd} | sPt| tus?| dks:|jddk7s&|jd |k7sd |vst||||syt| tust| turyd d ttd gt| td| | |j| d| zd S)Nrrcustomer_attestationrrrr]rclarification_fieldREADY_CUSTOMER_REVISIONrrreviseuVpress the existing 수정 button, then resubmit the unchanged final canonical answer; ) rXrYrZr[r]r^ next_field next_valuera) rr rrrr8r5rrr^rrWr)rrr authorityrr rrbrrareasonrrr]s rPcandidate_revision_handoffr{s`uuZ H'*K x & << $: :  (2Iooi(G 7D 909-G^Q (1J 2JE.J.J  3 & ? ;;w #9 9 ;;' (N : G +#Hg}gN Js"d:&6c&A+C*o8Z0kk%(j   rOc vt||d}|d}|jd}t|trt|tsJt |jd}|jddk(rkt|ts t dt |jd}|dk(r|jd }t|tus$d |cxkrttkst d t d t|}|td d d dddS|jd}|jd} |jd} t|tr6|jddk7s"t| tust| turtd d d dddS|ttdz k(r@| dks t|s t dtddttdft | dddStddttdft | dt|d|dzdSt|} |d k(r| td d d dddd!S| d}t|tsJt|} | td"d d ddd#S| \} }}}|jdd k7s|jd$|k7rtd d d dddd%S| jd} | jd} t| tust| tur t d&| }t | }|d'}t|tsJ|dd(k(rM||d)}|jd*|k7rtd d d dddd+Std,dttdf|d-|d.Sd*|vrtd d d dddd/St!|| ||}|sF|d0k(r/| d1k(r*| jd2t"k(rtd3d4d4ddd5d6Std7d d dddd8St%| \}}|sU|d9k(r>| jd2t"k(r&td:dttdf|t'd;|dd4d4d|d?|S|d@ks t)| stdAd d ddd#dBSt+|| ||\}}|std>d4d4d|d?|StdCdttdf|t'dD|dresolved authority precedes its matching committed publicationz$committed publication identity driftrrrrtz,clarification field is not publication-boundREADY_CUSTOMER_CLARIFICATIONzsubmit_clarification:z5reply only to the committed field-bound clarificationz8resolved authority still has a clarification publicationr# WAIT_DEPLOYoperatorzdeploy-final-candidatezWdeploy 4e9962be; startup must commit changed summary generation 25 before any UI actionWAIT_CANDIDATE_PUBLICATIONz1candidate-bound summary body is not yet committedrsrurvr_u<press latest 수정 once; generation 24/message 207 is staleSTOP_CUSTOMER_SUMMARY_QUALITYz do-not-attestWAIT_CANONICAL_RECONCILIATIONzBnormalized answers are not yet baseline-valid in a new publicationREADY_CUSTOMER_ATTESTattestz6press the matching committed attestation button once; rz"onboarding publication unavailable owner_reviewREADY_OWNER_ONBOARDING_APPROVEowner_okz7press Approve once; readiness finalization is automatic safety_holdSTOP_SAFETY_HOLDzclinical-review-required>ready finalizingrWAIT_AUTOMATIC_READINESSzautomatic-finalization!READY_OPERATOR_ACTIVATION_CUTOVERz!dualcoach_admin:customer:activatezbrun only after checklist evidence exists; commits registry activation then bootstrap g5->g6 ACTIVEzunknown onboarding outcomerrz.activation cutover is not atomically committedrrrXrREADY_OPERATOR_DISABLEzcustomer_admin:disablezCdisable exact customer, then stop service and await cleanup handoffREADY_CLEANUP_HANDOFFzsealed-cleanup:dry-runzIservice must be inactive; use sealed cleanup dry-run -> execute -> verifyz/active lifecycle customer unexpectedly disabledrREADY_CUSTOMER_START_CHECKINz send:checkinz'send checkin, then press Begin check-inr[zcheckin route driftrrVREADY_CUSTOMER_CHECKIN_ANSWERzcheckin:z"answer the visible check-in promptrREADY_CUSTOMER_CHECKIN_SUMMARYzcheckin:finalizezconfirm the visible summaryrrrzgeneration authority driftz&generated result lacks draft authorityWAIT_AUTOMATIC_GENERATIONzgeneration:autoz.no human action; wait for generated owner card>heldsentrejected supersededz&draft identity is duplicate or unknownrjrzowner card authority driftdraft_idgeneration_token publishedz'exact owner generation card unavailable destinationrzowner card route drift>editedcreatedREADY_OWNER_DRAFT_REVIEWzdraft:z:reviewz;choose regenerate or edit if needed; otherwise approve onceapprovedREADY_OWNER_EXPLICIT_SENDz:sendz9approval never sends; press Send to customer exactly oncezunknown draft outcome)rrrrr\rIrWrrrr5r rVrerrr^r?r8rrcrprrrrrrc)-rrrrr}rrcommitted_collectionrrr] committedryr rrrgenmidrr body_boundraquality_detailrrrwrmatchedrrrgrelevant_generationsrrdiddrgeneration_tokens cards_valuercarddestrXs- rPclassifyrs a +A * A z B a :a#66 6155#$GuuW~.."d# !BC CBFF7O$ L VVH%FF|3&a6.GCK.G$%ABB/H$%ABB#8#; #+8"& +..y9G-11,?J-11,?Jw-;;w'<7 #3. #3.8"& Vq(?*;B*?()UVV-sO O8d  +3J  014VaZL@gh *!, * * 8"&M *Ggt, ,,04I 3") FO BG^^] G$(>>;;/0NB8"&[#|4J"|4JJs*d:.>c.I$%KLLCj/C 01Nnd3 33g&,6&}5g>;;45>!<  &*M2sO+E73R%/8"&U.b'='RJ2I"c) $78OK!%""&0x0"&N*9)A &J"9-@!A_!T!1" !3 3/V  3"#)Rx5g>3")_*EG]G* &J3"#)'33'H !  *!W5 )T* !EF F]]<0 ]]<0  3 &$z*:#*E !GH H*o N "0 S)I   M !" *   + + $.", 33t  9::uuW~!QUU<%8A%=MNN lBAH!TXXZ !T"n%,h>1    ((\  #     $^   NOO hA a  *   sO  <   uuW~(C(233uuV} ! +   sO l# $quuV}o &7   55% & ,   sO l# $ 0  UU8R FG&$  &1!T"n%,l#quu\':: F&  %% r*K k4 (9::A a  EE. !S ( EE, 155#6 6    !IJ J '     C  A Q488H %O O    6{aEFFQiGC 4 41 155>SV8Wg 4%%$K k4 (9:: A a  EE*  $uuW~#rvv.@'A!BBuuW~!22 EE'Nk )   5zQFGG 8D 88M "D 5UDD566 ! "F && &   CL & 'SE !P   '   CL & 'SE N   0 11g B ( s. AlAl! Al'l,$l13l19A8l6ctjtj|ddj j S)NTrrr)rlrmr}rrro)rs rP event_hashrcs3 >> 1<CCE ikrOc$|jjdd|jjdd}|jr=|j j }|rt j|ddn|}t|jr td|jDnd|d |}t||d<tj|tjtjztjztj zd }tj"|t j$|dd d zj'tj(|tj*|y)NTparentsexist_ok@0000000000000000000000000000000000000000000000000000000000000000r event_sha256c3 K|]}dyw)rNrN)rrbs rPrzappend_event..rs/;a;s r)schemasequenceprevious_event_sha256rrrI)parentmkdirchmodrtrrr}r~SCHEMAsumopenrrzO_WRONLYO_CREATO_APPEND O_CLOEXECwriterrfsyncclose)patheventpreviousrWrowfds rP append_eventris#KKdT2KKeH {{} ++-rrqSITErI)rprs rP runtime_checkrs9 1 tax=A  #ycc}wrk)rzwalkrSKIPrr)rerdirsrbrs rPadd_treezWatcher.add_treesP''$)),JAtQ"&8$Q!4-q$8DG HHT!W -8s A A c2|js|jsytjdd}|j |j t j|t}|dkrtd|||jt|<y)NTrrzwatch failed: ) ruis_dirrrinotify_add_watchrrzfsencodeMASKrIrr)rerprrs rPrz Watcher.addsq <<> {{440  " "477BKKND A q5 >!!56 6  SVrOcXtj}|j|jtj |j |}|s t dtj|jd}d}|tjzt|krtj||\}}}} |tjz }|||| zjdddj} || z }|tzr t!d|t"zr|j$j'|t)| z } |dzr!| j+r|j-| |tjzt|kr|j/y#|j/wxYw)Nz stage monotonic deadline expiredirrzinotify overflowi@) selectorsDefaultSelectorregisterr EVENT_READselectrSrzreadEVsizer unpack_fromsplitrOVERrIIGNOREDrrrrrr) resecondsselrr@offrmaskrbnnamechilds rPwaitz Watcher.waitsP'') TWWi223 JJw'E&'IJJ''$''5)CC-3s8+ "sC 8 4Arww3q)//q9!<CCEq$;();<<'> ((DF3d:*$HHUO-3s8+ IIKCIIKs EFF)cBtj|jyrk)rzrrrds rPrz Watcher.closes rON)rrrgNone)rprrgr)rfloatrgr)rKrLrMrrrrrrNrOrPrrs+  !0rOrc td|jdk(rdndt|jt |t |ddddd S) NREADY_CONTINUOUS_LIFECYCLErREADY_FOR_DEPLOYARMED_POST_DEPLOYz recursive-inotify-before-actions`Tz=no raw updates, tokens, customer answers, or provider content) rrXdeployment_readinessrinitial_handoffcandidate_summary_revisionauthority_sha256event_subscriptionper_stage_timeout_maxtotal_timeout_maxprivacy)rrXrrfr{r)rprompts rP ready_docr/sQ.}} - $J!::<&@&C&qM@!%"R rOc tt|j}|jt |j}t |t |}t||}t|j||jdk(r|j|St|jd|jt|dt!t#j$|ddt'j(}|}|j*} t-|j.t'j(|z z |j0t'j(|z z }|dkr t3d|j5|t |j} t| t|k(rt7|| t | } t|jd |j*| j*| jt| d | j*|k7rPt!t#j$| jddt'j(}| j*}| | }}| j*d k(r1t8d t;| jd |jS#|jwxYw)Narm-onlyREADY)rhandoffr)Tr)flushrz"bounded lifecycle deadline expired TRANSITION)rfromtor3r)r"PASS_CONTINUOUS_TO_CLEANUP_HANDOFF)rrXr final_handoff)rrprofilerrrrr/rrmoderreventsrfrprintr}rtime monotonicrXmin stage_timeout total_timeoutrSrrrr) rrrrprstartstagelast remainingrqs rPrunrIsO AJJL Aa A!QA 177Avv   QUUW*Q-P $**Q$ 't4 NN E E 88D%4>>#3e#;<4>>#3e#;<IA~&'KLL FF9  "A!} 1 - 1 % A (HH(( uuw(21  xx4djjD9F(xxaqAxx22$B ( %&UUW   IH  sFJ64J66Kctj}|jdd}dD]}|j|}|j dt d|j dt d|dk(sJ|j d t d|j d t d |j d t d |j} |jdk(rNd|jcxkrd kr.n tdd|jcxkrdkstdtdttjt|dy#t $r(}td|t"j$Yd}~yd}~wtt&t(t*f$r(}td|t"j$Yd}~yd}~wwxYw)Nr<T)rro)r1observez --profile)rroz--readyrKz--eventsz--stage-timeoutr$)rrz--total-timeoutr%rztimeout bound invalidr4zFAIL: )filer`)argparseArgumentParseradd_subparsers add_parser add_argumentrr parse_argsr<rBrCrIr>r}rrIrSsysstderrOSError ValueErrorKeyError)rspr<rrrs rPmainrZ"sw  "B    6B' MM$  {= ytd; 9  NN:D4N @ NN,5$N G NN,5%N H( A  66Y AOO+t+ !89 945q3O%3O !89 94P !89 9 djjQ401  qcl, GZ : qcl,s%BE GFGGG__main__)rprrgrWrk)rprrobjectrgr\)rr\rglist[dict[str, object]])r^rWrrrgrW)rgrW)rr]rrWrrWrgdict[str, object] | None)rrrgrh)rrhrgr)rrhrrhrgr)rr\rgrW)r)rrhrYrWrgr^)rrhrgzBtuple[dict[str, object], str, list[dict[str, object]], int] | None)r rhrgtuple[bool, str])r rhrgrW)rrhr rhrrrgr\) rrhr rhrrrrhrgr\)r rhrgr\)rrhrgr\) rrhr rhrrrrhrgr_)rrhrgr^)rrhrgrV)rrhrgrW)rrrrhrgr)rrrrhrgr)rgzdict[str, str]r)rgr)rrhr.rVrgrh)rzargparse.Namespacergrh)R__doc__ __future__rrNrrrlr}rzrrvstructrTr? dataclassesrpathlibrtypingrrrir r rrrrrrrrrr5r>rrr?r@Structrrrrr RuntimeErrorrIrSrVrqrrrrrrrrrr rr8rKrYr^rcrerpr{rrrrrrrrr/rIrZrK SystemExitrNrOrPris,T"   !U 5UPePQuQPePRRT%TSS,, OUO 4U4%u2:|,n8z%gAC@BCEOQ   Q 0M MEV]]6   \  ~  $   .6:$- ) )),)58))EP3Dl:>/'1,O,O #,O,O^'9'9G'9T*GZ5p%%*;%LO%%P          #@#@ #@#@ #@  #@L)Xh2V  , B --`(9x6 z TV rO