8#j1dZddlmZddlmZddlmZmZmZddl m Z m Z m Z m Z mZdZdZeGdd Zdd Zdd Zdd Zdd ZddZy)u#utils.anu_callback_fallback — fallback cancel-on-success signal decider. task-2635 — normal callback registration enforcement (Core hardening). task-2635+1 — 5축 schema 인식 (registration_result_status 우선, legacy alias fallback). Spec: memory/specs/system_normal_callback_registration_implementation_spec_260523.md sha256: 0fbd1dad1e110c49474dfbdf13a21fb3bdd9c7f094128004dba8472840bb832d 회장 verbatim (task-2635 §3.4): ANU fallback cron 의 cancel-on-success signal = ``normal_callback_registration_status == REGISTERED`` + collector durable-success 마커 생성 단순 envelope sendfile 또는 result.json 존재 만으로는 cancel 안 함 (false cancel 차단) ANCHOR-4: fallback cancel-on-success = REGISTERED status + collector durable-success 마커. ) annotations) dataclass)AnyListOptional) NormalCallbackRegistrationStatusRegistrationResultStatusis_callback_completeis_success_statusnormalize_statuszutils.anu_callback_fallback.v2) collector_durable_success_markercollector_done_marker_pathcDeZdZUded<ded<ded<ded<dZded <y) FallbackDecisionboolcancel_fallbackstrreasondurable_success_marker_presentstatusNz Optional[str] schedule_id)__name__ __module__ __qualname____annotations__rN/home/jay/workspace/.worktrees/task-2729+7-dev1/utils/anu_callback_fallback.pyrr+s" K$(( K!%K%rrct|tstjjSd|vrt |j dSt |j dS)u:task-2635+1 — read axis-3 with backward-compat fallback.registration_result_statusregistration_status) isinstancedictr NOT_REGISTEREDvaluer getenvelopes r _read_axis_3r)4sP h %'66<<<#x/ -I JKK HLL)>? @@rct|tsy|jddury|jd}t|tr|j ryy)zTrue iff the envelope carries an authoritative collector durable-success marker. Either an explicit boolean (preferred) or a non-empty path. Fr Tr)r"r#r&rstrip)r(paths rhas_durable_success_markerr-=sM h %||674? <<4 5D$ rcRt|ts'tdddtjj St |}|jdxsd}t|}|tjj k(rD|jdr#|jddurtdd ||| Stdd ||| S|tjj k7rtdd |d ||| S|stdd||d S|stddd|| Stddd|| S)a0Decide whether to cancel the fallback safety-net cron. Returns ``cancel_fallback=True`` ONLY when: * registration_result_status == REGISTERED (real cron fired) * cron_schedule_id present (recovered from registrar) * collector durable-success marker present Fenvelope is not a dict)rrrrcron_schedule_idNexplicit_skip_reason(explicit_skip_authorizes_fallback_cancelTz;skipped with explicit reason + pre-approved fallback cancel)rrrrru\skipped status but explicit_skip_authorizes_fallback_cancel not set — fallback stays armedstatus z != REGISTERED (fail-closed)u@REGISTERED but cron_schedule_id missing — false cancel blockedz>REGISTERED + schedule_id present but no durable-success markerz;REGISTERED + schedule_id + collector durable-success marker) r"r#rrr$r%r)r&r-r SKIPPED_WITH_EXPLICIT_REASON REGISTERED)r(rrdurables rdecide_fallback_cancelr7Ksr h %!++03BBHH   ( #F,,12:dK(2G )FFLLL <<. /HLL 65 5$ $T/6'   !3,3#  )44:::!VJ&BC+2#    !U+2    !S+0#    L'+  rc*tt|S)uTrue iff a real normal callback was registered (REGISTERED + schedule_id). SKIPPED / NOT_REGISTERED / SENDFILE_ONLY / REGISTER_FAILED → False. )rr r's rexpected_collector_spawnr9s $X. //rc<t|tsdgSg}t|}t|s|j d|d|t j jk(r"|jds|j dt|s|j d|S)Nr/r3z is fail-closedr0z'REGISTERED but cron_schedule_id missingz'no collector durable-success marker yet) r"r#r)r appendr r5r%r&r-)r(reasonsrs rexplain_fail_closedr=s h %())G ( #F V $ /:; )44:::8<<D @A %h /@A NrN)r(rreturnr)r(rr>r)r(rr>r)r(rr>z List[str])__doc__ __future__r dataclassesrtypingrrrutils.callback_envelope_schemarr r r r FALLBACK_DECIDER_SCHEMADURABLE_SUCCESS_MARKER_KEYSrr)r-r7r9r=rrrrFsg$#!&&;  && &A K\0 r