iddlmZddlZddlZddlZddlmZmZGddeZ GddeZ Gdd e Z Gd d e Z Gd d e Z Gdde ZGdde ZGdde ZGdde ZGdde ZGdde ZGdde ZGdde ZGdde ZGd d!e ZGd"d#e ZGd$d%e ZGd&d'e ZGd(d)e ZGd*d+e ZGd,d-e Zd6d2Zd6d3Zej Gd4d5ej!Z"dS)7) annotationsN) server_lib transformsceZdZdZdS)UnreachableErrorzz We should never raise this error. Its only purpose is to explicitly indicate theoretically unreachable code. N)__name__ __module__ __qualname____doc__U/root/projects/qq-shell/venv/lib/python3.11/site-packages/inngest/_internal/errors.pyrr s  Dr rceZdZUdZejjZded<dZ ded<dZ ded<e dd Z e dd Z e dd ZdS)Errorz. Base error for all our custom errors server_lib.ErrorCodecodeTbool include_stack is_retriablereturnstrc t|SN)rselfs rmessagez Error.messages4yyr c*t|jSr)typerrs rnamez Error.name!sDzz""r str | Nonec@|jdurdStj|SNF)rr get_tracebackrs rstackz Error.stack%s&   & &4'---r Nrrrr )rr r r r ErrorCodeUNKNOWNr__annotations__rrpropertyrrr$r r rrrs",!5!=D====ML X###X#...X...r rc&eZdZddd fd ZxZS) CodedErrorT)rrrrrrrrNonecft|||_||_dSr)super__init__rr)rrrr __class__s rr0zCodedError.__init__.s2 !!! (r )rrrrrrrr-)rr r r0 __classcell__r1s@rr,r,-sL " ) ) ) ) ) ) ) ) ) ) ) )r r,c&eZdZejjZdS)URLInvalidErrorN)rr r rr' URL_INVALIDrr r rr5r5:s   +DDDr r5c>eZdZejjZeddZdS)FunctionConfigInvalidErrorerrpydantic.ValidationErrorrc|t|}|}t|dkr|S|dd}|t|dkr|Sd}|D]8}t |t r|cSt|dkr|dz }||z }9|dd}||S||dd|S)z{ Extract info from Pydantic's ValidationError and return our internal InvalidFunctionConfig error. rlocN.msgz: )rerrorslenget isinstanceint)clsr9defaultr@r<fieldpartr?s rfrom_validation_errorz0FunctionConfigInvalidError.from_validation_errorAs#c#hh-- v;;!  NQimmE"" ;#c((a--N  D$$$ 5zzA~~  TMEEQimmE"" ;Nsc!f%%%%&&&r N)r9r:rr8) rr r rr'FUNCTION_CONFIG_INVALIDr classmethodrIr r rr8r8>s=   7D'''['''r r8c&eZdZejjZdS)AsyncUnsupportedErrorN)rr r rr'ASYNC_UNSUPPORTEDrr r rrMrMbs   1DDDr rMc&eZdZejjZdS)SigVerificationFailedErrorN)rr r rr'SIG_VERIFICATION_FAILEDrr r rrPrPf   7DDDr rPc&eZdZejjZdS)BodyInvalidErrorN)rr r rr' BODY_INVALIDrr r rrTrTjs   ,DDDr rTc&eZdZejjZdS)EventKeyUnspecifiedErrorN)rr r rr'EVENT_KEY_UNSPECIFIEDrr r rrWrWns   5DDDr rWc&eZdZejjZdS)FunctionNotFoundErrorN)rr r rr'FUNCTION_NOT_FOUNDrr r rrZrZrs   2DDDr rZc&eZdZejjZdS)HeaderMissingErrorN)rr r rr'HEADER_MISSINGrr r rr]r]vs   .DDDr r]c&eZdZejjZdS)QueryParamMissingErrorN)rr r rr'QUERY_PARAM_MISSINGrr r rr`r`z   3DDDr r`c&eZdZejjZdS)SigningKeyMissingErrorN)rr r rr'SIGNING_KEY_UNSPECIFIEDrr r rrdrd~rRr rdc&eZdZejjZdS)RegistrationFailedErrorN)rr r rr'REGISTRATION_FAILEDrr r rrgrgrbr rgc&eZdZejjZdS) UnknownErrorN)rr r rr'r(rr r rrjrjs   'DDDr rjc*eZdZejjZdZdS)StepUnexpectedErrorFN)rr r rr'STEP_UNEXPECTEDrrr r rrlrls   /DMMMr rlc*eZdZejjZdZdS)OutputUnserializableErrorFN)rr r rr'OUTPUT_UNSERIALIZABLErrr r rroros   5DLLLr rocFeZdZdZejjZdZ d d fd Z xZ S) NonRetriableErrorz2End users can raise this error to prevent retries.FNrr quietrrr-cXt|||_dSr)r/r0rs)rrrsr1s rr0zNonRetriableError.__init__s( !!! r r")rr rsrrr-) rr r r rr'NON_RETRIABLE_ERRORrrr0r2r3s@rrrrrs`<<   3DL#r rrc<eZdZejjZ d d fd ZxZS) RetryAfterErrorFrr retry_after,int | datetime.timedelta | datetime.datetimersrrr-cpt|t|tr5tjt j|z}n;t|tjr!tj|z}||_||_dS)a Raise this error to retry at a specific time. Args: ---- message: Error message retry_after: Time to retry after in milliseconds, timedelta, or datetime quiet: Whether to supress logging ) millisecondsN) r/r0rCrDdatetimenow timedeltarxrs)rrrxrsr1s rr0zRetryAfterError.__init__s !!! k3 ' ' @"+//11H4F(555KK X%7 8 8 @"+//11K?K.9  r )F)rr rxryrsrrr-) rr r rr'RETRY_AFTER_ERRORrr0r2r3s@rrwrwsR   1D  !!!!!!!!!!!r rwc8eZdZejjZdfd ZxZS) SendEventsErrorrrids list[str]rr-cXt|||_dS)z Args: ---- message: Error message ids: List of event IDs that successfully sent N)r/r0r)rrrr1s rr0zSendEventsError.__init__s( !!!r )rrrrrr-) rr r rr'SEND_EVENT_FAILEDrr0r2r3s@rrrsH   1D          r rceZdZdZejjZdZe ddZ e ddZ e ddZ dfd Z xZS) StepErrorz Wraps a userland error. This is necessary because the Executor sends memoized error data which can't be deserialized into the original error class. Frrc|jS)z4 Returns the userland error message )_messagers rrzStepError.messages }r c|jS)z1 Returns the userland error name )_namers rrzStepError.names zr r c|jS)z8 Returns the userland error stack trace )_stackrs rr$zStepError.stacks {r rrr$r-ctt|||_||_||_dS)z Args: ---- message: Userland error's message name: Userland error's name stack: Userland error's stack trace N)r/r0rrr)rrrr$r1s rr0zStepError.__init__s6 !!!   r r%r&)rrrrr$r rr-)rr r r rr' STEP_ERROREDrrr*rrr$r0r2r3s@rrrs   ,DL XXXr rr9 Exceptionrrc>t|tr|jSdS)NT)rCrrr9s rrr s"#u  4r c>t|tr|jSdSr")rC _Quietablersrs ris_quietrs!#z""y 5r ceZdZUded<dS)rrrsN)rr r r)r r rrrsKKKKKr r)r9rrr)# __future__rr|typingpydanticinngest._internalrrrrrr,r5r8rMrPrTrWrZr]r`rdrgrjrlrorrrwrrrrruntime_checkableProtocolrr r rrs-"""""" 44444444     y   .....I...2 ) ) ) ) ) ) ) ),,,,,j,,,!'!'!'!'!'!'!'!'H22222E22288888888-----u---66666u66633333E333////////44444U44488888U88844444e444(((((5(((%         !!!!!e!!!@     e   55555555p  r