
    Αi                      % S SK Jr  S SKrS SKrS SKrS SKrS SKrS SKrS SKrS SK	J
r
JrJrJrJr  S SKrS SKJr  S SKrS SKJr  S SKrS SKJr  S SKJr  S SKJr  S SKJr  S S	KJ r J!r"J#r#  S S
KJ$r$  S SK%J&r&  S SK'J(r(J)r)  S SK*J+r+  S SK,J-r-J.r.J/r/  S SK0J1r1J2r2  S SK3J4r4  S SK5J6r7  SSK8J9r9J:r:  SSK;J<r<  \
(       aT  S SK=J>r>J?r?  S SK@J	rA  S SKJBrB  S SKCJDrD  SSK8JErE  SSK;JFrF  \\B\AR                  \   \H\B   \H\AR                  \      4   rIS\JS'   / rKSqLS rMS rNS rOS  rPS! rQS" rRS# rSS$ rTS/S% jrUS& rV " S' S(5      rW " S) S*5      rX " S+ S,5      rY " S- S.5      rZg)0    )annotationsN)TYPE_CHECKINGAnyLiteralUnionoverload)	TypeAlias)base)no_grad)core)global_scope)Variable_current_expected_place__get_paddle_place)fleet)
role_maker)in_dynamic_modein_pir_mode)is_belong_to_optimizer)
DataLoaderDatasetDistributedBatchSampler)INFER_MODEL_SUFFIXINFER_PARAMS_SUFFIX)Metric)	InputSpec   )EarlyStoppingconfig_callbacks)summary)CallableSequence)Tensor)_DTypeLiteral)Callback)ModelSummaryr	   _InputBatchFc                ^    U c  U $ [        U [        [        45      (       a  [        U 5      $ U /$ N)
isinstancelisttuple)values    Q/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/hapi/model.pyto_listr/   R   s.    }%$''E{7N    c                   [        U [        [        R                  R                  R
                  [        R                  R                  R                  R                  45      (       d   S5       e[        U [        R                  R                  R
                  5      (       a  [        R                  " U 5      $ [        5       R                  U R                  5      R                  5       n[        R                  " U5      $ )Nznot a variable)r*   r   r
   r   eagerr#   paddle	libpaddlepirValuenparrayr   find_varname
get_tensorvarts     r.   to_numpyr?   Z   s    h		..0E0E0I0I0O0OP    #tyy--..xx})446A88A;r0   c                    [        U [        5      (       d   S5       e/ n/ nU  H=  n[        U[        5      (       d   S5       eUR                  [        U5      5        X-  nM?     X4$ )Nz
not a listzsub content not a list)r*   r+   appendlen)loutlsplitssls       r.   flatten_listrG   d   sh    a,,DF"d##=%==#c"g
  <r0   c                z    / nU H2  n[        U 5      U:  d   S5       eU S U XS  pUR                  U5        M4     U$ )Nzlist length invalid)rB   rA   )rC   rE   rD   splitrF   s        r.   restore_flatten_listrJ   o   sJ    D1v5 55&5	1V9AB  Kr0   c                B    [         R                  " U 5      R                  $ r)   )inspectgetfullargspecargs)funcs    r.   extract_argsrP   x   s    !!$',,,r0   c                `    / n[         R                  " X5        [        R                  " USS9nU$ )Nr   )axis)dist
all_gatherr3   concat)xoutputs     r.   _all_gatherrX   |   s(    FOOF]]6*FMr0   c           	        [        U [        5      (       a   e Sn/ nU  H  nUR                  S5      n[        R                  " [
        R
                  " [
        R                  [
        R                  5      5       nUR                  S5        UR                  US   [        US   5      45      nUS:w  a  SnUR                  U5        S S S 5        M     U(       d  [        R                  " S5        Og M  ! , (       d  f       M  = f)NT:   r   r   F   )r*   strrI   
contextlibclosingsocketAF_INETSOCK_STREAM
settimeout
connect_exintrA   timesleep)	endpointsall_oknot_ready_endpointsepip_portsockresults          r.   wait_server_readyro      s    )S))))
 BhhsmG##fnnf.@.@A"'!*c'!*o)FGQ;"F'..r2   JJqM! 
 s   :AC44
D	c           
        US:  a  g SR                  U5      nUS S  nUR                  U5        U R                  5       nUS:X  a  U(       a  [        U5        [        R
                  " 5       (       a  UR                  [        R                  R                  S5      S[        R                  R                  R                  R                  S9n	UR                  S0 SU	0UUUS	.S
9  UR                  SSU	00 UUSUS.S
9  g [        R                  " 5       (       a  UR                  [        R                  R                  S5      S[        R                  R                  R                  R                  S9n
UR                  S0 SU
0UUUS	.S
9  UR                  SSU
00 UUSUS.S
9  g [        R                   R#                  5       R$                  [        R&                  R)                  5       ;   a  UR                  [        R                  R                  S5      S[        R                  R                  R                  R                  S9nUR                  S0 SU0UUUS	.S
9  UR                  SSU00 UUSUS.S
9  g g )Nr[   ,r   nccl_idT)r:   persistabletypec_gen_nccl_idOut)rankendpointother_endpoints)rt   inputsoutputsattrsc_comm_initX)nranksrw   ring_idrh   bkcl_idc_gen_bkcl_idxccl_idc_gen_xccl_id)joinremoveglobal_blockro   r   is_compiled_with_cuda
create_varr
   unique_namegenerateVarDescVarTypeRAW	append_opis_compiled_with_xpur3   distributedParallelEnvdevice_typedeviceget_all_custom_device_type)programrw   r   	wait_portcurrent_endpointrh   endpoints_strry   blocknccl_id_varbkcl_id_varxccl_id_vars               r.   init_communicatorr      s    zHHY'MlO+,  "EqyY/*!!##&&!!**95""**.. ' 
 	 K(,#2	 	 		
 	% *		 	 
	
 
	"	"	$	$&&!!**95""**.. ' 
 	 K(,#2	 	 		
 	% *		 	 
	
 	&&(44==335	6 &&!!**95""**.. ' 
 	 K(,#2	 	 		
 	% *		 	 
	
)	6r0   c                  ^ ^ T c~  [         R                  R                  5       R                  S:  a<  [        R
                  " [         R                  R                  5       R                  5      O[        R
                  " S5      m [        T 5      m [         R                  R                  R                  5       m[         R                  R                  5       R                  Tl        [         R                  R                  5       R                  Tl
        [         R                  R                  5       R                  Tl        [         R                  R                  5       R                  Tl        TR                  S:  a  g [        (       dk  [        T [        R
                  5      (       aL  U U4S jn[        5       (       a2  [        R                   " 5         U" 5         [        R"                  " T 5        SqT$  SqT$ )Nr   r   r[   c                    > [         R                  " 5       n [        U TR                  TR                  STR
                  TR                  5        [         R                  " T5      nUR                  U 5        g NT)	r
   Programr   
local_rankr   r   trainer_endpointsExecutorrun)communicator_progexeplacestrategys     r.   _init_context2prepare_distributed_context.<locals>._init_context  s\     $!##))** --&CGG%&r0   T)r3   r   r   r   r
   	CUDAPlacedev_idr   parallelParallelStrategyr   r   r   _parallel_context_initializedr*   r   disable_dygraphenable_dygraph)r   r   r   s   ` @r.   prepare_distributed_contextr      sq   } !!--/66: NN6--99;BBC" 	 e$E!!**;;=H((446==HO ,,88:EEH&&(::  	&&(99   )(Zt~~-N-N	'   "O&
 %)!O 1$(!Or0   c                    SnSn[        U [        5      (       a&  [        U R                  5      /nU R                  /nX4$ [        U [        [
        45      (       aC  U  Vs/ s H  n[        UR                  5      PM     nnU  Vs/ s H  o3R                  PM     nnX4$ [        U [        5      (       aH  U  Vs/ s H  n[        X   R                  5      PM     nnU  Vs/ s H  o@U   R                  PM     nnX4$ gs  snf s  snf s  snf s  snf )z=Get input shape list by given inputs in Model initialization.N)r*   Inputr+   shapedtyper,   dict)rz   shapesdtypesinputr:   s        r.   _update_input_infor   2  s    FF&%  v||$%,, > 
FT5M	*	*178$u{{#8+126%++62 > 
FD	!	!7=>vt$v|))*v>178,$$8 >  92>8s   C<D7!DDc                     ^  \ rS rSrSrU 4S jr\S 5       r\R                  S 5       rSS jr	SS jr
S rS	 rS
 rS rS rS rSS jrS rS rS rSrU =r$ )StaticPIRGraphAdapteriD  z&

Model training/inference with PIR.

c                H  > [         TU ]  5         Xl        [        R                  R
                  R                  5       U l        [        R                  R
                  R                  5       U l	        0 U l
        0 U l        0 U l        S U l        S U l        0 U l        0 U l        SSSSS.U l        [        R$                  R'                  5       R(                  U l        [        R$                  R'                  5       R,                  U l        SU l        0 U l        0 U l        S U l        g Nr   
eval_total
test_total
eval_batch
test_batchO0)super__init__modelr3   r5   r   default_startup_program_startup_progdefault_main_program
_orig_prog_label_vars_input_vars
_endpoints_loss_endpoint	_executor_progs_compiled_progs_merge_countr   r   r   _nranksr   _local_rank
_amp_level_amp_configs_amp_custom_lists_use_fp16_guardselfr   	__class__s     r.   r   StaticPIRGraphAdapter.__init__K  s    
 $ZZ__DDF **//>>@"! 	
 ))557>>!--99;FF!##r0   c                .    U R                   R                  $ r)   r   moder   s    r.   r   StaticPIRGraphAdapter.modej      zzr0   c                $    XR                   l        g r)   r   r   r-   s     r.   r   r   n      

r0   c                    U R                   R                  (       d   S5       eSU l        USL d   S5       eU R                  X5      $ N4model not ready, please call `model.prepare()` firsttrainTz?Does not support `update == False` in static graph mode by now.r   
_optimizerr   _runr   rz   labelsupdates       r.   train_batch!StaticPIRGraphAdapter.train_batchr  O    zz$$ 	
B	
$ 	~ 	
M	
~ yy((r0   c                2    SU l         U R                  X5      $ Nevalr   r   r   rz   r   s      r.   r    StaticPIRGraphAdapter.eval_batch|      	yy((r0   c                4    SU l         U R                  US 5      $ Ntestr   r   rz   s     r.   predict_batch#StaticPIRGraphAdapter.predict_batch      	yy&&r0   c                N    U R                   R                  R                  " U0 UD6$ r)   r   network
parametersr   rN   kwargss      r.   r   StaticPIRGraphAdapter.parameters  "    zz!!,,d=f==r0   c                V   S nS n[         R                  R                  U5      nUS:w  d   S5       e[         R                  R                  U5      nU(       a:  [         R                  R	                  U5      (       d  [         R
                  " U5        US-   nU" U R                  R                  R                  5       U5        U R                  R                  SS 5      nUb  U R                  R                  c  g US-   n/ n	UR                  5        HK  n
U
R                  (       d  M  U
R                  5       R                  5       S:X  d  M:  U	R!                  U
5        MM     U	 V
s0 s H(  oR                  (       d  M  U
R                  U" U
5      _M*     nn
U(       d  g U" X5        g s  sn
f )	Nc           	     r   U (       d  g U R                  5        VVs0 s HP  u  p#U[        U[        R                  R                  R
                  R                  5      (       a  [        U5      OU_MR     n nn[        US5       n[        R                  " X5        S S S 5        g s  snnf ! , (       d  f       g = fNwb)itemsr*   r3   r
   r4   r5   r6   r?   openpickledumpstatepathkvfs        r.   _save)StaticPIRGraphAdapter.save.<locals>._save  s     "KKM *DA !!V[[%:%:%>%>%D%DEE QK
 *   dD!QE% "! "!s   AB"B((
B6c                    [        5       R                  U R                  5      R                  5       n[        R
                  " U5      $ r)   )r   r9   r:   r;   r7   r8   r<   s     r.   r;   .StaticPIRGraphAdapter.save.<locals>.get_tensor  s/    ''1<<>A88A;r0    +path should be of 'dirname/filename' format	.pdparamsr   .pdoptz
pd_op.data)osr  basenamedirnameexistsmakedirsr   r  
state_dictr   getr   	list_varsrs   get_defining_opr:   rA   )r   r  r  r;   r
   dir_name
param_pathprog
optim_pathoptsr=   opt_dicts               r.   saveStaticPIRGraphAdapter.save  sM   	&	 ww%rzHHHz77??4(BGGNN844KK!K'
djj  ++-z:{{w-<4::008H_
>>#C3#6#6#8#=#=#?<#OC  $
 26
15#%CHHjo% 	 
 h#
s   $F&<F&c                   [        5       R                  U5      R                  5       nUR                  5       nUR	                  5       (       a   [
        R                  R                  5       nGOUR                  5       (       a   [
        R                  R                  5       nGOUR                  5       (       av  [
        R                  R                  R                  5       nUR                  UR                  5       5        [
        R                  R                  UR                  5       5      nGO-UR!                  5       (       a  [
        R                  R                  R                  5       nUR                  UR                  5       5        [
        R                  R#                  [
        R$                  R'                  5       R)                  S5      S   UR+                  5       5      nOt[
        R                  R                  R                  5       nUR                  UR                  5       5        [
        R                  R-                  UR/                  5       5      nUR1                  X%5        g )NrZ   r   )r   r9   r;   _placeis_cpu_placer3   r
   CPUPlaceis_cuda_pinned_placeCUDAPinnedPlaceis_xpu_placer   Place	set_placeXPUPlacexpu_device_idis_custom_placeCustomPlacer   
get_devicerI   custom_device_idr   gpu_device_idset)r   r:   ndarrayr>   pr   s         r.   _set_varStaticPIRGraphAdapter._set_var  s   N##D)446HHJ>>KK((*E##%%KK//1E^^  &&(AKK
#KK(():;E    &&(AKK
#KK++((*005a8!:L:L:NE   &&(AKK
#KK))!//*;<E	gr0   c                   U R                   c4  [        R                  " [        R                  " 5       5      R                  nOU R                   R                  n[
        R                  R                  R                  R                  U VVs/ s H  u  pEUPM	     snn[        5       U5        U H!  u  pEU R                  UR                  U5        M#     U R                  R                  (       a  U(       d  g U R                  X#5        g s  snnf r)   )r   r
   r   r7  _default_executorr3   r4   r5   create_loaded_parameterr   rG  r:   r   r   _load_optimizerr   param_state_pairsoptim_stateexecutorparamr  s         r.   loadStaticPIRGraphAdapter.load  s    >>!}}T]]_5GGH~~77H!!99'89'8|uU'89N	

 .LEMM%**e, .
 zz$$K[3 :s   
D
c                d   U R                   R                  SS 5      n/ nUR                  5        H:  nUR                  (       a  M  UR                  (       d  M)  UR                  U5        M<     U(       d  g [        R                  R                  U[        5       U5        [        U5      nU H  nUR                  R                  S5      (       a  UR                  U;  a  M5  UR                  U;   d   SUR                   S35       eU R                  UR                  XeR                     5        M     g )Nr   learning_rate_
variable [ ] is not in optimizer state file)r   r)  r*  is_parameterrs   rA   r
   r   _create_loaded_parameterr   r   r:   
startswithrG  )r   r  rP  r.  optimr=   converted_states          r.   rL  %StaticPIRGraphAdapter._load_optimizer  s    {{w->>#C###???LL% $
 		**5,.(Ku+Cxx""#344 885(88. SXXJ&FG. MM#((OHH$=> r0   c                   U R                   R                  U R                  S 5      nU(       d   S5       e[        U5      nUb  [        U5      n[	        U5      [	        U R
                  U R                     5      :X  d   S5       e0 nU R
                  U R                      Vs/ s H  oUR                  PM     nnU R
                  U R                      Vs/ s H  oUR                  PM     nn[        U5       H  u  pX   b  X   XI'   U R                  S:X  d  M"  Xx   [        R                  :X  d  M:  [        XI   [        R                  5      (       aC  XI   R                  [        R                   R                  R"                  R$                  5      XI'   M  [        XI   [&        R(                  5      (       d  M  XI   R+                  S5      XI'   M     Ub;  [        U R,                  U R                     5       H  u  pX(   XER                  '   M     U R.                  U R                     n
U R                  S:X  a  U
S   nO&[1        U
S   5      u  pU
S   U-   n[	        U
S   5      n/ nS	/[	        U5      -  n[        U5       H2  u  nnUUR3                  5       ;   a  UUU'   M!  UR5                  U5        M4     U R6                  R9                  UUUS
S9n[        U5       H,  u  nn[	        U5      S:  d  M  UR;                  UUU   5        M.     U Vs/ s H  n[&        R<                  " U5      PM     nnU R                  S:X  a  US S  $ [?        UWS  W5      n/ n[A        U RB                  RD                  U5       H$  u  nnUR5                  URF                  " U6 5        M&     U(       a  [	        U5      (       a  US U U4$ U(       a  US U $ U$ s  snf s  snf s  snf )N7Model is not ready, please call `model.prepare()` firstGnumber of inputs does not match number of arguments of `forward` methodO2float16r   rW   metriclossr  Ffeed
fetch_listreturn_numpyr   )$r   r)  r   r/   rB   r   r:   r   	enumerater   r3   rb  r*   r   DenseTensor_as_typer5   DataTypeFLOAT16r7   rE  astyper   r   rG   keysrA   r   r   insertr8   rJ   zipr   _metricsr   )r   rz   r   compiled_progrf  r  input_namesinput_dtypesidxnrh   rg  metric_listmetric_splitsnum_losspruned_fetch_listpruned_fetch_idx_name_mapi	fetch_varretsr:   metric_statesmetricsrc  r  s                            r.   r   StaticPIRGraphAdapter._run  sm   ,,00DA 	
E	
} V_F6{c$"2"2499"=>> 	
H	
>
 '+'7'7		'BC'B!vv'BC)-)9)9$)))DE)DA)DE,FC{& +$&<+<+Ndgt'7'788"g..vzz/G/G/O/OPDG44"gnnY7DG - #D$4$4TYY$?@%{VV A OODII.	99"8,J)5i6I)J&K"6*[8J9V,-H %'D3z?$:!%j1LAyDIIK'/8)!,!((3	 2 ~~!!(	 " 
 !!:;GAt4y1}AtDz* <
 &**TT*997N,T()_mL !4!4mDMFENN6==%01 E G	?G++&.4	?;G;y DE^ +s   !OO Oc                ~    / SQnU H3  nU R                  U5        U R                  U R                  U   U5        M5     g )N)r   r   r   )_make_program_initializer   r   modesr   s      r.   prepareStaticPIRGraphAdapter.prepareI  s8    )Dt$T[[.5 r0   c                r   U R                   R                  US 5      nUb  g U R                  R                  5       n/ n/ nUR	                  5       nU R
                  R                  R                  SSSS9nU HE  u  pxUR                  R                  5       n	U	 H   u  pX[R                     UR                  U
'   M"     MG     [        R                  " X R                  5         U R
                  R                  nU R
                  R                  (       a  U R
                  R                  O/ n[!        U5       Vs/ s H  oR#                  5       PM     nn[!        U5       Vs/ s H  oR#                  5       PM     nnXR$                  U'   US:X  Ga  U R
                  R&                  (       Ga  / nUR                  5        H  u  n
nUR)                  U5        M     [+        U5      U R
                  R&                  l        U R.                  S:w  Gaq  [0        R2                  (       Ga[  [4        R6                  R9                  U R
                  R                  U R
                  R&                  U R.                  S9u  U R
                  l        U R
                  l        [4        R6                  R;                  U R.                  SSS9   [!        U R
                  R                  R<                  " U6 5      nUS	:w  a7  U R
                  R>                  (       a  U R
                  R>                  " UU-   6 nUS	:w  aG  U R
                  R@                   H-  nUR)                  [!        URB                  " UU-   6 5      5        M/     S S S 5        O[!        U R
                  R                  R<                  " U6 5      nUS	:w  a7  U R
                  R>                  (       a  U R
                  R>                  " UU-   6 nUS	:w  aG  U R
                  R@                   H-  nUR)                  [!        URB                  " UU-   6 5      5        M/     [4        RD                  " U5      U l#        U R
                  R&                  RI                  U RF                  5        O[!        U R
                  R                  R<                  " U6 5      nUS	:w  a7  U R
                  R>                  (       a  U R
                  R>                  " UU-   6 nUS	:w  aG  U R
                  R@                   H-  nUR)                  [!        URB                  " UU-   6 5      5        M/     S S S 5        US:w  a  URK                  5         WU RL                  U'   X R                   U'   W[!        U5      US
.U RN                  U'   g s  snf s  snf ! , (       d  f       GNr= f! , (       d  f       Nz= f)Nr  T)prefixinclude_selfremove_duplicater   r   models
optimizerslevelrb  )r  r   use_promoter   rW   rd  rc  )(r   r)  r   cloneget_all_parameter_valuesr   r  named_sublayers_parametersr  r:   r
   program_guardr   _inputs_labelsr/   _create_feed_layerr   r   rA   r+   _parameter_listr   r   r   r3   ampdecorate	auto_castforward_lossrr  computeadd_nr   minimizeset_is_test_attrr   r   )r   r   r.  lossesr  
prog_paramr  layer_prefixsublayerparamskeyrQ  rz   r   r  	opt_paramr-   r{   rc  s                      r.   r  #StaticPIRGraphAdapter._make_programO  ss   {{tT*$$&224
**,,<<! = 

 '6"L))//1F$
,6zz,B$$S) % '6
 &8&89ZZ''F+/::+=+=TZZ''2F6=foFo**,oFF6=foFo**,oFF%+T"w4::#8#8#8	","2"2"4JC$$U+ #5 9=Y

%%5??d*t/I/I/I

++#'::#5#5'+zz'<'<"&// ,  >DJJ&

(=  --"ooYD .  #*$***<*<*D*Df*M"N6>djj.>.>%)ZZ%5%5&8H%JF6>*.***=*= '$+FNNWv=M,O$P!" +>  &djj&8&8&@&@&&IJGv~$***:*:!%!1!1Gf4D!Fv~&*jj&9&9F#NN '69I(K L ':
 '-ll6&:#

%%..t/B/BC!$**"4"4"<"<f"EF6>djj&6&6!ZZ--&0@BF6>"&**"5"5#FNNWv5E$GH #6u :~ 7?
 !!#!' DFO!
M GF& / :9sF   AV(6VV(V7EV(=B7V4G V(
V(
V%	 V((
V6c                   U R                   R                  c   S5       eU R                   R                  nU R                  c@  [        R                  " U5      U l        U R                  R                  U R                  5        U R                  S:X  aE  US:X  a?  [        R                  " 5       (       a%  U R                   R                  R                  U5        XR                  U'   g )N6device is not set, please call `model.prepare()` firstra  r   )r   r5  r   r
   r   r   r   r   r   r   r   amp_initr   )r   r.  r   r   s       r.   r  !StaticPIRGraphAdapter._initialize  s    zz  , 	
D	
, 

!!>>!!]]51DNNNt112 OOt#**,,JJ!!**51%)T"r0   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r)   )__name__
__module____qualname____firstlineno____doc__r   propertyr   setterr   r   r  r  r2  rG  rR  rL  r   r  r  r  __static_attributes____classcell__r   s   @r.   r   r   D  s    $>   
[[   ))'>-$^04(?4K<Z6b
H* *r0   r   c                     ^  \ rS rSrSrU 4S jr\S 5       r\R                  S 5       rSS jr	SS jr
S rS	 rS
 rS rS rS rSS jrS rS rS rSrU =r$ )StaticGraphAdapteri  z1

Model training/inference with a static graph.

c                  > [         TU ]  5         Xl        [        R                  " 5       U l        [        R                  " 5       U l        0 U l        0 U l	        0 U l
        S U l        S U l        0 U l        0 U l        SSSSS.U l        [         R"                  R%                  5       R&                  U l        [         R"                  R%                  5       R*                  U l        SU l        0 U l        0 U l        S U l        g r   )r   r   r   r
   r   r   r   r   r   r   r   r   r   r   r   r   r3   r   r   r   r   r   r   r   r   r   r   r   s     r.   r   StaticGraphAdapter.__init__  s    
 "99;335"! 	
 ))557>>!--99;FF!##r0   c                .    U R                   R                  $ r)   r   r   s    r.   r   StaticGraphAdapter.mode  r   r0   c                $    XR                   l        g r)   r   r   s     r.   r   r    r   r0   c                    U R                   R                  (       d   S5       eSU l        USL d   S5       eU R                  X5      $ r   r   r   s       r.   r   StaticGraphAdapter.train_batch  r   r0   c                2    SU l         U R                  X5      $ r   r   r   s      r.   r   StaticGraphAdapter.eval_batch   r   r0   c                4    SU l         U R                  US 5      $ r   r   r  s     r.   r   StaticGraphAdapter.predict_batch  r  r0   c                N    U R                   R                  R                  " U0 UD6$ r)   r  r	  s      r.   r  StaticGraphAdapter.parameters  r  r0   c                   S n[         R                  R                  U5      nUS:w  d   S5       e[         R                  R                  U5      nU(       a:  [         R                  R	                  U5      (       d  [         R
                  " U5        US-   nU" U R                  R                  R                  5       U5        U R                  R                  SS 5      nUb  U R                  R                  c  g US-   n[        [        UR                  5       5       Vs0 s H  oR                  U_M     n	nU	(       d  g U" X5        g s  snf )Nc           	     "   U (       d  g U R                  5        VVs0 s H(  u  p#U[        U[        5      (       a  [        U5      OU_M*     n nn[	        US5       n[
        R                  " X5        S S S 5        g s  snnf ! , (       d  f       g = fr  )r  r*   r   r?   r  r  r  r  s        r.   r  &StaticGraphAdapter.save.<locals>._save  sy     "KKM)DA *Q"9"98A;q@)   dD!QE% "!	 "!s   /A:B  
Br  r   r!  r   r"  )r#  r  r$  r%  r&  r'  r   r  r(  r   r)  r   filterr   r*  r:   )
r   r  r  r
   r,  r-  r.  r/  rF  r[  s
             r.   r2  StaticGraphAdapter.save  s   	& ww%rzHHHz77??4(BGGNN844KK!K'
djj  ++-z:{{w-<4::008H_
%&<dnn>NO
O!FFAIO 	 
 e 
s   Ec                   U R                   c4  [        R                  " [        R                  " 5       5      R                  nOU R                   R                  n[        R
                  R                  U VVs/ s H  u  pEUPM	     snn[        5       U5        U H  u  pEU R                  XE5        M     U R                  R                  (       a  U(       d  g U R                  X#5        g s  snnf r)   )r   r
   r   r7  rJ  r   rY  r   rG  r   r   rL  rM  s         r.   rR  StaticGraphAdapter.load+  s    >>!}}T]]_5GGH~~77H 			**'89'8|uU'89N	

 .LEMM%' .
 zz$$K[3 :s   6C'
c           	        U R                   R                  SS 5      n[        [        [        UR                  5       5      5      nU(       d  g [        R                  R                  U[        5       U5        [        U5      nU GHw  nUR                  S;   aS  SU;   a(  [        R                  " UR                  S5      5      S-
  OUR                  SS 5      nUb  XuUR                  '   GOUR                  R                  S5      (       a  UR                  U;  a  M  GOUR                  U;  Ga  U R                   R"                  R$                  nU R                   R"                  R&                  R(                  n	S n
U R                   R"                  R*                  R-                  5        GH	  nUc  UOU[/        U5      S-   S  nU R                   R"                  R*                  U   R1                  5        H  u  nnU
c  [3        UR-                  5       S SS	9 He  nUS
-   Uc  U	OU-   S
-   nUR                  U5      (       d  M+  U[/        U5      S  R5                  S
5      [/        U5      -   nU[/        US
-   5      U n
Mg     US
-   U
-   S
-   U-   S-   nUR                  U5      X^R                  '   M     GM     UR                  U;   d   SUR                   S35       eU R7                  XeUR                     5        GMz     g )Nr   @LR_DECAY_COUNTER@global_stepr  r   r  rU  c                    [        U 5      $ r)   rB   rV   s    r.   <lambda>4StaticGraphAdapter._load_optimizer.<locals>.<lambda>t  s    #a&r0   Tr  reverse__0rV  rW  )r   r)  r+   r  r   r*  r
   r   rY  r   r   r:   r7   r8   poprZ  r   r   _namer   r  _accumulatorsro  rB   r  sortedfindrG  )r   r  rP  r.  r[  r\  r=   	state_valopt_nameopt_cls_nameopt_unq_namer:   
accum_name
param_name	state_var	state_keyr  prefix_offsetdy_state_names                      r.   rL  "StaticGraphAdapter._load_optimizer@  s   {{w-V2DNN4DEF		**5,.(Ku+Cxx@@ %7 XXo11-@AAE(,,-A4H 
 (09CHH-$$%566 885( ) 88?2#zz44::H#'::#8#8#B#B#K#KL#'L $

 5 5 C C H H J  (/ !!%c(ma&7&9!: # "ZZ22@@FLLN&%+3 28$)JJL(8,02"I )3*-). 08/? -919)* +.). %+ (1';';F'C'C8A,/KM9**.$s)c&k9B 8A,/0:S0@-.0=8*'2": !+"%!&".!/ #&!& #-	!-
 #'!' * !0 3 3M B ,NN;Q O !Kj 88. SXXJ&FG. MM#sxx89i r0   c                   [        5       R                  UR                  5      R                  5       nUR	                  5       nUR                  5       (       a  [        R                  " 5       nOUR                  5       (       a  [        R                  " 5       nOa[        R                  R                  5       nUR                  UR	                  5       5        [        R                  " UR                  5       5      nUR                  X%5        g r)   )r   r9   r:   r;   r5  r6  r
   r7  r8  r9  r   r;  r<  r   rC  rD  )r   r=   rE  r>   rF  r   s         r.   rG  StaticGraphAdapter._set_var  s    N##CHH-88:HHJ>>MMOE##%%((*E		!AKK
#NN1??#45E	gr0   c           
     
   U R                   R                  U R                  S 5      nU(       d   S5       e[        U5      nUb  [        U5      n[	        U5      [	        U R
                  U R                     5      :X  d   S5       e0 nU R
                  U R                      Vs/ s H  oUR                  PM     nnU R
                  U R                      Vs/ s H  oUR                  PM     nn[        U5       H  u  pX   b  X   XI'   U R                  S:X  d  M"  Xx   [        R                  :X  d  M:  [        XI   [        R                  5      (       a9  XI   R                  [        R                   R"                  R$                  5      XI'   M  [        XI   [&        R(                  5      (       d  M  XI   R+                  S5      XI'   M     Ub;  [        U R,                  U R                     5       H  u  pX(   XER                  '   M     U R.                  U R                     n
U R                  S:X  a  U
S   nO&[1        U
S   5      u  pU
S   U-   n[	        U
S   5      n/ nS	/[	        U5      -  n[        U5       HF  u  nnUR                  UR3                  5       ;   a  UR                  UU'   M5  UR5                  U5        MH     U R6                  R9                  UUUS
S9n[        U5       H,  u  nn[	        U5      S:  d  M  UR;                  UUU   5        M.     U Vs/ s H  n[&        R(                  " U5      PM     nnU R                  S:X  a  US S  $ [=        UWS  W5      n/ n[?        U R@                  RB                  U5       GH  u  nnU R                  S:w  Gaj  U R@                  RD                  GbR  [        U R@                  RD                  [F        5      (       Ga(  U RH                  S:  Ga  [	        U R@                  RD                  RJ                  5      nUS   RL                  S   nU RN                  R                  U R                  S-   S5      nUU-   U:  aj  U Vs/ s H  nUS [Q        UU-
  5      2S4   PM     nnSU RN                  U R                  S-   '   [Q        UU-
  5      U RN                  U R                  S-   '   O@U RN                  U R                  S-   ==   U-  ss'   UU RN                  U R                  S-   '   UR5                  URR                  " U6 5        GM     U(       a  [	        U5      (       a  US U U4$ U(       a  US U $ U$ s  snf s  snf s  snf s  snf )Nr_  r`  ra  rb  r   rW   rc  rd  r  Fre  r   r   r   _total._batch)*r   r)  r   r/   rB   r   r:   r   ri  r   r3   rb  r*   r   rj  rk  r   r   FP16r7   r8   rn  r   r   rG   ro  rA   r   r   rp  rJ   rq  r   rr  _test_dataloaderr   r   datasetr   r   re   r   )r   rz   r   rs  rf  r  rt  ru  rv  rw  rh   rg  rx  ry  rz  r{  r|  r}  r~  r  r:   r  r  rc  r  
total_sizesamplescurrent_countss                                r.   r   StaticGraphAdapter._run  s   ,,00DA 	
E	
} V_F6{c$"2"2499"=>> 	
H	
>
 '+'7'7		'BC'B!vv'BC)-)9)9$)))DE)DA)DE,FC{& +$&<+<+Ndgt'7'788"g..t||/C/C/H/HIDG22"gnnY7DG - #D$4$4TYY$?@%{VV A OODII.	99"8,J)5i6I)J&K"6*[8J9V,-H %'D3z?$:!%j1LAy~~,/8~~)!,!((3	 2 ~~!!(	 " 
 !!:;GAt4y1}AtDz* <
 &**TT*997N,T()_mL !4!4mDMFE 		W$JJ//;tzz::JGGLL1$ !<!<!D!DE
(..+ $ 1 1 5 5dii(6JA N 7*j8KPKPa;C
] :;;S@A5   ?@D%%dii(&:;>A"]2?D%%dii(&:; %%dii(&:;wF;>ED%%dii(&:;NN6==%011 E4 G	?G++&.4	?;G;g DE^ +&s   !UU UU!c                ~    / SQnU H3  nU R                  U5        U R                  U R                  U   U5        M5     g )N)r   r   r   )r  _compile_and_initializer   r  s      r.   r  StaticGraphAdapter.prepare  s8    )Dt$((T):DA r0   c           
        U R                   R                  US 5      nUb  g U R                  R                  5       nUS:w  aI  [	        UR                  5       R                  5       H"  nUR                  5       R                  S5        M$     US:X  a  U R                  R                  (       a  U R                  R                  R                  (       av  U R                  R                  R                  U R                     nUR                  5       R                  UR                     nXPR                  R                  R                  U'   / n/ n[        R                  " X R                  5         U R                  R                   nU R                  R"                  (       a  U R                  R"                  O/ n	[%        U5       V
s/ s H  oR'                  5       PM     nn
[%        U	5       V
s/ s H  oR'                  5       PM     n	n
XR(                  U'   [%        U R                  R*                  R,                  " U6 5      nUS:w  a6  U R                  R.                  (       a  U R                  R.                  " X-   6 nU R0                  S:  aB  US:w  a<  U Vs/ s H  n[3        U5      PM     nnUS:w  a  U	 Vs/ s H  n[3        U5      PM     n	nUS:w  aF  U R                  R4                   H,  nUR7                  [%        UR8                  " X-   6 5      5        M.     US:X  GaD  U R                  R                  (       Ga(  [:        R<                  " U5      U l        U R0                  S:  a  [@        RB                  " SS9n[D        RF                  " U5        [D        RH                  " 5       nU RJ                  S:w  ag  SUl&        U RN                  RQ                  5       Ul)        URR                  RU                  U RV                  5        U RJ                  S:H  URR                  S	'   [D        RX                  " U R                  R                  US
9U R                  l	        OU RJ                  S:w  a  [Z        R\                  (       a  U RV                  (       a4  [:        R^                  RL                  R`                  " S0 U RV                  D6OS n[:        R^                  RL                  Rb                  " U R                  R                  4UU RJ                  S:H  U Rd                  S.U RN                  D6U R                  l	        U R                  R                  Rg                  U R>                  5        S S S 5        US:w  a  UR                  SS9nWU Rh                  U'   X R                   U'   W[%        U5      US.U Rj                  U'   g s  sn
f s  sn
f s  snf s  snf ! , (       d  f       Nq= f)Nr   r   r   r   T)is_collectiver   ra  use_pure_fp16)r   )	amp_listsr  use_fp16_guardfor_testr   )6r   r)  r   r  r+   r   ops
_remove_opr   r   _learning_rate_mapvarsr:   r
   r  r   r  r  r/   r  r   r  r  r  r   rX   rr  rA   r  r3   r  r   r   PaddleCloudRoleMakerr   initDistributedStrategyr   r  r   copyamp_configsr   r   distributed_optimizerr   r   staticAutoMixedPrecisionListsr  r   r  r   r   )r   r   r.  oplr_var
new_lr_varr  r  rz   r   r  r{   orC   rc  roledist_strategyr  s                     r.   r   StaticGraphAdapter._make_program  sy   {{tT*$$& 7?4,,.223!!#..q1 4 GO

%%

%%88 ZZ**==dooNF**,11&++>J=GJJ!!44T:&8&89ZZ''F+/::+=+=TZZ''2F6=foFo**,oFF6=foFo**,oFF%+T"djj0088&ABGv~$**"2"2))G,<>||aDGO3:;7a;q>7;6>6<=fk!nfF=v~"jj11FNN76>>G<L+N#OP 2 w4::#8#8#8&,ll6&:#<<!#%::NDJJt$$)$=$=$?M$.,0)484E4E4J4J4L1%11889O9OP OOt3 &11/B -2,G,G

---DJJ) __,1K1K
  11 ))AA "44 "  -3MM,=,=,F,F

---"+&*oo&='+';';	-
 ++-DJJ) 

%%..t/B/BCi :l 7?::t:,D!' DFO!
s GF <= :9sE   *AWV:W)V?BWW)W5W	
JW:W
Wc                   U R                   R                  US 5      nUb  U$ U R                  R                  c   S5       eU R                  R                  nU R                  GcV  [
        R                  " U5      U l        / nU R                  R                  5        H  n[
        R                  " 5       R                  UR                  5      nUR                  R                  S5      (       d,  U(       a%  UR                  5       R                  5       (       a  M}  UR                  U5        M     U R                  R!                  5       nUR"                   H&  n	U	R$                  S:X  d  M  UR                  U	5        M(     U(       a6  U R                  R'                  U5      n
U R                  R)                  U
5        U R*                  S:X  aE  US:X  a?  [,        R.                  " 5       (       a%  U R                  R0                  R3                  U5        U R4                  S:  a  [
        R6                  " U5      nOUnX0R                   U'   g )Nr  rr   r}   ra  r   r[   )r   r)  r   r5  r   r
   r   r   r*  r   r9   r:   rZ  r;   _is_initializedrA   r   r  rt   _pruner   r   r   r   r   r  r   CompiledProgram)r   r.  r   rs  r   uninitializedvar_pyr=   r   r  startup_progs              r.   r  *StaticGraphAdapter._compile_and_initializes  s   ,,00t<$  zz  , 	
D	
, 

!!
 >>!!]]51DNM,,668'')226;;?..y99(88::$$V, 9 &&335Eii77m+!((,   #1188G""<0 OOt#**,,JJ!!**51<<! 006M M%2T"r0   r  r   r)   )r  r  r  r  r  r   r  r   r  r   r   r  r  r2  rR  rL  rG  r   r  r  r  r  r  r  s   @r.   r  r    s    $>   
[[   ))'>!@4*]:~b<HBZ
x53 53r0   r  c                     ^  \ rS rSrU 4S jr\S 5       r\R                  S 5       rSS jrSS jr	S r
S rS	 rSS
 jrS rSrU =r$ )DynamicGraphAdapteri  c                  > [         TU ]  5         Xl        [        R                  R                  5       R                  U l        [        R                  R                  5       R                  U l	        SSSSS.U l
        S U l        SU l        0 U l        0 U l        SU l        U R                  S:  Ga"  [         R"                  " 5         [        R                  R$                  R'                  5       n[        R                  R                  5       R                  Ul        [        R                  R                  5       R                  Ul        [        R                  R                  5       R(                  Ul        [        R                  R                  5       R*                  Ul        [        R,                  " U R                  R.                  U5      U l        g g )Nr   r   r   Tr   )r   r   r   r3   r   r   r   r   r   r   r   _input_infor   r   r   r   rS   init_parallel_envr   r   r   r   DataParallelr  	ddp_model)r   r   r   r   s      r.   r   DynamicGraphAdapter.__init__  s]   
))557>>!--99;FF	
  !##<<!""$))22CCEH$00<<>EEHO"("4"4"@"@"B"M"MH""..0BB & ""..0AA % $001C1CXNDN r0   c                .    U R                   R                  $ r)   r   r   s    r.   r   DynamicGraphAdapter.mode  r   r0   c                $    XR                   l        g r)   r   r   s     r.   r   r,    r   r0   c           	     :   U R                   R                  (       d   S5       eU R                   R                  R                  5         SU l        [        U5      n[        U5      U l        U=(       d    / n[        U5       Vs/ s H  n[        R                  " U5      PM     nnU R                  S:w  aP  U R                   R                  c9  [        R                  R                  " S0 U R                  D6U R                   l        [        R                  R                  " SSU R                  S:g  0U R                   DSU R                  0D6   U R"                  S:  a5  U R$                  " U Vs/ s H  n[        R                  " U5      PM     sn6 nO>U R                   R                  " U Vs/ s H  n[        R                  " U5      PM     sn6 nS S S 5        U R                   R&                  " [        W5      U-   6 n[        U5      n[        R(                  " U5      nU R                  S:w  a  U R                   R                  R+                  U5      n	U	R-                  5         U(       a^  U R                   R                  R/                  U R                   R                  U	5        U R                   R                  R1                  5         O`UR-                  5         U(       aI  U R                   R                  R/                  U5        U R                   R                  R1                  5         / n
U R                   R2                   Ha  nUR4                  " [        U5      U-   6 nUR6                  " [        U5       Vs/ s H  n[9        U5      PM     sn6 nU
R;                  U5        Mc     [=        U
5      S:  a  U Vs/ s H  n[9        U5      PM     snU
4$ U Vs/ s H  n[9        U5      PM     sn$ s  snf s  snf s  snf ! , (       d  f       GN5= fs  snf s  snf s  snf )	Nr   r   r   enabler  r   r   r  )r   r   r  r   r   r/   r   r&  r3   	to_tensorr   _scalerr  
GradScalerr   r  r   r   r)  r  r  scalebackwardr  clear_gradientsrr  r  r   r?   rA   rB   )r   rz   r   r   rC   rV   r{   r  
final_lossscaledr  rc  metric_outsms                 r.   r   DynamicGraphAdapter.train_batch  s*   zz$$ 	
B	
$ 	

  "	-f52/6v?!&""1%? ??d"tzz'9'9'A!'!6!6!K9J9J!KDJJZZ!! 
??d*
$$
 //

 ||a..*O16+;+;A+>*OP**,,39:6af&&q)6:
 !!GG$4v$=?\\&)
??d"ZZ''--j9FOO

""++DJJ,A,A6J

""224!

%%..z:

""224jj))F ..77+;f+DFKW[5IJ5I5IJKANN1 * 7|a $**6ahqk6*G4	
 (..v!(1+v.	
Q @ +P ;
 
>  K +.sB    O-
!O<+ O2
O<* O7

O<6P
7PP2
O<<
Pc           	        U R                   R                  R                  5         SU l        [	        U5      n[        U5      U l        U=(       d    / n[	        U5       Vs/ s H  n[        R                  " U5      PM     nnU R                   R                  " U Vs/ s H  n[        R                  " U5      PM     sn6 n[        R                  R                  5       n[	        U5       H  nUR                  US9  M     U H  nUR                  US9  M     U R                   R                  (       a0  U R                   R                  " [	        U5      U-   6 n[	        U5      nU R                  S:  Ga  [	        U5       Vs/ s H  n[        U5      PM     nnU Vs/ s H  n[        U5      PM     nnU R                   R                  GbW  [!        U R                   R                  ["        5      (       Ga-  [%        U R                   R                  R&                  5      n	US   R(                  S   n
U R*                  R-                  U R                  S-   S5      nX-   U	:  a  U Vs/ s H  owS [/        X-
  5       PM     nnU Vs/ s H  o3S [/        X-
  5       PM     nnSU R*                  U R                  S-   '   [/        X-
  5      U R*                  U R                  S-   '   O?U R*                  U R                  S-   ==   U
-  ss'   XR*                  U R                  S-   '   / nU R                   R0                   Ha  nUR2                  " [	        U5      U-   6 nUR4                  " [	        U5       Vs/ s H  n[7        U5      PM     sn6 nUR9                  U5        Mc     U R                   R                  (       a.  [%        U5      (       a  W Vs/ s H  n[7        U5      PM     snU4$ U R                   R                  (       a  W Vs/ s H  n[7        U5      PM     sn$ U$ s  snf s  snf s  snf s  snf s  snf s  snf s  snf s  snf s  snf )Nr   )r   r   r   r  r  )r   r  r   r   r/   r   r&  r3   r0  r   rA  _tor  r   rX   r  r*   r   rB   r  r   r   r)  re   rr  r  r   r?   rA   )r   rz   r   rC   rV   r{   expected_devicer  r  r  r  r  r  rc  r8  r9  s                   r.   r   DynamicGraphAdapter.eval_batch  s   

!	-f52/6v?!&""1%?**$$F&KFqv'7'7':F&KL !--224!AEEE) " AEEE)  ::ZZ%%(86(ACFV_F<<!/6w/?@/?!{1~/?G@.45fk!nfF5zz**6:

++Z< < !!<!<!D!DE
!!***1- $ 1 1 5 5dii(6JA N *j8FMFM;C
 :;<g   GMFL;C
 :;<f   ?@D%%dii(&:;>A"2?D%%dii(&:; %%dii(&:;wF;>E%%dii(&:;jj))F ..77+;f+DFKW[5IJ5I5IJKANN1	 * ::G)/0AHQK0'99ZZ)/0AHQK00Nm @&K A5  K 10s6    P P$?P)P.#P3P8/P=
QQc                >   U R                   R                  R                  5         SU l        [	        U5       Vs/ s H  n[
        R                  " U5      PM     nn[        U5      U l        U R                   R                  " U6 nU R                  S:  aW  [        U R                   R                  [        R                  5      (       a$  [	        U5       Vs/ s H  n[        U5      PM     nn[	        U5       Vs/ s H  n[        U5      PM     sn$ s  snf s  snf s  snf )Nr   r   )r   r  r   r   r/   r3   r0  r   r&  r   r*   r5  r
   r   rX   r?   )r   rz   rV   r{   r  s        r.   r  !DynamicGraphAdapter.predict_batchI  s    

!	/6v?!&""1%?-f5**$$f-<<!
4::+<+<dnn M M/6w/?@/?!{1~/?G@%,W%56%5%566 @ A6s    DD8Dc                N    U R                   R                  R                  " U0 UD6$ r)   r  r	  s      r.   r  DynamicGraphAdapter.parametersT  r  r0   c                   U R                   R                  R                  5       n[        R                  " X!S-   5        U R                   R
                  bf  U R                   R
                  R                  5       (       a=  U R                   R
                  R                  5       n[        R                  " X1S-   5        [        U R                   S5      (       a  U R                   R                  bh  U R                   R                  R                  5       (       a>  U R                   R                  R                  5       n[        R                  " XAS-   5        g g g g )Nr!  r"  r1  	.pdscaler)r   r  r(  r3   r2  r   hasattrr1  )r   r  r  r[  scalers        r.   r2  DynamicGraphAdapter.saveW  s    ##..0F;./::  ,zz$$//11

--88:E(?34::y))djj.@.@.Lzz!!,,..++668F;$67 / /M)r0   c                   U H  u  pEUR                  U5        M     [        U R                  S5      (       aC  U R                  R                  b,  U(       a%  U R                  R                  R	                  U5        U R                  R
                  (       a  U(       d  g [        U5      nU R                  R
                  R                  nUc  SnU R                  R
                  R                  R                  nUS UR                  S5       n	U R                  R                  R                  5        Vs/ s H  oDR                  PM     n
n[        UR                  5       S SS9 H  u  pUS;   a5  US:X  a-  [         R"                  " UR%                  S5      5      S	-   US
'   M>  M@  U
 H  nUR'                  US-   U	-   5      (       a  U[)        US-   U	-   S-   5      S  nO2UR'                  US-   5      (       a  X:X  a  U[)        US-   5      S  nOMi  US UR                  S5       nUS-   U-   S-   U-   S-   nXU'   M     M     [        U R                  R
                  S5      (       d<  [*        R,                  " S5        U R                  R
                  R/                  U5        g U R                  R
                  R1                  U5        g s  snf )Nr1  r  r  c                    [        U S   5      $ )Nr   r  r  s    r.   r  *DynamicGraphAdapter.load.<locals>.<lambda>  s    s1Q4yr0   Tr  r  r  r   r  r  set_state_dictzTpaddle.base.optimizer is deprecated in API 2.0, please use paddle.optimizer instead.)	set_valuerE  r   r1  load_state_dictr   r   r  r   r  rfindr  r  r:   r  r  r7   r8   r  rZ  rB   warningswarnset_dictrK  )r   rN  rO  scaler_staterQ  r  r\  r  r  r  param_namesvar_namer  r  r  r  s                   r.   rR  DynamicGraphAdapter.loadc  s   -LEOOE" . 4::y))djj.@.@.L

""22<@ zz$$K {+zz,,22Lzz,,66?? 9,"4"4S"9:/3zz/A/A/L/L/NO/Nezz/NO#)%8$$
H @@ 33!4!45I!JKaO $M2 4 #.J**:+;h+FGG%-
S 08 ;c ABD&
 !++J,<==$4 &.c*s2B.C.E%F
 !+,Cj.>.>s.C!DJ #&'  %	%
  " 6?M25 #.$
T tzz,,.>??MMf JJ!!**?;JJ!!00Ac Ps   2Kc                   U R                   S:X  a  U R                  R                  S:X  a  [        R                  " 5       (       ah  [
        R                  R                  U R                  R                  U R                  R                  SS9u  U R                  l        U R                  l	        U R                   S:w  a  S U R                  l
        g g )Nra  r   r  r   )r   r   r   r   r   r3   r  r  r  r   r1  r   s    r.   r  DynamicGraphAdapter.prepare  s    OOt#

7***,,8>

8K8Kzz))::00 9L 95DJJ

 5
 ??d"!%DJJ #r0   )r   r   r   r&  r   r   r   r   r)  r   r   r   r)   )r  r  r  r  r   r  r   r  r   r   r  r  r2  rR  r  r  r  r  s   @r.   r$  r$    sb    O>   
[[   5
n<|	7>
8KBZ& &r0   r$  c                     \ rS rSr% SrS\S'   S\S'   S\S'     S"       S#S
 jjr  S$       S%S jjr\" 5        S&     S'S jj5       r	\" 5       S(S j5       r
S)S*S jjr  S+       S,S jjrS-S jrS r    S.         S/S jjr               S0                               S1S jjr      S2               S3S jjr\     S4             S5S jj5       r\     S4             S6S jj5       r\     S4             S7S jj5       r     S8S jrS9S jr0 4S jr  S"     S:S jjrS;S jrS rS rS rS  rS!rg	)<Modeli  aX  

A Model object is a network with training and inference features.
Dynamic graph and static graph are supported at the same time,
switched by `paddle.enable_static()`. The usage is as follows.
But note, the switching between dynamic and static should be before
instantiating a Model. The input description, i.e, paddle.static.InputSpec,
must be required for static graph.

When training on GPU, auto mixed precision (AMP O1) and pure float16
(AMP O2) training are both supported in static graph mode and dynamic mode.
In static graph mode, before training with pure float16 (AMP O2),
`multi_precision` could be set to True when creating optimizer, which can
avoid poor accuracy or slow convergence in a way, and inputs of dtype float
should be cast to float16 by users. `paddle.static.amp.fp16_guard` API
should be also used to limit the range of pure float16 training, otherwise,
'use_fp16_guard' should be set to False by users. However, limiting the
range of is not supported during training using AMP.

Args:
    network (paddle.nn.Layer): The network is an instance of
        paddle.nn.Layer.
    inputs (InputSpec|list|tuple|dict|None, optional): `inputs`, entry points of network,
        could be a InputSpec instance, or list/tuple of InputSpec instances,
        or dict ({name: InputSpec}), and it couldn't be None in static
        graph. Default: None.
    labels (InputSpec|list|tuple|None, optional): `labels`, entry points of network,
        could be a InputSpec instance or list/tuple of InputSpec instances,
        or None. For static graph, if labels is required in loss,
        labels must be set. Otherwise, it could be None. Default: None.


Examples:
    1. A common example

    .. code-block:: python
        :name: code-example1

        >>> import paddle
        >>> import paddle.nn as nn
        >>> import paddle.vision.transforms as T
        >>> from paddle.static import InputSpec

        >>> device = paddle.set_device('cpu') # or 'gpu'

        >>> net = nn.Sequential(
        ...     nn.Flatten(1),
        ...     nn.Linear(784, 200),
        ...     nn.Tanh(),
        ...     nn.Linear(200, 10))
        ...
        >>> # inputs and labels are not required for dynamic graph.
        >>> input = InputSpec([None, 784], 'float32', 'x')
        >>> label = InputSpec([None, 1], 'int64', 'label')

        >>> model = paddle.Model(net, input, label)
        >>> optim = paddle.optimizer.SGD(learning_rate=1e-3,
        ...     parameters=model.parameters())
        ...
        >>> model.prepare(optim,
        ...             paddle.nn.CrossEntropyLoss(),
        ...             paddle.metric.Accuracy())
        ...
        >>> transform = T.Compose([
        ...     T.Transpose(),
        ...     T.Normalize([127.5], [127.5])
        >>> ])
        >>> data = paddle.vision.datasets.MNIST(mode='train', transform=transform)
        >>> model.fit(data, epochs=2, batch_size=32, verbose=1)


    2. An example using mixed precision training.

    .. code-block:: python
        :name: code-example2

        >>> # doctest: +REQUIRES(env:GPU)
        >>> import paddle
        >>> paddle.device.set_device('gpu')
        >>> import paddle.nn as nn
        >>> import paddle.vision.transforms as T

        >>> def run_example_code():
        ...     device = paddle.set_device('gpu')
        ...
        ...     net = nn.Sequential(nn.Flatten(1), nn.Linear(784, 200), nn.Tanh(),
        ...                         nn.Linear(200, 10))
        ...
        ...     model = paddle.Model(net)
        ...     optim = paddle.optimizer.SGD(learning_rate=1e-3, parameters=model.parameters())
        ...
        ...     amp_configs = {
        ...         "level": "O1",
        ...         "custom_white_list": {'conv2d'},
        ...         "use_dynamic_loss_scaling": True
        ...     }
        ...     model.prepare(optim,
        ...         paddle.nn.CrossEntropyLoss(),
        ...         paddle.metric.Accuracy(),
        ...         amp_configs=amp_configs)
        ...
        ...     transform = T.Compose([T.Transpose(), T.Normalize([127.5], [127.5])])
        ...     data = paddle.vision.datasets.MNIST(mode='train', transform=transform)
        ...     model.fit(data, epochs=2, batch_size=32, verbose=1)
        ...
        >>> # mixed precision training is only supported on GPU now.
        >>> if paddle.is_compiled_with_cuda():
        ...     run_example_code()
        ...
z Literal['train', 'eval', 'test']r   paddle.nn.Layerr  boolstop_trainingNc                @   SU l         Xl        S U l        S U l        S U l        S U l        S U l        S U l        SU l        S U l	        SU l
        [        5       (       d1  [        U[        [        [        [         45      (       d  [#        S5      eOU(       a  [%        U5      U l        U R'                  USS9U l        U R'                  U5      U l        [        5       (       a  [)        U 5      U l        g [-        5       (       a  [/        U 5      U l        g [1        U 5      U l        g )Nr   Fz='inputs' must be list or tuple or dict, and couldn't be None.T)is_input)r   r  r  r  r  _loss_weightsr   r&  _is_shape_inferredr  r\  r   r*   r+   r,   r   r   	TypeErrorr   _verify_specr$  _adapterr   r   r  )r   r  rz   r   s       r.   r   Model.__init__3  s     	
!"' $"  ftUD%&@AAS  B 1&9D(($(?((0 /5DM]]1$7DM.t4DMr0   c                    U R                   R                  XU5      n[        5       (       a  U R                  c  U R	                  5         U$ )aG  

Run one training step on one batch of data. And using `update` indicates
whether optimizer update gradients computing by this batch.

Args:
    inputs (numpy.ndarray|Tensor|list): Batch of input data. It could
        be a numpy array or paddle.Tensor, or a list of arrays or
        tensors (in case the model has multiple inputs).
    labels (numpy.ndarray|Tensor|list, optional): Batch of labels. It could be
        a numpy array or paddle.Tensor, or a list of arrays or tensors
        (in case the model has multiple labels). If has no labels,
        set None. Default: None.
    update (bool, optional): Whether update parameters after loss.backward() computing.
        Set it to False to accumulate gradients. Default: True.

Returns:
    A list of scalar training loss if the model has no metrics,
    or a tuple (list of scalar loss, list of metrics) if the model
    set metrics.

Examples:

    .. code-block:: python

        >>> import paddle
        >>> import paddle.nn as nn
        >>> from paddle.static import InputSpec
        >>> paddle.seed(2023)

        >>> device = paddle.set_device('cpu') # or 'gpu'

        >>> net = nn.Sequential(
        ...     nn.Linear(784, 200),
        ...     nn.Tanh(),
        ...     nn.Linear(200, 10))
        ...
        >>> input = InputSpec([None, 784], 'float32', 'x')
        >>> label = InputSpec([None, 1], 'int64', 'label')
        >>> model = paddle.Model(net, input, label)
        >>> optim = paddle.optimizer.SGD(learning_rate=1e-3,
        ...     parameters=model.parameters())
        >>> model.prepare(optim, paddle.nn.CrossEntropyLoss())
        >>> data = paddle.rand((4, 784), dtype="float32")
        >>> label = paddle.randint(0, 10, (4, 1), dtype="int64")
        >>> loss = model.train_batch([data], [label])
        >>> print(loss)
        [array(3.0039132, dtype=float32)]

)rc  r   r   r&  _update_inputs)r   rz   r   r   rd  s        r.   r   Model.train_batchX  s@    p }}((@!1!1!9!r0   c                    U R                   R                  X5      n[        5       (       a  U R                  c  U R	                  5         U$ )a=  

Run one evaluating step on a batch of data.

Args:
    inputs (numpy.ndarray|Tensor|list): Batch of input data. It could
        be a numpy array or paddle.Tensor, or a list of arrays or
        tensors (in case the model has multiple inputs).
    labels (numpy.ndarray|Tensor|list, optional): Batch of labels. It could be
        a numpy array or paddle.Tensor, or a list of arrays or tensors
        (in case the model has multiple labels). If has no labels,
        set None. Default: None.

Returns:
    A list of scalar testing loss if the model has no metrics,
    or a tuple (list of scalar loss, list of metrics) if the model
    set metrics.

Examples:

    .. code-block:: pycon

        >>> import paddle
        >>> import paddle.nn as nn
        >>> from paddle.static import InputSpec
        >>> paddle.seed(2023)

        >>> device = paddle.set_device('cpu')  # or 'gpu'

        >>> net = nn.Sequential(
        ...     nn.Linear(784, 200),
        ...     nn.Tanh(),
        ...     nn.Linear(200, 10),
        ... )
        >>> input = InputSpec([None, 784], 'float32', 'x')
        >>> label = InputSpec([None, 1], 'int64', 'label')
        >>> model = paddle.Model(net, input, label)
        >>> optim = paddle.optimizer.SGD(
        ...     learning_rate=1e-3,
        ...     parameters=model.parameters(),
        ... )
        >>> model.prepare(
        ...     optim,
        ...     paddle.nn.CrossEntropyLoss(),
        ...     metrics=paddle.metric.Accuracy(),
        ... )
        >>> data = paddle.rand((4, 784), dtype="float32")
        >>> label = paddle.randint(0, 10, (4, 1), dtype="int64")
        >>> loss, acc = model.eval_batch([data], [label])
        >>> print(loss, acc)
        >>> # doctest: +SKIP("Random output")
        [array(3.0039132, dtype=float32)] [np.float64(0.0)]
        >>> # doctest: -SKIP

)rc  r   r   r&  rf  )r   rz   r   rd  s       r.   r   Model.eval_batch  s>    v }}''7!1!1!9!r0   c                    U R                   R                  U5      n[        5       (       a  U R                  c  U R	                  5         U$ )a  

Run one predicting step on a batch of data.

Args:
    inputs (numpy.ndarray|Tensor|list): Batch of input data. It could
        be a numpy array or paddle.Tensor, or a list of arrays or
        tensors (in case the model has multiple inputs).

Returns:
    A list of numpy.ndarray of predictions, that is the outputs
    of Model forward.

Examples:

    .. code-block:: python

        >>> import paddle
        >>> import paddle.nn as nn
        >>> from paddle.static import InputSpec
        >>> paddle.seed(2023)

        >>> device = paddle.set_device('cpu') # or 'gpu'

        >>> input = InputSpec([None, 784], 'float32', 'x')
        >>> label = InputSpec([None, 1], 'int64', 'label')

        >>> net = nn.Sequential(
        ...     nn.Linear(784, 200),
        ...     nn.Tanh(),
        ...     nn.Linear(200, 10),
        ...     nn.Softmax())
        ...
        >>> model = paddle.Model(net, input, label)
        >>> model.prepare()
        >>> data = paddle.rand((1, 784), dtype="float32")
        >>> out = model.predict_batch([data])
        >>> print(out)
        [array([[0.10844935, 0.04650883, 0.11790176, 0.04962315, 0.10899059,
                 0.08197589, 0.03125402, 0.03232312, 0.3786293 , 0.04434395]],
              dtype=float32)]

)rc  r  r   r&  rf  )r   rz   rd  s      r.   r  Model.predict_batch  s>    Z }}**62!1!1!9!r0   c                    [         R                  R                  5       R                  S:X  a5  U(       d  U R	                  U5        gU R
                  R                  U5        gg)a	  

This function saves parameters, optimizer information or model and
parameters only for inference to path. It depends on the parameter
`training`.

If `training` is set to True, the parameters saved contain all
the trainable Variable, will save to a file with suffix ".pdparams".
The optimizer information contains all the variable used by optimizer.
For Adam optimizer, contains beta1, beta2, momentum etc. All the
information will save to a file with suffix ".pdopt". (If the optimizer
have no variable need to save (like SGD), the fill will not generated).
This function will silently overwrite existing file at the target location.

If `training` is set to False, only inference model will be saved.

Args:
    path (str): The file prefix to save model. The format
        is 'dirname/file_prefix' or 'file_prefix'. if empty str.
        A exception will be raised.
    training (bool, optional): Whether to save for training. If not, save
        for inference only. Default: True.

Returns:
    None

Examples:

    .. code-block:: python

        >>> # doctest: +TIMEOUT(80)
        >>> import paddle
        >>> import paddle.nn as nn
        >>> import paddle.vision.transforms as T
        >>> from paddle.static import InputSpec
        >>> from paddle.vision.datasets import MNIST

        >>> dynamic = True  # False
        >>> # If use static graph, do not set
        >>> if not dynamic:
        ...     paddle.enable_static()

        >>> transform = T.Compose([T.Transpose(),
        ...                        T.Normalize([127.5], [127.5])])
        >>> train_dataset = MNIST(mode='train', transform=transform)
        >>> train_loader = paddle.io.DataLoader(train_dataset, batch_size=64)
        >>> val_dataset = MNIST(mode='test', transform=transform)
        >>> val_loader = paddle.io.DataLoader(val_dataset, batch_size=64)

        >>> input = InputSpec([None, 1, 28, 28], 'float32', 'image')
        >>> label = InputSpec([None, 1], 'int64', 'label')

        >>> model = paddle.Model(paddle.vision.models.LeNet(), input, label)
        >>> optim = paddle.optimizer.Adam(learning_rate=0.001, parameters=model.parameters())
        >>> model.prepare(optim, paddle.nn.CrossEntropyLoss(), paddle.metric.Accuracy(topk=(1, 2)))
        >>> model.fit(train_loader, val_loader, epochs=2, verbose=0)
        >>> model.save('checkpoint/test')  # save for training
        >>> model.save('inference_model', False)  # save for inference

r   N)r3   r   r   r   _save_inference_modelrc  r2  )r   r  trainings      r.   r2  
Model.save  sJ    | ))+66!;**40""4(	 <r0   c                  ^ S nU4S jnS nU" U5      nU" US-   5      mT(       d   S5       e/ nU R                   R                  5       R                  5        H  u  p U" X5      n
UR                  W
5        M!     U(       a  S	O
U" US
-   5      n[        5       (       a|  S	n[        U S5      (       aM  U R                  b@  [        R                  R                  US-   5      (       a  [        R                  " US-   5      nU R                   R                  X|U5      $ U R                   R                  X|5      $ ! [         a<  nU(       a.  [        R
                  " SU S3[        U5      -   5        Sn S	nAGNUeS	nAff = f)a  

Load from files storing the model states and optimizer states. The file
for optimizer states is not necessary if no need to restore the optimizer.

NOTE: parameters are retrieved out from the file storing model states
according to their structured names.

For fine-tuning or transfer-learning models where some of the layers have
changed, keep parameters needed to restore have same structured names in
the pre-trained model and fine-tuning model.

Args:
    path (str): The prefix of files storing the model states and
        optimizer states. The files would be `path.pdparams` and
        `path.pdopt` separately, and the latter is not necessary
        when no need to restore.
    skip_mismatch (bool, optional): Whether to skip the loading of mismatch
        parameter or raise an error when mismatch happens (not found
        the parameter in file storing model states of or receives a
        mismatch shape). Default: False.
    reset_optimizer (bool, optional): If True, ignore the providing file storing
        optimizer states and initialize optimizer states from scratch.
        Otherwise, restore optimizer states from `path.pdopt` if
        a optimizer has been set to the model. Default: False.

Returns:
    None

Examples:

    .. code-block:: python

        >>> import paddle
        >>> import paddle.nn as nn
        >>> from paddle.static import InputSpec

        >>> device = paddle.set_device('cpu')

        >>> input = InputSpec([None, 784], 'float32', 'x')

        >>> model = paddle.Model(nn.Sequential(
        ...     nn.Linear(784, 200),
        ...     nn.Tanh(),
        ...     nn.Linear(200, 10),
        ...     nn.Softmax()), input)
        ...
        >>> model.save('checkpoint/test')
        >>> model.load('checkpoint/test')

c                    [         R                  R                  U 5      (       d  g [        U S5       n[        R
                  " USS9sS S S 5        $ ! , (       d  f       g = f)Nrblatin1)encoding)r#  r  r&  r  r  rR  )r  r  s     r.   _load_state_from_path)Model.load.<locals>._load_state_from_path  s>    77>>$''dD!Q{{1x8 "!!s   A
Ac           	       > TR                  U S 5      nUc  [        U  S35      e[        UR                  5      [        UR                  5      :w  a:  [        U  S[        UR                  5       S[        UR                  5       S35      eX4$ )Nz$ is not found in the providing file.z receives a shape z, but the expected shape is .)r)  
ValueErrorr+   r   )r  rQ  r  param_states      r.   _check_match Model.load.<locals>._check_match  s    OOC.E} C5(L!MNNEKK D$55 e-d5;;.?-@@\]abgbmbm]n\oopq  <r0   c                j    [         R                  R                  U 5      u  pUS;   d   SU S35       eU $ )N)r  r!  r"  z.pdmodelzUnknown postfix z from weights)r#  r  splitext)r  exts     r.   _strip_postfix"Model.load.<locals>._strip_postfix  sI    ((.ID   5
 "#m45  Kr0   r!  z-Failed to load parameters, please check path.zSkip loading for z. TNr"  r1  rD  )r  r(  r  ry  rO  rP  r]   rA   r   rE  r1  r#  r  r&  r3   rR  rc  )r   r  skip_mismatchreset_optimizerru  r{  r  matched_param_stater  rQ  	match_reserrrO  rR  rz  s                 @r.   rR  
Model.loadK  s^   t	9	 	 d#+D;,>?KKK{ ,,11399;JC(4	  &&y1 < $D)>th)O 	
 LtY''DLL,D77>>$"455#);;tk/A#BL==%%#,  ==%%&9GG1   MM$5cU""=C"HI&*OIs   D66
E< /E75E77E<c                6    U R                   R                  5       $ )a,  

Returns a list of parameters of the model.

Returns:
    A list of Parameter in static graph.
    A list of ParamBase in dynamic graph.

Examples:

    .. code-block:: python

        >>> import paddle
        >>> import paddle.nn as nn
        >>> from paddle.static import InputSpec
        >>> paddle.seed(2023)
        >>> input = InputSpec([None, 784], 'float32', 'x')

        >>> model = paddle.Model(nn.Sequential(
        ...     nn.Linear(784, 200),
        ...     nn.Tanh(),
        ...     nn.Linear(200, 10)), input)
        ...
        >>> params = model.parameters()
        >>> print(params)
        [Parameter containing:
        Tensor(shape=[784, 200], dtype=float32, place=Place(cpu), stop_gradient=False,
        [[ 0.05713400,  0.00314646, -0.03754271, ..., -0.02529256,
           0.04872842, -0.06670858],
         ...,
         [ 0.06268418,  0.06550254, -0.02103353, ...,  0.06395906,
           0.05509177, -0.06355451]]), Parameter containing:
        Tensor(shape=[200], dtype=float32, place=Place(cpu), stop_gradient=False,
        [0., 0., 0., ..., 0., 0.]), Parameter containing:
        Tensor(shape=[200, 10], dtype=float32, place=Place(cpu), stop_gradient=False,
        [[ 0.12933084,  0.07726504,  0.05336720, ...,  0.10865459,
           0.06605886,  0.13684085],
         ...,
         [-0.10171061, -0.01649965, -0.13420501, ...,  0.11190581,
          -0.12700224,  0.02916957]]), Parameter containing:
        Tensor(shape=[10], dtype=float32, place=Place(cpu), stop_gradient=False,
        [0., 0., 0., 0., 0., 0., 0., 0., 0., 0.])]

)rc  r  r	  s      r.   r  Model.parameters  s    Z }}''))r0   c                B  ^ ^ U 4S jn0 T R                   l        0 T R                   l        T(       d  ST R                   l        g [	        T[
        5      (       a*  TS;  a  [        S5      eTT R                   l        U" 5         g ST;  a  ST R                   l        O(TS   S;  a  [        S5      eTS   T R                   l        [        TR                  5       5      S1-
  nU(       a  T R                   R                  S:X  a  g ST;   a  [        S	5      eU" 5         T R                   R                  S:w  a8  U(       a1  S
 H+  nXC;   d  M
  TU   T R                   R                  U'   X41-  nM-     UU 4S jnU" U5      nU H  nTU   T R                   R                  U'   M!     g )Nc                 0  > T R                   R                  S:X  a{  T R                  R                  (       a_  [	        T R                  R                  [
        R                  R                  [
        R                  R                  45      (       d   S5       eg g g )Nra  zcOnly ClipGradByNorm and ClipGradByGlobalNorm are supported in amp training with level=O2 currently.)	rc  r   r   
_grad_clipr*   r3   nnClipGradByGlobalNormClipGradByNormr   s   r.   _check_pure_fp16_configs4Model._prepare_amp.<locals>._check_pure_fp16_configs  su    }}''4/DOO4N4N!OO..YY33VYY5M5MN   z	  5O/r0   r   )r   O1ra  z6The level of amp_configs should be 'O0', 'O1' or 'O2'.r  r  z2amp_configs['level'] should be 'O0', 'O1' or 'O2'.r  zl'use_pure_fp16' is an invalid parameter, the level of mixed precision training only depends on 'O1' or 'O2'.)custom_white_listcustom_black_listcustom_black_varnamesc                   > 1 SknX-
  (       a  [        S[        X-
  5       S35      eSU ;   a?  [        5       (       a  [        S5      eTS   TR                  l        U R                  S5        U $ )N>   
decr_ratio
incr_ratior  init_loss_scalingincr_every_n_stepsdecr_every_n_nan_or_infuse_dynamic_loss_scalingz\Except for 'level', the keys of 'amp_configs' must be accepted by mixed precision APIs, but z could not be recognized.r  z8'use_fp16_guard' is supported in static graph mode only.)ry  r,   r   rc  r   r   )amp_config_key_setaccepted_param_setr  r   s     r.   _check_amp_configs.Model._prepare_amp.<locals>._check_amp_configs,  s    " "6 rsx  zL  za  tb  sc  c|  }   #55"$$$R  1<<L0M-"))*:;%%r0   )	rc  r   r   r   r*   r]   ry  rD  ro  )r   r  r  r  r  r  amp_configs_setr  s   ``      r.   _prepare_ampModel._prepare_amp  s   		 +-'%'" '+DMM$S))"44 L  (3DMM$$&k)+/(W%-?? H  ,7w+?( !1!1!34y@!T]]%=%=%Ek)~  	!" ==##t+0B

 3BM"CDMM33J? ',6&	&2 --?@"C.9#.>DMM&&s+ #r0   c                <   [        5       U l        [        U R                  [        R                  5      (       Ga  [
        R                  R                  5       R                  S:  a  [        (       d  [        5       (       a  [        R                  " 5       R                  n[        R                  " 5       R                  n[        R                  " 5         [
        R                  " U R                  5        U[        R                  " 5       l        U[        R                  " 5       l        O[!        U R                  5        Sq	Xl        UbD  [        U[
        R$                  R&                  5      (       d  [)        U5      (       d  [+        S5      eX l        U=(       d    / n[/        U5       H6  n[        U[0        5      (       a  M   UR2                  R4                   S35       e   [/        U5      U l        U R9                  U5        U R:                  R=                  5         g)a  

Configures the model before running.

Args:
    optimizer (Optimizer|None, optional): Optimizer must be set in training
        and should be a Optimizer instance. It can be None in eval
        and test mode. Default: None.
    loss (Loss|Callable|None, optional): Loss function can
        be a `paddle.nn.Layer` instance or any callable function
        taken the predicted values and ground truth values as input.
        It can be None when there is no loss. Default: None.
    metrics (Metric|list[Metric]|None, optional): If metrics is set, all
        metrics will be calculated and output in train/eval mode. Default: None.
    amp_configs (str|dict|None, optional): AMP configurations. If AMP or pure
        float16 training is used, the key 'level' of 'amp_configs'
        should be set to 'O1' or 'O2' respectively. Otherwise, the
        value of 'level' defaults to 'O0', which means float32
        training. In addition to 'level', parameters consistent with
        mixed precision API could also be passed in. The supported
        keys are: 'init_loss_scaling', 'incr_ratio', 'decr_ratio',
        'incr_every_n_steps', 'decr_every_n_nan_or_inf',
        'use_dynamic_loss_scaling', 'custom_white_list',
        'custom_black_list', and 'custom_black_varnames'or
        'use_fp16_guard' is only supported in static graph mode. Mixed
        precision API documentations  :ref:`api_paddle_amp_auto_cast`
        and  :ref:`api_paddle_amp_GradScaler` could be referenced
        for details. For convenience, 'amp_configs' could be set to
        'O1' or 'O2' if no more parameters are needed. 'amp_configs'
        could be None in float32 training. Default: None.

Returns:
    None

r   TNzI'loss' must be sub classes of `paddle.nn.Layer` or any callable function.z is not sub class of Metric)_get_devicer5  r*   r
   r   r3   r   r   r   r   r   r   random_seedr   r   disable_staticr   r   r  Layercallablera  r  r/   r   r   r  rr  r  rc  r  )r   	optimizerrd  r  r  main_prog_seedstartup_prog_seedrc  s           r.   r  Model.prepareI  s   X "mdkk4>>22 ""..077!;55"$$%)%>%>%@%L%LN446BB & ((*))$++6 ?MD--/;) 002> 0<04-#dFIIOO44Xd^^_  
-Rg&Fff-- ##,,--HI- '  (+&r0   c                L   Uc   S5       e[        U[        [        45      (       a3  [        S U 5       5      (       a  [	        U5      S:X  d   S5       eUu  nnO[        U[
        5      (       a  X3nn[        U[        5      (       a$  [        UWUU
S9n[        UUU R                  USS9nOUnUb7  [        U[        5      (       a"  [        UWS	9n[        UUU R                  USS9nOUb  UnOSnUSLnUU l
        Xl        U R                  U5      nXl        UbK  [        U[
        5      (       a6  [        U[
        5      (       a!  US
:  d   S5       eUU-  S-   n[        UU5      n[        UU UUUUUU	U R!                  5       S9	n[#        S U 5       5      (       a  U(       d  [$        R&                  " S5        UR)                  S5        [+        U5       H  nUR-                  U5        U R/                  UUS5      nUR1                  UU5        U(       ab  UU-  S
:X  aY  U R                  U5      nUR)                  SUU R!                  5       S.5        U R/                  UUS5      nUR3                  SU5        U R4                  (       d  M    O   UR3                  SW5        SU l
        g)a  

Trains the model for a fixed number of epochs. If `eval_data` is set,
evaluation will be done at the end of each epoch.

Args:
    train_data (Dataset|DataLoader, optional): An iterable data loader is used for
        train. An instance of paddle paddle.io.Dataset or
        paddle.io.Dataloader is recommended. Default: None.
    eval_data (Dataset|DataLoader, optional): An iterable data loader is used for
        evaluation at the end of epoch. If None, will not do evaluation.
        An instance of paddle.io.Dataset or paddle.io.Dataloader
        is recommended. Default: None.
    batch_size (int|list, optional): The batch size of train_data and eval_data. When
        train_data and eval_data are both the instance of Dataloader, this
        parameter will be ignored. Default: 1.
    epochs (int, optional): The number of epochs to train the model. Default: 1.
    eval_freq (int, optional): The frequency, in number of epochs, an evaluation
        is performed. Default: 1.
    log_freq (int, optional): The frequency, in number of steps, the training logs
        are printed. Default: 10.
    save_dir(str|None, optional): The directory to save checkpoint during training.
        If None, will not save checkpoint. Default: None.
    save_freq (int, optional): The frequency, in number of epochs, to save
        checkpoint. Default: 1.
    verbose (int, optional): The verbosity mode, should be 0, 1, or 2. 0 = silent,
        1 = progress bar, 2 = one line per epoch. Default: 2.
    drop_last (bool, optional): Whether drop the last incomplete batch of
        train_data when dataset size is not divisible by the batch size.
        When train_data is an instance of Dataloader, this parameter
        will be ignored. Default: False.
    shuffle (bool, optional): Whether to shuffle train_data. When train_data is
        an instance of Dataloader, this parameter will be ignored.
        Default: True.
    num_workers (int, optional): The number of subprocess to load data, 0 for no
        subprocess used and loading data in main process.
        When train_data and eval_data are both the instance of
        Dataloader, this parameter will be ignored. Default: 0.
    callbacks (Sequence[Callback]|Callback|None, optional): A list of `Callback` instances to apply
        during training. If None, :ref:`api_paddle_callbacks_ProgBarLogger` and
        :ref:`api_paddle_callbacks_ModelCheckpoint` are automatically inserted. Default: None.
    accumulate_grad_batches (int, optional): The number of batches to accumulate gradient
        during training process before optimizer updates. It can mimic large batch
        size. Default: 1.
    num_iters (int|None, optional): The number of iterations to evaluate the model.
        If None, evaluate on whole input dataset, otherwise, evaluate `num_iters` times.
        Default: None.

Returns:
    None

Examples:
    1. An example use Dataset and set batch size, shuffle in fit.
       How to make a batch is done internally.

    .. code-block:: python
        :name: code-example3

        >>> # doctest: +TIMEOUT(80)
        >>> import paddle
        >>> import paddle.vision.transforms as T
        >>> from paddle.vision.datasets import MNIST
        >>> from paddle.static import InputSpec

        >>> dynamic = True
        >>> if not dynamic:
        ...     paddle.enable_static()
        ...
        >>> transform = T.Compose([T.Transpose(),
        ...                        T.Normalize([127.5], [127.5])])
        >>> train_dataset = MNIST(mode='train', transform=transform)
        >>> val_dataset = MNIST(mode='test', transform=transform)

        >>> input = InputSpec([None, 1, 28, 28], 'float32', 'image')
        >>> label = InputSpec([None, 1], 'int64', 'label')

        >>> model = paddle.Model(
        ...     paddle.vision.models.LeNet(),
        ...     input, label)
        >>> optim = paddle.optimizer.Adam(
        ...     learning_rate=0.001, parameters=model.parameters())
        >>> model.prepare(
        ...     optim,
        ...     paddle.nn.CrossEntropyLoss(),
        ...     paddle.metric.Accuracy(topk=(1, 2)))
        >>> model.fit(train_dataset,
        ...             val_dataset,
        ...             epochs=2,
        ...             batch_size=64,
        ...             save_dir='mnist_checkpoint')
        ...

    2. An example use DataLoader, batch size and shuffle is set in
       DataLoader.

    .. code-block:: python
        :name: code-example4

        >>> # doctest: +TIMEOUT(80)
        >>> import paddle
        >>> import paddle.vision.transforms as T
        >>> from paddle.vision.datasets import MNIST
        >>> from paddle.static import InputSpec

        >>> dynamic = True
        >>> if not dynamic:
        ...     paddle.enable_static()
        ...
        >>> transform = T.Compose([T.Transpose(),
        ...                        T.Normalize([127.5], [127.5])])
        >>> train_dataset = MNIST(mode='train', transform=transform)
        >>> train_loader = paddle.io.DataLoader(train_dataset,
        ...     batch_size=64)
        >>> val_dataset = MNIST(mode='test', transform=transform)
        >>> val_loader = paddle.io.DataLoader(val_dataset,
        ...     batch_size=64)
        ...
        >>> input = InputSpec([None, 1, 28, 28], 'float32', 'image')
        >>> label = InputSpec([None, 1], 'int64', 'label')

        >>> model = paddle.Model(
        ...     paddle.vision.models.LeNet(), input, label)
        >>> optim = paddle.optimizer.Adam(
        ...     learning_rate=0.001, parameters=model.parameters())
        >>> model.prepare(
        ...     optim,
        ...     paddle.nn.CrossEntropyLoss(),
        ...     paddle.metric.Accuracy(topk=(1, 2)))
        >>> model.fit(train_loader,
        ...             val_loader,
        ...             epochs=2,
        ...             save_dir='mnist_checkpoint')
        ...
Nztrain_data must be given!c              3  B   #    U  H  n[        U[        5      v   M     g 7fr)   )r*   re   ).0rV   s     r.   	<genexpr>Model.fit.<locals>.<genexpr>9	  s      9
(21Jq#
   r[   zGbatch_size length error, expected train_batch_size and eval_batch_size.)
batch_sizeshuffle	drop_lastTbatch_samplerplacesnum_workersreturn_listr  r   !num_iters must be greater than 0!r   )r   epochsstepslog_freq	save_freqsave_dirverboser  c              3  B   #    U  H  n[        U[        5      v   M     g 7fr)   )r*   r   )r  r  s     r.   r  r  	  s     :Tz!]++Tr  z$EarlyStopping needs validation data.r   r   r  r  )r*   r,   r+   allrB   re   r   r   r   r5  r  _accumulate_len_data_loader	num_itersminr   _metrics_nameanyrO  rP  on_beginrangeon_epoch_begin_run_one_epochon_epoch_endon_endr\  )r   
train_data	eval_datar  r  	eval_freqr  r  r  r  r  r  r  	callbacksaccumulate_grad_batchesr  train_batch_sizeeval_batch_sizetrain_samplertrain_loadereval_samplereval_loaderdo_evalr  cbksepochlogs
eval_steps	eval_logss                                r.   fit	Model.fit  s   p %B'BB%j5$-00S 9
(29
 6
 6
 z?a' Y' 1;-o
C((0:oj'**3+#	M &+{{' L &L Z	7%C%C2oL %*{{' K "#KKT) +2%%l3"!9c**5#&&q=E"EE=5(A-F	5)E&&(

 :T:::7MM@Ag6]E&&&|T7CDeT*59,1!22;?
(T5G5G5IJ
 !//T6J	FI.!!!! #$ 	GT" $r0   c                Z   Ub6  [        U[        5      (       a!  [        XS9n[        UUU R                  USS9n	OUn	Xl        [        UU UUU R                  5       S9n
U R                  U	5      nXpl	        UbH  [        U[        5      (       a3  [        U[        5      (       a  US:  d   S5       e[        X{5      nXl	        U
R                  SXR                  5       S	.5        U R                  XS5      nU
R                  SU5        SU l        0 nU R                  5        H	  nX   X'   M     U$ )
a6	  
Evaluate the loss and metrics of the model on input dataset.

Args:
    eval_data (Dataset|DataLoader): An iterable data loader is used for
        evaluation. An instance of paddle.io.Dataset or
        paddle.io.Dataloader is recommended.
    batch_size (int, optional): The batch size of train_data and eval_data.
        When eval_data is the instance of Dataloader, this argument will be
        ignored. Default: 1.
    log_freq (int, optional): The frequency, in number of steps, the eval logs
        are printed. Default: 10.
    verbose (int, optional): The verbosity mode, should be 0, 1, or 2. 0 = silent,
        1 = progress bar, 2 = one line per epoch. Default: 2.
    num_workers (int, optional): The number of subprocess to load data,
        0 for no subprocess used and loading data in main process. When
        train_data and eval_data are both the instance of Dataloader,
        this parameter will be ignored. Default: 0.
    callbacks (Sequence[Callback]|Callback|None, optional): A list of `Callback` instances to apply
        during training. If None, `ProgBarLogger` and `ModelCheckpoint`
        are automatically inserted. Default: None.
    num_iters (int|None, optional): The number of iterations to evaluate the model.
        If None, evaluate on whole input dataset, otherwise, evaluate `num_iters` times.
        Default: None.
Returns:
    dict: Result of metric. The key is the names of Metric,
        value is a scalar or numpy.array.

Examples:

    .. code-block:: python

        >>> # doctest: +SKIP('Cause each step's acc and using time are not same when repeat running')
        >>> import paddle
        >>> import paddle.vision.transforms as T
        >>> from paddle.static import InputSpec

        >>> # declarative mode
        >>> transform = T.Compose([T.Transpose(),
        ...                        T.Normalize([127.5], [127.5])])
        >>> val_dataset = paddle.vision.datasets.MNIST(mode='test', transform=transform)

        >>> input = InputSpec([-1, 1, 28, 28], 'float32', 'image')
        >>> label = InputSpec([None, 1], 'int64', 'label')
        >>> model = paddle.Model(paddle.vision.models.LeNet(), input, label)
        >>> model.prepare(metrics=paddle.metric.Accuracy())
        >>> result = model.evaluate(val_dataset, batch_size=64)
        >>> print(result)
        {'acc': 0.0699}
Nr  Tr  )r   r  r  r  r   r  r   r  )r*   r   r   r   r5  r  r   r  r  r  re   r  r  r  r  )r   r  r  r  r  r  r  r  r  r  r  r  r  eval_resultr  s                  r.   evaluateModel.evaluate	  s:   z  Z	7%C%C2L %*{{' K $K +&&(
 **;7
"!9c**:s++q=E"EE=Y3J'Nj5G5G5IJ	
 "";f=FD! $##%A!WKN & r0   c                    g r)   r  r   	test_datar  r  stack_outputsr  r  s          r.   predictModel.predict
  s     "%r0   c                    g r)   r  r  s          r.   r  r  
  s     .1r0   c                    g r)   r  r  s          r.   r  r  
  s	     ADr0   c                   Ub6  [        U[        5      (       a!  [        XS9n[        UUU R                  USS9nOUnXl        [        X`US9n	U R                  U5      n
SU
0nU	R                  SU5        / nU R                  XS5      u  p[        [        U6 5      nU(       a&  U Vs/ s H  n[        R                  " U5      PM     nnSU l        U	R                  SU5        U$ s  snf )a  
Compute the output predictions on testing data.

Args:
    test_data (Dataset|DataLoader): An iterable data loader is used for
        predict. An instance of paddle.io.Dataset or paddle.io.Dataloader
        is recommended.
    batch_size (int, optional): The batch size of test_data. When test_data is the
        instance of Dataloader, this argument will be ignored. Default: 1.
    num_workers (int, optional): The number of subprocess to load data, 0 for no subprocess
        used and loading data in main process. When test_data is the instance of Dataloader,
        this argument will be ignored. Default: 0.
    stack_outputs (bool, optional): Whether stack output field like a batch, as for an output
        field of a sample is in shape [X, Y], test_data contains N samples, predict
        output field will be in shape [N, X, Y] if stack_output is True, and will
        be a length N list in shape [[X, Y], [X, Y], ..., [X, Y]] if stack_outputs
        is False. stack_outputs as False is used for DenseTensor output situation,
        it is recommended set as True if outputs contains no DenseTensor. Default: False.
    verbose (int, optional): The verbosity mode, should be 0, 1, or 2. 0 = silent,
        1 = progress bar, 2 = one line per batch. Default: 1.
    callbacks(Sequence[Callback]|Callback|None, optional): A Callback instance, Default: None.

Returns:
    list: output of models.

Examples:

    .. code-block:: python

        >>> import numpy as np
        >>> import paddle
        >>> from paddle.static import InputSpec

        >>> class MnistDataset(paddle.vision.datasets.MNIST):
        ...     def __init__(self, mode, return_label=True):
        ...         super().__init__(mode=mode)
        ...         self.return_label = return_label
        ...
        ...     def __getitem__(self, idx):
        ...         img = np.reshape(self.images[idx], [1, 28, 28])
        ...         if self.return_label:
        ...             return img, np.array(self.labels[idx]).astype('int64')
        ...         return img
        ...
        ...     def __len__(self):
        ...         return len(self.images)
        ...
        >>> test_dataset = MnistDataset(mode='test', return_label=False)

        >>> # imperative mode
        >>> input = InputSpec([-1, 1, 28, 28], 'float32', 'image')
        >>> model = paddle.Model(paddle.vision.models.LeNet(), input)
        >>> model.prepare()
        >>> result = model.predict(test_dataset, batch_size=64)
        >>> print(len(result[0]), result[0][0].shape)
        157 (64, 10)
        >>> # declarative mode
        >>> device = paddle.set_device('cpu')
        >>> paddle.enable_static()
        >>> input = InputSpec([-1, 1, 28, 28], 'float32', 'image')
        >>> model = paddle.Model(paddle.vision.models.LeNet(), input)
        >>> model.prepare()
        >>> result = model.predict(test_dataset, batch_size=64)
        >>> print(len(result[0]), result[0][0].shape)
        157 (64, 10)
Nr  Tr  )r   r  r  r  )r*   r   r   r   r5  r  r   r  r  r  r+   rq  r7   vstackr  )r   r  r  r  r  r  r  test_samplertest_loaderr  
test_stepsr  r{   outss                 r.   r  r  (
  s    X  Z	7%C%C2L %*{{' K $K +	wG**;7
$i&++KyIsG}% 3:;74ryy7G; $It$ <s   % C"c                v   [        5       (       a  [        R                  R                  S5         U R                  nU R
                  c  [        S5      eU R                  (       a'  [        R                  " SU R
                  S    S35        [        R                  R                  X!U R                  S9  SSS5        g[        R                  R!                  U5      nUS:X  a  [#        S5      e[        R                  R%                  U5      nU(       a:  [        R                  R'                  U5      (       d  [        R(                  " U5        UnU[*        -   nU[,        -   nU R.                  R0                  R3                  S	S5      nU(       d   S
5       e[5        5       (       a  Un	OUR7                  SS9n	[9        U R.                  R:                  S	   5      n
U R.                  R<                  S	   S   n[        R>                  RA                  UU
UU R.                  RB                  U	S9  g! , (       d  f       g= f)z
Save inference model can be used in static or dynamic mode.

Args:
    path (str): The path prefix to save model. The format is
        ``dirname/file_prefix`` or ``file_prefix``.
Returns:
    None
NzSaving inference model needs 'inputs' or running before saving. Please specify 'inputs' in Model initialization or input training data and perform a training for shape derivation.z'inputs' was not specified when Model initialization, so the input shape to be saved will be the shape derived from the user's actual inputs. The input shape to be saved is r   zT. For saving correct input shapes, please provide 'inputs' for Model initialization.)
input_specr  zThe input path MUST be format of dirname/file_prefix [dirname\file_prefix in Windows system], but received file_prefix is empty string.r   r_  Tr  rW   )r   )"r   r
   	framework_dygraph_guardr  r&  RuntimeErrorr`  rO  rP  r3   jitr2  r  r#  r  r$  ry  r%  r&  r'  r   r   rc  r   r)  r   r  r+   r   r   r  save_inference_modelr   )r   r  layerfile_prefixr%  
model_pathmodel_filenameparams_filenamer.  
infer_progrz   rh   s               r.   rm  Model._save_inference_model
  s    ..t4##+& N  **MM H  IM  IY  IY  Z[  I\  H]  ]q  r 

E 54 ''**40Kb  3  ggood+Grww~~g66G$ J(+==N),??O==''++FD9D I4 }}!
!ZZZ6
$--33F;<F008BIMM..''" / Y 54s   BH**
H8c                   / n[        U5       GHJ  u  pg[        R                  R                  U5      n[	        US   R
                  5      (       a  US   R                  5       S   OUS   R
                  S   nUR                  X6U5        US:w  Ga  US [        U R                  5       U[        U R                  5      S  /n	US:X  a<  U	R                  US-   U R                  -  S:H  =(       d    US-   [        U5      :H  5        [        XS-   5      " U	6 n
U R                  (       a2  U R                  (       a!  U
S    Vs/ s H  n[        U5      PM     sn/nO1U R                  (       a  U
 Vs/ s H  n[        U5      PM     sn/nO/ nU R                   H-  nUR                  5       nUR!                  [#        U5      5        M/     [        U R%                  5       5      [        U5      :X  d   e['        U R%                  5       U5       H
  u  nnUXO'   M     OWU R                  b(  U R)                  US [        U R                  5       5      n
OU R)                  U5      n
UR                  U
5        XdS'   US:X  d-  U R*                  R,                  R/                  US-   S5      S::  a/  U[        R0                  R3                  5       R4                  -  US'   OU R*                  R,                  US-      US'   UR7                  X6U5        [9        U S5      (       d  GM
  U R:                  c  GM  U =R:                  S-  sl        U R:                  S::  d  GMB  S	U l        U ?  O   U R?                  5         US:X  a  XE4$ U$ s  snf s  snf )
Nr   r  r   r   r  stepr  r  T) ri  r3   utilsflattenr  r   on_batch_beginrB   r  rA   r  getattrrr  r  float
accumulateextendr/   r  rq  r  rc  r   r)  r   r   r   on_batch_endrE  r  r\  _reset_metrics)r   data_loaderr  r   r  r{   r  datar  r  r  rC   r  rc  resr  r  s                    r.   r  Model._run_one_epoch
  s    #K0JD <<''-D DGMM** Q"!W]]1%  $$T6y  3#dll"34d3t||;L;N6OP7?NNT%5%55: 8!8s;'77
 tH_5w?==TZZ26q':'Qa':;GZZ267$Qa$78G G #mmF ++-CNN73<0 , 4--/0CL@@@ 2 2 4g>DAqDG ? <<+--d3FS5F.GHD--d3Dt$L==--11$/1EJ !3!3!?!?!A!H!HH \" &*]]%?%?x%P\"""4t4t[))dnn.H!#>>Q&)-D&U 1V 	9= Y  ;7s   =M8,M=c                |    Uc  U R                   c   S5       eUb  UnOU R                   n[        U R                  X2S9$ )a4
  Prints a string summary of the network.

Args:
    input_size (tuple|InputSpec|list[tuple|InputSpec], optional): Size of input tensor.
        if not set, input_size will get from ``self._inputs`` if network only have
        one input, input_size can be tuple or InputSpec. if model have multiple
        input, input_size must be a list which contain every input's shape. Default: None.
    dtype (str, optional): If dtype is None, 'float32' will be used, Default: None.

Returns:
    Dict: A summary of the network including total params and total trainable params.

Examples:
    .. code-block:: pycon

        >>> import paddle
        >>> from paddle.static import InputSpec

        >>> input = InputSpec([None, 1, 28, 28], 'float32', 'image')
        >>> label = InputSpec([None, 1], 'int64', 'label')
        >>> model = paddle.Model(paddle.vision.models.LeNet(), input, label)
        >>> optim = paddle.optimizer.Adam(learning_rate=0.001, parameters=model.parameters())
        >>> model.prepare(optim, paddle.nn.CrossEntropyLoss())
        >>> params_info = model.summary()
        >>> print(params_info)
        ---------------------------------------------------------------------------
        Layer (type)       Input Shape          Output Shape         Param #
        ===========================================================================
          Conv2D-1       [[1, 1, 28, 28]]      [1, 6, 28, 28]          60
            ReLU-1        [[1, 6, 28, 28]]      [1, 6, 28, 28]           0
          MaxPool2D-1     [[1, 6, 28, 28]]      [1, 6, 14, 14]           0
          Conv2D-2       [[1, 6, 14, 14]]     [1, 16, 10, 10]         2,416
            ReLU-2       [[1, 16, 10, 10]]     [1, 16, 10, 10]           0
          MaxPool2D-2    [[1, 16, 10, 10]]      [1, 16, 5, 5]            0
          Linear-1          [[1, 400]]            [1, 120]           48,120
          Linear-2          [[1, 120]]            [1, 84]            10,164
          Linear-3          [[1, 84]]             [1, 10]              850
        ===========================================================================
        Total params: 61,610
        Trainable params: 61,610
        Non-trainable params: 0
        ---------------------------------------------------------------------------
        Input size (MB): 0.00
        Forward/backward pass size (MB): 0.11
        Params size (MB): 0.24
        Estimated Total Size (MB): 0.35
        ---------------------------------------------------------------------------
        {'total_params': np.int64(61610), 'trainable_params': np.int64(61610)}

z)'input_size' or 'self._input' must be set)r   )r  r    r  )r   
input_sizer   _input_sizes       r.   r    Model.summary4  sK    r %)A 	
7	
A !$K,,Kt||[??r0   c           
        / nUc  U(       a  [        U R                  R                  5      SS  nUb?  Ub<  [        5       (       a-  [	        U5       VVs/ s H  u  px[        XU   X'   S9PM     nnnOU Vs/ s H  n[        US /S9PM     nnOm[        U5      nOa[        U[        5      (       aA  USL d   e[        U R                  R                  5       Vs/ s H  nUS:w  d  M  X   PM     nnO[        U5      nUbJ  [	        U5       H;  u  py[        U	[
        5      (       d   eU	R                  b  M+  [        SU SU	 S35      e   U$ s  snnf s  snf s  snf )	Nr   )r:   r   r   )r:   r   Fr   zRequires Input[z(].name != None, but receive `None` with rx  )rP   r  r  r   ri  r   r/   r*   r   r:   ry  )
r   specsr   r   r^  	out_specs	arg_namesr}  rw  specs
             r.   rb  Model._verify_specv  sz   	= ()=)=>qrB	 &*')) %.i$8!$8DA 11IVYG$8  !I
 GP PiAdV!<iI PI#EN	t$$u$$$ &dll&:&:;;A; ;  I  I $Y/!$....99$$)!,TUYTZZ[\  0 5!
 !Q
s   E	5E
E$Ec                J    U R                    H  nUR                  5         M     g r)   )rr  reset)r   rc  s     r.   r  Model._reset_metrics  s    mmFLLN $r0   c                    U R                   (       a  S/O/ nU R                   H+  nUR                  [        UR	                  5       5      5        M-     U$ )Nrd  )r  rr  r  r/   r:   )r   metrics_namer9  s      r.   r  Model._metrics_name  s>    #'::x2A 12 r0   c                D     [        U5      nU$ ! [         a    S n U$ f = fr)   )rB   	Exception)r   r  r  s      r.   r  Model._len_data_loader  s3    	$E   	E	s    c                    U R                   R                  U l        U R                  bU  [        U R                  5      S:X  a;  U R                  SU R                  S   U R                  S   S5      U l        SU l        ggg)z.Update self._inputs according to given inputs.Nr[   r   r   T)rc  r&  rB   rb  r  r`  r   s    r.   rf  Model._update_inputs  sv    ==44'C0@0@,AQ,F,,d&&q)4+;+;A+>DL '+D#	 -G'r0   )r  rc  r&  r  r`  r  r  r_  rr  r   r5  r  r   r  r  r\  )NN)r  rZ  rz   z1Input | Sequence[Input] | dict[str, Input] | Noner   zInput | Sequence[Input] | NonereturnNoner   )rz   r'   r   _InputBatch | Noner   r[  r*  8list[float] | tuple[list[npt.NDArray[Any]], list[float]]r)   )rz   r'   r   r,  r*  r-  )rz   r'   r*  list[npt.NDArray[Any]])T)r  r]   rn  r[  r*  r+  )FF)r  r]   r  r[  r  r[  r*  r+  )rN   r   r
  r   r*  zlist[Tensor])NNNN)
r  z!paddle.optimizer.Optimizer | Nonerd  z;paddle.nn.Layer | Callable[[Tensor, Tensor], Tensor] | Noner  zMetric | list[Metric] | Noner  zstr | dict[str, Any] | Noner*  r+  )NNr   r   r   
   Nr   r[   FTr   Nr   N) r  Dataset | DataLoader | Noner  r0  r  zint | list[int]r  re   r  re   r  re   r  z
str | Noner  re   r  re   r  r[  r  r[  r  re   r  $Sequence[Callback] | Callback | Noner  re   r  
int | Noner*  r+  )r   r/  r[   r   NN)r  Dataset | DataLoaderr  re   r  re   r  re   r  re   r  r1  r  r2  r*  z#dict[str, float | npt.NDArray[Any]]).....)r  r3  r  re   r  re   r  zLiteral[True]r  re   r  r1  r*  r.  )r  r3  r  re   r  re   r  zLiteral[False]r  re   r  r1  r*  z"list[tuple[npt.NDArray[Any], ...]])r  r3  r  re   r  re   r  r[  r  re   r  r1  r*  z5list[npt.NDArray[Any] | tuple[npt.NDArray[Any], ...]])r   r   Fr   N)r  r]   r*  r+  )r  z>tuple[int, ...] | Input | list[tuple[int, ...] | Input] | Noner   z_DTypeLiteral | Noner*  r&   )NNF)r  r  r  r  r  __annotations__r   r   r   r   r  r2  rR  r  r  r  r  r  r   r  rm  r  r    rb  r  r  r  rf  r  r  r0   r.   rY  rY    s   m^ +*
 EI15	#5 #5 B#5 /	#5
 
#5P &*	;; #; 	;
 
B;z Y@D=!=+==	A= =~ Y/ /bB)N $ %	tHtH tH 	tH
 
tHl-*^W?v 8< 0437T 4T  H	T  .T  1T  
T p 3715&'#:>'( $!w%/w% /w% $	w%
 w% w% w% w% w% w% w% w% w% 8w% "%w%  !w%" 
#w%x :> $m'm m 	m
 m m 8m m 
-m^  '*:=%'% % 	%
 %% % 8% 
 % %  (+:=1'1 1 	1
 &1 1 81 
,1 1  !:=D'D D 	D
 D D 8D 
?D D qf>J Wz &*@@ K@@
 $@@ 
@@D)V+r0   rY  r)   )[
__future__r   r^   rL   r#  r  r`   rf   rO  typingr   r   r   r   r   numpyr7   typing_extensionsr	   r3   paddle.distributedr   rS   paddle.optimizerr
   paddle.autogradr   paddle.baser   paddle.base.executorr   paddle.base.frameworkr   r   r  r   r   paddle.distributed.fleet.baser   paddle.frameworkr   r   paddle.framework.io_utilsr   	paddle.ior   r   r   paddle.jit.translated_layerr   r   paddle.metricr   paddle.staticr   r   r  r   r   model_summaryr    collections.abcr!   r"   numpy.typingnptr#   paddle._typing.dtype_liker$   r%   r&   NDArrayr+   r'   r4  __all__r   r/   r?   rG   rJ   rP   rX   ro   r   r   r   r   r  r$  rY  r  r0   r.   <module>rM     s:   #   	       '  !   #  - 
 % 4 9 < B B O   , 6 "27#+"CVS[[	 K   % -*d
N0f$A* A*H`3 `3FQ& Q&hz+ z+r0   