Ë
    ‡\;jZ  ã                   ó:   — d dl Z ddlmZ dad„ Zd„ Zd„ Zd„ Zd„ Zy)	é    Né   )Ú	Parameterc                  óZ   — t         d uxr" t        t        j                  dd«      «      dkD  S )NÚPADDLE_TRAINERS_NUMÚ1é   )Ú__parallel_ctx__clz__ÚintÚosÚgetenv© ó    úkG:\00. PROJECTS\API\Inventory\templateJSON\kerjaOCR\Lib\site-packages\paddle/distributed/parallel_helper.pyÚ_is_data_parallel_moder      s/   € ô 	 TÐ)ò 	;Ü”—	‘	Ð/°Ó5Ó6¸Ñ:ðr   c                  ó   — t         d uS )N©r	   r   r   r   Ú_is_parallel_ctx_initializedr      s   € ä ¨Ð,Ð,r   c                 ó"   — t         �J d«       ‚| a y )Nz-ParallelContext can only be initialized once.r   )Úccl_parallel_contexts    r   Ú_set_parallel_ctxr   "   s    € ô 	Ð%ð7à6ó7Ø%à0Ñr   c                  óF   — t         €J d«       ‚t         j                  «        y )Nz&ParallelContext should be initialized.)r	   Úinitr   r   r   Ú_init_parallel_ctxr   *   s&   € ô 	Ð)ð0à/ó0Ø)ä×ÑÕ r   c                 óŠ   — ddl m} | D ]8  }|j                  rŒt        |t        «      sŒ!|j
                  sŒ. ||dd¬«       Œ: y )Nr   )Ú	broadcastr   T)Úsync_op)Údistributedr   Úis_distributedÚ
isinstancer   Ú	trainable)Ú
parametersr   Úparams      r   Ú_broadcast_parametersr#   2   s9   € Ý'ãˆð ×ÒØÜ�eœYÕ'¨E¯O«OÙ�e˜Q¨Ö-ñ r   )	r   Ú	frameworkr   r	   r   r   r   r   r#   r   r   r   Ú<module>r%      s,   ðó 
å !àÐ òò-ò
1ò!ó	.r   