%`iddlZddlZddlZddlmZddlmZmZddlZddl m cm Z ddl m ZddlmZmZmZddlmZmZmZmZmZmZddlmZmZejeZeGdde Z!eGd d e!Z"eGd d e!Z#eGd de!Z$eGdde!Z%eGdde!Z&eGdde!Z'eGdde'Z(eGdde'Z)eGdde!Z*eGdde!Z+eGdde!Z,eGdd e!Z-eGd!d"e!Z.eGd#d$e!Z/eGd%d&e!Z0eGd'd(e!Z1eGd)d*e1Z2eGd+d,e!Z3eGd-d.e1e4Z5eGd/d0e1Z6eGd1d2e1Z7eGd3d4e1Z8eGd5d6e1Z9eGd7d8e1Z:eGd9d:e!e;Ze!Z>eGd?d@e!Z?eGdAdBe!Z@eGdCdDe!ZAeGdEdFe!ZBeGdGdHe!ZCeGdIdJe!ZDeGdKdLe!ZEeGdMdNe!ZFedOPGdQdRe*ZGedOPGdSdTeGe;ZHedOPGdUdVe*ZIedOPGdWdXe!ZJeGdYdZeKe!ZLge=e!e$e&e'e-e1e2e5e8e9e:e7e<e>e?e@eAeBe%eCe(eDe)eGeHeFeIeJeLe+ZMdS)[N)format_exception)OptionalUnion)ActorIDTaskIDWorkerID)PYTHONActorDiedErrorContextAddressLanguage NodeDeathInfo RayException) DeveloperAPI PublicAPIcDeZdZdZdZedZedZdS)RayErrorz'Super class of all ray exception types.ct|||jf}dt|}t t t j||S)N )languageserialized_exceptionformatted_exception_string) type __traceback__joinrrr pickledumpsSerializeToString)selfexc_infors b/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/exceptions.pyto_byteszRayError.to_bytessgJJd&89%)YY/?/J%K%K"!'d!3!3'A         c|t}||t|SN)rParseFromStringrfrom_ray_exception)b ray_exceptions r from_byteszRayError.from_bytes's3$ %%a(((**=999r"c|jtkrJ tj|jS#t $r#t |dd}t|cYSwxYwt|S)Nrz(No formatted exception string available.) rr rloadsr ExceptiongetattrUnserializableExceptionCrossLanguageError)r(original_stacktraces r r&zRayError.from_ray_exception-s  !V + + D|M$FGGG D D D'.!0>''# //BCCCCC D&m44 4s+*AAN)__name__ __module__ __qualname____doc__r! staticmethodr)r&r"r rrs_11::\: 55\555r"rc"eZdZdZfdZxZS)r/zRaised from another language.ctdtj|j|jdS)NzAn exception raised from {}: {})super__init__formatr Namerr)rr( __class__s r r:zCrossLanguageError.__init__DsR  . 5 5 m4558       r")r1r2r3r4r: __classcell__r=s@r r/r/@s>''         r"r/cDeZdZdZ ddeedeefdZdZdS)TaskCancelledErrorzRaised when this task is cancelled. Args: task_id: The TaskID of the function that was directly cancelled. Ntask_id error_messagec"||_||_dSr$)rBrC)rrBrCs r r:zTaskCancelledError.__init__Vs *r"cnd}|jrdt|jzdz}|jr ||jz }|S)NzTask: z was cancelled. )rBstrrCrmsgs r __str__zTaskCancelledError.__str__\sI < DS...1CCC   & 4% %C r")NN) r1r2r3r4rrrGr:rJr6r"r rArAMsfPT++'+?G}++++ r"rAcHeZdZdZ d dZd dZd dZd dZdZd Z dS) RayTaskErroraIndicates that a task threw an exception during execution. If a task throws an exception during execution, a RayTaskError is stored in the object store for each of the task's outputs. When an object is retrieved from the object store, the Python method that retrieved it checks to see if the object is a RayTaskError and if it is then an exception is thrown propagating the error message. Nc 8ddl} |r||_n| j|_|pt j|_|p| j|_ ||_ ||_ ||_ ||_ ||_ tj|nd#tjt$f$rK} d|jjd| d} t(| t-| |_Yd} ~ nd} ~ wwxYw|||j|||f|_|JdS)zInitialize a RayTaskError.rNz(The original cause of the RayTaskError (z) isn't serializable: z&. Overwriting the cause to a RayError.)ray proctitle_raylet getproctitleosgetpidpidutilget_node_ip_addressip function_name traceback_str actor_repr _actor_idcauserr PicklingError TypeErrorr=loggerwarningrargs) rrXrYr\rOrTrWrZactor_idrNeerr_msgs r r:zRayTaskError.__init__psH   8&DNN [5577DN%")++64466**$!  + L    $i0 + + +8Z)88AB888  NN7 # # #!'**DJJJJJJ +#M4:y#rR (((((s B D6AC<<Dreturnctjdkr.t|jtr|S|S)zMakes a object instance that inherits from both RayTaskError and the type of `self.cause`. Raises TypeError if the cause class can't be subclassed) )sys version_info isinstancer\ExceptionGroup,_make_exceptiongroup_dual_exception_instance$_make_normal_dual_exception_instancers r make_dual_exception_instancez)RayTaskError.make_dual_exception_instancesN  w & &: J, , &DDFF F88:::r"c|jj}t|Gfddt|d|jd}|_|_|jS)Nc0eZdZdZfdZdZfdZdS)>RayTaskError._make_normal_dual_exception_instance..clsc$||_|f|_dSr$r\rarr\s r r:zGRayTaskError._make_normal_dual_exception_instance..cls.__init__" "H r"c|jfSr$rarclss r __reduce__zIRayTaskError._make_normal_dual_exception_instance..cls.__reduce__TY''r"c,t|j|Sr$r-r\rnames r __getattr__zJRayTaskError._make_normal_dual_exception_instance..cls.__getattr__tz4000r"cSr$r6r error_msgs r rJzFRayTaskError._make_normal_dual_exception_instance..cls.__str__   r"N)r1r2r3r:r|rrJ)r{rsr r{rsse % % % ( ( ( ( ( 1 1 1 ! ! ! ! ! ! !r"r{ RayTaskError()r\r=rGrLr1r3r cause_clsrr{rs @@r rnz1RayTaskError._make_normal_dual_exception_instancesJ( II  ! ! ! ! ! ! ! !, ! ! !5y1444 s4:r"c|jj}t|Gfddt|d|jd}|_|_|jS)Nc@eZdZfdZdZfdZdZfdZxZS)FRayTaskError._make_exceptiongroup_dual_exception_instance..clscbt||j|j}|Sr$)r9__new__message exceptions)r{r\rr=s r rzNRayTaskError._make_exceptiongroup_dual_exception_instance..cls.__new__s&wwsEM5;KLL r"c$||_|f|_dSr$rurvs r r:zORayTaskError._make_exceptiongroup_dual_exception_instance..cls.__init__rwr"c|jfSr$ryrzs r r|zQRayTaskError._make_exceptiongroup_dual_exception_instance..cls.__reduce__r}r"c,t|j|Sr$rrs r rzRRayTaskError._make_exceptiongroup_dual_exception_instance..cls.__getattr__rr"cSr$r6rs r rJzNRayTaskError._make_exceptiongroup_dual_exception_instance..cls.__str__rr") r1r2r3rr:r|rrJr>)r=r{rs@r r{rs      % % % ( ( ( ( ( 1 1 1 ! ! ! ! ! ! ! ! !r"r{rrrrs @@r rmz9RayTaskError._make_exceptiongroup_dual_exception_instancesJ( II  ! ! ! ! ! ! ! !,  ! ! !$5y1444 s4:r"c|jj}tt|r|S |S#t $r>}t dt|jd||cYd}~Sd}~wwxYw)a;Returns an exception that's an instance of the cause's class. The returned exception inherits from both RayTaskError and the cause class and contains all of the attributes of the cause exception. If the cause class can't be subclassed, issues a warning and returns `self`. zUser exception type z in RayTaskError can't be subclassed! This exception is raised as RayTaskError only. You can use `ray_task_error.cause` to access the user exception. Failure in subclassing: N) r\r= issubclassrLrpr^r_r`r)rrrcs r as_instanceof_causez RayTaskError.as_instanceof_causesJ( lI . . K 4466 6    NNKtDJ'7'7KKHIKK    KKKKKK s9 B3A<6B<Bc |jd}g}d}t|D]#\}}|drwt jj|jdt jj d|j d|j }|j r|d|j d|j d z }n|d z }d}|||d rad |vs d |vsd |vsd|vrQd|vr|d|dzt|kr ||dzdrd}|rd}||%d|S)z"Format a RayTaskError as a string.rFz Traceback z()z (pid=z, ip=z , actor_id=z, repr=rz File z ray/worker.pyz ray/_private/zray/util/tracing/zray/_raylet.pyxz&ray._raylet.raise_if_dependency_failedzJ At least one of the input arguments for this task could not be computed:z T)rYstripsplit enumerate startswithcoloramaForeCYANrORESETrTrWrZr[appendlenr)rlinesoutcode_from_internal_fileilinetraceback_lines r rJzRayTaskError.__str__s"((**0066"'!''1 !1 !GAt|,,/ !})5~55}*55!H55,0755 ?*"OdnOOT_OOONN#c)N*/' >****++ !4''"d**&$..$,, ||_||_||_||_dSr$)rbr_actor_init_failed _preempted)rrbrrrs r r:zRayActorError.__init__Vs%! ""3#r"rec|jSr$)rros r rJzRayActorError.__str__fs ~r"c|jSr$)rros r rzRayActorError.preemptedis r"c|jSr$)rros r rzRayActorError.actor_init_failedms &&r") r1r2r3r4BASE_ERROR_MSGrGboolr:rJpropertyrrr6r"r rrKsRN'"' $$$$ $  $$$$ 4X'4'''X'''r"rcheZdZdZdZ ddeeeefffd Z e defdZ xZ S) ActorDiedErroraiIndicates that the actor died unexpectedly before finishing a task. This exception could happen either because the actor process dies while executing a task, or because a task is submitted to a dead actor. Args: cause: The cause of the actor error. `RayTaskError` type means the actor has died because of an exception within `__init__`. `ActorDiedErrorContext` means the actor has died because of an unexpected system error. None means the cause isn't known. Theoretically, this shouldn't happen, but it's there as a safety check. z7The actor died unexpectedly before finishing this task.Nr\cLd}tj}d}d}|snt|tr"d}|j}d|}nt|t sJtjg}|d|j|dt|j  |j dkr|d|j |j d kr|d |j |jd kr|d |j|jd kr|d |j||j|jr|d |jr|jjt(jkrd}d|}t|j  }t/||||dS)zF Construct a RayActorError by building the arguments. NFTz@The actor died because of an error raised in its creation task, z class_name: z actor_id: rz pid: rFz name: z namespace: z ip: zAThe actor never ran - it was cancelled before it started running.r)rrrkrLr[rJr r class_namerrbhexrTr ray_namespacenode_ip_addressrC never_startednode_death_inforeasonr AUTOSCALER_DRAIN_PREEMPTEDrr9r:)rr\rbrrrerror_msg_linesr=s r r:zActorDiedError.__init__sL"1 ! & 5  | , ,# 5 $ H%==??%% Ie%:;; ; ;;-<=O  " "#FE4D#F#F G G G  " "#Q'%.2I2I2M2M2O2O#Q#Q R R RyA~~&&'<'<'<===zR&&'>%*'>'>???"b((&&'Lu7J'L'LMMM$**&&'G0E'G'GHHH  " "5#6 7 7 7" &&W% !)0 ;<<!  /22Iu~..2244H 9.?KKKKKr" task_errorc t|Sr$)r)rs r from_task_errorzActorDiedError.from_task_errorsj)))r"r$) r1r2r3r4rrrrLr r:r5rr>r?s@r rrrs  ONMQ3L3LeL2G$GHI3L3L3L3L3L3Lj*L***\*****r"rc8eZdZdZdedeeffd ZxZS)ActorUnavailableErrorzLRaised when the actor is temporarily unavailable but may be available later.rCrbc|!t|nd}d|d|d}d}d}t||||dS)Nz The actor z is unavailable: z:. The task may or may not have been executed on the actor.F)rrr9r:)rrCrbrrrr=s r r:zActorUnavailableError.__init__s.6.B78$$((*** 7 7 7M 7 7 7 "  9.?KKKKKr") r1r2r3r4rGrbytesr:r>r?s@r rrsaVV Lc LXe_ L L L L L L L L L Lr"rc eZdZdZddZdZdS)RaySystemErrorzpIndicates that Ray encountered a system error. This exception can be thrown when the raylet is killed. Nc"||_||_dSr$ client_excrY)rrrYs r r:zRaySystemError.__init__s$*r"cBd|j}|jr |d|jz }|S)NzSystem error: z traceback: rrs r rJzRaySystemError.__str__s86T_66   > =);== =Ir"r$r1r2r3r4r:rJr6r"r rrsA ++++r"rc4eZdZdZdeffd ZdefdZxZS)AuthenticationErroraIndicates that an authentication error occurred. Most commonly, this is caused by a missing or mismatching token set on the client (e.g., a Ray CLI command interacting with a remote cluster). Only applicable when `RAY_AUTH_MODE` is not set to `disabled`. rcf||_d|_t|dS)NT)r__suppress_context__r9r:)rrr=s r r:zAuthenticationError.__init__s2 %)! !!!!!r"recd}ddlm}ddlm}m}|}||jkr||}d|d}d}|jdz|z|zS) NrFr)get_authentication_mode_name)AuthenticationModeget_authentication_modez# Note: RAY_AUTH_MODE is currently 'z' (not 'token').a Ensure that the token for the cluster is available in a local file (e.g., ~/.ray/auth_token or via RAY_AUTH_TOKEN_PATH) or as the `RAY_AUTH_TOKEN` environment variable. To generate a token for local development, use `ray get-auth-token --generate` For remote clusters, ensure that the token is propagated to all nodes of the cluster when token authentication is enabled. For more information, see: https://docs.ray.io/en/latest/ray-security/token-auth.html.)0ray._private.authentication.authentication_utilsr ray._rayletrrTOKENr)rauth_mode_noterrr current_mode mode_name help_texts r rJzAuthenticationError.__str__s       LKKKKKKK..00 -3 3 344\BBIQiQQQ   d |c!N2Y>>r"r1r2r3r4rGr:rJr>r?s@r rrsi"""""""?????????r"rceZdZdZdS)UserCodeExceptiona Indicates that an exception occurred while executing user code. For example, this exception can be used to wrap user code exceptions from a remote task or actor. The `retry_exceptions` parameter will still respect the underlying cause of this exception.Nr1r2r3r4r6r"r rr s==  Dr"rc"eZdZdZfdZxZS)ObjectStoreFullErrorzIndicates that the object store is full. This is raised if the attempt to store the object fails because the object store is full even after multiple retries. cXtt|dzS)Nz The local object store is full of objects that are still in scope and cannot be evicted. Tip: Use the `ray memory` command to list active objects in the cluster.)r9rrJrr=s r rJzObjectStoreFullError.__str__s,)40088:: 5  r"r1r2r3r4rJr>r?s@r rrsB          r"rc"eZdZdZfdZxZS)OutOfDiskErrorzIndicates that the local disk is full. This is raised if the attempt to store the object fails because both the object store and disk are full. cXtt|dzS)Nz The object cannot be created because the local object store is full and the local disk's utilization is over capacity (95% by default).Tip: Use `df` on this node to check disk usage and `ray memory` to check object store memory usage.)r9rrJrs r rJzOutOfDiskError.__str__.s+^T**2244 ?  r"rr?s@r rr&sB          r"rceZdZdZdZdZdS)OutOfMemoryErrorzIndicates that the node is running out of memory and is close to full. This is raised if the node is low on memory and tasks or actors are being evicted to free up memory. c||_dSr$rrrs r r:zOutOfMemoryError.__init__C  r"c|jSr$rros r rJzOutOfMemoryError.__str__F |r"Nrr6r"r rr:s<r"rceZdZdZdZdZdS) NodeDiedErrorz6Indicates that the node is either dead or unreachable.c||_dSr$rrs r r:zNodeDiedError.__init__Orr"c|jSr$rros r rJzNodeDiedError.__str__Rrr"Nrr6r"r rrJs8@@r"rc$eZdZdZdZdZdZdS)ObjectLostErrorzIndicates that the object is lost from distributed memory, due to node failure or system error. Args: object_ref_hex: Hex ID of the object. cl||_||_|tjd|_dS)Nz )object_ref_hex owner_addressreplace ray_constantsCALL_STACK_LINE_DELIMITER call_site)rrrr s r r:zObjectLostError.__init___s5,*"**  3V  r"cPd|jd}|jr|d|jz }n|dz }|S)NzFailed to retrieve object z. zThe ObjectRef was created at: zTo see information about where this ObjectRef was created in Python, set the environment variable RAY_record_ref_creation_sites=1 during `ray start` and `ray.init()`.)rr rHs r _base_strzObjectLostError._base_strfsLB4+>BBB >  DDNDD DCC   C  r"cH|dzd|jdzS)N zAll copies of z have been lost due to node failure. Check cluster logs (`/tmp/ray/session_latest/logs`) for more information about the failure.r rros r rJzObjectLostError.__str__ss: NN   6!4666  r"N)r1r2r3r4r:r rJr6r"r rrVsK            r"rceZdZdZdZdS)ObjectFetchTimedOutErrorzgIndicates that an object fetch timed out. Args: object_ref_hex: Hex ID of the object. cH|dzd|jdzS)NrzFetch for object z` timed out because no locations were found for the object. This may indicate a system-level bug.rros r rJz ObjectFetchTimedOutError.__str__s: NN   $D$7$$$  r"Nrr6r"r rr-      r"rc eZdZdZddZdZdS)RpcErrorz0Indicates an error in the underlying RPC system.Nc"||_||_dSr$)rrpc_code)rrrs r r:zRpcError.__init__s   r"c|jSr$rros r rJzRpcError.__str__rr"r$rr6r"r rrs=::!!!!r"rceZdZdZdZdS)ReferenceCountingAssertionErrorzIndicates that an object has been deleted while there was still a reference to it. Args: object_ref_hex: Hex ID of the object. c6|dzdzS)Nrz_The object has already been deleted by the reference counting protocol. This should not happen.r ros r rJz'ReferenceCountingAssertionError.__str__s& NN   4  r"Nrr6r"r rrs-     r"rceZdZdZdZdS)ObjectFreedErrorzIndicates that an object was manually freed by the application. Attributes: object_ref_hex: Hex ID of the object. c6|dzdzS)NrzThe object was manually freed using the internal `free` call. Please ensure that `free` is only called once the object is no longer needed.rros r rJzObjectFreedError.__str__s& NN   !  r"Nrr6r"r rrrr"rceZdZdZdZdS)OwnerDiedErrorzIndicates that the owner of the object has died while there is still a reference to the object. Args: object_ref_hex: Hex ID of the object. c.d}|jro t}||j|j}t |j}d|d|}n#t$rYnwxYw|dzd|dzS)Nz`/tmp/ray/session_latest/logs`z`/tmp/ray/session_latest/logs/*z*` at IP address rzThe object's owner has exited. This is the Python worker that first created the ObjectRef via `.remote()` or `ray.put()`. Check cluster logs (z7) for more information about the Python worker failure.) rr r% ip_addressr worker_idrr,r )rlog_locaddrip_addrr%s r rJzOwnerDiedError.__str__s2    yy$$T%7888/$T^44 0immoo00&-00     NN   ?(/???  sAA)) A65A6Nrr6r"r r"r"s-     r"r"ceZdZdZdZdS)ObjectReconstructionFailedErrorzpIndicates that the object cannot be reconstructed. Args: object_ref_hex: Hex ID of the object. c6|dzdzS)NrzThe object cannot be reconstructed because it was created by an actor, ray.put() call, or its ObjectRef was created by a different worker.rros r rJz'ObjectReconstructionFailedError.__str__s& NN   ?  r"Nrr6r"r r*r*rr"r*ceZdZdZdZdS)2ObjectReconstructionFailedMaxAttemptsExceededErrorzIndicates that the object cannot be reconstructed because the maximum number of task retries has been exceeded. Args: object_ref_hex: Hex ID of the object. c6|dzdzS)NrzThe object cannot be reconstructed because the maximum number of task retries has been exceeded. To prevent this error, set `@ray.remote(max_retries=)` (default 3).rros r rJz:ObjectReconstructionFailedMaxAttemptsExceededError.__str__ s' NN   H  r"Nrr6r"r r-r--      r"r-ceZdZdZdZdS)-ObjectReconstructionFailedLineageEvictedErrorzIndicates that the object cannot be reconstructed because its lineage was evicted due to memory pressure. Args: object_ref_hex: Hex ID of the object. c6|dzdzS)NrzThe object cannot be reconstructed because its lineage has been evicted to reduce memory pressure. To prevent this error, set the environment variable RAY_max_lineage_bytes= (default 1GB) during `ray start`.rros r rJz5ObjectReconstructionFailedLineageEvictedError.__str__!s' NN   R  r"Nrr6r"r r1r1r/r"r1ceZdZdZdS)GetTimeoutErrorz.Indicates that a call to the worker timed out.Nrr6r"r r4r4.s88Dr"r4ceZdZdZdS)PlasmaObjectNotAvailablezACalled when an object was not available within the given timeout.Nrr6r"r r6r65sKKDr"r6ceZdZdZdS)AsyncioActorExitzBRaised when an asyncio actor intentionally exits via exit_actor().Nrr6r"r r8r8<LLDr"r8c&eZdZdZddefdZdZdS)RuntimeEnvSetupErrorzRaised when a runtime environment fails to be set up. Args: error_message: The error message that explains why runtime env setup has failed. NrCc||_dSr$rCrrCs r r:zRuntimeEnvSetupError.__init__L*r"ctdg}|jr||jd|S)Nz%Failed to set up runtime environment.r)rCrr)rmsgss r rJzRuntimeEnvSetupError.__str__Os:78   , KK* + + +yyr"r$r1r2r3r4rGr:rJr6r"r r;r;CsM++c++++r"r;ceZdZdZdZdS)TaskPlacementGroupRemoved:Raised when the corresponding placement group was removed.cdS)Nz@The placement group corresponding to this task has been removed.r6ros r rJz!TaskPlacementGroupRemoved.__str__ZsQQr"Nrr6r"r rDrDVs.DDRRRRRr"rDceZdZdZdZdS)ActorPlacementGroupRemovedrEcdS)NzAThe placement group corresponding to this Actor has been removed.r6ros r rJz"ActorPlacementGroupRemoved.__str__bsRRr"Nrr6r"r rHrH^s.DDSSSSSr"rHceZdZdZdS)PendingCallsLimitExceededzRaised when the pending actor calls exceeds `max_pending_calls` option. This exception could happen probably because the caller calls the callee too frequently. Nrr6r"r rKrKfs  Dr"rKc$eZdZdZdefdZdZdS)TaskUnschedulableErrorzRaised when the task cannot be scheduled. One example is that the node specified through NodeAffinitySchedulingStrategy is dead. rCc||_dSr$r=r>s r r:zTaskUnschedulableError.__init__yr?r"cd|jS)NzThe task is not schedulable: r=ros r rJzTaskUnschedulableError.__str__|sCt/ACCCr"NrBr6r"r rMrMqsM +c++++DDDDDr"rMc$eZdZdZdefdZdZdS)ActorUnschedulableErrorzRaised when the actor cannot be scheduled. One example is that the node specified through NodeAffinitySchedulingStrategy is dead. rCc||_dSr$r=r>s r r:z ActorUnschedulableError.__init__r?r"cd|jS)NzThe actor is not schedulable: r=ros r rJzActorUnschedulableError.__str__sD0BDDDr"NrBr6r"r rQrQsM +c++++EEEEEr"rQceZdZdZdS)ObjectRefStreamEndOfStreamErrorzWRaised by streaming generator tasks when there are no more ObjectRefs to read. Nrr6r"r rUrU Dr"rUceZdZdZdS)(OufOfBandObjectRefSerializationExceptionznRaised when an `ray.ObjectRef` is out of band serialized by `ray.cloudpickle`. It is an anti pattern. Nrr6r"r rXrXrVr"rXalpha) stabilityceZdZdZdS)RayChannelErrorz[Indicates that Ray encountered a system error related to ray.experimental.channel. Nrr6r"r r\r\rVr"r\ceZdZdZdS)RayChannelTimeoutErrorz;Raised when the Compiled Graph channel operation times out.Nrr6r"r r^r^sEEDr"r^ceZdZdZdS)RayCgraphCapacityExceededzBRaised when the Compiled Graph channel's buffer is at max capacityNrr6r"r r`r`r9r"r`c$eZdZdZdefdZdZdS)r.aRaised when there is an error deserializing a serialized exception. This occurs when deserializing (unpickling) a previously serialized exception fails. In this case, we fall back to raising the string representation of the original exception along with its stack trace that was captured at the time of serialization. For more details and how to handle this with custom serializers, :ref:`configuring custom exeception serializers ` Args: original_stack_trace: The string representation and stack trace of the original exception that was captured during serialization. original_stack_tracec||_dSr$_original_stack_trace)rrbs r r:z UnserializableException.__init__s%9"""r"cd|jS)NzFailed to deserialize exception. Refer to https://docs.ray.io/en/latest/ray-core/objects/serialization.html#custom-serializers-for-exceptions for more information. Original exception: rdros r rJzUnserializableException.__str__s ,) , , r"NrBr6r"r r.r.sH  :S::::     r"r.c.eZdZdZdeffd ZdZxZS)ActorAlreadyExistsErrora%Raised when a named actor already exists. Note that this error is not only a subclass of RayError, but also a subclass of ValueError, to maintain backward compatibility. Args: error_message: The error message that contains information about the actor name and namespace. rCcXt|||_dSr$)r9r:rC)rrCr=s r r:z ActorAlreadyExistsError.__init__s) '''*r"c|jSr$r=ros r rJzActorAlreadyExistsError.__str__s !!r"rr?s@r rhrhs]+c++++++"""""""r"rh)NloggingrRri tracebackrtypingrrrray._private.ray_constants_privater ray.cloudpickle cloudpicklerrrrrray.core.generated.common_pb2r r r r r rray.util.annotationsrr getLoggerr1r_r,rr/rArLrrrrrrrrrrrrrrrAssertionErrorrrr"r*r-r1 TimeoutErrorr4r6r8r;rDrHrKrMrQrUrXr\r^r`r. ValueErrorrhRAY_EXCEPTION_TYPESr6r"r rys  &&&&&&""""""""222222222 111111111198888888  8 $ $ #5#5#5#5#5y#5#5 #5L               . OOOOO8OO Od VVVVV8VV V           #'#'#'#'#'H#'#' #'LH*H*H*H*H*]H*H*H*V L L L L LM L L L X " '?'?'?'?'?('?'? '?T               8            X    &      x     H  % % % % % h% %  % P          &x     o~   &        & # # # # # _# #  # L      o    &          *      O    *      h           x          x     8 $ RRRRRRR R SSSSSSS S            D D D D DX D D  D  E E E E Eh E E  E     h        x    W     n    W     _l    W         W     h   4"""""j(""""            $ $ 7 2     ! "# $% &' () *+ ,- ./ 01 23 45 6-7 89 :; <= >? r"