+
    "Ý³j  ã                   ó¾   € R t ^ RIt^ RIHt ^ RIHt ^ RIHt ^RIH	t	 ^RI
Ht ^RIHtHtHt ^RIHt ^R	IHtHt  ! R
 R]4      t ! R R]4      t ! R R4      tR# )zFCheckpoint policy composed with looper boundaries and a state adapter.N)Úasdict)ÚPath)ÚProtocol)Úemit_device_telemetry)Ú,checkpoint_identity_without_physical_gpu_ids)ÚCheckpointConfigÚCheckpointErrorÚCheckpointStore)ÚContinuationCodec)ÚLoopBoundaryÚLoopPlanc                   óH   a € ] tR t^t o RtV 3R lR ltV 3R lR ltRtV tR# )ÚCheckpointAdaptera_  Adapters own model/processor schema, never scheduling or publication.

capture() returns full continuation and a complete artifact mapping; blobs
may be reused by digest across generations. restore() must validate its
schema before mutating live state. Unsupported processors fail in prepare,
before the looper runs, not halfway through a checkpoint.
c                ó\   <€ V ^8„  d   QhRS[ S[S[S[S[S[,          3,          3,          /# )é   Úreturn)ÚtupleÚobjectÚdictÚstrÚbytesr   )ÚformatÚ__classdict__s   "€Ú\/home/luca/screen-checking/.venv/lib/python3.14/site-packages/gptqmodel/looper/checkpoint.pyÚ__annotate__ÚCheckpointAdapter.__annotate__   s&   ø€ ×DÑD™™v¡t©C±¹µÐ,=Õ'>Ð>Õ?ÑDó    c                ó   € R # ©N© ©Úselfs   &r   ÚcaptureÚCheckpointAdapter.capture   s   € Ár   c                ó@   <€ V ^8„  d   QhRS[ RS[S[S[3,          RR/# )r   ÚcontinuationÚ	artifactsr   N)r   r   r   r   )r   r   s   "€r   r   r      s    ø€ ×TÑT¡FÐT±t¹CÁ¸IµÐTÈ4ÑTr   c                ó   € R # r   r   )r!   r%   r&   s   &&&r   ÚrestoreÚCheckpointAdapter.restore   s   € ÑQTr   r   N)	Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r"   r(   Ú__static_attributes__Ú__classdictcell__©r   s   @r   r   r      s   ø‡ € ñ÷ EÐDçTÖTr   r   c                   ó   € ] tR t^tRtRtR# )ÚCheckpointStoppedzFA requested stop was committed at a safe boundary; restart can resume.r   N)r*   r+   r,   r-   r.   r/   r   r   r   r3   r3      s   † ÝPr   r3   c                   ór   a € ] tR t^"t o RtV 3R lR ltR tR tV 3R lR ltR t	R	 t
V 3R
 lR ltRtV tR# )ÚCheckpointExtensiona  The store lease must enclose prepare, execution, and finalization.

No signal handlers are installed globally. A caller's SIGINT/SIGTERM handler
may call request_stop(); it does no I/O or synchronization. Hard kills need
no handler and recover using the store's published generations.
c                ó&   <€ V ^8„  d   QhRS[ RS[/# )r   ÚconfigÚadapter)r   r   )r   r   s   "€r   r   Ú CheckpointExtension.__annotate__*   s   ø€ ÷ %ñ %Ñ/ð %Ñ:Kñ %r   c                óž   € \        TVP                  '       g   \        MR R7      V n        W n        R V n        ^ V n        ^ V n        RV n        R # )N)Úidentity_projectionF)	r	   Ústrict_device_checkr   Ústorer8   ÚplanÚ	next_stepÚ_committed_cursorÚ_stop_requested)r!   r7   r8   s   &&&r   Ú__init__ÚCheckpointExtension.__init__*   sK   € Ü$Øà×-×-Ð-õ !Màô	
ˆŒ
ð ŒØˆŒ	ØˆŒØ!"ˆÔØ$ˆÖr   c                ó:   € V P                   P                  4        V # r   )r=   Ú	__enter__r    s   &r   rE   ÚCheckpointExtension.__enter__7   s   € Ø�
‰
×ÑÔØˆr   c                ó6   € V P                   P                  ! V!  # r   )r=   Ú__exit__)r!   Úargss   &*r   rH   ÚCheckpointExtension.__exit__;   s   € Ø�z‰z×"Ò" DÑ)Ð)r   c                ó,   <€ V ^8„  d   QhRS[ RS[RS[/# )r   r>   Úidentityr   )r   r   Úint)r   r   s   "€r   r   r9   >   s'   ø€ ÷ Bñ B™Hð B±ð B¹ñ Br   c           
     ó\  € V P                   e   \        R4      h/ VCRVP                   Uu. uF  p\        V4      NK  	  up/CV n        \        R\        V P                  P                  4      VP                  R4      R7        V P                  P                  V P                  4      pTEeß   TR,          \        TP                  4      8”  d   \        R	4      hTR
,          P                  R4      TP                  R4      8H  pT P                  P                  P                  '       g*   \        P                  ! \         4      P#                  R4       \        RTR,          TR
,          P                  R4      TP                  R4      RT P                  P                  P                  TR7       \        RTR,          TR,          R7        \$        P&                  ! T P                  P                  TR,          4      4      pTR,          P)                  4        UU	u/ uF   w  r‰Y€P                  P+                  T	4      bK"  	  p
pp	T P,                  P/                  Yz4       TR,          ;T n        T n        \        RT P4                  R7       Yn         T P4                  # u upi   \         d;   p\        R\        T P                  P                  4      \        T4      R7       h R p?ii ; iu up	pi   \0         d/   p\        RTR,          \3        T4      P                   R7       h R p?ii ; i)Nz-checkpoint extension cannot be prepared twiceÚexecution_planÚcheckpoint_prepareÚdevice_topology)ÚrootrQ   Úcheckpoint_prepare_rejected)rR   ÚreasonÚcursorz/checkpoint cursor is outside the execution planrL   zÌCheckpoint strict device UUID/serial checks explicitly disabled; GPU count, indices, pools, model and capability checks remain enforced. Bit-exact quantization across different hardware is not guaranteed.Úcheckpoint_topology_validatedT)rU   Úexpected_topologyÚactual_topologyÚmatchedr<   Úphysical_identity_matchedÚcheckpoint_restore_beginr%   )rU   r%   r&   Úcheckpoint_restore_failed)rU   Ú
error_typeÚcheckpoint_restore_complete©rU   )r>   r   Ústepsr   rL   r   r   r=   rR   ÚgetÚloadÚlenr7   r<   ÚloggingÚ	getLoggerr*   Úwarningr
   ÚloadsÚitemsÚobject_pathr8   r(   Ú	ExceptionÚtyper?   r@   )r!   r>   rL   ÚstepÚmanifestÚexcrZ   r%   ÚnameÚrefr&   s   &&&        r   ÚprepareÚCheckpointExtension.prepare>   s¸  € Ø�9‰9Ò Ü!Ð"QÓRÐRð
Øð
à¸¿
º
ÓC¹
°œv dž|¹
ÑCñ
ˆŒô 	Ø Ü�T—Z‘Z—_‘_Ó%Ø$ŸL™LÐ):Ó;õ	
ð
	Ø—z‘z—‘ t§}¡}Ó5ˆHð ÓØ˜Õ!¤C¨¯
©
£OÔ3Ü%Ð&WÓXÐXØ(0°Õ(<×(@Ñ(@Ø!ó)à—‘Ð/Ó0ñ)1Ð%ð —:‘:×$Ñ$×8×8Ð8Ü×!Ò!¤(Ó+×3Ñ3ðZôô
 "Ø/Ø Õ)Ø"*¨:Õ"6×":Ñ":Ð;LÓ"MØ (§¡Ð->Ó ?ØØ$(§J¡J×$5Ñ$5×$IÑ$IØ*Cõô "Ø*Ø Õ)Ø% nÕ5õð
Ü0×6Ò6Ø—J‘J—N‘N 8¨NÕ#;Ó<ó �ð
 &.¨kÕ%:×%@Ñ%@Ô%Bôá%B™	˜ð Ÿ*™*×0Ñ0°Ó5Ò5Ù%Bð ñ ð —‘×$Ñ$ \Ô=ð 7?¸xÕ6HÐHˆDŒN˜TÔ3Ü!Ð"?ÈÏÉÕWØŒ	Ø�~‰~Ðùò{ Døô ô 	Ü!Ø-Ü˜Ÿ™Ÿ™Ó)Ü˜3“xõð
 ûð	üóJøô
 ô Ü%Ø/Ø# HÕ-Ü# C›y×1Ñ1õð
 ûðúsH   ¬JÂ%J$ ÇAK2 È&K,ÉK2 Ê$K)Ê/5K$Ë$K)Ë,K2 Ë2L+Ë=)L&Ì&L+c                ól   € V P                  VP                  V P                  P                  V4      4      # r   )rq   r>   r8   Úbind)r!   Úcontexts   &&r   Úon_startÚCheckpointExtension.on_start‚   s&   € Ø�|‰|˜GŸL™L¨$¯,©,×*;Ñ*;¸GÓ*DÓEÐEr   c                ó   € R V n         R# )TN)rA   r    s   &r   Úrequest_stopÚ CheckpointExtension.request_stop…   s
   € Ø#ˆÖr   c                ó    <€ V ^8„  d   QhRS[ /# )r   Úboundary)r   )r   r   s   "€r   r   r9   ˆ   s   ø€ ÷ 5Xñ 5X¡Lñ 5Xr   c           	     óú  € V P                   f   \        R4      hV P                   P                  VP                  4      pW P                  ^,           8w  d   \        R4      hW P
                  ,
          V P                  P                  P                  8¬  ;'       g7    V\        V P                   P                  4      8H  ;'       g    V P                  pV'       Ed    VP                  4        \        RVR7       V P                  P                  4       w  rEV P                  P!                  \"        P$                  ! V4      4      pVP'                  4        UUu/ uFR  w  rxT\)        V\*        4      '       d   V P                  P-                  V4      MV P                  P!                  V4      bKT  	  p	ppV P                  P/                  V P0                  VVV	R7       W n        \        RVV\        V	4      R7       \3        V P                  RR 4      p
V
eM   T
! V	P'                  4        UUu/ uF)  w  r{WpP                  P4                  R	,          V,          bK+  	  upp4        V P                  P7                  4        W n        V P                  '       d   \        RVR7       \C        RV 24      hR # u uppi u uppi   \8        \        3 d/    \:        P<                  ! \>        4      PA                  R
RR7        Li ; i)Nz1prepare the checkpoint extension before executionz-boundary does not follow the execution cursorÚcheckpoint_capture_beginr_   )rL   rU   r%   r&   Úcheckpoint_committed)rU   r%   Úartifact_countÚ	committedÚobjectsz.Checkpoint committed but object cleanup failedT)Úexc_infoÚcheckpoint_stoppedz'checkpoint committed; resume from step )"r>   r   Úafterrl   r?   r@   r=   r7   Úinterval_layersrc   r`   rA   Úquiescer   r8   r"   Úputr
   Údumpsrh   Ú
