&`i) hddlmZmZmZddlmZddlmZdada dZ dZ defd Z ed Z edd d eeefd eeeefdefdZedd d eeefd eeeefdefdZedededdfdZe ddd d eeefdeeefded eeeefdef dZedddd eeefded eeeefdefdZedd deeefd eeeefdeefdZdS))ListOptionalUnion)client_mode_hook) GcsClientFNcdadadS)NFglobal_gcs_client _initializedp/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/experimental/internal_kv.py_internal_kv_resetr sLLLr ctSNr r r rinternal_kv_get_gcs_clientrs r gcs_clientc|J|adadS)z;Initialize the internal KV for use in other function calls.NTr )rs r_initialize_internal_kvrs  ! ! !"LLLr ctduSrrr r r_internal_kv_initializedrs D ((r ) namespacekeyrreturnc t|tr|}t|tr|}t|tsJt||S)z Fetch the value of a binary key.) isinstancestrencodebytesr internal_kv_getrrs r_internal_kv_getr#!sr #sjjll)S!!'$$&& c5 ! !!! !  , ,S) < <r>s+((((((((((::::::!!!!!!   )))HL = = = sEz  =*25e3D*E =  = = = =HL @ @ @ sEz  @*25e3D*E @  @ @ @ @DcDCDDDDDD T .2 TTT sEz T e TT c5j)* T  TTTT: -1 L L L sEz  L Lc5j)* L  L L L LKOAAA #u* A-5eCJ6G-HA %[AAAAAAr