9Łj> UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZddlmZddlmZdZd ed <d Zd ed <d Zd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZd ed<dZ d ed<dZ!d ed<dZ"d ed<dZ#d ed <d!Z$d ed"<d#d$d%d&d'd(d)d*d+Z%d ed,<ed-Z&d.Z'ed/Z(d ed0<e(d1z Z)d ed2<d3Z*d ed4<d5Z+d ed6<e jXd7Z-d8Z.d9Z/d:Z0hd;Z1Gd<d=e2Z3Gd>d?e3Z4ed@AGdBdCZ5dfdDZ6dgdhdEZ7didFZ8djdGZ9dkdHZ: dldIZ;dmdJZdpdMZ? dq drdNZ@ dsdOZAdtdPZBdudQZC dvdRZD dwdSZE dxdTZFdydUZGdzdVZH d{dWZId|dXZJd}dYZKd~dZZLdd[ZMdd\ZNdd]ZOdd^ZPdd_ZQGd`daZRddbZSddcZTdddZUeVdek(r eWeUy)zNContinuous, event-first Task26 lifecycle observer and role-handoff controller.) annotationsN) dataclass)date)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-packagesztask26-continuous-lifecycle-v4z?/home/cube/.hermes/profiles/dualcoachtest/workspace/checkin_cliDOMAIN_PACKAGE_ROOT checkin_cliDOMAIN_MODULE_ROOTu활동 수준: 보통. 주 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__/home/cube/projects/richard/traning coach/.omo/evidence/task26/task26-continuous-lifecycle-observer-v4-4e9962be/continuous_lifecycle.pyrMrMbrSrMc eZdZy)LifecycleTimeoutNrNrRrSrTrWrWfrUrSrWT)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)r\r]r^r_rarbrdre) r\r]r^listr_rarbrdreselfs rTdocz Prompt.docusIkkIIZZ$**%//kk||kk  rSN)returndict[str, object])rOrPrQ__annotations__rdrerjrRrSrTrZrZjs; K I J  KGSFC  rSrZcdtj|jjSN)hashlibsha256 read_bytes hexdigest)ps rTsharus >>!,,. ) 3 3 55rSc|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_symlinkrMstatS_ISREGst_modest_uidosgetuidS_IMODEjsonloadsrrJSONDecodeError)rtdefaultses rTloadrs 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) isinstancergdictget)vxks rTrowsrs!T41a 1d 3144!T4A!%%(D)#$Q4?4a:a+>4??5 I 5@sBB.BBctjtjtj j d}d|d|d|S)N=znon2::)base64urlsafe_b64encodebytesfromhexrdecoderstrip)rb generationhs rTcallbackrsH  s!34;;=DDSIA 6(!J' --bootstrap-session zg --expected-generation 5 --package-root /home/cube/.hermes/profiles/dualcoachtest/workspace/checkin_cli)rrrRrSrT exact_cutoverrs4 b   M N   t  trSc |Dcgc]#}t|j|d|k(s"|%}}t|dk(r|dSdScc}w)Nrcr)r[rlen)seqfieldvaluerrs rT_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.jsonversionsteprachat_idtopic_idfinalized_event_id)rrrrar_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)rrrrrrrrr[rx read_text splitlinesstriprrrgvalues)rootbootbrregcrnrwfpubsprroutocwrbindractivebsbdraftgensrrrauditaps rTcapturers 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 generationr]ownerzpublication role route driftrr\ sent_auditedrzduplicate sent_audited delivery)rrrrrrMrrsetrgaddrrr) rrcseenrrrr]r_dterminals rTvalidate_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)rrrrintrM)arawbwrbpavbvs rTvalidate_transitionr6sa 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 ! rSctj|ddddj}tj|j S)NFT,r) ensure_ascii sort_keys separators allow_nan)rdumpsencoderprqrs)rencodeds rTcanonical_digestrUsEjj    fh   >>' " , , ..rSc |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|}}|Dcgc]}t|trn|jd t k(rV|jddk(rBt|jdtur"t|jdtur|}}td|Dd} t fd|Dd} t|dk(r | k(r|| kDr|SdScc}wcc}w)Nrr COMMITTEDpayloadrrarrrr]r_rrc38K|]}t|dyw)rNr).0records rT z(committed_publication..sC1BvVL ! "1Bs)rc3\K|]#}t|dkrt|d%yw)rraNr)rr rs rTr z(committed_publication..s5 +6,'(:5 |$ %+s),r) rrrtyperrgrrrmaxr) rr]rrrarr matchescommitted_recordslatest prior_messagers @rTcommitted_publicationr`sL%% &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  F fd # JJ| $ / JJw ; . L) *c 1 L) *c 1 C1BCF +  M w<1 v!5*}:T E sBresolved clarifyinganswers_digestrr>kindr question_korr> ambiguity contradictionr)rrrrrrgr rrr[rr6rappend) rrr rrrrkeyrunsignedtypedritems rTreconciliation_authorityr&sll9%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/r\>noneprovidedFzstructured answer unavailable: r0)Fz#health review input requires reviewr1Tzgoal=z ; activity=z; health=no-review)rrr[r)r goal_valuegoalactivity_valueactivityrrs rTsummary_qualityr@s-[)J j# &xBFFzR  [[!45N nc * "  -+  #n    |<@ E"%&%))H*=F + ;E7CC C{{,-U:;{{)*%7; 5k(3EF FFrSc 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)Nrc, c32K|]}t|ywro)r[rr%s rTr z7authoritative_summary..value..s734SY3s)rrrgjoinr[)rrrawrs rTrz$authoritative_summary..valuesTkk%  ;#)sbyN c4 997377B7 B3xrScj|}t|tsy|jddk(ry|jd}|jddk7st|tsydj d|DxsdS) NrBr\r:없음rr;rDc3HK|]}t|ts|s|ywrorr[rFs rTr z.structured..sOut 40E$dus """)rrrrgrG)rrHrrs rT structuredz)authoritative_summary..structureds|kk% #t$ 778  &  778  **UD2I IIOuO O  rSr(r)r*r+r&r/r0r1r2r3r4r$u · c3>K|]\}}|d|yw) NrR)rlabelrrMs rTr z(authoritative_summary..s2  LE5 ':e$%& s))u 알레르기r))u 불내증r*)u종교·윤리 제한r+)u비선호 식품r,)u 식품 선호r- u - 목표: u - 활동: r%u- 식사: 하루 r4u끼u- 조리·예산: r2r3u- 식사 시간: r5u*- 알레르기·불내증·식품 제한: u=- 건강 관련 입력: 별도 검토 입력이 없습니다.)rB)rr[rr[rkr[)rr[rkr[)rr[rG)rrr=r? restrictionsrMs` @rTauthoritative_summaryrSs  (H E I I GKK $% D)'   c#gkk-. /0  ;;    L 99,- .0[1eR=S T&< => ?8 G K   rSc|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 입력 내용을 정리했어요rc))u확인된 내용facts_ko)u안전 관련 참고사항safety_observations_korRc3<K|]}t|tywrorLrFs rTr z-candidate_attestation_text..As@28$ 4%&sc3&K|] }d| yw)z- NrRrFs rTr z-candidate_attestation_text..Es&FvtD6{vs)rcu\이 요약은 참고용이며 안전 판정·승인·활성화를 대신하지 않습니다.u=내용이 맞으면 아래 확인 버튼을 눌러 주세요.rQu 아래 버튼을 누르면 입력 확인이 저장되고 운영자 검토로 넘어갑니다. 이 단계에서 영양 코칭이 시작되거나 활성화되지는 않습니다.) rrrrSr[rgtupleallextendrG) rrrrrUsummarylinestitler"rs rTcandidate_attestation_textra,s\\"23N nd +!!*-H h %*7g&X\\,=W  gs #7 /W =E s%(,,s*; ftUm4C@28@= LL"eG&Fv&FG H LL  % ] ]rSct|||}t|duxrC|jdtj|j j k(S)N body_digest)raboolrrprqrrs)rrrrtexts rTcandidate_body_boundrfTsV &h GD  D T KK &'..*G*Q*Q*S S rSc ,t|ttk7s|jddk7ry|jd}t|tsyt t }|t jvr t jjd| tjd}tt t|ddj}|jtjsyt!|}|j#d t$d d d |j'|t)j*}t|dd}t|tr|rt5|dkDryd|fS#t,t.t0t2f$rYywxYw)Nr$r7)FNr%rz'checkin_cli.nutrition_onboarding_models__file__rcz1.0 completedpending unpublished)schema_versionrsession_statusreview_decisionpublication_status)as_ofiT)rr6rrr[r@syspathinsert importlib import_modulergetattrresolveis_relative_torBrupdaterbuild_onboarding_baselinertoday ImportErrorOSError TypeError ValueErrorr)r rationalepackagemodelssourcerbaseline normalizeds rTshipped_baseline_validationrasX 7|s6{"gkk2E&F*&T 01I i %%&Gchh 7#(()RSc'&*b9:;CCE$$%7%?%?%ABw- &%,  33G4::<3PX';TB  j# &jC Oc.s 0iU5D=i)Fz5publication contains forbidden internal or stale copy)u- 목표: 유지u- 활동: 보통u주 3회u60분u6,000~8,000보u%별도 검토 입력이 없습니다.c3&K|]}|v ywrorRrs rTr z.publication_summary_quality..s3(u}(r)Fz8publication lacks Korean goal/activity/no-review summary)Tz,candidate-render-bound Korean summary passed)rarfanyr\)rrrr forbiddenrequiredres @rTpublication_summary_qualityrsf &h GD |/'='G I 0i 00MH 3(3 3P ?rSc |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_attestationrr rrarclarification_fieldREADY_CUSTOMER_REVISIONrrreviseuVpress the existing 수정 button, then resubmit the unchanged final canonical answer; ) r\r]r^r_rarb next_field next_valuere) rrrrr&r@r6r rrfrr[r)rrr authorityrrrrr quality_okreasonrrras rTcandidate_revision_handoffrs`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   rSc 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 driftrrrrz,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 committedrrrrcu<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 committedrrr\rREADY_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 driftrr^READY_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 unknownrrzowner 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)rrrrrdrMr[r rrr6rrZrrr&rfrCr@rrrrrrrrrg)-rrrrrrrcommitted_collectionrrra committedrrrrrgenmidrr body_boundrquality_detailrrrwrmatchedrrrgrelevant_generationsrrdiddrgeneration_tokens cards_valuercarddestr\s- rTclassifyrs 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)rprqrrrrs)rs rT event_hashrs3 >> 1<CCE ikrSc$|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)rNrR)rrs rTr zappend_event..s/;a;s r)schemasequenceprevious_event_sha256rrrQ)parentmkdirchmodrxrrrrSCHEMAsumopenrr~O_WRONLYO_CREATO_APPEND O_CLOEXECwriterrfsyncclose)rreventpreviousr_rowfds rT append_eventrs#KKdT2KKeH {{} ++-ycc}wro)r~walkrSKIPrr)rirdirsrrs rTadd_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: ) ryis_dirrrinotify_add_watchrr~fsencodeMASKrMr r)rirtrrs rTrz Watcher.addsq <<> {{440  " "477BKKND A q5 >!!56 6  SVrScXtj}|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_READselectrWr~readEVsizer unpack_fromsplitrOVERrMIGNOREDr rrr(rr) risecondsselrrHoffrmaskrnnamechilds rTwaitz Watcher.waitsP'') TWWi223 JJw'E&'IJJ''$''5)CC-3s8+ "sC 8 4Arww3q)//q9!<CCEq$;();<<'> ((DF3d:*$HHUO-3s8+ IIKCIIKs EFF)cBtj|jyro)r~rrrhs rTrz Watcher.closes rSN)rrrkNone)rtrrkrD)r:floatrkrD)rOrPrQr!r&rrArrRrSrTrrs+  !0rSrc td|jdk(rdndt|jdk(rdnd|jt |t |dd d d d S) NREADY_CONTINUOUS_LIFECYCLErREADY_FOR_DEPLOYARMED_POST_DEPLOYrPASS_SHIPPED_CHECKIN_CLINOT_APPLICABLEz recursive-inotify-before-actions`Tz=no raw updates, tokens, customer answers, or provider content) rr\deployment_readinessrbaseline_validationinitial_handoffcandidate_summary_revisionauthority_sha256event_subscriptionper_stage_timeout_maxtotal_timeout_maxprivacy)rr\rrjrr)rprompts rT ready_docrXsh.}} - $J}} 77 '!!::<&@&C&qM@!%"R) rSc 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)rhandoffrRTr)flushrz"bounded lifecycle deadline expired TRANSITION)rfromtor\rRr"PASS_CONTINUOUS_TO_CLEANUP_HANDOFF)rr\r final_handoff)rrprofiler&rrrrXrrmoderreventsrjrprintrrtime monotonicr\min stage_timeout total_timeoutrWrArrr) rrrrtrstartstagelast remainingr>qs rTrunrrsO 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)NreT)rr)rZobservez --profile)r rz--readyrtz--eventsz--stage-timeoutrL)r rz--total-timeoutrMrztimeout bound invalidr]zFAIL: )file)argparseArgumentParseradd_subparsers add_parser add_argumentrrE parse_argsrerkrlrMrgrrrrrWrqstderrr}rKeyError)rsprerrrs rTmainrVsw  "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__)rtrrkr[ro)rtrrobjectrkr)rrrklist[dict[str, object]])rbr[rrrkr[)rkr[)rrrr[rr[rkdict[str, object] | None)rrrkrl)rrlrkrD)rrlrrlrkrD)rrrkr[)r)rrlr]r[rkr)rrlrkzBtuple[dict[str, object], str, list[dict[str, object]], int] | None)rrlrktuple[bool, str])rrlrkr[)rrlrrlrrrkr`) rrlrrlrrrrlrkrd)rrlrkztuple[bool, str | None])rrlrkrd)rrlrkrd) rrlrrlrrrrlrkr)rrlrkr)rrlrkrZ)rrlrkr[)rrrrrlrkrD)rrrrrlrkrD)rkzdict[str, str]rC)rkr)rrlrWrZrkrl)rzargparse.Namespacerkrl)X__doc__ __future__rrxrrrprtrr~r.rzstructrqrh dataclassesrdatetimerpathlibrtypingrr rmr r rrrrrrrrrr6r?rrr@rBrCrDStructr4r+r8r9r$ RuntimeErrorrMrWrZrurrrrrrrrrrr&r@rSrarfrrrrrrrrrrrrrrXrrrrO SystemExitrRrSrTrskT"   !U 5UPePQuQPePRRT%TSS,, OUO 4U4%u2:|,n8z%gAC@BCEOQ   Q *!EU0-?E?M MEV]]6   \  ~  $   .6:$- ) )),)58))EP3Dl:>/'1:: #::z'9'9G'9T*GZ5p%%*;%LO%%P         B %@%@ %@%@ %@  %@P)Xh2V  , B --`29x6 z TV rS