o il5@sJdZddlZddlmZddlmZddlmZmZm Z m Z ddl Z ddl Z ddlZ GdddeZGdd d eZGd d d eZGd d d eZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGdddeZGd d!d!eZd"ed#efd$d%Z dS)&zCommon Temporal exceptions.N) timedelta)IntEnum)AnyOptionalSequenceTuplec@s&eZdZdZedeefddZdS) TemporalErrorz!Base for all Temporal exceptions.returncC|jS)zVCause of the exception. This is the same as ``Exception.__cause__``. ) __cause__selfr[/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/temporalio/exceptions.pycauseszTemporalError.causeN)__name__ __module__ __qualname____doc__propertyr BaseExceptionrrrrrr src szeZdZdZddddedeejjj j dee ddffdd Z e defd d Ze deejjj j fd d ZZS) FailureErrorz=Base for runtime failures during workflow/activity execution.N)failureexc_argsmessagerrr cs*|dur|f}tj|||_||_dS)zInitialize a failure error.N)super__init___message_failure)r rrr __class__rrrs   zFailureError.__init__cCr )zMessage.)rr rrrr*zFailureError.messagecCr )z#Underlying protobuf failure object.)rr rrrr/r!zFailureError.failure)rrrrstrr temporalioapirv1Failurerrrr __classcell__rrrrrs"$rc s<eZdZdZdddededeeddffdd ZZS) WorkflowAlreadyStartedErroraLThrown by a client or workflow when a workflow execution has already started. Attributes: workflow_id: ID of the already-started workflow. workflow_type: Workflow type name of the already-started workflow. run_id: Run ID of the already-started workflow if this was raised by the client. N)run_id workflow_id workflow_typer)r cs"td||_||_||_dS)z,Initialize a workflow already started error.z"Workflow execution already startedN)rrr*r+r))r r*r+r)rrrr?s  z$WorkflowAlreadyStartedError.__init__)rrrrr"rrr'rrrrr(5s r(c@s4eZdZdZeejjjj j Z eejjjj j Z dS)ApplicationErrorCategoryziSeverity category for your application error. Maps to corresponding client-side logging/metrics behaviorsN)rrrrintr#r$enumsr%r,&APPLICATION_ERROR_CATEGORY_UNSPECIFIED UNSPECIFIED!APPLICATION_ERROR_CATEGORY_BENIGNBENIGNrrrrr,Is  r,cseZdZdZdddejddededeede d ee d ed dffd d Z e d e efddZe d eefddZe d e fddZe d ee fddZe d efddZZS)ApplicationErrorz0Error raised during workflow/activity execution.NF)type non_retryablenext_retry_delaycategoryrdetailsr4r5r6r7r csFtj||s|n|d|fd||_||_||_||_||_dS)z Initialize an application error.z: )rN)rr_details_type_non_retryable_next_retry_delay _category)r rr4r5r6r7r8rrrrYs  zApplicationError.__init__cCr z"User-defined details on the error.r9r rrrr8nr!zApplicationError.detailscCr )zGeneral error type.r:r rrrr4sr!zApplicationError.typecCr )aWhether the error was set as non-retryable when created. Note: This is not whether the error is non-retryable via other means such as retry policy. This is just whether the error was marked non-retryable upon creation by the user. r;r rrrr5xszApplicationError.non_retryablecCr )zDelay before the next activity retry attempt. User activity code may set this when raising ApplicationError to specify a delay before the next activity retry. )r<r rrrr6sz!ApplicationError.next_retry_delaycCr )z*Severity category of the application error)r=r rrrr7r!zApplicationError.category)rrrrr,r0r"rrboolrrrrr8r4r5r6r7r'rrrrr3Vs> r3csFeZdZdZd dededdffdd Zedeefd d Z Z S) CancelledErrorz/Error raised on workflow/activity cancellation. Cancelledrr8r Nct|||_dS)zInitialize a cancelled error.Nrrr9r rr8rrrr  zCancelledError.__init__cCr r>r?r rrrr8r!zCancelledError.details)rD rrrrr"rrrrr8r'rrrrrCs rCcsDeZdZdZdededdffdd Zedeefdd Z Z S) TerminatedErrorz&Error raised on workflow cancellation.rr8r NcrE)zInitialize a terminated error.NrFrGrrrrrHzTerminatedError.__init__cCr r>r?r rrrr8r!zTerminatedError.detailsrIrrrrrJs rJc@sXeZdZdZeejjjj j Z eejjjj j Z eejjjj jZeejjjj jZdS) TimeoutTypez-Type of timeout for :py:class:`TimeoutError`.N)rrrrr-r#r$r.r%rKTIMEOUT_TYPE_START_TO_CLOSESTART_TO_CLOSETIMEOUT_TYPE_SCHEDULE_TO_STARTSCHEDULE_TO_STARTTIMEOUT_TYPE_SCHEDULE_TO_CLOSESCHEDULE_TO_CLOSETIMEOUT_TYPE_HEARTBEAT HEARTBEATrrrrrKs   rKcsfeZdZdZdedeedeeddffdd Z e deefd d Z e deefd d Z Z S) TimeoutErrorz*Error raised on workflow/activity timeout.rr4last_heartbeat_detailsr Ncst|||_||_dS)zInitialize a timeout error.N)rrr:_last_heartbeat_details)r rr4rUrrrrs  zTimeoutError.__init__cCr )zType of timeout error.r@r rrrr4r!zTimeoutError.typecCr )z  rgcseZdZdZdededededededed eed d ffd d Ze d efddZ e d efddZ e d efddZ e d efddZ e d efddZe d efddZe d eefddZZS)ChildWorkflowErrorz'Error raised on child workflow failure.r namespacer*r)r+initiated_event_idrirmr Nc s:t|||_||_||_||_||_||_||_dS)z"Initialize a child workflow error.N) rr _namespace _workflow_id_run_id_workflow_type_initiated_event_idrors) r rrzr*r)r+r{rirmrrrr3s  zChildWorkflowError.__init__cCr )zNamespace for this error.)r|r rrrrzIr!zChildWorkflowError.namespacecCr )zWorkflow ID for this error.)r}r rrrr*Nr!zChildWorkflowError.workflow_idcCr )zRun ID for this error.)r~r rrrr)Sr!zChildWorkflowError.run_idcCr )zWorkflow type for this error.)rr rrrr+Xr!z ChildWorkflowError.workflow_typecCr )z"Initiated event ID for this error.)rr rrrr{]r!z%ChildWorkflowError.initiated_event_idcCr rurvr rrrribr!z#ChildWorkflowError.started_event_idcCr rwrxr rrrrmgr!zChildWorkflowError.retry_state)rrrrr"r-rrXrrrzr*r)r+r{rirmr'rrrrry0sF   ryc seZdZdZdedededededef fdd Zed efd d Zed efd dZ ed efddZ ed efddZ ed efddZ Z S)NexusOperationErrorz:Error raised on Nexus operation failure inside a Workflow.rrhendpointservice operationoperation_tokencs.t|||_||_||_||_||_dS)aInitialize a Nexus operation error. Args: message: The error message. scheduled_event_id: The NexusOperationScheduled event ID for the failed operation. endpoint: The endpoint name for the failed operation. service: The service name for the failed operation. operation: The name of the failed operation. operation_token: The operation token returned by the failed operation. N)rrrn _endpoint_service _operation_operation_token)r rrhrrrrrrrrps  zNexusOperationError.__init__r cCr )z>The NexusOperationScheduled event ID for the failed operation.rtr rrrrhr!z&NexusOperationError.scheduled_event_idcCr )z+The endpoint name for the failed operation.)rr rrrrr!zNexusOperationError.endpointcCr )z*The service name for the failed operation.)rr rrrrr!zNexusOperationError.servicecCr )z!The name of the failed operation.)rr rrrrr!zNexusOperationError.operationcCr )z5The operation token returned by the failed operation.)rr rrrrr!z#NexusOperationError.operation_token)rrrrr"r-rrrhrrrrr'rrrrrms2r exceptionr cCs@t|tjpt|tpt|tpt|tpt|tot|jtS)aCCheck whether the given exception is considered a cancellation exception according to Temporal. This is often used in a conditional of a catch clause to check whether a cancel occurred inside of a workflow. This can occur from :py:class:`asyncio.CancelledError` or :py:class:`CancelledError` or either :py:class:`ActivityError` or :py:class:`ChildWorkflowError` if either of those latter two have a :py:class:`CancelledError` cause. Args: exception: Exception to check. Returns: True if a cancelled exception, false if not. ) isinstanceasynciorCrgryrr)rrrris_cancelled_exceptions   r)!rrdatetimerenumrtypingrrrrtemporalio.api.common.v1r#temporalio.api.enums.v1temporalio.api.failure.v1 Exceptionrrr(r,r3rCrJrKrTrWrXrgryrrrBrrrrrs.    ;6=8