
    :[gj                     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        M/var/www/html/bid-api/venv/lib/python3.12/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   