
    :Djj                     r    d Z ddlZddlmZmZmZ  ej                  d      ZerddlZdee	ef   ddde
fd	Zy)
z)Utilities for the XGBoost Dask interface.    N)TYPE_CHECKINGAnyDictz[xgboost.dask]local_paramworkerzdistributed.Workerreturnc                    t        |d      r|j                  j                  n|j                  }d}dD ]F  }| j                  |d      | j                  ||      |k7  s,t        j                  d       | |   } n |dk(  s||}|S )zIGet the number of threads from a worker and the user-supplied parameters.stateN)nthreadn_jobsz-Overriding `nthreads` defined in dask worker.r   )hasattrr
   nthreadsgetLOGGERinfo)r   r   dwnt	n_threadsps        VC:\Crop_Prediction\Backend\crop-ai-system\venv\Lib\site-packages\xgboost/dask/utils.pyget_n_threadsr      s     %,FG$<6<<  &//DI" ??1d#/KOOAt4LPT4TKKGH#AI	
 A~*	    )__doc__loggingtypingr   r   r   	getLoggerr   distributedstrintr    r   r   <module>r       sP    /  + +			+	, tCH~ 7K PS r   