%`i1 |ddlZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZddlmZddlmZmZmZmZmZddlZddded ed eeeffd Zddded ed efd Zd ejfd ZeZded ej fdZ!dZ"dZ#deeefd eeeffdZ$ej%ej&zZ'de(fdZ)eZ*d2de(fdZ+dZ,dZ-deefdZ.d3deefdZ/dZ0 d4d!ed"efd#Z1d$Z2d%Z3d&Z4d'Z5d(Z6d5d*ed+ed,efd-Z7Gd.d/e Z8Gd0d1e8Z9dS)6N)ABCabstractmethod) signature) ModuleType)Any CoroutineDictOptionalTupleF reload_module full_pathr returncdd|vrE|ddkrtd|d|d\}}n,|d}|d|}||dzd}t j|}|rt j||t||fS)aiGiven a full import path to a module attr, return the imported module and attr. If `reload_module` is set, the module will be reloaded using `importlib.reload`. Args: full_path: The full import path to the module and attr. reload_module: Whether to reload the module. Returns: A tuple of the imported module and attr. :zGot invalid import path "z-". An import path may have at most one colon..N)count ValueErrorsplitrfind importlib import_modulereloadgetattr)rr module_name attr_namelast_period_idxmodules e/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/_common/utils.pyimport_module_and_attrr!s i ??3  ! # #:I::: "+!5!5 YY#//#.. 0 01 o1334  $[ 1 1F!   769-- --c0t||dS)aGiven a full import path to a module attr, return the imported attr. If `reload_module` is set, the module will be reloaded using `importlib.reload`. For example, the following are equivalent: MyClass = import_attr("module.submodule:MyClass") MyClass = import_attr("module.submodule.MyClass") from module.submodule import MyClass Returns: Imported attr r r)r!)rr s r import_attrr$3s ")= I I I! LLr"c>tj}|jdkrt|jdkri t j}|J|S#t $rB}dt|vsJt j cYd}~Sd}~wwxYwt j S)ajGet a running async event loop if one exists, otherwise create one. This function serves as a proxy for the deprecating get_event_loop(). It tries to get the running loop first, and if no running loop could be retrieved: - For python version <3.10: it falls back to the get_event_loop call. - For python version >= 3.10: it uses the same python implementation of _get_event_loop() at asyncio/events.py. Ideally, one should use high level APIs like asyncio.run() with python version >= 3.7, if not possible, one should create and manage the event loops explicitly.  Nzno running event loop) sys version_infomajorminorasyncioget_running_loop RuntimeErrorstrget_event_loop_policyget_event_loop) vers_infoloopes r get_or_create_event_loopr5Cs I! 2 5 5 D+--D###K D D D+c!ff4444022AACC C C C C C C  D  ! # ##s= B 7B>B B  coroutinect|}t||tj|S)a1Schedule a task reliably to the event loop. This API is used when you don't want to cache the reference of `asyncio.Task`. For example, ``` get_event_loop().create_task(coroutine(*args)) ``` The above code doesn't guarantee to schedule the coroutine to the event loops When using create_task in a "fire and forget" way, we should keep the references alive for the reliable execution. This API is used to fire and forget asynchronous execution. https://docs.python.org/3/library/asyncio-task.html#creating-tasks )r5 create_task_BACKGROUND_TASKSaddadd_done_callbackdiscard)r6tasks r run_background_taskr>gsP$ $ % % 1 1) < '(#GL /C1ACCD r"lengthc^dtjt|S)zjGenerates random string of length consisting exclusively of - Lower-case ASCII chars - Digits )k)joinrandomchoicesRANDOM_STRING_ALPHABET)rPs r get_random_alphanumeric_stringrXs& 776>"8FCCC D DDr"rbackctj} ||dz}|jd|jS#t$rYdSwxYw)aL Get the location (filename and line number) of a function caller, `back` frames up the stack. Args: back: The number of frames to go up the stack, not including this function. Returns: A string with the filename and line number of the caller. For example, "myfile.py:123". rrUNKNOWN)inspectstackfilenamelineno IndexError)rYr]frames r get_call_locationrbs[ MOOEdQh.115<111 yys 1 ??cdtjvrtjdStjdr dtjvrtjdStjdstjdr+tjtjd}ntj }|S)N RAY_TMPDIRlinuxTMPDIRdarwintmp) osenvironr(platform startswithpathrTseptempfile gettempdir)tempdirs r get_user_temp_dirrrsrz!!z,''   ) )(h"*.D.Dz(##   * *(cl.E.Eg.N.N(',,rvu--%'' Nr"cZtjtdS)Nray)rirmrTrrr"r get_ray_temp_dirrvs 7<<)++U 3 33r"temp_dircb|t}tj|dS)Nray_current_cluster)rvrirmrT)rws r get_ray_address_filerzs*#%% 7<<"7 8 88r"ct|}tj|r( tj|dS#t $rYdSwxYwdSN)rzrirmexistsremoveOSError)rw address_files r reset_ray_addressrsl'11L w~~l##  Il # # # # #    DD sA AAc|d}t|dkrtdd|dd}|d}t j|}t ||S)z`Load a class at runtime given a full path. Example of the path: mypkg.mysubpkg.myclass rz:You need to pass a valid path like mymodule.provider_classN)rlenrrTrrr)rm class_data module_path class_strrs r load_classrsu CJ :UVVV((:crc?++K2I  $[ 1 1F 69 % %%r"+/sys/fs/cgroup/memory/memory.limit_in_bytes/sys/fs/cgroup/memory.maxmemory_limit_filenamememory_limit_filename_v2czd}tj|r\t|d5}t |}dddn #1swxYwYntj|rtt|d5}|}|rt |}nd}dddn #1swxYwYtj j }|t||S|S)aReturn the total amount of system memory in bytes. Args: memory_limit_filename: The path to the file that contains the memory limit for the Docker container. Defaults to /sys/fs/cgroup/memory/memory.limit_in_bytes. memory_limit_filename_v2: The path to the file that contains the memory limit for the Docker container in cgroups v2. Defaults to /sys/fs/cgroup/memory.max. Returns: The total amount of system memory in bytes. Nr) rirmr}openrMreadstrip isnumericpsutilvirtual_memorytotalmin)rr docker_limitfmax_filepsutil_memory_in_bytess r get_system_memoryr s,L w~~+,, $ ' - - 1qvvxx~~//00L 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 0 1 1$ *C 0 0 $Avvxx~~''H!!## $"8}}  $  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $$244:>N   r"utf-8byte_str allow_none encode_typec||rdSt|tstd|d||S)aMake this unicode in Python 3, otherwise leave it as bytes. Args: byte_str: The byte string to decode. allow_none: If true, then we will allow byte_str to be None in which case we will return an empty string. TODO(rkn): Remove this flag. This is only here to simplify upgrading to flatbuffers 1.10.0. encode_type: The encoding type to use for decoding. Defaults to "utf-8". Returns: A byte string in Python 2 and a unicode string in Python 3. NrRz The argument z must be a bytes object.) isinstancebytesrr)rrrs r rr`sSJr h & &MKKKKLLL ??; ' ''r"c*eZdZedefdZdS) TimerBaserct)zReturn the current time.)NotImplementedErrorselfs r timezTimerBase.timevs "!r"N)__name__ __module__ __qualname__rfloatrrur"r rrus9"e"""^"""r"rceZdZdefdZdS)Timerrc(tjSr|)rrs r rz Timer.time}sy{{r"N)rrrrrrur"r rr|s/er"r)rr|)rr)Fr):r,rrrr\rirUstringr(rorabcrrrtypesrtypingrrr r r rr/boolr!r$AbstractEventLoopr5setr9Taskr>rNrLrOascii_lowercasedigitsrWrMrX_PRINTED_WARNINGrbrrrvrzrrrrrrrrrrrrur"r rs   ########88888888888888 .3....&*. :s?....>:? M M M3 M$ M3 M M M M $'";$$$$BCEE9<1'/$+T#s(^+S#X++++^ /&-?E3EEEE355C*   44498C=9999   & & & "O$? ,",","" ,",",","^ ...   ...   ((S(d(((((*""""""""Ir"