o i@sddlmZddlmZddlmZddlmZmZedddZ eddd Z ed Z ed Z Gd d d e ZGdddeZGddde ZGdddeZGdddeZeddGdddZeddGdddZdS)) annotations) dataclass)Enum)OptionalTypeVarInputTT) contravariantOutputT) covariantServiceHandlerTServiceTcsReZdZdZdddfd d Zedd dZedddZedddZZ S) HandlerErrora A Nexus handler error. This exception is used to represent errors that occur during the handling of a Nexus operation that should be reported to the caller as a handler error. Example: .. code-block:: python import nexusrpc # Raise a bad request error raise nexusrpc.HandlerError( "Invalid input provided", type=nexusrpc.HandlerErrorType.BAD_REQUEST ) # Raise a retryable internal error raise nexusrpc.HandlerError( "Database unavailable", type=nexusrpc.HandlerErrorType.INTERNAL, retryable=True ) N)retryable_overridemessagestrtypeHandlerErrorTyperOptional[bool]cst|||_||_dS)a Initialize a new HandlerError. :param message: A descriptive message for the error. This will become the `message` in the resulting Nexus Failure object. :param type: The :py:class:`HandlerErrorType` of the error. :param retryable_override: Optionally set whether the error should be retried. By default, the error type is used to determine this. N)super__init___type_retryable_override)selfrrr __class__V/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/nexusrpc/_common.pyr.s  zHandlerError.__init__returncC|jS)zU The optional retryability override set when this error was created. )rrrrrrEzHandlerError.retryable_overrideboolcCs\|jdur|jStjtjtjtjtjh}tjtjtj tj h}|j |vr%dS|j |vr,dSdS)a Whether this error should be retried. If :py:attr:`retryable_override` is None, then the default behavior for the error type is used. See https://github.com/nexus-rpc/api/blob/main/SPEC.md#predefined-handler-errors NFT) rr BAD_REQUESTUNAUTHENTICATED UNAUTHORIZED NOT_FOUNDNOT_IMPLEMENTEDRESOURCE_EXHAUSTEDINTERNAL UNAVAILABLEUPSTREAM_TIMEOUTr)rnon_retryable_typesretryable_typesrrr retryableLs$   zHandlerError.retryablecCr)z The type of handler error. See :py:class:`HandlerErrorType` and https://github.com/nexus-rpc/api/blob/main/SPEC.md#predefined-handler-errors. )rrrrrrlszHandlerError.type)rrrrrr)rr)rr!)rr) __name__ __module__ __qualname____doc__rpropertyrr-r __classcell__rrrrr s  r c@sDeZdZdZdZ dZ dZ dZ dZ dZ dZ d Z d Z d S) rzuNexus handler error types. See https://github.com/nexus-rpc/api/blob/main/SPEC.md#predefined-handler-errors r"r#r$r%r'r(r&r)r*N) r.r/r0r1r"r#r$r%r'r(r&r)r*rrrrrws(rcs0eZdZdZd fdd Zed d d ZZS) OperationErrora An error that represents "failed" and "canceled" operation results. :param message: A descriptive message for the error. This will become the `message` in the resulting Nexus Failure object. :param state: Example: .. code-block:: python import nexusrpc # Indicate operation failed raise nexusrpc.OperationError( "Processing failed due to invalid data", state=nexusrpc.OperationErrorState.FAILED ) # Indicate operation was canceled raise nexusrpc.OperationError( "Operation was canceled by user request", state=nexusrpc.OperationErrorState.CANCELED ) rrstateOperationErrorStatecst|||_dS)N)rr_state)rrr5rrrrs  zOperationError.__init__rcCr)z- The state of the operation. )r7rrrrr5r zOperationError.state)rrr5r6)rr6)r.r/r0r1rr2r5r3rrrrr4s r4c@s&eZdZdZdZ dZ dZ dZdS)OperationStatez6 Describes the current state of an operation. running succeededfailedcanceledN)r.r/r0r1RUNNING SUCCEEDEDFAILEDCANCELEDrrrrr8sr8c@seZdZdZdZ dZdS)r6zR The state of an operation as described by an :py:class:`OperationError`. r;r<N)r.r/r0r1r?r@rrrrr6s r6)frozenc@s$eZdZUdZded< ded<dS) OperationInfoz) Information about an operation. rtokenr8r5Nr.r/r0r1__annotations__rrrrrBs rBc@s$eZdZUdZded< ded<dS)Linkz A Link contains a URL and a type that can be used to decode the URL. The URL may contain arbitrary data (percent-encoded). It can be used to pass information about the caller to the handler, or vice versa. rurlrNrDrrrrrFs rFN) __future__r dataclassesrenumrtypingrrrr r r Exceptionr rr4r8r6rBrFrrrrs*    cF'