Ë
    uPêjL  ã                   óZ   — d dl Z d dlmZmZmZ d dlmZ er	d dlmZ	 e	Z
neZ
 G d„ d«      Zy)é    N)ÚTYPE_CHECKINGÚAnyÚFinal)Úcalculate_max_parallel_requests)ÚRouterc                   ó&   — e Zd Zededefd„«       Zy)ÚInitalizeCachedClientÚlitellm_router_instanceÚmodelc                 óL  — |j                  di «      }|d   d   }|j                  dd «      }|j                  dd «      }|j                  dd «      }t        |||| j                  ¬«      }|r9t        j                  |«      }|› d�}	| j
                  j                  |	|d	¬
«       y y )NÚlitellm_paramsÚ
model_infoÚidÚrpmÚtpmÚmax_parallel_requests)r   r   r   Údefault_max_parallel_requestsÚ_max_parallel_requests_clientT)ÚkeyÚvalueÚ
local_only)Úgetr   r   ÚasyncioÚ	SemaphoreÚcacheÚ	set_cache)
r
   r   r   Úmodel_idr   r   r   Ú calculated_max_parallel_requestsÚ	semaphoreÚ	cache_keys
             út/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/router_utils/client_initalization_utils.pyÚ set_max_parallel_requests_clientz6InitalizeCachedClient.set_max_parallel_requests_client   sÂ   € à %§	¡	Ð*:¸BÓ ?ˆØ Ñ-¨dÑ3ˆØ#×'Ñ'¨¨tÓ4ˆØ#×'Ñ'¨¨tÓ4ˆØ'5×'9Ñ'9Ð:QÐSWÓ'XÐÜ2QØØ"7ØØ*A×*_Ñ*_ô	3
Ð(ñ ,Ü&×0Ñ0Ð1QÓRˆIØ"* Ð+HÐIˆIØ#×)Ñ)×3Ñ3ØØØð 4õ ð ,ó    N)Ú__name__Ú
__module__Ú__qualname__ÚstaticmethodÚLitellmRouterÚdictr"   © r#   r!   r	   r	      s#   „ ØðÀ-ð ÐX\ò ó ñr#   r	   )r   Útypingr   r   r   Úlitellm.utilsr   Úlitellm.routerr   Ú_Routerr(   r	   r*   r#   r!   ú<module>r/      s+   ðÛ ß ,Ñ ,å 9áÝ0à�Mà€M÷ò r#   