o iD@sdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZddlmZddlmZddlmZddlmZdd lmZdd lmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)ddl*Z+ddl,Z+ddl-Z+ddl.Z+ddl/Z/ddl0Z0dd l0m1Z1ddl2Z3ddl4Z3ddl5Z3ddl6Z3ddl7Z3ddl8Z3ddl9Z3e j:d krdd l;mm?Z?ee@ZAGdddeZBeddGdddeBZCeddGdddeCZDeddGdddeCZEGdddeZFGdddeZGGdd d eZHGd!d"d"eGeFZIGd#d$d$eIZJGd%d&d&eHZKGd'd(d(eHZLe+jMjNOZPGd)d*d*eHZQGd+d,d,eHZRGd-d.d.ejSZTGd/d0d0eHZUe!d1eVZWGd2d3d3eZXGd4d5d5eZYGd6d7d7eZZGd8d9d9eZZ[Gd:d;d;e[Z\eddGdr)r(r)r*r+rBr,r,r,r-r<sr<c@seZdZUdZded< ed&dd Ze d'd(ddZd)ddZd*ddZ d+ddZ e d,ddZ e d-d#dZ d'd.d%dZ d S)/PayloadConverterz8Base payload converter to/from multiple payloads/values.zClassVar[PayloadConverter]defaultvalues Sequence[Any]r>&List[temporalio.api.common.v1.Payload]cCt)aEncode values into payloads. Implementers are expected to just return the payload for :py:class:`temporalio.common.RawValue`. Args: values: Values to be converted. Returns: Converted payloads. Note, this does not have to be the same number as values given, but must be at least one and cannot be more than was given. Raises: Exception: Any issue during conversion. r?rArFr,r,r- to_payloadsszPayloadConverter.to_payloadsNpayloads*Sequence[temporalio.api.common.v1.Payload] type_hintsOptional[List[Type]] List[Any]cCrI)aDecode payloads into values. Implementers are expected to treat a type hint of :py:class:`temporalio.common.RawValue` as just the raw value. Args: payloads: Payloads to convert to Python values. type_hints: Types that are expected if any. This may not have any types if there are no annotations on the target. If this is present, it must have the exact same length as payloads even if the values are just "object". Returns: Collection of Python values. Note, this does not have to be the same number as values given, but at least one must be present. Raises: Exception: Any issue during conversion. r?rArLrNr,r,r- from_payloadsszPayloadConverter.from_payloads!temporalio.api.common.v1.PayloadscCstjjjj||dS)zf:py:meth:`to_payloads` for the :py:class:`temporalio.api.common.v1.Payloads` wrapper. rL) temporalioapicommonv1PayloadsrKrJr,r,r-to_payloads_wrappersz$PayloadConverter.to_payloads_wrapper+Optional[temporalio.api.common.v1.Payloads]cCs|r|jsgS||jS)zh:py:meth:`from_payloads` for the :py:class:`temporalio.api.common.v1.Payloads` wrapper. )rLrRrArLr,r,r-from_payloads_wrappers  z&PayloadConverter.from_payloads_wrappervaluer temporalio.api.common.v1.PayloadcCs||gdS)aConvert a single value to a payload. This is a shortcut for :py:meth:`to_payloads` with a single-item list and result. Args: value: Value to convert to a single payload. Returns: Single converted payload. r)rKrAr^r,r,r- to_payloads zPayloadConverter.to_payloadpayloadcCdSNr,)rArbr,r,r- from_payloadszPayloadConverter.from_payload type_hintType[temporalio.types.AnyType]temporalio.types.AnyTypecCrcrdr,rArbrfr,r,r-resOptional[Type]cCs"||g|r |gdSddS)aTConvert a single payload to a value. This is a shortcut for :py:meth:`from_payloads` with a single-item list and result. Args: payload: Payload to convert to value. type_hint: Optional type hint to say which type to convert to. Returns: Single converted value. Nr)rRrir,r,r-re s"rFrGr>rHrdrLrMrNrOr>rPrFrGr>rS)rLr[r>rP)r^r r>r_)rbr_r>r )rbr_rfrgr>rhrbr_rfrjr>r ) r(r)r*r+r4rrKrRrZr]rarrer,r,r,r-rDs$        rDc@sBeZdZdZeedddZedd d Ze ddddZd S)EncodingPayloadConverterzgBase converter to/from single payload/value with a known encoding for use in CompositePayloadConverter.r>r0cCrI)z3Encoding for the payload this converter works with.r?rAr,r,r-encoding"sz!EncodingPayloadConverter.encodingr^r *Optional[temporalio.api.common.v1.Payload]cCrI)aEncode a single value to a payload or None. Args: value: Value to be converted. Returns: Payload of the value or None if unable to convert. Raises: TypeError: Value is not the expected type. ValueError: Value is of the expected type but otherwise incorrect. RuntimeError: General error during encoding. r?r`r,r,r-ra(z#EncodingPayloadConverter.to_payloadNrbr_rfrjcCrI)a*Decode a single payload to a Python value or raise exception. Args: payload: Payload to convert to Python value. type_hint: Type that is expected if any. This may not have a type if there are no annotations on the target. Return: The decoded value from the payload. Since the encoding is checked by the caller, this should raise an exception if the payload cannot be converted. Raises: RuntimeError: General error during decoding. r?rir,r,r-re9sz%EncodingPayloadConverter.from_payloadr>r0r^r r>rrrdrn) r(r)r*r+propertyrrqrarer,r,r,r-ros roc@sjeZdZUdZded<d#ddZd#d d Zd$ddZ d%d&ddZd'ddZ d(ddZ e j d)d!d"Z dS)*CompositePayloadConverteraComposite payload converter that delegates to a list of encoding payload converters. Encoding/decoding are attempted on each payload converter successively until it succeeds. Attributes: converters: List of payload converters to delegate to, in order. z(Mapping[bytes, EncodingPayloadConverter] convertersror>NonecGs|j|dS)z|Initializes the data converter. Args: converters: Payload converters to delegate to, in order. N)_set_convertersrArxr,r,r-__init__]sz"CompositePayloadConverter.__init__cGsdd|D|_dS)NcSsi|]}|j|qSr,)rqencode.0cr,r,r- fsz=CompositePayloadConverter._set_converters..)rxr{r,r,r-rzesz)CompositePayloadConverter._set_convertersrFrGrHcCsg}t|D]:\}}d}t|tjjr|j}n|jD] }||}|dur)nq|dur;t d|dt |d| |q|S)zEncode values trying each converter. See base class. Always returns the same number of payloads as values. Raises: RuntimeError: No known converter NzValue at index z of type z has no known converter) enumerate isinstancerUrWRawValuerbrxrFra RuntimeErrortypeappend)rArFrLindexr^rb converterr,r,r-rKhs    z%CompositePayloadConverter.to_payloadsNrLrMrNrOrPc Csg}|pg}tt||D]U\}\}}|tjjkr#|tj|q |jdd}|j|}|dur=t d| z || ||Wq t yb} zt d|d| d| d} ~ ww|S)zDecode values trying each converter. See base class. Always returns the same number of values as payloads. Raises: KeyError: Unknown payload encoding RuntimeError: Error during decode rq NzUnknown payload encoding zPayload at index z with encoding z could not be converted) rrrUrWrrmetadatagetrxKeyErrordecoderer) rArLrNrFrrbrfrqrerrr,r,r-rRs*   z'CompositePayloadConverter.from_payloadsr=r&rcCs.||}|dur |St|}|j||S)zReturn a new instance with context set on the component converters. If none of the component converters returned new instances, return self. N)get_converters_with_contextrrz)rAr=rx new_instancer,r,r-rBs   z&CompositePayloadConverter.with_context(Optional[list[EncodingPayloadConverter]]cCsd|jsdSg}d}|jD]}t|tr&|||||d|uO}q||q|r0|SdS)ziReturn converter instances with context set. If no converter uses context, return None. NF)_any_converter_takes_contextrxrFrr<rrB)rAr=rxany_with_contextrr,r,r-rs   z5CompositePayloadConverter.get_converters_with_contextr:cCstdd|jDS)Ncss|]}t|tVqdSrd)rr<r~r,r,r- s  zICompositePayloadConverter._any_converter_takes_context..)anyrxrFrpr,r,r-rsz6CompositePayloadConverter._any_converter_takes_context)rxror>ryrkrdrlrC)r=r&r>r)r>r:)r(r)r*r+r4r|rzrKrRrBr functoolscached_propertyrr,r,r,r-rwQs    ! rwcs.eZdZUdZded< dfdd ZZS) DefaultPayloadConverteraDefault payload converter compatible with other Temporal SDKs. This handles None, bytes, all protobuf message types, and any type that :py:func:`json.dump` accepts. A singleton instance of this is available at :py:attr:`PayloadConverter.default`. z$Tuple[EncodingPayloadConverter, ...]#default_encoding_payload_convertersr>rycstjtjdS)z#Create a default payload converter.N)superr|rrrp __class__r,r-r|z DefaultPayloadConverter.__init__r>ry)r(r)r*r+r4r| __classcell__r,r,rr-rs rc@6eZdZdZedddZdd d Z ddddZd S)BinaryNullPayloadConverterzr0cCdS)See base class.z binary/nullr,rpr,r,r-rqz#BinaryNullPayloadConverter.encodingr^r rrcCs(|durtjjjjd|jidSdS)rNrq)r)rUrVrWrXPayloadrqr}r`r,r,r-ras   z%BinaryNullPayloadConverter.to_payloadNrbr_rfrjcCst|jdkr tddS)rrz'Expected empty data set for binary/nullN)lendatarrir,r,r-resz'BinaryNullPayloadConverter.from_payloadrtrurdrnr(r)r*r+rvrqrarer,r,r,r-r   rc@r)BinaryPlainPayloadConverterz>Converter for 'binary/plain' payloads supporting bytes values.r>r0cCr)rz binary/plainr,rpr,r,r-rqrz$BinaryPlainPayloadConverter.encodingr^r rrcCs,t|trtjjjjd|ji|dSdS)rrqrrN) rbytesrUrVrWrXrrqr}r`r,r,r-ras  z&BinaryPlainPayloadConverter.to_payloadNrbr_rfrjcCs|jSr)rrir,r,r-re z(BinaryPlainPayloadConverter.from_payloadrtrurdrnrr,r,r,r-rrrcsJeZdZdZddfdd Zedd d ZdddZ ddddZZ S)JSONProtoPayloadConverterzJConverter for 'json/protobuf' payloads supporting protobuf Message values.Fignore_unknown_fieldsr:ct||_dS)zInitialize a JSON proto converter. Args: ignore_unknown_fields: Determines whether converter should error if unknown fields are detected N)rr|_ignore_unknown_fields)rArrr,r-r|s  z"JSONProtoPayloadConverter.__init__r>r0cCr)rz json/protobufr,rpr,r,r-rq#rz"JSONProtoPayloadConverter.encodingr^r rrcCsdt|tjjjr0|jdur0tjtjj |ddd}t j j j j|j|jjd|dSdS)rN,:T) separators sort_keysrq messageTyper)rgoogleprotobufmessageMessage DESCRIPTORjsondumps json_format MessageToDictrUrVrWrXrrqr} full_name)rAr^json_strr,r,r-ra(s    z$JSONProtoPayloadConverter.to_payloadNrbr_rfrjc Cs|jdd}zt|}tjjj|j ||j dWSt y0}zt d||d}~wtjjj yC}zt d|d}~ww)rrr)rUnknown Protobuf type NFailed parsing)rrr_sym_db GetSymbolrrrParserrrr ParseErrorrArbrf message_typer^rr,r,r-re>s  z&JSONProtoPayloadConverter.from_payload)F)rr:rtrurdrn) r(r)r*r+r|rvrqrarerr,r,rr-rs  rc@r)BinaryProtoPayloadConverterzLConverter for 'binary/protobuf' payloads supporting protobuf Message values.r>r0cCr)rzbinary/protobufr,rpr,r,r-rqUrz$BinaryProtoPayloadConverter.encodingr^r rrcCsJt|tjjjr#|jdur#tjjj j |j |jj d|dSdS)rNrr)rrrrrrrUrVrWrXrrqr}rSerializeToStringr`r,r,r-raZs   z&BinaryProtoPayloadConverter.to_payloadNrbr_rfrjc Cs|jdd}zt|}||j|WSty,}ztd||d}~wt j j j y?}ztd|d}~ww)rrrrNr) rrrrrParseFromStringrrrrrr DecodeErrorrr,r,r-reis   z(BinaryProtoPayloadConverter.from_payloadrtrurdrnrr,r,r,r-rRs  rcs"eZdZdZdfdd ZZS)AdvancedJSONEncodera*Advanced JSON encoder. This encoder supports dataclasses and all iterables as lists. It also uses Pydantic v1's "dict" methods if available on the object, but this is deprecated. Pydantic users should upgrade to v2 and use temporalio.contrib.pydantic.pydantic_data_converter. or r>cst|tr |St|rt|tst|St|dd}t|r%|St|t s5t|t j j r5t |St|t jr?t|St|S)zZOverride JSON encoding default. See :py:meth:`json.JSONEncoder.default`. dictN)rr isoformat dataclasses is_dataclassrasdictgetattrcallablelist collectionsabcIterableuuidUUIDr0rrE)rArdict_fnrr,r-rEs     zAdvancedJSONEncoder.default)rr r>r )r(r)r*r+rErr,r,rr-rzs rcsneZdZUdZded<ded<ded<edd gd d!fddZed"ddZd#ddZ d$d%dd Z Z S)&JSONPlainPayloadConverteraoConverter for 'json/plain' payloads supporting common Python values. For encoding, this supports all values that :py:func:`json.dump` supports and by default adds extra encoding support for dataclasses, classes with ``dict()`` methods, and all iterables. For decoding, this uses type hints to attempt to rebuild the type from the type hint. Optional[Type[json.JSONEncoder]]_encoder Optional[Type[json.JSONDecoder]]_decoderr0 _encodingNz json/plain)encoderdecoderrqcustom_type_convertersrrrqrSequence[JSONTypeConverter]r>rycs&t||_||_||_||_dS)amInitialize a JSON data converter. Args: encoder: Custom encoder class object to use. decoder: Custom decoder class object to use. encoding: Encoding name to use. custom_type_converters: Set of custom type converters that are used when converting from a payload to type-hinted values. N)rr|rrr_custom_type_converters)rArrrqrrr,r-r|s  z"JSONPlainPayloadConverter.__init__cCs|jSr)rrpr,r,r-rqsz"JSONPlainPayloadConverter.encodingr^r rrcCsFt|dr tdtjjjjd|j it j ||j ddd dS)r parse_objzIf you're using Pydantic v2, use temporalio.contrib.pydantic.pydantic_data_converter. If you're using Pydantic v1 and cannot upgrade, refer to https://github.com/temporalio/samples-python/tree/main/pydantic_converter_v1 for better v1 support.rqrT)clsrrr) hasattrwarningswarnrUrVrWrXrrr}rrrr`r,r,r-ras    z$JSONPlainPayloadConverter.to_payloadrbr_rfrjc CsPztj|j|jd}|rt|||j}|WStjy'}ztd|d}~ww)r)rrN)rloadsrr value_to_typerJSONDecodeErrorr)rArbrfobjrr,r,r-res z&JSONPlainPayloadConverter.from_payload) rrrrrqr0rrr>ryrtrurdrn) r(r)r*r+r4rr|rvrqrarerr,r,rr-rs    r_JSONTypeConverterUnhandledc@s*eZdZdZeeZ ed dd Zd S) JSONTypeConverterzConverter for converting an object from Python :py:func:`json.loads` result (e.g. scalar, list, or dict) to a known type. hintrr^r r>1Union[Optional[Any], _JSONTypeConverterUnhandled]cCrI)aConvert the given value to a type based on the given hint. Args: hint: Type hint to use to help in converting the value. value: Value as returned by :py:func:`json.loads`. Usually a scalar, list, or dict. Returns: The converted value or :py:attr:`Unhandled` if this converter does not handle this situation. r?)rArr^r,r,r-to_typed_valuersz JSONTypeConverter.to_typed_valueN)rrr^r r>r) r(r)r*r+robject Unhandledrrr,r,r,r-rs  rc@s^eZdZdZedddZeddd Zdd d ZdddZdddZ dddZ dddZ dS) PayloadCodeczaCodec for encoding/decoding to/from bytes. Commonly used for compression or encryption. rLrMr>rHct)aDEncode the given payloads. Args: payloads: Payloads to encode. This value should not be mutated. Returns: Encoded payloads. Note, this does not have to be the same number as payloads given, but must be at least one and cannot be more than was given. r?r\r,r,r-r} zPayloadCodec.encodecr)aDDecode the given payloads. Args: payloads: Payloads to decode. This value should not be mutated. Returns: Decoded payloads. Note, this does not have to be the same number as payloads given, but must be at least one and cannot be more than was given. r?r\r,r,r-rrzPayloadCodec.decoderSryc0||jIdH}|jdd=|j|dS)z:py:meth:`encode` for the :py:class:`temporalio.api.common.v1.Payloads` wrapper. This replaces the payloads within the wrapper. N)r}rLextendrArL new_payloadsr,r,r-encode_wrapper+ zPayloadCodec.encode_wrappercr)z:py:meth:`decode` for the :py:class:`temporalio.api.common.v1.Payloads` wrapper. This replaces the payloads within. N)rrLrrr,r,r-decode_wrapper6rzPayloadCodec.decode_wrapperfailure!temporalio.api.failure.v1.Failurec|||jIdHdS)zEncode payloads of a failure. Intended as a helper method, not for overriding. It is not guaranteed that all failures will be encoded with this method rather than encoding the underlying payloads. N)_apply_to_failure_payloadsrrArr,r,r-encode_failureAzPayloadCodec.encode_failurecr )zDecode payloads of a failure. Intended as a helper method, not for overriding. It is not guaranteed that all failures will be decoded with this method rather than decoding the underlying payloads. N)r rr r,r,r-decode_failureHrzPayloadCodec.decode_failurecb>Callable[[temporalio.api.common.v1.Payloads], Awaitable[None]]cs|dr!tjjjj|jgd}||IdH|j|jd|dr6|j dr6||j j IdHn>|drK|j drK||j j IdHn)|dr`|j dr`||j j IdHn|d rt|jdrt||jj IdH|d r||j|IdHdSdS) Nencoded_attributesrTrapplication_failure_infodetailstimeout_failure_infolast_heartbeat_detailscanceled_failure_inforeset_workflow_failure_infocause)HasFieldrUrVrWrXrYrCopyFromrLrrrrrrr r)rArrrLr,r,r-r OsD       z'PayloadCodec._apply_to_failure_payloadsN)rLrMr>rH)rLrSr>ry)rr r>ry)rr rrr>ry) r(r)r*r+rr}rrrr rr r,r,r,r-rs    rc@s8eZdZUdZded< edd d ZedddZdS)FailureConvertera]Base failure converter to/from errors. Note, for workflow exceptions, :py:attr:`to_failure` is only invoked if the exception is an instance of :py:class:`temporalio.exceptions.FailureError`. Users should extend :py:class:`temporalio.exceptions.ApplicationError` if they want a custom workflow exception to work with this class. zClassVar[FailureConverter]rE exception BaseExceptionpayload_converterrDrr r>rycCrI)aKConvert the given exception to a Temporal failure. Users should make sure not to alter the ``exception`` input. Args: exception: The exception to convert. payload_converter: The payload converter to use if needed. failure: The failure to update with error information. r?)rArrrr,r,r- to_failure{szFailureConverter.to_failurecCrI)a2Convert the given Temporal failure to an exception. Users should make sure not to alter the ``failure`` input. Args: failure: The failure to convert. payload_converter: The payload converter to use if needed. Returns: Converted error. r?)rArrr,r,r- from_failureszFailureConverter.from_failureNrrrrDrr r>ryrr rrDr>r)r(r)r*r+r4rr r!r,r,r,r-ros  rcsPeZdZdZdddfdd ZdddZdddZdddZdddZZ S) DefaultFailureConverterzzDefault failure converter. A singleton instance of this is available at :py:attr:`FailureConverter.default`. Fencode_common_attributesr&r:r>rycr)aCreate the default failure converter. Args: encode_common_attributes: If ``True``, the message and stack trace of the failure will be moved into the encoded attribute section of the failure which can be encoded with a codec. N)rr|_encode_common_attributes)rAr&rr,r-r|s  z DefaultFailureConverter.__init__rrrrDrr cCst|tjjr||||n)t|tjr||||ntjjt ||j j d}|j |_ |j |_ |||||jrT|j||j|jdgdd|_d|_dSdS)r)r)r stack_tracerzEncoded failureN)rrU exceptions FailureError_error_to_failurenexusrpc HandlerError_nexus_handler_error_to_failureApplicationErrorr0rr( __traceback__ __cause__r'rrrKrr()rArrr failure_errorr,r,r-r s*   z"DefaultFailureConverter.to_failureerror"temporalio.exceptions.FailureErrorcCs|jr ||jdS|j|_|jrdt|j|_|jr)| |j||j n|j s8|j r8| |j ||j t |tjjr}|j|jrL|j|j_|j|j_|jr_|jj||j|jrj|jj|j|jr{tjjjj|j|j_dSdSt |tjjr|j tjjjj!|jpd|j _"|j#r|j j#||j#dSdSt |tjj$r|j%|jr|j%j||jdSdSt |tjj&r|j'dSt |tjj(r|j)|j|j)_dSt |tjj*r |j+|j,|j+_,|j-|j+_-|j.|j+_.|j/|j+j/_0|j1|j+_1tjjjj2|j3pd|j+_3dSt |tjj4r_|j5|j6|j5_6|j7|j5j8_7|j9|j5j8_9|j:|j5j:_0|j;|j5_;|j-|j5_-tjjjj2|j3pYd|j5_3dSt |tjj<r|j=|j,|j=_,|j>|j=_>|j?|j=_?|j@|j=_@|jA|j=_AdSdS)N r)Brrrr1join traceback format_tbr(r2r r__suppress_context__ __context__rrUr*r0r SetInParentr non_retryablerrZnext_retry_delay FromTimedeltacategoryrVenumsrXApplicationErrorCategory ValueType TimeoutErrorr TimeoutType timeout_typerCancelledErrorrTerminatedErrorterminated_failure_info ServerErrorserver_failure_info ActivityErroractivity_failure_infoscheduled_event_idstarted_event_ididentityr8name activity_id RetryState retry_stateChildWorkflowError%child_workflow_execution_failure_infor1r2workflow_executionrun_idr7initiated_event_idNexusOperationError&nexus_operation_execution_failure_infoendpointservice operationoperation_tokenrAr4rrr,r,r-r,s                             z)DefaultFailureConverter._error_to_failurenexusrpc.HandlerErrorcCst||_|jrdt|j|_|jr||j||j |j |j j |j _ tjjjj|jdur;tjjjjjn|jdurGtjjjjjntjjjjj|j _dS)Nr6TF)r0rr1r7r8r9r(r2r rnexus_handler_failure_infor<rrQrUrVrArXNexusHandlerErrorRetryBehaviorrCretryable_override,NEXUS_HANDLER_ERROR_RETRY_BEHAVIOR_RETRYABLE0NEXUS_HANDLER_ERROR_RETRY_BEHAVIOR_NON_RETRYABLE.NEXUS_HANDLER_ERROR_RETRY_BEHAVIOR_UNSPECIFIEDretry_behaviorr`r,r,r-r/9s        z7DefaultFailureConverter._nexus_handler_error_to_failurec Cs|drBtjjj}|||}z*||jgd}t |t r<| d}t |t r/||_ | d}t |t r<||_WnY|drq|j}tjj|j pQdg||jR|jp]d|j|jtjt|jd}n=|d r|j} tjj|j pd | jrtjt| jnd|| jd }n|d r|j } tjj!|j pd g|| jR}n|drtj"|j pd}n|dr|j#} tjj$|j pd| jd}n|dr|j%} tjj&|j pd| j'| j(| j)| j*j+| j,| j-rtj.t| j-ndd}n|dr3|j/} tjj0|j pd| j1| j2j3| j2j4| j5j+| j6| j(| j-r.tj.t| j-ndd}n{|dr|j7}zt8j9|j}Wnt:y[t;tjj?jj@jAkridn|j>tjj?jj@jBkrvdnd}t8jC|j pd||d}n)|dr|jD}tjjE|j pd |j'|jF|jG|jH|jId!}n tjJ|j pd"}t |tjjJr||_K|d#r|L|jM||_N|S)$rrrrr(rzApplication errorN)rr=r>r@rTimeout)rrr CancelledrI TerminatedrKz Server error)r=rMzActivity error)rNrOrPr8rRrTrVzChild workflow error)r1r2rXr7rYrOrTrbz Unknown Nexus HandlerErrorType: TFzNexus handler error)rrdr[zNexus operation error)rNr\r]r^r_z Failure errorr)OrrUrVrrXFailurerrRrrrrr0rr(rr*r0r]rrr=r> ToTimedeltarBintr@rrDrFrErrrGrHrKrJrMrLrNrOrPr8rQrRrTrSrVrUr1rWr2rXr7rYrbr-HandlerErrorTyperloggerwarningINTERNALrhrArcrerfr.r[rZr\r]r^r_r+_failurer!rr2)rArr new_failurerrr(app_infor timeout_info cancel_info server_infoact_info child_inforb_typerdnexus_op_failure_infor,r,r-r!Ns                            z$DefaultFailureConverter.from_failure)r&r:r>ryr")r4r5rrDrr r>ry)r4rarrDrr r>ryr#) r(r)r*r+r|r r,r/r!rr,r,rr-r$s  gr$cs"eZdZdZdfdd ZZS),DefaultFailureConverterWithEncodedAttributeszImplementation of :py:class:`DefaultFailureConverter` which moves message and stack trace to encoded attributes subject to a codec. r>rycstjdddS)z;Create a default failure converter with encoded attributes.Tr%N)rr|rprr,r-r|rz5DefaultFailureConverterWithEncodedAttributes.__init__r)r(r)r*r+r|rr,r,rr-r}sr}c@seZdZUdZeZded< dZded< eZ ded< e j d d Z d ed < e j d d Z d ed< ded< d4ddZd5ddZ d6d7dd Zd8d"d#Z d6d9d%d&Zd:d+d,Zd;d-d.ZdrycCs(t|d|t|d|dS)Nrr)r __setattr__rrrpr,r,r- __post_init__szDataConverter.__post_init__rFrGrHcs*|j|}|jr|j|IdH}|S)aEncode values into payloads. First converts values to payloads then encodes payloads using codec. Args: values: Values to be converted and encoded. Returns: Converted and encoded payloads. Note, this does not have to be the same number as values given, but must be at least one and cannot be more than was given. N)rrKrr})rArFrLr,r,r-r}s  zDataConverter.encoderLrMrNrOrPcs(|jr |j|IdH}|j||S)zDecode payloads into values. First decodes payloads using codec then converts payloads to values. Args: payloads: Payloads to be decoded and converted. Returns: Decoded and converted values. N)rrrrRrQr,r,r-rszDataConverter.decoderScs tjjjj||IdHdS)za:py:meth:`encode` for the :py:class:`temporalio.api.common.v1.Payloads` wrapper. NrT)rUrVrWrXrYr}rJr,r,r-r)szDataConverter.encode_wrapperr[cs$|r|jsgS||j|IdHS)za:py:meth:`decode` for the :py:class:`temporalio.api.common.v1.Payloads` wrapper. N)rLrrQr,r,r-r1s zDataConverter.decode_wrapperrrrr cs4|j||j||jr|j|IdHdSdS)zConvert and encode failure.N)rr rrr )rArrr,r,r-r =s zDataConverter.encode_failurecs*|jr |j|IdH|j||jS)zDecode and convert failure.N)rrrr!rr r,r,r-rEszDataConverter.decode_failurer=r&rcCs|j}|j}|j}t|tr||}t|tr||}t|tr'||}tdd||jf||jf||jffDr>|St|}t |d|t |d|t |d||S)z@Return an instance with context set on the component converters.css|] \}}||uVqdSrdr,)rneworigr,r,r-rXs  z-DataConverter.with_context..rrr) rrrrr<rBallrreplacerr)rAr=rrrclonedr,r,r-rBMs*       zDataConverter.with_contextrrkrdrlrm)rLr[rNrOr>rP)rrrr r>ry)rr r>rrC)r(r)r*r+rrr4rr$rrfieldrrrr}rrrr rrBr,r,r,r-r~s0        r~r>cCstjS)zgDefault data converter. .. deprecated:: Use :py:meth:`DataConverter.default` instead. )r~rEr,r,r,r-rEwrrE attributesRUnion[temporalio.common.SearchAttributes, temporalio.common.TypedSearchAttributes]rV)temporalio.api.common.v1.SearchAttributesrycCsjt|tjjr|D]\}}|j|jt||q dS|s dS|D]\}}|j|t |q$dS)zConvert search attributes into an API message. Args: attributes: Search attributes to convert. The dictionary form of this is DEPRECATED. api: API message to set converted attributes on. N) rrUrWTypedSearchAttributesindexed_fieldsrQr#encode_typed_search_attribute_valueitemsencode_search_attribute_values)rrVtyped_ktyped_vkvr,r,r-encode_search_attributess  rkeyPtemporalio.common.SearchAttributeKey[temporalio.common.SearchAttributeValueType]r^0Optional[temporalio.common.SearchAttributeValue]r_cCs|dur tjdSt||jstd|d|jt|tr%|}t|t r8|D] }t|t s7tdq,tj|}|j |j d<|S)zConvert typed search attribute value into a payload. Args: key: Key for the value. value: Value to convert. Returns: Payload for the value. NzValue of type z% not suitable for indexed value type z,All values of a keyword list must be stringsr)rErrarorigin_value_type TypeErrorindexed_value_typerrrr0_metadata_typer}r)rr^rrbr,r,r-rs     rvals'temporalio.common.SearchAttributeValuescCst|ts tdd}g}|D]@}t|tr$|jdurtd|}n&t|ttt t fs8tdt |j d|rDt ||urDtd|sJt |}| |qtj|gdS)zConvert search attribute values into a payload. .. deprecated:: Use typed search attributes instead. Args: vals: List of values to convert. z%Search attribute values must be listsNz6Timezone must be present on all search attribute dateszSearch attribute value of type z. not one of str, int, float, bool, or datetimez@Search attribute values must have the same type for the same keyr)rrrrtzinfo ValueErrorrr0rnfloatr:rr(rrErrK)rval_type safe_valsrr,r,r-rs.     rnon_typed_attributes,Optional[temporalio.common.SearchAttributes]typed_attributes1Optional[temporalio.common.TypedSearchAttributes]cCsD|r|r |jr tdt||dS|r|jr t||dSdSdS)NzLCannot provide both deprecated search attributes and typed search attributes)search_attributesrr)rrrVr,r,r-%_encode_maybe_typed_search_attributess  rCallable[[str], datetime]cCstjdkrtjStjS)zIsolates system version check and returns relevant datetime passer Returns: A callable to parse date strings into datetimes. r)sys version_infor fromisoformatr isoparser,r,r,r-_get_iso_datetime_parsers r"temporalio.common.SearchAttributescsttj}i}|jD],\}}||gd}t|ts|g}|jddkr3t fdd|D}|||<q |S)a Decode API search attributes to values. .. deprecated:: Use typed search attributes instead. Args: api: API message with search attribute values to convert. Returns: Converted search attribute values (new mapping every time). rrDatetimecsg|]}|qSr,r,)rrrr,r- sz,decode_search_attributes..) rErrrrRrrrrr)rVconvretrrvalr,rr-decode_search_attributess  r'temporalio.common.TypedSearchAttributesc Cstj}g}|jD]V\}}|jd}|sq tjj || }|s%q | |}|j tjj jkrBt|trBt|dkr>q |d}|j tjj jkrQt}||}t||jra|tj||q tj|S)zDecode API search attributes to typed search attributes. Args: api: API message with search attribute values to convert. Returns: Typed search attribute collection (new object every time). rr)rErrrrrrUrWSearchAttributeKey_from_metadata_typerrerSearchAttributeIndexedValueType KEYWORD_LISTrrrDATETIMErrrSearchAttributePairr) rVrpairsrr metadata_typerrr r,r,r-decode_typed_search_attributess:      rrb&temporalio.common.SearchAttributeValuecCs6tj|}t|tr|jddkrt|}|S)Nrr)rErrerr0rrr)rbrr,r,r-_decode_search_attribute_valueNs rrrr custom_convertersrc Cs|D]}|||}|tjur|Sq|tur|S|turNt|tr>zt|WSty=}zt d||d}~wwt|trE|St dt ||t usV|t urjt|t t fsft dt |||S|t urt|t s|t dt |t |S|turt|tst dt |t|S|turt|tttfst dt |t|S|t dur|durt dt |dSt|d d}|rt|||St|d |}t|d d }|tus|tjur||vrt d |d||S|tu} tjdkr | pt|t} | r/|D]} z t| ||WSty$Yqwt d|d|t|rMt|tjjrMt|tjjsQt d|dt |i} d} t|ddsct|ddrgt|} t |dkr|dturt|dt!s|dnd} t |dkr|dturt|dt!s|dnd}|"D]\}}|}| r| #|}| rzCt|tr| t us| t ur| |}n| t urddd|}n | t durddi|}t| t rt|| st| ||}Wnty}zt dt$|d| d||d}~ww|r;zt|||}Wnty:}z t dt$|d||d}~ww|| |<q| rK|d i| } | St%&|rt|t'sft d |d!t |d"t%(|}t|}i}|D]:}|#|j)t%j*}|t%j*urzt||j)||||j)<Wqsty}z t d#|j)d$||d}~wwqs|d i|St+|d%d}t|t,st|t-rt|t'st d&|d!t |d"t|d%|St|rt|t.rt|t st d'|d(t |||Stjd)kr,t|r,t|t/r,t|ts(t d'|d*t |||St|r=t|t0j1r=||St|rt|tjj2rt|tjj2s_t d|dt |g}|rzt |dkrt|dt!sz|dt3urt|}ngt4|D]b\}}|t5ur|d}n0t ||kr||t3ur||}n|d+t3ur|d,}nt d-|d.t |d/|dz |6t|||Wqty}z t d0|d1||d}~ww|t5urt5|S|t7urt7|S|tj8urt8|S|St d2|)3aConvert a given value to the given type hint. This is used internally to convert a raw JSON loaded value to a specific type hint. Args: hint: Type hint to convert the value to. value: Raw value (e.g. primitive, dict, or list) to convert from. custom_converters: Set of custom converters to try before doing default conversion. Converters are tried in order and the first value that is not :py:attr:`JSONTypeConverter.Unhandled` will be returned from this function instead of doing default behavior. Returns: Converted value. Raises: TypeError: Unable to convert to the given hint. z Failed parsing datetime string: Nz)Expected datetime or ISO8601 string, got z$Expected value to be int|float, was zExpected value to be bool, was zExpected value to be str, was z Expected value to be bytes, was z!Expected None, got value of type __supertype__ __origin____args__r,zValue z not in literal values r"zFailed converting to z from z Expected z , value was __required_keys____optional_keys__rrTF)truefalsenullzFailed converting key z to type z in mapping z Failed converting value for key zCannot convert to dataclass z , value is z not dictzFailed converting field z on dataclass rzCannot convert to zCannot convert to enum z!, value not an integer, value is rz, value not a string, value is rzType z only expecting z values, got at least zFailed converting z index z'Unserializable type during conversion: )9rrrr rrr0rrrrrnrr:rrrrrtyping_extensionsrrrr$ Exceptioninspectisclass issubclassrrrrrrrrreprrrrfieldsrQMISSINGgetattr_static classmethod staticmethodrr!rrrEllipsisrtuplersetdeque)rr^rrrr supertypeorigin type_argsis_unionargret_dict per_key_typeskey_type value_typerthis_value_typer field_hints field_valuesr field_valueparse_obj_attrret_listiitemarg_typer,r,r-rWs                                           r)r>r~)rrrVrr>ry)rrr^rr>r_)rrr>r_)rrrrrVrr>ry)r>r)rVrr>r)rVrr>r)rbr_r>r)rrr^r rrr>r )kr+ __future__rrcollections.abcrrrrrr8rrrrrrrenumr itertoolsrloggingr typingr r r r rrrrrrrrrrrrrgoogle.protobuf.duration_pb2rgoogle.protobuf.json_formatgoogle.protobuf.messagegoogle.protobuf.symbol_databaser-rrtemporalio.api.common.v1rUtemporalio.api.enums.v1temporalio.api.failure.v1temporalio.api.sdk.v1temporalio.commontemporalio.exceptionstemporalio.typesrdateutilr r!typesr$r(rpr&r/r5r6r<rDrorwrrrrsymbol_databaseDefaultrrr JSONEncoderrrrrrrrr$r}r~rrErrrrrrrrrrrr,r,r,r-s      L       u2| <(" Jj2;      & &   0