ԴjdUdZddlmZddlZddlZddlZddlZddlZddlZddl 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(Z"ded)<ed*Z#d+Z$e jJd,Z&d-Z'd.Z(d/Z)hd0Z*Gd1d2e+Z,Gd3d4e,Z-ed56Gd7d8Z.dWd9Z/dXdYd:Z0dZd;Z1d[d<Z2d\d=Z3 d]d>Z4d^d?Z5d_d@Z6d`dAZ7dadBZ8 db dcdCZ9 dddDZ:dedEZ;dfdFZ< dgdGZ= dhdHZ>didIZ?djdJZ@dkdKZAdldLZBdmdMZCdndNZDdodOZEdpdPZFGdQdRZGdqdSZHdrdTZIdpdUZJeKdVk(r eLeJy)szNContinuous, event-first Task26 lifecycle observer and role-handoff controller.) annotationsN) dataclass)Path)Final@e2f1699e8586ed3f835eaa2a3eaeaecaf5e52a4ad82aa931caade0ed377077cer SUCCESSOR@b025a71695b620555f701f1c248545bd343428c430db37b2d8bd16148e0b0b7aCORE@bd5f44592e95b152cc466446fcbb607df586dc13482d0d3413fed80a476d2a70WHEEL@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@f04ea498ad12a257fb1322da4c8cfd2f91fc9403f0b978617fcc00df41729209)z1gateway/platforms/dualcoach_activation_cutover.pyz$gateway/platforms/dualcoach_admin.pyz0gateway/platforms/telegram_customer_bootstrap.pyzgateway/platforms/telegram.pyz8gateway/platforms/nutrition_onboarding_reconciliation.pyzFgateway/platforms/telegram_nutrition_onboarding_runtime_publication.pyRUNTIMEzK/home/cube/projects/richard/hermes-agent/.venv/lib/python3.12/site-packagesztask26-continuous-lifecycle-v3iIIIii@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-v3-e2f1699e/continuous_lifecycle.pyrErERrKrEc eZdZy)LifecycleTimeoutNrFrJrKrLrOrOVrMrKrOT)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)rTrUrVrWrYrZr\r]) rTrUrVlistrWrYrZr\r]selfs rLdocz Prompt.docesIkkIIZZ$**%//kk||kk  rKN)returndict[str, object])rGrHrI__annotations__r\r]rbrJrKrLrRrRZs; K I J  KGSFC  rKrRcdtj|jjSN)hashlibsha256 read_bytes hexdigest)ps rLsharmrs >>!,,. ) 3 3 55rKc|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_symlinkrEstatS_ISREGst_modest_uidosgetuidS_IMODEjsonloadsrjJSONDecodeError)rldefaultses rLloadrvs 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) isinstancer_dictget)vxks rLrowsrs!T41a 1d 3144!T4A!%%(D)#$Q4?4a:a+>4??5 I 5@sBB.BBctjtjtj j d}d|d|d|S)N=znon2::)base64urlsafe_b64encodebytesfromhexrdecoderstrip)rZ generationhs rLcallbackrsH  s!34;;=DDSIA 6(!J' --bootstrap-session zg --expected-generation 5 --package-root /home/cube/.hermes/profiles/dualcoachtest/workspace/checkin_cli)rrrJrKrL exact_cutoverrs4 b   M N   t  trKc |Dcgc]#}t|j|d|k(s"|%}}t|dk(r|dSdScc}w)Nr[r)rSrlen)seqfieldvaluerrs rL_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.jsonversionsteprYchat_idtopic_idfinalized_event_id)rrrrYrWrz)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)rrrrrrrrrSrp read_text splitlinesstripryrzr_values)rootbootbrregcrnrwfpubsprroutocwrbindractivebsbdraftgensrrrauditaps rLcapturers 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_idrrrWzcustomer route driftrzoutbox schema driftz duplicate publication generationrUownerzpublication role route driftrrT sent_auditedrzduplicate sent_audited delivery)rrrrrrErrsetr_addrrr) r}rcseenrrrrUrWdterminals rLvalidate_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)rrrrintrE)arawbwrbpavbvs rLvalidate_transitionr&sa 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 ! rKctj|ddddj}tj|j S)NFT,r) ensure_ascii sort_keys separators allow_nan)rydumpsencoderhrirk)rencodeds rLcanonical_digestrEsEjj    fh   >>' " , , ..rKcv|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 COMMITTEDpayloadrrYrrrrUrWrrc3K|]n}t|tr\|jdtk(rD|jddk(r0t |jdt urt |dpyw)rrrrN)rrrrtyper).0records rL z(committed_publication..rsd  &$' <(G3 7#{2VZZ -.#5 |$ % sA4A6)r|r) rrrrrr_rrrmaxr) r}rUrrrrYrrmatcheslatests rLcommitted_publicationrPs%% &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)rrrrrr_rrrrSrr5rappend) rr rrr r r keyrunsignedtypedritems rLreconciliation_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.rT>noneprovidedFzstructured answer unavailable: r/)Fz#health review input requires reviewr0Tzgoal=z ; activity=z; health=no-review)rrrSr)r  goal_valuegoalactivity_valueactivityrrs rLsummary_qualityr4s-[)J j# &xBFFzR  [[!45N nc * "  -+  #n    |<@ E"%&%))H*=F + ;E7CC C{{,-U:;{{)*%7; 5k(3EF FFrKc 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|ywrg)rSrrs rLrz7authoritative_summary..value..s734SY3s)rrr_joinrS)rr|rawr s rLrz$authoritative_summary..valuesTkk%  ;#)sbyN c4 997377B7 B3xrKcj|}t|tsy|jddk(ry|jd}|jddk7st|tsydj d|DxsdS) Nr6rTr.u없음rr/r8c3HK|]}t|ts|s|ywrgrrSr:s rLrz.structured..sOut 40E$dus """)rrrr_r;)rr<rr s rL structuredz)authoritative_summary..structureds|kk% #t$ 778  &  778  **UD2I IIOuO O  rKrrrrr%r#r$r%r&r'r(r#u · c3>K|]\}}|d|yw) NrJ)rlabelrr@s rLrz(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=- 건강 관련 입력: 별도 검토 입력이 없습니다.)r6)rrSr|rSrcrS)rrSrcrS)rrSr;)r rr1r3 restrictionsr@s` @rLauthoritative_summaryrFs  (H E I I GKK $% D)'   c#gkk-. /0  ;;    L 99,- .0[1eR=S T&< => ?8 G K   rKc|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) Nr advisory summary_kou 입력 내용을 정리했어요r[))u확인된 내용facts_ko)u안전 관련 참고사항safety_observations_korJc3<K|]}t|tywrgr?r:s rLrz-candidate_attestation_text..#s@28$ 4%&sc3&K|] }d| yw)z- NrJr:s rLrz-candidate_attestation_text..'s&FvtD6{vs)r[u\이 요약은 참고용이며 안전 판정·승인·활성화를 대신하지 않습니다.u=내용이 맞으면 아래 확인 버튼을 눌러 주세요.rDu 아래 버튼을 누르면 입력 확인이 저장되고 운영자 검토로 넘어갑니다. 이 단계에서 영양 코칭이 시작되거나 활성화되지는 않습니다.) rrrrFrSr_tupleallextendr;) rr r r rHsummarylinestitlerrs rLcandidate_attestation_textrTs\\"23N nd +!!*-H h %*7g&X\\,=W  gs #7 /W =E s%(,,s*; ftUm4C@28@= LL"eG&Fv&FG H LL  % ] ]rKct|||C|jdtjj j k7ryd}t fd|Dryd}tfd|Dsyy ) N body_digest)Fz.publication body is not candidate-render-bound){rrTr6u 수정 전u 실제 총활동량은 불명확u 위험 신호c3&K|]}|v ywrgrJrtokentexts rLrz.publication_summary_quality..Ks 0iU5D=i)Fz5publication contains forbidden internal or stale copy)u- 목표: 유지u- 활동: 보통u%별도 검토 입력이 없습니다.c3&K|]}|v ywrgrJrYs rLrz.publication_summary_quality..Ns3(u}(r\)Fz8publication lacks Korean goal/activity/no-review summary)Tz,candidate-render-bound Korean summary passed)rTrrhrirrkanyrO)rr r r forbiddenrequiredr[s @rLpublication_summary_qualityra6sw &h GD ;;} % )F)P)P)R RFI 0i 00M`H 3(3 3P ?rKc |jd}t|}t|tr|jddk7s|yt |}|jd}|t|tsy|\}}}}t |\}} |s,|jddk7s|jd|k7sd|vryt d} |jd} |jd } t| tust| turyd d ttd gt| td | | |j| d| zd S)Nrrcustomer_attestationrrclarification_fieldrrrYREADY_CUSTOMER_SUMMARY_REVISIONrrreviseuVpress the existing 수정 button, then resubmit the unchanged final canonical answer; ) rTrUrVrWrYrZ next_field next_valuer]) rrrrrr4r5rrrrSr) r}rr authorityrr r_ quality_okreasonrrrYs rLcandidate_revision_handoffrmSs>uuZ H'*K x & << $: :  (2Iooi(G 7D 9$-!G^Q(1J ;;w #9 9 ;;' (N : G + 2JE.J.J Js"d:&6c&A3C*o8Z0kk%(j   rKc 8t||d}|d}|jd}|jd}t|trt|tsJt |jd}|jddk(rt|ts t dt |jd}|d k(rt|jd d }d |cxkrttkrn t d t|ts t d td dttdft |jddt|d|dzdSt|}|dk(r|tdddddddS|d} t| tsJt|} | tddddddS| \} } } }| jddk7s| jd| k7rtdddddddS|jd }|jd}t|tust|tur t d!|}t |}|d"}t|tsJ|dd#k(rM| |d$}| jd%|k7rtddddddd&Std'dttdf|d(|d)Sd%| vrtddddddd*St| \}}|rt!|| || \}}|std+d,d,d|d-|Std.dttdf|t#d/|d0d1|zSt|d2}t|ts t d3|jd }|jd}t|tust|tur t d!|}t |}|d4k(r&td5d2t$t$df|t#d6|d0d7S|d8k(rtd9d2t$t$df|d:S|d;vr/|dStd?d,d,ddd@t'dASt dB|jddCk7s|jd dDk7r t dE|jdFi}g}t|trY|j)Dcgc]@}t|tr.|jdGt*k(r|jdHdIk(r|B}}|r&|rtdJd,d,dddKdLStdMd,d,dddNdOS|s t dP|jdQ}t|tstdRdttdfddSdTS|jdUtdgk7r t dV|jdWdXk7rFtdYdttdft |jddZ|jdWd[S|jd\s4td]dttdft |jdd^d_S|jd`i}g}t|tro|j-Dcgc]T\}}t|tr?|jdGt*k(r'|jda|jdak(r||fV}}}|jdbg}t|t.s t dc|D cgc]O} t| tr=| jdGt*k(r%| jda|jdak(r| Q}!} |s|!r t ddtdedddddfdgS|D"cgc]}"|"djdHdhvr|"}#}"t|#dk7r t di|#d \}$}%|!D chc]3} t| jdjt s#| jdj5}&} |jdkg}'t|'t.s t dl|'D"cgc]s}"t|"tra|"jdm|$k(s7|"jdj|$|%jdnhvs|"jdj|&vr|"jddok(r|"u}(}"t|(dk7r t dp|(d })|)jdq}*|*t$t$ddrk7r t dst |%jdH}+|+dtvr8tdud2t$t$dft |)jddv|$dwdxS|+dyk(r8tdzd2t$t$dft |)jddv|$d{d|St d}cc}wcc}}wcc} wcc}"wcc} wcc}"w)~Nrrrrenabledrrzonboarding workflow unavailablerrrzcollection authority driftREADY_CUSTOMER_ONBOARDINGrrYzsubmit_answer:zanswer onboarding question rz'/22 by replying to the committed prompt)r]rc"WAIT_MATCHING_CUSTOMER_PUBLICATIONsystem)localrzpublication:autoz0workflow state alone never authorizes a callbackrWAIT_RECONCILIATION_AUTHORITYzreconciliation:autorz>resolved authority precedes its matching committed publicationrz$committed publication identity driftr rrrdz,clarification field is not publication-boundREADY_CUSTOMER_CLARIFICATIONzsubmit_clarification:z5reply only to the committed field-bound clarificationz8resolved authority still has a clarification publicationSTOP_CUSTOMER_SUMMARY_QUALITYoperatorz do-not-attestREADY_CUSTOMER_ATTESTattestr[z6press 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 committedrrrTrREADY_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-inrWzcheckin route driftrrQREADY_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 unknownrZrzowner 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)rrrrboolrErSrrr5rRrrrrr4rarrrrrrr_),r}rrrrlrorcur committedrrir rr r rrYgenmidr rrkquality_detailrrrwrmatchedrrrgrelevant_generationsrrdiddrgeneration_tokens cards_valuercarddestrTs, rLclassifyr|s a +A * A z B mA a :a#66 6155#$GuuW~.."d# !BC CBFF7O$ L bffXq)*C)c&k)$%ABB2>;;/0NB8"&[#|4J"|4JJs*d:.>c.I$%KLLCj/C 01Nnd3 33g&,6&}5g>;;45>!<  &*M2sO+E73R%/8"&U*9)A &J-H.* N3"#)'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.-Ae=!Af.Af)f /$ffA8fctjtj|ddj j S)NTrrr)rhriryrrrk)rs rL event_hashrs3 >> 1<CCE ikrKc$|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)rNrJ)rrjs rLrzappend_event..s/;a;s r)schemasequenceprevious_event_sha256rrrD)parentmkdirchmodrprrryrzSCHEMAsumopenrrvO_WRONLYO_CREATO_APPEND O_CLOEXECwriterrfsyncclose)patheventpreviousrRrowfds rL append_eventrs#KKdT2KKeH {{} ++-ycc}wrg)rvwalkrSKIPrr)rardirsrjrs rLadd_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: ) rqis_dirrrinotify_add_watchrrvfsencodeMASKrErr)rarlrrs rLrz Watcher.addsq <<> {{440  " "477BKKND A q5 >!!56 6  SVrKcXtj}|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_READselectrOrvreadEVsizer unpack_fromsplitrOVERrEIGNOREDrrrrrr) rasecondsselrr<offrmaskrjnnamechilds rLwaitz Watcher.waitsP'') TWWi223 JJw'E&'IJJ''$''5)CC-3s8+ "sC 8 4Arww3q)//q9!<CCEq$;();<<'> ((DF3d:*$HHUO-3s8+ IIKCIIKs EFF)cBtj|jyrg)rvrrr`s rLrz Watcher.close4s rKN)rrrcNone)rlrrcr)rfloatrcr)rGrHrIrrrrrrJrKrLrrs+  !0rKrc ttdt|jt|t |ddddd S)NREADY_CONTINUOUS_LIFECYCLEz recursive-inotify-before-actions`Tz=no raw updates, tokens, customer answers, or provider content) rrTrinitial_handoffcandidate_summary_revisionauthority_sha256event_subscriptionper_stage_timeout_maxtotal_timeout_maxprivacy)rrrbrmr)r}prompts rL ready_docr8s;.J!::<&@&C&qM@!%"R  rKc 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)rhandoffrTr)flushrz"bounded lifecycle deadline expired TRANSITION)rfromtorrr"PASS_CONTINUOUS_TO_CLEANUP_HANDOFF)rrTr final_handoff)rrprofilerrrrrrrmoderreventsrbrprintryrtime monotonicrTmin stage_timeout total_timeoutrOrrrr) rrr}rlrstartstagelast remainingrqs rLrunr0GsO 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)rr`)robservez --profile)rr`z--readyr2z--eventsz--stage-timeoutr )rr|z--total-timeoutr rztimeout bound invalidrzFAIL: )file)argparseArgumentParseradd_subparsers add_parser add_argumentrr  parse_argsr#r)r*rEr%ryrr0rOsysstderrOSError ValueErrorKeyError)rspr#rrr~s rLmainrBsw  "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__)rlrrcrSrg)rlrr|objectrcrD)rrDrclist[dict[str, object]])rZrSrrrcrS)rcrS)rrErrSrrSrcdict[str, object] | None)rrrcrd)r}rdrcr)rrdrrdrcr)rrDrcrS)r)r}rdrUrSrcrF)rrdrczBtuple[dict[str, object], str, list[dict[str, object]], int] | None)r rdrctuple[bool, str])r rdrcrS)rrdr rdr rrcrX) rrdr rdr rrrdrcrG)r}rdrcrF)r}rdrcrR)rrdrcrS)rrrrdrcr)rrrrdrcr)rczdict[str, str]r)rcr)r}rdrrRrcrd)rzargparse.Namespacercrd)M__doc__ __future__rr6rrrhryrvrrrstructr<r& dataclassesrpathlibrtypingrrrer r rrrrrrrrrr5r<rrStructrrrrr RuntimeErrorrErOrRrmrrrrrrrrrrrr4rFrTrarmrrrrrrrrrr0rBrG SystemExitrJrKrLrQsT"   !U 5UPePQuQPePRRT%TSS,, OUO 4U4%u2:|,n8z%gACOQ  Q *V]]6   \  ~  $   .6:$- ) )),)58))EP3Dl:>/'1,O,O #,O,O^'9'9G'9T*GZ5p%%*;%LO%%P@@ @@ @  @:&RJ2Z  , B --` 9x6 z TV rK