t:i 2SrSSKrSSKrSSKJr SSKJrJrJ r J r SSK r SSK r SSK Jr SSK Jr SSKJr \R&"S 5rS \\\4S S S \4SjrS\ \\\4S\S \ \ \\44Sjr\S \4Sj5r\S \4Sj5r\S \4Sj5rg)z)Utilities for the XGBoost Dask interface.N)cache)AnyDictOptionalTuple)Version)parse)Configz[xgboost.dask] local_paramworkerzdistributed.Workerreturnc"[US5(aURRO URnSnSHHnURUS5cMURXB5U:wdM/[R S5 Xn O US:XdUcUnU$)zIGet the number of threads from a worker and the user-supplied parameters.stateN)nthreadn_jobsz-Overriding `nthreads` defined in dask worker.r)hasattrrnthreadsgetLOGGERinfo)r r dwnt n_threadsps U/srv/projetos/modelo_ml_acdoc/venv/lib/python3.13/site-packages/xgboost/dask/utils.py get_n_threadsrs%,FG$<$<6<< &//DI " ??1d # /KOOA4LPT4T KKG H#I  # A~* dconfigcoll_cfgcS/nSnSnUb<UH5nXR;a[SU35e[R"SUS3[5 M7 O0nUR SS5nUb1UR S5(aUR S5(aUS S nUb"[RRU5up4Uc [5nURb;Ub,URU:wa[S US URS35eURnURbPUS:wa>Ub;URS:wa+XAR:wa[S US URS35eURnX44$![a Nf=f)zGet the tracker address from the optional user configuration. Parameters ---------- dconfig : Dask global configuration. coll_cfg : Collective configuration. Returns ------- The IP address along with the port number. scheduler_addressNrzUnknown configuration: zeUse `coll_cfg` instead of the Dask global configuration store for the XGBoost tracker configuration: .[]z\Conflicting host IP addresses from the dask configuration and the collective configuration: z v.s. zPConflicting ports from the dask configuration and the collective configuration: ) ValueErrorwarningswarn FutureWarningr startswithendswith distributedcommget_address_host_portr tracker_host_ip tracker_port)rr valid_confighost_ipportks rget_address_from_userr6"s&((LG DA$ #:1#!>?? MM??@cD  kk-t4Gw11#667;K;KC;P;P!B- ',,BB7KMG8+  8#;#;w#F--4IVHr;rr_DASK_2025_3_0rAus ?mJ7 77r)__doc__loggingr( functoolsrfcachetypingrrrrr9r-packaging.versionrr r8 collectiver getLoggerrstrintrr6r<boolr?rAr;rrrMs/%-- %4   + , tCH~ 7K PS F d38n %F17F 8C=# FR+w++999888r