o i@sUddlmZddlZddlZddlmZddlmZmZm Z m Z m Z ddl m Z e dZdZded<er9ddlZed d Gd d d e e ZdddZedZdddZdS)) annotationsN) dataclass) TYPE_CHECKINGAnyGenericLiteralOptional)OutputTOperationTokenTypeOPERATION_TOKEN_TYPE_WORKFLOWT)frozenc@sbeZdZUdZded<ded<dZded< ddddZedddZdddZ edddZ dS)WorkflowHandlea A handle to a workflow that is backing a Nexus operation. .. warning:: This API is experimental and unstable. Do not instantiate this directly. Use :py:func:`temporalio.nexus.WorkflowRunOperationContext.start_workflow` to create a handle. str namespace workflow_idNz Optional[int]versionclienttemporalio.client.Client result_typeOptional[type[OutputT]]return.temporalio.client.WorkflowHandle[Any, OutputT]cCs4|j|jkrtd|jd|j|j|j|dS)zECreate a :py:class:`temporalio.client.WorkflowHandle` from the token.zClient namespace z* does not match operation token namespace )r)r ValueErrorget_workflow_handler)selfrrr]/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/temporalio/nexus/_token.py_to_client_workflow_handle#s  z)WorkflowHandle._to_client_workflow_handleworkflow_handleWorkflowHandle[OutputT]cCs||jj|jdS)aKCreate a :py:class:`WorkflowHandle` from a :py:class:`temporalio.client.WorkflowHandle`. This is a private method not intended to be used by users. It does not check that the supplied client.WorkflowHandle references a workflow that has been instrumented to supply the result of a Nexus operation. )rr)_clientrid)clsrrrr#_unsafe_from_client_workflow_handle2s z2WorkflowHandle._unsafe_from_client_workflow_handlecCs$ttjt|j|jddddS)z3Convert handle to a base64url-encoded token string.)tnswid),:) separatorsutf-8)_base64url_encode_no_paddingjsondumpsr rrencode)rrrrto_tokenAszWorkflowHandle.to_tokentokenc Cs*|stdzt|}Wnty}ztd|d}~wwz t|d}Wnty9}ztd|d}~wwt|tsHtdt|| d}|t kr[td|d t | d }|durl|d krltd | d }|rxt|t s|td| d}|dust|t std||||dS)zODecodes and validates a token from its base64url-encoded string representation.z&invalid workflow token: token is emptyz#failed to decode token as base64urlNr+z,failed to unmarshal workflow operation tokenz+invalid workflow token: expected dict, got r%zinvalid workflow token type: z , expected: vrzGinvalid workflow token: 'v' field, if present, must be 0 or null/absentr'zGinvalid workflow token: missing, empty, or non-string workflow ID (wid)r&zt|t}rtd|dt| d}t||S)Nz?invalid base64URL encoded string: contains invalid characters: rI)set_base64_url_alphabetrlenrJurlsafe_b64decode)rM invalid_charspaddingrrrr4s r4)rGrHrr)rMrrrH) __future__rrJr- dataclassesrtypingrrrrrnexusrpcr r r rEtemporalio.client temporaliorr,rOrPr4rrrrs"    o