ї -`┐iРЦСл≈UddlmZmZddlmZddlmZddlmZm Z erddl mZddlm Z daedzed<d efd └Zd efd└Zddedzd efd └Z ddddedd dfd└Zdd└ZdS)И)з TYPE_CHECKINGзOptional)зKVConnectorBaseType)зKVConnectorFactory)зKVConnectorBase_V1зKVConnectorRole)з VllmConfig)з KVCacheConfigNз_KV_CONNECTOR_AGENTзreturncС2≈t─ Jdі╚┌tS)NzAdisaggregated KV cache transfer parallel group is not initialized╘r╘СЗ┌/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/vllm/distributed/kv_transfer/kv_transfer_state.pyзget_kv_transfer_grouprs!─щп*п*ьKЯ+т*п*УпrcС≈tduS╘Nrrrrзhas_kv_transfer_grouprs ─щ═dп*п*rз connectorcСF≈|─t}|─dSt|tі╚S)a\Check if the KV connector is the v1 connector. If the argument is None, it will check the global KV connector Args: connector: The KV connector to check. If None, it will check the global KV connector. Note: This function will no-longer be needed after the v1 KV connector becomes the default. NF)rз isinstancer)rs rзis_v1_kv_transfer_grouprs+─Ппщ'┬ Юпь┬uЕ░iу!3я4т4п4rзvllm_configr зkv_cache_configr cС┬≈|j─dS|jjr*t─%tj|t j|╛і╚adSdSdS)z6 Initialize KV cache transfer parallel group. N)зconfigзroler)зkv_transfer_configзis_kv_transfer_instancerrзcreate_connectorrзWORKER)rrs rзensure_kv_transfer_initializedr#3sb─Пт%п-ь┬П т&т>П Еп'Е0тAьщ т'ь+П Я Т пппП П Ю'п'rcСN≈t│t═і╚dadSdSr)rзshutdownrrrзensure_kv_transfer_shutdownr&Js.─Еп&щв$р$я&т&п&ь"пппП'п&rr)rN)зtypingrrз.vllm.distributed.kv_transfer.kv_connector.baserз1vllm.distributed.kv_transfer.kv_connector.factoryrз,vllm.distributed.kv_transfer.kv_connector.v1rrзvllm.configr зvllm.v1.kv_cache_interfacer rз__annotations__rзboolrrr#r&rrrЗr/srПП+п*п*п*п*п*п*п*п*ЮNпNпNпNпNпNьPпPпPпPпPпPППППППППП П9ь&п&п&п&п&п&ь8п8п8п8п8п8Ю26пп(╗4я/п6п6я6Пп2ППППП+≤tП+П+П+П+П5П5п':╦Tя'AП5хTП5П5П5П5П,MQП П ьП ь08╦т0IП Ю П П П П П.#П#П#П#П#П#r