isinstancer   Úput_fileÚcommitrL   ÚgetattrrR   ÚcollectÚOSErrorrd   re   r*   rf   r3   )r!   r|   rU   Úduer%   r&   Úcontinuation_refro   ÚdataÚartifact_refsÚcallbackrp   s   &&          r   Úon_boundaryÚCheckpointExtension.on_boundaryˆ   s�  € Ø�9‰9ÒÜ!Ð"UÓVÐVØ—‘—‘ §¡Ó/ˆØ—^‘^ aÕ'Ô'Ü!Ð"QÓRÐRà×+Ñ+Õ+¨t¯z©z×/@Ñ/@×/PÑ/PÑP÷ $ð $Øœ˜TŸY™YŸ_™_Ó-Ñ-÷$ð $à×#Ñ#ð 	÷
 ˆ3Ø×ÑÔÜ!Ð"<ÀVÕLØ&*§l¡l×&:Ñ&:Ó&<Ñ#ˆLØ#Ÿz™zŸ~™~Ô.?×.EÒ.EÀlÓ.SÓTÐð
 #,§/¡/Ô"3ô	ñ #4‘J�Dð Ü˜d¤D×)Ò)ð —j‘j×)Ñ)¨$Ô/à—Z‘Z—^‘^ DÓ)ò*ñ #4ð	 ñ ð �J‰J×ÑØŸ™ØØ-Ø'ð	 ô ð &,Ô"Ü!Ø&ØØ-Ü" =Ó1õ	ô ˜tŸ|™|¨[¸$Ó?ˆHØÒ#Ùð *7×)<Ñ)<Ô)>ôá)>™I˜Dð Ÿj™jŸo™o°	Õ9¸CÕ?Ò?Ù)>òôðØ—
‘
×"Ñ"Ô$ð  ŒØ××ÐÜ!Ð"6¸vÕFÜ#Ð&MÈfÈXÐ$VÓWÐWñ  ùóGùó,øô œ_Ð-ô ä×!Ò!¤(Ó+×3Ñ3ØDÈtð 4ö ðús   ÅAJ/È(/J5
É J; Ê;<K:Ë9K:)r@   rA   r8   rL   r?   r>   r=   N)r*   r+   r,   r-   r.   rB   rE   rH   rq   rv   ry   r•   r/   r0   r1   s   @r   r5   r5   "   sB   ø‡ € ñ÷%ð %òò*÷Bð BòHFò$÷5Xö 5Xr   r5   )r.   rd   Údataclassesr   Úpathlibr   Útypingr   Úutils.device_telemetryr   Úcheckpoint_devicesr   Úcheckpoint_storer   r   r	   r%   r
   Ú	extensionr   r   r   r3   r5   r   r   r   Ú<module>rž      sP   ðá Lã Ý Ý Ý å :Ý Lß PÑ PÝ +ß -ôU˜ô UôQ˜ô Q÷[Xó [Xr   