&`i7 HddlmZmZmZmZddlZiZdedefdZdZddZ dS) )AnyDictHashableListNfnreturnc t|}t|}||ftvr>ddd}i||}t|t jdi||t||f<t||fS)aLazily defines a ray.remote function. This is used in Datasets to avoid circular import issues with ray.remote. (ray imports ray.data in order to allow ``ray.data.read_foo()`` to work, which means ray.remote cannot be used top-level in ray.data). NOTE: Dynamic arguments should not be passed in directly, and should be set with ``options`` instead: ``cached_remote_fn(fn, **static_args).options(**dynamic_args)``. DEFAULT)scheduling_strategy max_retries)_make_hashablehashCACHED_FUNCTIONS%_add_system_error_to_retry_exceptionsrayremote)rray_remote_args hashable_args args_hashdefault_ray_remote_argss p/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/data/_internal/remote_fn.pycached_remote_fnrs&#?33M]##I I... $- # # I4HH-o>>>,ICJ,I,I,I,I",M,M"i) RO ,,c~t|ttfrtd|DSt|tr=d|D}tt |dSt|t r|Stdt|d)Nc,g|]}t|Srr).0os r z"_make_hashable..1s 555AnQ''555rcPg|]#\}}t|t|f$Srr)rkvs rr!z"_make_hashable..3s1TTT1nQ''):):;TTTrc|dS)Nrr)ts rz _make_hashable..4s QqTr)keyzType z is not hashable) isinstancertupleritemssortedr ValueErrortype)obj converteds rrr/s#e}%%>55555666 C  >TT TTT VI>>:::;;; C " "> <c<<<===rc:|dd}t|ttfsJt|tr8tjj|vr%|tjjn|stjjg}||d<dS)aModify the remote args so that Ray retries `RaySystemError`s. Ray typically automatically retries system errors. However, in some cases, Ray won't retry system errors if they're raised from task code. To ensure that Ray Data is fault tolerant to those errors, we need to add `RaySystemError` to the `retry_exceptions` list. TODO: Fix this in Ray Core. See https://github.com/ray-project/ray/pull/45079. retry_exceptionsFN)getr)listboolr exceptionsRaySystemErrorappend)rr2s rrr;s'**+=uEE &t 5 555 5 #T**; N )1A A A =>>>> ;N9:*:O&'''r)rN) typingrrrrrrrrrrrrr:s,,,,,,,,,,,, $-$-C$-$-$-$-N > > >;;;;;;r