o
    i                    @  s   d Z ddlmZ ddlmZ ddlmZmZmZm	Z	 ddl
ZddlZddlZddlZddlZddlZer:ddlmZ G dd dZG d	d
 d
ZG dd dZG dd dZG dd dZdS )z*Generated RPC calls for Temporal services.    )annotations)	timedelta)TYPE_CHECKINGMappingOptionalUnionN)ServiceClientc                   @  s  e Zd ZdZdddZdi dfdddZdi dfdddZdi dfdddZdi dfdddZdi dfdd"d#Z	di dfdd&d'Z
di dfdd*d+Zdi dfdd.d/Zdi dfdd2d3Zdi dfdd6d7Zdi dfdd:d;Zdi dfdd>d?Zdi dfddBdCZdi dfddFdGZdi dfddJdKZdi dfddNdOZdi dfddRdSZdi dfddVdWZdi dfddZd[Zdi dfdd^d_Zdi dfddbdcZdi dfddfdgZdi dfddjdkZdi dfddndoZdi dfddrdsZdi dfddvdwZdi dfddzd{Zdi dfdd~dZ di dfdddZ!di dfdddZ"di dfdddZ#di dfdddZ$di dfdddZ%di dfdddZ&di dfdddZ'di dfdddZ(di dfdddZ)di dfdddZ*di dfdddZ+di dfdddZ,di dfdddZ-di dfdddZ.di dfdddZ/di dfdddZ0di dfdddÄZ1di dfdddǄZ2di dfddd˄Z3di dfdddτZ4di dfdddӄZ5di dfdddׄZ6di dfdddۄZ7di dfddd߄Z8di dfdddZ9di dfdddZ:di dfdddZ;di dfdddZ<di dfdddZ=di dfdddZ>di dfdddZ?di dfdddZ@di dfdddZAdi dfdddZBdi dfdd
dZCdi dfdddZDdi dfdddZEdi dfdddZFdi dfdÐddZGdi dfdĐddZHdi dfdŐd"d#ZIdi dfdƐd&d'ZJdi dfdǐd*d+ZKdi dfdȐd.d/ZLdi dfdɐd2d3ZMdi dfdʐd6d7ZNdi dfdːd:d;ZOdi dfd̐d>d?ZPdi dfd͐dBdCZQdi dfdΐdFdGZRdi dfdϐdJdKZSdi dfdАdNdOZTdi dfdѐdRdSZUdi dfdҐdVdWZVdi dfdӐdZd[ZWdi dfdԐd^d_ZXdi dfdՐdbdcZYdi dfd֐dfdgZZdi dfdאdjdkZ[di dfdؐdndoZ\di dfdِdrdsZ]di dfdڐdvdwZ^di dfdېdzd{Z_di dfdܐd~dZ`dS (  WorkflowServicez"RPC calls for the WorkflowService.clientr   c                 C     || _ d| _dS )3Initialize service with the provided ServiceClient.workflowN_client_serviceselfr
    r   j/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/temporalio/bridge/services_generated.py__init__      
zWorkflowService.__init__FNreq@temporalio.api.workflowservice.v1.CountWorkflowExecutionsRequestretryboolmetadataMapping[str, Union[str, bytes]]timeoutOptional[timedelta]returnAtemporalio.api.workflowservice.v1.CountWorkflowExecutionsResponsec              	     ,   | j jd|| jtjjjj|||dI dH S )zAInvokes the WorkflowService.count_workflow_executions rpc method.count_workflow_executionsrpcr   service	resp_typer   r   r   N)r   	_rpc_callr   
temporalioapiworkflowservicev1CountWorkflowExecutionsResponser   r   r   r   r   r   r   r   r"         
z)WorkflowService.count_workflow_executions7temporalio.api.workflowservice.v1.CreateScheduleRequest8temporalio.api.workflowservice.v1.CreateScheduleResponsec              	     r!   )z7Invokes the WorkflowService.create_schedule rpc method.create_scheduler#   N)r   r'   r   r(   r)   r*   r+   CreateScheduleResponser-   r   r   r   r1   /   r.   zWorkflowService.create_schedule;temporalio.api.workflowservice.v1.CreateWorkflowRuleRequest<temporalio.api.workflowservice.v1.CreateWorkflowRuleResponsec              	     r!   )z<Invokes the WorkflowService.create_workflow_rule rpc method.create_workflow_ruler#   N)r   r'   r   r(   r)   r*   r+   CreateWorkflowRuleResponser-   r   r   r   r5   A   r.   z$WorkflowService.create_workflow_rule7temporalio.api.workflowservice.v1.DeleteScheduleRequest8temporalio.api.workflowservice.v1.DeleteScheduleResponsec              	     r!   )z7Invokes the WorkflowService.delete_schedule rpc method.delete_scheduler#   N)r   r'   r   r(   r)   r*   r+   DeleteScheduleResponser-   r   r   r   r9   S   r.   zWorkflowService.delete_schedule?temporalio.api.workflowservice.v1.DeleteWorkerDeploymentRequest@temporalio.api.workflowservice.v1.DeleteWorkerDeploymentResponsec              	     r!   )z@Invokes the WorkflowService.delete_worker_deployment rpc method.delete_worker_deploymentr#   N)r   r'   r   r(   r)   r*   r+   DeleteWorkerDeploymentResponser-   r   r   r   r=   e   r.   z(WorkflowService.delete_worker_deploymentFtemporalio.api.workflowservice.v1.DeleteWorkerDeploymentVersionRequestGtemporalio.api.workflowservice.v1.DeleteWorkerDeploymentVersionResponsec              	     r!   )zHInvokes the WorkflowService.delete_worker_deployment_version rpc method. delete_worker_deployment_versionr#   N)r   r'   r   r(   r)   r*   r+   %DeleteWorkerDeploymentVersionResponser-   r   r   r   rA   w   r.   z0WorkflowService.delete_worker_deployment_version@temporalio.api.workflowservice.v1.DeleteWorkflowExecutionRequestAtemporalio.api.workflowservice.v1.DeleteWorkflowExecutionResponsec              	     r!   )zAInvokes the WorkflowService.delete_workflow_execution rpc method.delete_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   DeleteWorkflowExecutionResponser-   r   r   r   rE      r.   z)WorkflowService.delete_workflow_execution;temporalio.api.workflowservice.v1.DeleteWorkflowRuleRequest<temporalio.api.workflowservice.v1.DeleteWorkflowRuleResponsec              	     r!   )z<Invokes the WorkflowService.delete_workflow_rule rpc method.delete_workflow_ruler#   N)r   r'   r   r(   r)   r*   r+   DeleteWorkflowRuleResponser-   r   r   r   rI      r.   z$WorkflowService.delete_workflow_rule;temporalio.api.workflowservice.v1.DeprecateNamespaceRequest<temporalio.api.workflowservice.v1.DeprecateNamespaceResponsec              	     r!   )z;Invokes the WorkflowService.deprecate_namespace rpc method.deprecate_namespacer#   N)r   r'   r   r(   r)   r*   r+   DeprecateNamespaceResponser-   r   r   r   rM      r.   z#WorkflowService.deprecate_namespace?temporalio.api.workflowservice.v1.DescribeBatchOperationRequest@temporalio.api.workflowservice.v1.DescribeBatchOperationResponsec              	     r!   )z@Invokes the WorkflowService.describe_batch_operation rpc method.describe_batch_operationr#   N)r   r'   r   r(   r)   r*   r+   DescribeBatchOperationResponser-   r   r   r   rQ      r.   z(WorkflowService.describe_batch_operation;temporalio.api.workflowservice.v1.DescribeDeploymentRequest<temporalio.api.workflowservice.v1.DescribeDeploymentResponsec              	     r!   )z;Invokes the WorkflowService.describe_deployment rpc method.describe_deploymentr#   N)r   r'   r   r(   r)   r*   r+   DescribeDeploymentResponser-   r   r   r   rU      r.   z#WorkflowService.describe_deployment:temporalio.api.workflowservice.v1.DescribeNamespaceRequest;temporalio.api.workflowservice.v1.DescribeNamespaceResponsec              	     r!   )z:Invokes the WorkflowService.describe_namespace rpc method.describe_namespacer#   N)r   r'   r   r(   r)   r*   r+   DescribeNamespaceResponser-   r   r   r   rY      r.   z"WorkflowService.describe_namespace9temporalio.api.workflowservice.v1.DescribeScheduleRequest:temporalio.api.workflowservice.v1.DescribeScheduleResponsec              	     r!   )z9Invokes the WorkflowService.describe_schedule rpc method.describe_scheduler#   N)r   r'   r   r(   r)   r*   r+   DescribeScheduleResponser-   r   r   r   r]      r.   z!WorkflowService.describe_schedule:temporalio.api.workflowservice.v1.DescribeTaskQueueRequest;temporalio.api.workflowservice.v1.DescribeTaskQueueResponsec              	     r!   )z;Invokes the WorkflowService.describe_task_queue rpc method.describe_task_queuer#   N)r   r'   r   r(   r)   r*   r+   DescribeTaskQueueResponser-   r   r   r   ra     r.   z#WorkflowService.describe_task_queueAtemporalio.api.workflowservice.v1.DescribeWorkerDeploymentRequestBtemporalio.api.workflowservice.v1.DescribeWorkerDeploymentResponsec              	     r!   )zBInvokes the WorkflowService.describe_worker_deployment rpc method.describe_worker_deploymentr#   N)r   r'   r   r(   r)   r*   r+    DescribeWorkerDeploymentResponser-   r   r   r   re     r.   z*WorkflowService.describe_worker_deploymentHtemporalio.api.workflowservice.v1.DescribeWorkerDeploymentVersionRequestItemporalio.api.workflowservice.v1.DescribeWorkerDeploymentVersionResponsec              	     r!   )zJInvokes the WorkflowService.describe_worker_deployment_version rpc method."describe_worker_deployment_versionr#   N)r   r'   r   r(   r)   r*   r+   'DescribeWorkerDeploymentVersionResponser-   r   r   r   ri   +  r.   z2WorkflowService.describe_worker_deployment_versionBtemporalio.api.workflowservice.v1.DescribeWorkflowExecutionRequestCtemporalio.api.workflowservice.v1.DescribeWorkflowExecutionResponsec              	     r!   )zCInvokes the WorkflowService.describe_workflow_execution rpc method.describe_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   !DescribeWorkflowExecutionResponser-   r   r   r   rm   =  r.   z+WorkflowService.describe_workflow_execution=temporalio.api.workflowservice.v1.DescribeWorkflowRuleRequest>temporalio.api.workflowservice.v1.DescribeWorkflowRuleResponsec              	     r!   )z>Invokes the WorkflowService.describe_workflow_rule rpc method.describe_workflow_ruler#   N)r   r'   r   r(   r)   r*   r+   DescribeWorkflowRuleResponser-   r   r   r   rq   O  r.   z&WorkflowService.describe_workflow_rule>temporalio.api.workflowservice.v1.ExecuteMultiOperationRequest?temporalio.api.workflowservice.v1.ExecuteMultiOperationResponsec              	     r!   )z?Invokes the WorkflowService.execute_multi_operation rpc method.execute_multi_operationr#   N)r   r'   r   r(   r)   r*   r+   ExecuteMultiOperationResponser-   r   r   r   ru   a  r.   z'WorkflowService.execute_multi_operation:temporalio.api.workflowservice.v1.FetchWorkerConfigRequest;temporalio.api.workflowservice.v1.FetchWorkerConfigResponsec              	     r!   )z;Invokes the WorkflowService.fetch_worker_config rpc method.fetch_worker_configr#   N)r   r'   r   r(   r)   r*   r+   FetchWorkerConfigResponser-   r   r   r   ry   s  r.   z#WorkflowService.fetch_worker_config7temporalio.api.workflowservice.v1.GetClusterInfoRequest8temporalio.api.workflowservice.v1.GetClusterInfoResponsec              	     r!   )z8Invokes the WorkflowService.get_cluster_info rpc method.get_cluster_infor#   N)r   r'   r   r(   r)   r*   r+   GetClusterInfoResponser-   r   r   r   r}     r.   z WorkflowService.get_cluster_info=temporalio.api.workflowservice.v1.GetCurrentDeploymentRequest>temporalio.api.workflowservice.v1.GetCurrentDeploymentResponsec              	     r!   )z>Invokes the WorkflowService.get_current_deployment rpc method.get_current_deploymentr#   N)r   r'   r   r(   r)   r*   r+   GetCurrentDeploymentResponser-   r   r   r   r     r.   z&WorkflowService.get_current_deploymentBtemporalio.api.workflowservice.v1.GetDeploymentReachabilityRequestCtemporalio.api.workflowservice.v1.GetDeploymentReachabilityResponsec              	     r!   )zCInvokes the WorkflowService.get_deployment_reachability rpc method.get_deployment_reachabilityr#   N)r   r'   r   r(   r)   r*   r+   !GetDeploymentReachabilityResponser-   r   r   r   r     r.   z+WorkflowService.get_deployment_reachability<temporalio.api.workflowservice.v1.GetSearchAttributesRequest=temporalio.api.workflowservice.v1.GetSearchAttributesResponsec              	     r!   )z=Invokes the WorkflowService.get_search_attributes rpc method.get_search_attributesr#   N)r   r'   r   r(   r)   r*   r+   GetSearchAttributesResponser-   r   r   r   r     r.   z%WorkflowService.get_search_attributes6temporalio.api.workflowservice.v1.GetSystemInfoRequest7temporalio.api.workflowservice.v1.GetSystemInfoResponsec              	     r!   )z7Invokes the WorkflowService.get_system_info rpc method.get_system_infor#   N)r   r'   r   r(   r)   r*   r+   GetSystemInfoResponser-   r   r   r   r     r.   zWorkflowService.get_system_infoFtemporalio.api.workflowservice.v1.GetWorkerBuildIdCompatibilityRequestGtemporalio.api.workflowservice.v1.GetWorkerBuildIdCompatibilityResponsec              	     r!   )zIInvokes the WorkflowService.get_worker_build_id_compatibility rpc method.!get_worker_build_id_compatibilityr#   N)r   r'   r   r(   r)   r*   r+   %GetWorkerBuildIdCompatibilityResponser-   r   r   r   r     r.   z1WorkflowService.get_worker_build_id_compatibilityBtemporalio.api.workflowservice.v1.GetWorkerTaskReachabilityRequestCtemporalio.api.workflowservice.v1.GetWorkerTaskReachabilityResponsec              	     r!   )zDInvokes the WorkflowService.get_worker_task_reachability rpc method.get_worker_task_reachabilityr#   N)r   r'   r   r(   r)   r*   r+   !GetWorkerTaskReachabilityResponser-   r   r   r   r     r.   z,WorkflowService.get_worker_task_reachabilityAtemporalio.api.workflowservice.v1.GetWorkerVersioningRulesRequestBtemporalio.api.workflowservice.v1.GetWorkerVersioningRulesResponsec              	     r!   )zCInvokes the WorkflowService.get_worker_versioning_rules rpc method.get_worker_versioning_rulesr#   N)r   r'   r   r(   r)   r*   r+    GetWorkerVersioningRulesResponser-   r   r   r   r     r.   z+WorkflowService.get_worker_versioning_rulesDtemporalio.api.workflowservice.v1.GetWorkflowExecutionHistoryRequestEtemporalio.api.workflowservice.v1.GetWorkflowExecutionHistoryResponsec              	     r!   )zFInvokes the WorkflowService.get_workflow_execution_history rpc method.get_workflow_execution_historyr#   N)r   r'   r   r(   r)   r*   r+   #GetWorkflowExecutionHistoryResponser-   r   r   r   r     r.   z.WorkflowService.get_workflow_execution_historyKtemporalio.api.workflowservice.v1.GetWorkflowExecutionHistoryReverseRequestLtemporalio.api.workflowservice.v1.GetWorkflowExecutionHistoryReverseResponsec              	     r!   )zNInvokes the WorkflowService.get_workflow_execution_history_reverse rpc method.&get_workflow_execution_history_reverser#   N)r   r'   r   r(   r)   r*   r+   *GetWorkflowExecutionHistoryReverseResponser-   r   r   r   r   '  r.   z6WorkflowService.get_workflow_execution_history_reverseGtemporalio.api.workflowservice.v1.ListArchivedWorkflowExecutionsRequestHtemporalio.api.workflowservice.v1.ListArchivedWorkflowExecutionsResponsec              	     r!   )zIInvokes the WorkflowService.list_archived_workflow_executions rpc method.!list_archived_workflow_executionsr#   N)r   r'   r   r(   r)   r*   r+   &ListArchivedWorkflowExecutionsResponser-   r   r   r   r   9  r.   z1WorkflowService.list_archived_workflow_executions<temporalio.api.workflowservice.v1.ListBatchOperationsRequest=temporalio.api.workflowservice.v1.ListBatchOperationsResponsec              	     r!   )z=Invokes the WorkflowService.list_batch_operations rpc method.list_batch_operationsr#   N)r   r'   r   r(   r)   r*   r+   ListBatchOperationsResponser-   r   r   r   r   K  r.   z%WorkflowService.list_batch_operationsEtemporalio.api.workflowservice.v1.ListClosedWorkflowExecutionsRequestFtemporalio.api.workflowservice.v1.ListClosedWorkflowExecutionsResponsec              	     r!   )zGInvokes the WorkflowService.list_closed_workflow_executions rpc method.list_closed_workflow_executionsr#   N)r   r'   r   r(   r)   r*   r+   $ListClosedWorkflowExecutionsResponser-   r   r   r   r   ]  r.   z/WorkflowService.list_closed_workflow_executions8temporalio.api.workflowservice.v1.ListDeploymentsRequest9temporalio.api.workflowservice.v1.ListDeploymentsResponsec              	     r!   )z8Invokes the WorkflowService.list_deployments rpc method.list_deploymentsr#   N)r   r'   r   r(   r)   r*   r+   ListDeploymentsResponser-   r   r   r   r   o  r.   z WorkflowService.list_deployments7temporalio.api.workflowservice.v1.ListNamespacesRequest8temporalio.api.workflowservice.v1.ListNamespacesResponsec              	     r!   )z7Invokes the WorkflowService.list_namespaces rpc method.list_namespacesr#   N)r   r'   r   r(   r)   r*   r+   ListNamespacesResponser-   r   r   r   r     r.   zWorkflowService.list_namespacesCtemporalio.api.workflowservice.v1.ListOpenWorkflowExecutionsRequestDtemporalio.api.workflowservice.v1.ListOpenWorkflowExecutionsResponsec              	     r!   )zEInvokes the WorkflowService.list_open_workflow_executions rpc method.list_open_workflow_executionsr#   N)r   r'   r   r(   r)   r*   r+   "ListOpenWorkflowExecutionsResponser-   r   r   r   r     r.   z-WorkflowService.list_open_workflow_executionsBtemporalio.api.workflowservice.v1.ListScheduleMatchingTimesRequestCtemporalio.api.workflowservice.v1.ListScheduleMatchingTimesResponsec              	     r!   )zDInvokes the WorkflowService.list_schedule_matching_times rpc method.list_schedule_matching_timesr#   N)r   r'   r   r(   r)   r*   r+   !ListScheduleMatchingTimesResponser-   r   r   r   r     r.   z,WorkflowService.list_schedule_matching_times6temporalio.api.workflowservice.v1.ListSchedulesRequest7temporalio.api.workflowservice.v1.ListSchedulesResponsec              	     r!   )z6Invokes the WorkflowService.list_schedules rpc method.list_schedulesr#   N)r   r'   r   r(   r)   r*   r+   ListSchedulesResponser-   r   r   r   r     r.   zWorkflowService.list_schedules@temporalio.api.workflowservice.v1.ListTaskQueuePartitionsRequestAtemporalio.api.workflowservice.v1.ListTaskQueuePartitionsResponsec              	     r!   )zBInvokes the WorkflowService.list_task_queue_partitions rpc method.list_task_queue_partitionsr#   N)r   r'   r   r(   r)   r*   r+   ListTaskQueuePartitionsResponser-   r   r   r   r     r.   z*WorkflowService.list_task_queue_partitions>temporalio.api.workflowservice.v1.ListWorkerDeploymentsRequest?temporalio.api.workflowservice.v1.ListWorkerDeploymentsResponsec              	     r!   )z?Invokes the WorkflowService.list_worker_deployments rpc method.list_worker_deploymentsr#   N)r   r'   r   r(   r)   r*   r+   ListWorkerDeploymentsResponser-   r   r   r   r     r.   z'WorkflowService.list_worker_deployments4temporalio.api.workflowservice.v1.ListWorkersRequest5temporalio.api.workflowservice.v1.ListWorkersResponsec              	     r!   )z4Invokes the WorkflowService.list_workers rpc method.list_workersr#   N)r   r'   r   r(   r)   r*   r+   ListWorkersResponser-   r   r   r   r     r.   zWorkflowService.list_workers?temporalio.api.workflowservice.v1.ListWorkflowExecutionsRequest@temporalio.api.workflowservice.v1.ListWorkflowExecutionsResponsec              	     r!   )z@Invokes the WorkflowService.list_workflow_executions rpc method.list_workflow_executionsr#   N)r   r'   r   r(   r)   r*   r+   ListWorkflowExecutionsResponser-   r   r   r   r     r.   z(WorkflowService.list_workflow_executions:temporalio.api.workflowservice.v1.ListWorkflowRulesRequest;temporalio.api.workflowservice.v1.ListWorkflowRulesResponsec              	     r!   )z;Invokes the WorkflowService.list_workflow_rules rpc method.list_workflow_rulesr#   N)r   r'   r   r(   r)   r*   r+   ListWorkflowRulesResponser-   r   r   r   r     r.   z#WorkflowService.list_workflow_rules6temporalio.api.workflowservice.v1.PatchScheduleRequest7temporalio.api.workflowservice.v1.PatchScheduleResponsec              	     r!   )z6Invokes the WorkflowService.patch_schedule rpc method.patch_scheduler#   N)r   r'   r   r(   r)   r*   r+   PatchScheduleResponser-   r   r   r   r   #  r.   zWorkflowService.patch_schedule6temporalio.api.workflowservice.v1.PauseActivityRequest7temporalio.api.workflowservice.v1.PauseActivityResponsec              	     r!   )z6Invokes the WorkflowService.pause_activity rpc method.pause_activityr#   N)r   r'   r   r(   r)   r*   r+   PauseActivityResponser-   r   r   r   r   5  r.   zWorkflowService.pause_activity>temporalio.api.workflowservice.v1.PollActivityTaskQueueRequest?temporalio.api.workflowservice.v1.PollActivityTaskQueueResponsec              	     r!   )z@Invokes the WorkflowService.poll_activity_task_queue rpc method.poll_activity_task_queuer#   N)r   r'   r   r(   r)   r*   r+   PollActivityTaskQueueResponser-   r   r   r   r   G  r.   z(WorkflowService.poll_activity_task_queue;temporalio.api.workflowservice.v1.PollNexusTaskQueueRequest<temporalio.api.workflowservice.v1.PollNexusTaskQueueResponsec              	     r!   )z=Invokes the WorkflowService.poll_nexus_task_queue rpc method.poll_nexus_task_queuer#   N)r   r'   r   r(   r)   r*   r+   PollNexusTaskQueueResponser-   r   r   r   r   Y  r.   z%WorkflowService.poll_nexus_task_queueDtemporalio.api.workflowservice.v1.PollWorkflowExecutionUpdateRequestEtemporalio.api.workflowservice.v1.PollWorkflowExecutionUpdateResponsec              	     r!   )zFInvokes the WorkflowService.poll_workflow_execution_update rpc method.poll_workflow_execution_updater#   N)r   r'   r   r(   r)   r*   r+   #PollWorkflowExecutionUpdateResponser-   r   r   r   r   k  r.   z.WorkflowService.poll_workflow_execution_update>temporalio.api.workflowservice.v1.PollWorkflowTaskQueueRequest?temporalio.api.workflowservice.v1.PollWorkflowTaskQueueResponsec              	     r!   )z@Invokes the WorkflowService.poll_workflow_task_queue rpc method.poll_workflow_task_queuer#   N)r   r'   r   r(   r)   r*   r+   PollWorkflowTaskQueueResponser-   r   r   r   r   }  r.   z(WorkflowService.poll_workflow_task_queue6temporalio.api.workflowservice.v1.QueryWorkflowRequest7temporalio.api.workflowservice.v1.QueryWorkflowResponsec              	     r!   )z6Invokes the WorkflowService.query_workflow rpc method.query_workflowr#   N)r   r'   r   r(   r)   r*   r+   QueryWorkflowResponser-   r   r   r   r     r.   zWorkflowService.query_workflowDtemporalio.api.workflowservice.v1.RecordActivityTaskHeartbeatRequestEtemporalio.api.workflowservice.v1.RecordActivityTaskHeartbeatResponsec              	     r!   )zFInvokes the WorkflowService.record_activity_task_heartbeat rpc method.record_activity_task_heartbeatr#   N)r   r'   r   r(   r)   r*   r+   #RecordActivityTaskHeartbeatResponser-   r   r   r   r     r.   z.WorkflowService.record_activity_task_heartbeatHtemporalio.api.workflowservice.v1.RecordActivityTaskHeartbeatByIdRequestItemporalio.api.workflowservice.v1.RecordActivityTaskHeartbeatByIdResponsec              	     r!   )zLInvokes the WorkflowService.record_activity_task_heartbeat_by_id rpc method.$record_activity_task_heartbeat_by_idr#   N)r   r'   r   r(   r)   r*   r+   'RecordActivityTaskHeartbeatByIdResponser-   r   r   r   r     r.   z4WorkflowService.record_activity_task_heartbeat_by_id>temporalio.api.workflowservice.v1.RecordWorkerHeartbeatRequest?temporalio.api.workflowservice.v1.RecordWorkerHeartbeatResponsec              	     r!   )z?Invokes the WorkflowService.record_worker_heartbeat rpc method.record_worker_heartbeatr#   N)r   r'   r   r(   r)   r*   r+   RecordWorkerHeartbeatResponser-   r   r   r   r     r.   z'WorkflowService.record_worker_heartbeat:temporalio.api.workflowservice.v1.RegisterNamespaceRequest;temporalio.api.workflowservice.v1.RegisterNamespaceResponsec              	     r!   )z:Invokes the WorkflowService.register_namespace rpc method.register_namespacer#   N)r   r'   r   r(   r)   r*   r+   RegisterNamespaceResponser-   r   r   r   r    r.   z"WorkflowService.register_namespaceGtemporalio.api.workflowservice.v1.RequestCancelWorkflowExecutionRequestHtemporalio.api.workflowservice.v1.RequestCancelWorkflowExecutionResponsec              	     r!   )zIInvokes the WorkflowService.request_cancel_workflow_execution rpc method.!request_cancel_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   &RequestCancelWorkflowExecutionResponser-   r   r   r   r    r.   z1WorkflowService.request_cancel_workflow_execution6temporalio.api.workflowservice.v1.ResetActivityRequest7temporalio.api.workflowservice.v1.ResetActivityResponsec              	     r!   )z6Invokes the WorkflowService.reset_activity rpc method.reset_activityr#   N)r   r'   r   r(   r)   r*   r+   ResetActivityResponser-   r   r   r   r	    r.   zWorkflowService.reset_activity=temporalio.api.workflowservice.v1.ResetStickyTaskQueueRequest>temporalio.api.workflowservice.v1.ResetStickyTaskQueueResponsec              	     r!   )z?Invokes the WorkflowService.reset_sticky_task_queue rpc method.reset_sticky_task_queuer#   N)r   r'   r   r(   r)   r*   r+   ResetStickyTaskQueueResponser-   r   r   r   r    r.   z'WorkflowService.reset_sticky_task_queue?temporalio.api.workflowservice.v1.ResetWorkflowExecutionRequest@temporalio.api.workflowservice.v1.ResetWorkflowExecutionResponsec              	     r!   )z@Invokes the WorkflowService.reset_workflow_execution rpc method.reset_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   ResetWorkflowExecutionResponser-   r   r   r   r    r.   z(WorkflowService.reset_workflow_executionDtemporalio.api.workflowservice.v1.RespondActivityTaskCanceledRequestEtemporalio.api.workflowservice.v1.RespondActivityTaskCanceledResponsec              	     r!   )zFInvokes the WorkflowService.respond_activity_task_canceled rpc method.respond_activity_task_canceledr#   N)r   r'   r   r(   r)   r*   r+   #RespondActivityTaskCanceledResponser-   r   r   r   r  1  r.   z.WorkflowService.respond_activity_task_canceledHtemporalio.api.workflowservice.v1.RespondActivityTaskCanceledByIdRequestItemporalio.api.workflowservice.v1.RespondActivityTaskCanceledByIdResponsec              	     r!   )zLInvokes the WorkflowService.respond_activity_task_canceled_by_id rpc method.$respond_activity_task_canceled_by_idr#   N)r   r'   r   r(   r)   r*   r+   'RespondActivityTaskCanceledByIdResponser-   r   r   r   r  C  r.   z4WorkflowService.respond_activity_task_canceled_by_idEtemporalio.api.workflowservice.v1.RespondActivityTaskCompletedRequestFtemporalio.api.workflowservice.v1.RespondActivityTaskCompletedResponsec              	     r!   )zGInvokes the WorkflowService.respond_activity_task_completed rpc method.respond_activity_task_completedr#   N)r   r'   r   r(   r)   r*   r+   $RespondActivityTaskCompletedResponser-   r   r   r   r  U  r.   z/WorkflowService.respond_activity_task_completedItemporalio.api.workflowservice.v1.RespondActivityTaskCompletedByIdRequestJtemporalio.api.workflowservice.v1.RespondActivityTaskCompletedByIdResponsec              	     r!   )zMInvokes the WorkflowService.respond_activity_task_completed_by_id rpc method.%respond_activity_task_completed_by_idr#   N)r   r'   r   r(   r)   r*   r+   (RespondActivityTaskCompletedByIdResponser-   r   r   r   r!  g  r.   z5WorkflowService.respond_activity_task_completed_by_idBtemporalio.api.workflowservice.v1.RespondActivityTaskFailedRequestCtemporalio.api.workflowservice.v1.RespondActivityTaskFailedResponsec              	     r!   )zDInvokes the WorkflowService.respond_activity_task_failed rpc method.respond_activity_task_failedr#   N)r   r'   r   r(   r)   r*   r+   !RespondActivityTaskFailedResponser-   r   r   r   r%  y  r.   z,WorkflowService.respond_activity_task_failedFtemporalio.api.workflowservice.v1.RespondActivityTaskFailedByIdRequestGtemporalio.api.workflowservice.v1.RespondActivityTaskFailedByIdResponsec              	     r!   )zJInvokes the WorkflowService.respond_activity_task_failed_by_id rpc method."respond_activity_task_failed_by_idr#   N)r   r'   r   r(   r)   r*   r+   %RespondActivityTaskFailedByIdResponser-   r   r   r   r)    r.   z2WorkflowService.respond_activity_task_failed_by_idBtemporalio.api.workflowservice.v1.RespondNexusTaskCompletedRequestCtemporalio.api.workflowservice.v1.RespondNexusTaskCompletedResponsec              	     r!   )zDInvokes the WorkflowService.respond_nexus_task_completed rpc method.respond_nexus_task_completedr#   N)r   r'   r   r(   r)   r*   r+   !RespondNexusTaskCompletedResponser-   r   r   r   r-    r.   z,WorkflowService.respond_nexus_task_completed?temporalio.api.workflowservice.v1.RespondNexusTaskFailedRequest@temporalio.api.workflowservice.v1.RespondNexusTaskFailedResponsec              	     r!   )zAInvokes the WorkflowService.respond_nexus_task_failed rpc method.respond_nexus_task_failedr#   N)r   r'   r   r(   r)   r*   r+   RespondNexusTaskFailedResponser-   r   r   r   r1    r.   z)WorkflowService.respond_nexus_task_failedBtemporalio.api.workflowservice.v1.RespondQueryTaskCompletedRequestCtemporalio.api.workflowservice.v1.RespondQueryTaskCompletedResponsec              	     r!   )zDInvokes the WorkflowService.respond_query_task_completed rpc method.respond_query_task_completedr#   N)r   r'   r   r(   r)   r*   r+   !RespondQueryTaskCompletedResponser-   r   r   r   r5    r.   z,WorkflowService.respond_query_task_completedEtemporalio.api.workflowservice.v1.RespondWorkflowTaskCompletedRequestFtemporalio.api.workflowservice.v1.RespondWorkflowTaskCompletedResponsec              	     r!   )zGInvokes the WorkflowService.respond_workflow_task_completed rpc method.respond_workflow_task_completedr#   N)r   r'   r   r(   r)   r*   r+   $RespondWorkflowTaskCompletedResponser-   r   r   r   r9    r.   z/WorkflowService.respond_workflow_task_completedBtemporalio.api.workflowservice.v1.RespondWorkflowTaskFailedRequestCtemporalio.api.workflowservice.v1.RespondWorkflowTaskFailedResponsec              	     r!   )zDInvokes the WorkflowService.respond_workflow_task_failed rpc method.respond_workflow_task_failedr#   N)r   r'   r   r(   r)   r*   r+   !RespondWorkflowTaskFailedResponser-   r   r   r   r=    r.   z,WorkflowService.respond_workflow_task_failed?temporalio.api.workflowservice.v1.ScanWorkflowExecutionsRequest@temporalio.api.workflowservice.v1.ScanWorkflowExecutionsResponsec              	     r!   )z@Invokes the WorkflowService.scan_workflow_executions rpc method.scan_workflow_executionsr#   N)r   r'   r   r(   r)   r*   r+   ScanWorkflowExecutionsResponser-   r   r   r   rA    r.   z(WorkflowService.scan_workflow_executions=temporalio.api.workflowservice.v1.SetCurrentDeploymentRequest>temporalio.api.workflowservice.v1.SetCurrentDeploymentResponsec              	     r!   )z>Invokes the WorkflowService.set_current_deployment rpc method.set_current_deploymentr#   N)r   r'   r   r(   r)   r*   r+   SetCurrentDeploymentResponser-   r   r   r   rE  	  r.   z&WorkflowService.set_current_deploymentJtemporalio.api.workflowservice.v1.SetWorkerDeploymentCurrentVersionRequestKtemporalio.api.workflowservice.v1.SetWorkerDeploymentCurrentVersionResponsec              	     r!   )zMInvokes the WorkflowService.set_worker_deployment_current_version rpc method.%set_worker_deployment_current_versionr#   N)r   r'   r   r(   r)   r*   r+   )SetWorkerDeploymentCurrentVersionResponser-   r   r   r   rI    r.   z5WorkflowService.set_worker_deployment_current_versionJtemporalio.api.workflowservice.v1.SetWorkerDeploymentRampingVersionRequestKtemporalio.api.workflowservice.v1.SetWorkerDeploymentRampingVersionResponsec              	     r!   )zMInvokes the WorkflowService.set_worker_deployment_ramping_version rpc method.%set_worker_deployment_ramping_versionr#   N)r   r'   r   r(   r)   r*   r+   )SetWorkerDeploymentRampingVersionResponser-   r   r   r   rM  -  r.   z5WorkflowService.set_worker_deployment_ramping_version7temporalio.api.workflowservice.v1.ShutdownWorkerRequest8temporalio.api.workflowservice.v1.ShutdownWorkerResponsec              	     r!   )z7Invokes the WorkflowService.shutdown_worker rpc method.shutdown_workerr#   N)r   r'   r   r(   r)   r*   r+   ShutdownWorkerResponser-   r   r   r   rQ  ?  r.   zWorkflowService.shutdown_workerItemporalio.api.workflowservice.v1.SignalWithStartWorkflowExecutionRequestJtemporalio.api.workflowservice.v1.SignalWithStartWorkflowExecutionResponsec              	     r!   )zLInvokes the WorkflowService.signal_with_start_workflow_execution rpc method.$signal_with_start_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   (SignalWithStartWorkflowExecutionResponser-   r   r   r   rU  Q  r.   z4WorkflowService.signal_with_start_workflow_execution@temporalio.api.workflowservice.v1.SignalWorkflowExecutionRequestAtemporalio.api.workflowservice.v1.SignalWorkflowExecutionResponsec              	     r!   )zAInvokes the WorkflowService.signal_workflow_execution rpc method.signal_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   SignalWorkflowExecutionResponser-   r   r   r   rY  c  r.   z)WorkflowService.signal_workflow_execution<temporalio.api.workflowservice.v1.StartBatchOperationRequest=temporalio.api.workflowservice.v1.StartBatchOperationResponsec              	     r!   )z=Invokes the WorkflowService.start_batch_operation rpc method.start_batch_operationr#   N)r   r'   r   r(   r)   r*   r+   StartBatchOperationResponser-   r   r   r   r]  u  r.   z%WorkflowService.start_batch_operation?temporalio.api.workflowservice.v1.StartWorkflowExecutionRequest@temporalio.api.workflowservice.v1.StartWorkflowExecutionResponsec              	     r!   )z@Invokes the WorkflowService.start_workflow_execution rpc method.start_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   StartWorkflowExecutionResponser-   r   r   r   ra    r.   z(WorkflowService.start_workflow_execution;temporalio.api.workflowservice.v1.StopBatchOperationRequest<temporalio.api.workflowservice.v1.StopBatchOperationResponsec              	     r!   )z<Invokes the WorkflowService.stop_batch_operation rpc method.stop_batch_operationr#   N)r   r'   r   r(   r)   r*   r+   StopBatchOperationResponser-   r   r   r   re    r.   z$WorkflowService.stop_batch_operationCtemporalio.api.workflowservice.v1.TerminateWorkflowExecutionRequestDtemporalio.api.workflowservice.v1.TerminateWorkflowExecutionResponsec              	     r!   )zDInvokes the WorkflowService.terminate_workflow_execution rpc method.terminate_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   "TerminateWorkflowExecutionResponser-   r   r   r   ri    r.   z,WorkflowService.terminate_workflow_execution<temporalio.api.workflowservice.v1.TriggerWorkflowRuleRequest=temporalio.api.workflowservice.v1.TriggerWorkflowRuleResponsec              	     r!   )z=Invokes the WorkflowService.trigger_workflow_rule rpc method.trigger_workflow_ruler#   N)r   r'   r   r(   r)   r*   r+   TriggerWorkflowRuleResponser-   r   r   r   rm    r.   z%WorkflowService.trigger_workflow_rule8temporalio.api.workflowservice.v1.UnpauseActivityRequest9temporalio.api.workflowservice.v1.UnpauseActivityResponsec              	     r!   )z8Invokes the WorkflowService.unpause_activity rpc method.unpause_activityr#   N)r   r'   r   r(   r)   r*   r+   UnpauseActivityResponser-   r   r   r   rq    r.   z WorkflowService.unpause_activity>temporalio.api.workflowservice.v1.UpdateActivityOptionsRequest?temporalio.api.workflowservice.v1.UpdateActivityOptionsResponsec              	     r!   )z?Invokes the WorkflowService.update_activity_options rpc method.update_activity_optionsr#   N)r   r'   r   r(   r)   r*   r+   UpdateActivityOptionsResponser-   r   r   r   ru    r.   z'WorkflowService.update_activity_options8temporalio.api.workflowservice.v1.UpdateNamespaceRequest9temporalio.api.workflowservice.v1.UpdateNamespaceResponsec              	     r!   )z8Invokes the WorkflowService.update_namespace rpc method.update_namespacer#   N)r   r'   r   r(   r)   r*   r+   UpdateNamespaceResponser-   r   r   r   ry    r.   z WorkflowService.update_namespace7temporalio.api.workflowservice.v1.UpdateScheduleRequest8temporalio.api.workflowservice.v1.UpdateScheduleResponsec              	     r!   )z7Invokes the WorkflowService.update_schedule rpc method.update_scheduler#   N)r   r'   r   r(   r)   r*   r+   UpdateScheduleResponser-   r   r   r   r}    r.   zWorkflowService.update_schedule>temporalio.api.workflowservice.v1.UpdateTaskQueueConfigRequest?temporalio.api.workflowservice.v1.UpdateTaskQueueConfigResponsec              	     r!   )z@Invokes the WorkflowService.update_task_queue_config rpc method.update_task_queue_configr#   N)r   r'   r   r(   r)   r*   r+   UpdateTaskQueueConfigResponser-   r   r   r   r    r.   z(WorkflowService.update_task_queue_configItemporalio.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityRequestJtemporalio.api.workflowservice.v1.UpdateWorkerBuildIdCompatibilityResponsec              	     r!   )zLInvokes the WorkflowService.update_worker_build_id_compatibility rpc method.$update_worker_build_id_compatibilityr#   N)r   r'   r   r(   r)   r*   r+   (UpdateWorkerBuildIdCompatibilityResponser-   r   r   r   r  )  r.   z4WorkflowService.update_worker_build_id_compatibility;temporalio.api.workflowservice.v1.UpdateWorkerConfigRequest<temporalio.api.workflowservice.v1.UpdateWorkerConfigResponsec              	     r!   )z<Invokes the WorkflowService.update_worker_config rpc method.update_worker_configr#   N)r   r'   r   r(   r)   r*   r+   UpdateWorkerConfigResponser-   r   r   r   r  ;  r.   z$WorkflowService.update_worker_configNtemporalio.api.workflowservice.v1.UpdateWorkerDeploymentVersionMetadataRequestOtemporalio.api.workflowservice.v1.UpdateWorkerDeploymentVersionMetadataResponsec              	     r!   )zQInvokes the WorkflowService.update_worker_deployment_version_metadata rpc method.)update_worker_deployment_version_metadatar#   N)r   r'   r   r(   r)   r*   r+   -UpdateWorkerDeploymentVersionMetadataResponser-   r   r   r   r  M  s   

z9WorkflowService.update_worker_deployment_version_metadataDtemporalio.api.workflowservice.v1.UpdateWorkerVersioningRulesRequestEtemporalio.api.workflowservice.v1.UpdateWorkerVersioningRulesResponsec              	     r!   )zFInvokes the WorkflowService.update_worker_versioning_rules rpc method.update_worker_versioning_rulesr#   N)r   r'   r   r(   r)   r*   r+   #UpdateWorkerVersioningRulesResponser-   r   r   r   r  a  r.   z.WorkflowService.update_worker_versioning_rules@temporalio.api.workflowservice.v1.UpdateWorkflowExecutionRequestAtemporalio.api.workflowservice.v1.UpdateWorkflowExecutionResponsec              	     r!   )zAInvokes the WorkflowService.update_workflow_execution rpc method.update_workflow_executionr#   N)r   r'   r   r(   r)   r*   r+   UpdateWorkflowExecutionResponser-   r   r   r   r  s  r.   z)WorkflowService.update_workflow_executionGtemporalio.api.workflowservice.v1.UpdateWorkflowExecutionOptionsRequestHtemporalio.api.workflowservice.v1.UpdateWorkflowExecutionOptionsResponsec              	     r!   )zIInvokes the WorkflowService.update_workflow_execution_options rpc method.!update_workflow_execution_optionsr#   N)r   r'   r   r(   r)   r*   r+   &UpdateWorkflowExecutionOptionsResponser-   r   r   r   r    r.   z1WorkflowService.update_workflow_execution_optionsr
   r   )
r   r   r   r   r   r   r   r   r   r    )
r   r/   r   r   r   r   r   r   r   r0   )
r   r3   r   r   r   r   r   r   r   r4   )
r   r7   r   r   r   r   r   r   r   r8   )
r   r;   r   r   r   r   r   r   r   r<   )
r   r?   r   r   r   r   r   r   r   r@   )
r   rC   r   r   r   r   r   r   r   rD   )
r   rG   r   r   r   r   r   r   r   rH   )
r   rK   r   r   r   r   r   r   r   rL   )
r   rO   r   r   r   r   r   r   r   rP   )
r   rS   r   r   r   r   r   r   r   rT   )
r   rW   r   r   r   r   r   r   r   rX   )
r   r[   r   r   r   r   r   r   r   r\   )
r   r_   r   r   r   r   r   r   r   r`   )
r   rc   r   r   r   r   r   r   r   rd   )
r   rg   r   r   r   r   r   r   r   rh   )
r   rk   r   r   r   r   r   r   r   rl   )
r   ro   r   r   r   r   r   r   r   rp   )
r   rs   r   r   r   r   r   r   r   rt   )
r   rw   r   r   r   r   r   r   r   rx   )
r   r{   r   r   r   r   r   r   r   r|   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r   r   r   r   r   r   r   r   r   )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r   )
r   r#  r   r   r   r   r   r   r   r$  )
r   r'  r   r   r   r   r   r   r   r(  )
r   r+  r   r   r   r   r   r   r   r,  )
r   r/  r   r   r   r   r   r   r   r0  )
r   r3  r   r   r   r   r   r   r   r4  )
r   r7  r   r   r   r   r   r   r   r8  )
r   r;  r   r   r   r   r   r   r   r<  )
r   r?  r   r   r   r   r   r   r   r@  )
r   rC  r   r   r   r   r   r   r   rD  )
r   rG  r   r   r   r   r   r   r   rH  )
r   rK  r   r   r   r   r   r   r   rL  )
r   rO  r   r   r   r   r   r   r   rP  )
r   rS  r   r   r   r   r   r   r   rT  )
r   rW  r   r   r   r   r   r   r   rX  )
r   r[  r   r   r   r   r   r   r   r\  )
r   r_  r   r   r   r   r   r   r   r`  )
r   rc  r   r   r   r   r   r   r   rd  )
r   rg  r   r   r   r   r   r   r   rh  )
r   rk  r   r   r   r   r   r   r   rl  )
r   ro  r   r   r   r   r   r   r   rp  )
r   rs  r   r   r   r   r   r   r   rt  )
r   rw  r   r   r   r   r   r   r   rx  )
r   r{  r   r   r   r   r   r   r   r|  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )a__name__
__module____qualname____doc__r   r"   r1   r5   r9   r=   rA   rE   rI   rM   rQ   rU   rY   r]   ra   re   ri   rm   rq   ru   ry   r}   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r	  r  r  r  r  r  r!  r%  r)  r-  r1  r5  r9  r=  rA  rE  rI  rM  rQ  rU  rY  r]  ra  re  ri  rm  rq  ru  ry  r}  r  r  r  r  r  r  r  r   r   r   r   r	      s   r	   c                   @  s   e Zd ZdZd@ddZdi dfdAddZdi dfdBddZdi dfdCddZdi dfdDddZdi dfdEd"d#Z	di dfdFd&d'Z
di dfdGd*d+Zdi dfdHd.d/Zdi dfdId2d3Zdi dfdJd6d7Zdi dfdKd:d;Zdi dfdLd>d?ZdS )MOperatorServicez"RPC calls for the OperatorService.r
   r   c                 C  r   )r   operatorNr   r   r   r   r   r     r   zOperatorService.__init__FNr   Atemporalio.api.operatorservice.v1.AddOrUpdateRemoteClusterRequestr   r   r   r   r   r   r   Btemporalio.api.operatorservice.v1.AddOrUpdateRemoteClusterResponsec              	     r!   )zDInvokes the OperatorService.add_or_update_remote_cluster rpc method.add_or_update_remote_clusterr#   N)r   r'   r   r(   r)   operatorservicer+    AddOrUpdateRemoteClusterResponser-   r   r   r   r    r.   z,OperatorService.add_or_update_remote_cluster<temporalio.api.operatorservice.v1.AddSearchAttributesRequest=temporalio.api.operatorservice.v1.AddSearchAttributesResponsec              	     r!   )z=Invokes the OperatorService.add_search_attributes rpc method.add_search_attributesr#   N)r   r'   r   r(   r)   r  r+   AddSearchAttributesResponser-   r   r   r   r    r.   z%OperatorService.add_search_attributes<temporalio.api.operatorservice.v1.CreateNexusEndpointRequest=temporalio.api.operatorservice.v1.CreateNexusEndpointResponsec              	     r!   )z=Invokes the OperatorService.create_nexus_endpoint rpc method.create_nexus_endpointr#   N)r   r'   r   r(   r)   r  r+   CreateNexusEndpointResponser-   r   r   r   r    r.   z%OperatorService.create_nexus_endpoint8temporalio.api.operatorservice.v1.DeleteNamespaceRequest9temporalio.api.operatorservice.v1.DeleteNamespaceResponsec              	     r!   )z8Invokes the OperatorService.delete_namespace rpc method.delete_namespacer#   N)r   r'   r   r(   r)   r  r+   DeleteNamespaceResponser-   r   r   r   r    r.   z OperatorService.delete_namespace<temporalio.api.operatorservice.v1.DeleteNexusEndpointRequest=temporalio.api.operatorservice.v1.DeleteNexusEndpointResponsec              	     r!   )z=Invokes the OperatorService.delete_nexus_endpoint rpc method.delete_nexus_endpointr#   N)r   r'   r   r(   r)   r  r+   DeleteNexusEndpointResponser-   r   r   r   r    r.   z%OperatorService.delete_nexus_endpoint9temporalio.api.operatorservice.v1.GetNexusEndpointRequest:temporalio.api.operatorservice.v1.GetNexusEndpointResponsec              	     r!   )z:Invokes the OperatorService.get_nexus_endpoint rpc method.get_nexus_endpointr#   N)r   r'   r   r(   r)   r  r+   GetNexusEndpointResponser-   r   r   r   r    r.   z"OperatorService.get_nexus_endpoint5temporalio.api.operatorservice.v1.ListClustersRequest6temporalio.api.operatorservice.v1.ListClustersResponsec              	     r!   )z5Invokes the OperatorService.list_clusters rpc method.list_clustersr#   N)r   r'   r   r(   r)   r  r+   ListClustersResponser-   r   r   r   r    r.   zOperatorService.list_clusters;temporalio.api.operatorservice.v1.ListNexusEndpointsRequest<temporalio.api.operatorservice.v1.ListNexusEndpointsResponsec              	     r!   )z<Invokes the OperatorService.list_nexus_endpoints rpc method.list_nexus_endpointsr#   N)r   r'   r   r(   r)   r  r+   ListNexusEndpointsResponser-   r   r   r   r    r.   z$OperatorService.list_nexus_endpoints=temporalio.api.operatorservice.v1.ListSearchAttributesRequest>temporalio.api.operatorservice.v1.ListSearchAttributesResponsec              	     r!   )z>Invokes the OperatorService.list_search_attributes rpc method.list_search_attributesr#   N)r   r'   r   r(   r)   r  r+   ListSearchAttributesResponser-   r   r   r   r  0  r.   z&OperatorService.list_search_attributes<temporalio.api.operatorservice.v1.RemoveRemoteClusterRequest=temporalio.api.operatorservice.v1.RemoveRemoteClusterResponsec              	     r!   )z=Invokes the OperatorService.remove_remote_cluster rpc method.remove_remote_clusterr#   N)r   r'   r   r(   r)   r  r+   RemoveRemoteClusterResponser-   r   r   r   r  B  r.   z%OperatorService.remove_remote_cluster?temporalio.api.operatorservice.v1.RemoveSearchAttributesRequest@temporalio.api.operatorservice.v1.RemoveSearchAttributesResponsec              	     r!   )z@Invokes the OperatorService.remove_search_attributes rpc method.remove_search_attributesr#   N)r   r'   r   r(   r)   r  r+   RemoveSearchAttributesResponser-   r   r   r   r  T  r.   z(OperatorService.remove_search_attributes<temporalio.api.operatorservice.v1.UpdateNexusEndpointRequest=temporalio.api.operatorservice.v1.UpdateNexusEndpointResponsec              	     r!   )z=Invokes the OperatorService.update_nexus_endpoint rpc method.update_nexus_endpointr#   N)r   r'   r   r(   r)   r  r+   UpdateNexusEndpointResponser-   r   r   r   r  f  r.   z%OperatorService.update_nexus_endpointr  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )r  r  r  r  r   r  r  r  r  r  r  r  r  r  r  r  r  r   r   r   r   r    sf    
r  c                   @  s\  e Zd ZdZdddZdi dfdddZdi dfdddZdi dfdddZdi dfdddZdi dfdd"d#Z	di dfdd&d'Z
di dfdd*d+Zdi dfdd.d/Zdi dfdd2d3Zdi dfdd6d7Zdi dfdd:d;Zdi dfdd>d?Zdi dfddBdCZdi dfddFdGZdi dfddJdKZdi dfd dNdOZdi dfddRdSZdi dfddVdWZdi dfddZd[Zdi dfdd^d_Zdi dfddbdcZdi dfddfdgZdi dfddjdkZdi dfddndoZdi dfd	drdsZdi dfd
dvdwZdi dfddzd{Zdi dfdd~dZ di dfdddZ!di dfdddZ"di dfdddZ#di dfdddZ$di dfdddZ%di dfdddZ&di dfdddZ'di dfdddZ(di dfdddZ)di dfdddZ*di dfdddZ+di dfdddZ,di dfdddZ-di dfdddZ.di dfdddZ/di dfdddZ0di dfdddÄZ1di dfdddǄZ2di dfddd˄Z3di dfd ddτZ4di dfd!ddӄZ5di dfd"ddׄZ6di dfd#ddۄZ7di dfd$dd߄Z8di dfd%ddZ9di dfd&ddZ:di dfd'ddZ;di dfd(ddZ<dS ()  CloudServicezRPC calls for the CloudService.r
   r   c                 C  r   )r   cloudNr   r   r   r   r   r   |  r   zCloudService.__init__FNr   >temporalio.api.cloud.cloudservice.v1.AddNamespaceRegionRequestr   r   r   r   r   r   r   ?temporalio.api.cloud.cloudservice.v1.AddNamespaceRegionResponsec              	     .   | j jd|| jtjjjjj|||dI dH S )z9Invokes the CloudService.add_namespace_region rpc method.add_namespace_regionr#   N)	r   r'   r   r(   r)   r  cloudservicer+   AddNamespaceRegionResponser-   r   r   r   r       z!CloudService.add_namespace_region>temporalio.api.cloud.cloudservice.v1.AddUserGroupMemberRequest?temporalio.api.cloud.cloudservice.v1.AddUserGroupMemberResponsec              	     r  )z:Invokes the CloudService.add_user_group_member rpc method.add_user_group_memberr#   N)	r   r'   r   r(   r)   r  r  r+   AddUserGroupMemberResponser-   r   r   r   r    r  z"CloudService.add_user_group_member8temporalio.api.cloud.cloudservice.v1.CreateApiKeyRequest9temporalio.api.cloud.cloudservice.v1.CreateApiKeyResponsec              	     r  )z3Invokes the CloudService.create_api_key rpc method.create_api_keyr#   N)	r   r'   r   r(   r)   r  r  r+   CreateApiKeyResponser-   r   r   r   r    r  zCloudService.create_api_keyBtemporalio.api.cloud.cloudservice.v1.CreateConnectivityRuleRequestCtemporalio.api.cloud.cloudservice.v1.CreateConnectivityRuleResponsec              	     r  )z=Invokes the CloudService.create_connectivity_rule rpc method.create_connectivity_ruler#   N)	r   r'   r   r(   r)   r  r  r+   CreateConnectivityRuleResponser-   r   r   r   r    r  z%CloudService.create_connectivity_rule;temporalio.api.cloud.cloudservice.v1.CreateNamespaceRequest<temporalio.api.cloud.cloudservice.v1.CreateNamespaceResponsec              	     r  )z5Invokes the CloudService.create_namespace rpc method.create_namespacer#   N)	r   r'   r   r(   r)   r  r  r+   CreateNamespaceResponser-   r   r   r   r    r  zCloudService.create_namespaceEtemporalio.api.cloud.cloudservice.v1.CreateNamespaceExportSinkRequestFtemporalio.api.cloud.cloudservice.v1.CreateNamespaceExportSinkResponsec              	     r  )zAInvokes the CloudService.create_namespace_export_sink rpc method.create_namespace_export_sinkr#   N)	r   r'   r   r(   r)   r  r  r+   !CreateNamespaceExportSinkResponser-   r   r   r   r    r  z)CloudService.create_namespace_export_sink?temporalio.api.cloud.cloudservice.v1.CreateNexusEndpointRequest@temporalio.api.cloud.cloudservice.v1.CreateNexusEndpointResponsec              	     r  )z:Invokes the CloudService.create_nexus_endpoint rpc method.r  r#   N)	r   r'   r   r(   r)   r  r  r+   r  r-   r   r   r   r    r  z"CloudService.create_nexus_endpoint@temporalio.api.cloud.cloudservice.v1.CreateServiceAccountRequestAtemporalio.api.cloud.cloudservice.v1.CreateServiceAccountResponsec              	     r  )z;Invokes the CloudService.create_service_account rpc method.create_service_accountr#   N)	r   r'   r   r(   r)   r  r  r+   CreateServiceAccountResponser-   r   r   r   r    r  z#CloudService.create_service_account6temporalio.api.cloud.cloudservice.v1.CreateUserRequest7temporalio.api.cloud.cloudservice.v1.CreateUserResponsec              	     r  )z0Invokes the CloudService.create_user rpc method.create_userr#   N)	r   r'   r   r(   r)   r  r  r+   CreateUserResponser-   r   r   r   r    r  zCloudService.create_user;temporalio.api.cloud.cloudservice.v1.CreateUserGroupRequest<temporalio.api.cloud.cloudservice.v1.CreateUserGroupResponsec              	     r  )z6Invokes the CloudService.create_user_group rpc method.create_user_groupr#   N)	r   r'   r   r(   r)   r  r  r+   CreateUserGroupResponser-   r   r   r   r  #  r  zCloudService.create_user_group8temporalio.api.cloud.cloudservice.v1.DeleteApiKeyRequest9temporalio.api.cloud.cloudservice.v1.DeleteApiKeyResponsec              	     r  )z3Invokes the CloudService.delete_api_key rpc method.delete_api_keyr#   N)	r   r'   r   r(   r)   r  r  r+   DeleteApiKeyResponser-   r   r   r   r   5  r  zCloudService.delete_api_keyBtemporalio.api.cloud.cloudservice.v1.DeleteConnectivityRuleRequestCtemporalio.api.cloud.cloudservice.v1.DeleteConnectivityRuleResponsec              	     r  )z=Invokes the CloudService.delete_connectivity_rule rpc method.delete_connectivity_ruler#   N)	r   r'   r   r(   r)   r  r  r+   DeleteConnectivityRuleResponser-   r   r   r   r  G  r  z%CloudService.delete_connectivity_rule;temporalio.api.cloud.cloudservice.v1.DeleteNamespaceRequest<temporalio.api.cloud.cloudservice.v1.DeleteNamespaceResponsec              	     r  )z5Invokes the CloudService.delete_namespace rpc method.r  r#   N)	r   r'   r   r(   r)   r  r  r+   r  r-   r   r   r   r  Y  r  zCloudService.delete_namespaceEtemporalio.api.cloud.cloudservice.v1.DeleteNamespaceExportSinkRequestFtemporalio.api.cloud.cloudservice.v1.DeleteNamespaceExportSinkResponsec              	     r  )zAInvokes the CloudService.delete_namespace_export_sink rpc method.delete_namespace_export_sinkr#   N)	r   r'   r   r(   r)   r  r  r+   !DeleteNamespaceExportSinkResponser-   r   r   r   r
  k  r  z)CloudService.delete_namespace_export_sinkAtemporalio.api.cloud.cloudservice.v1.DeleteNamespaceRegionRequestBtemporalio.api.cloud.cloudservice.v1.DeleteNamespaceRegionResponsec              	     r  )z<Invokes the CloudService.delete_namespace_region rpc method.delete_namespace_regionr#   N)	r   r'   r   r(   r)   r  r  r+   DeleteNamespaceRegionResponser-   r   r   r   r  }  r  z$CloudService.delete_namespace_region?temporalio.api.cloud.cloudservice.v1.DeleteNexusEndpointRequest@temporalio.api.cloud.cloudservice.v1.DeleteNexusEndpointResponsec              	     r  )z:Invokes the CloudService.delete_nexus_endpoint rpc method.r  r#   N)	r   r'   r   r(   r)   r  r  r+   r  r-   r   r   r   r    r  z"CloudService.delete_nexus_endpoint@temporalio.api.cloud.cloudservice.v1.DeleteServiceAccountRequestAtemporalio.api.cloud.cloudservice.v1.DeleteServiceAccountResponsec              	     r  )z;Invokes the CloudService.delete_service_account rpc method.delete_service_accountr#   N)	r   r'   r   r(   r)   r  r  r+   DeleteServiceAccountResponser-   r   r   r   r    r  z#CloudService.delete_service_account6temporalio.api.cloud.cloudservice.v1.DeleteUserRequest7temporalio.api.cloud.cloudservice.v1.DeleteUserResponsec              	     r  )z0Invokes the CloudService.delete_user rpc method.delete_userr#   N)	r   r'   r   r(   r)   r  r  r+   DeleteUserResponser-   r   r   r   r    r  zCloudService.delete_user;temporalio.api.cloud.cloudservice.v1.DeleteUserGroupRequest<temporalio.api.cloud.cloudservice.v1.DeleteUserGroupResponsec              	     r  )z6Invokes the CloudService.delete_user_group rpc method.delete_user_groupr#   N)	r   r'   r   r(   r)   r  r  r+   DeleteUserGroupResponser-   r   r   r   r    r  zCloudService.delete_user_groupCtemporalio.api.cloud.cloudservice.v1.FailoverNamespaceRegionRequestDtemporalio.api.cloud.cloudservice.v1.FailoverNamespaceRegionResponsec              	     r  )z>Invokes the CloudService.failover_namespace_region rpc method.failover_namespace_regionr#   N)	r   r'   r   r(   r)   r  r  r+   FailoverNamespaceRegionResponser-   r   r   r   r     r  z&CloudService.failover_namespace_region6temporalio.api.cloud.cloudservice.v1.GetAccountRequest7temporalio.api.cloud.cloudservice.v1.GetAccountResponsec              	     r  )z0Invokes the CloudService.get_account rpc method.get_accountr#   N)	r   r'   r   r(   r)   r  r  r+   GetAccountResponser-   r   r   r   r$    r  zCloudService.get_account5temporalio.api.cloud.cloudservice.v1.GetApiKeyRequest6temporalio.api.cloud.cloudservice.v1.GetApiKeyResponsec              	     r  )z0Invokes the CloudService.get_api_key rpc method.get_api_keyr#   N)	r   r'   r   r(   r)   r  r  r+   GetApiKeyResponser-   r   r   r   r(    r  zCloudService.get_api_key6temporalio.api.cloud.cloudservice.v1.GetApiKeysRequest7temporalio.api.cloud.cloudservice.v1.GetApiKeysResponsec              	     r  )z1Invokes the CloudService.get_api_keys rpc method.get_api_keysr#   N)	r   r'   r   r(   r)   r  r  r+   GetApiKeysResponser-   r   r   r   r,  	  r  zCloudService.get_api_keys=temporalio.api.cloud.cloudservice.v1.GetAsyncOperationRequest>temporalio.api.cloud.cloudservice.v1.GetAsyncOperationResponsec              	     r  )z8Invokes the CloudService.get_async_operation rpc method.get_async_operationr#   N)	r   r'   r   r(   r)   r  r  r+   GetAsyncOperationResponser-   r   r   r   r0  	  r  z CloudService.get_async_operation?temporalio.api.cloud.cloudservice.v1.GetConnectivityRuleRequest@temporalio.api.cloud.cloudservice.v1.GetConnectivityRuleResponsec              	     r  )z:Invokes the CloudService.get_connectivity_rule rpc method.get_connectivity_ruler#   N)	r   r'   r   r(   r)   r  r  r+   GetConnectivityRuleResponser-   r   r   r   r4  1	  r  z"CloudService.get_connectivity_rule@temporalio.api.cloud.cloudservice.v1.GetConnectivityRulesRequestAtemporalio.api.cloud.cloudservice.v1.GetConnectivityRulesResponsec              	     r  )z;Invokes the CloudService.get_connectivity_rules rpc method.get_connectivity_rulesr#   N)	r   r'   r   r(   r)   r  r  r+   GetConnectivityRulesResponser-   r   r   r   r8  C	  r  z#CloudService.get_connectivity_rules8temporalio.api.cloud.cloudservice.v1.GetNamespaceRequest9temporalio.api.cloud.cloudservice.v1.GetNamespaceResponsec              	     r  )z2Invokes the CloudService.get_namespace rpc method.get_namespacer#   N)	r   r'   r   r(   r)   r  r  r+   GetNamespaceResponser-   r   r   r   r<  U	  r  zCloudService.get_namespaceBtemporalio.api.cloud.cloudservice.v1.GetNamespaceExportSinkRequestCtemporalio.api.cloud.cloudservice.v1.GetNamespaceExportSinkResponsec              	     r  )z>Invokes the CloudService.get_namespace_export_sink rpc method.get_namespace_export_sinkr#   N)	r   r'   r   r(   r)   r  r  r+   GetNamespaceExportSinkResponser-   r   r   r   r@  g	  r  z&CloudService.get_namespace_export_sinkCtemporalio.api.cloud.cloudservice.v1.GetNamespaceExportSinksRequestDtemporalio.api.cloud.cloudservice.v1.GetNamespaceExportSinksResponsec              	     r  )z?Invokes the CloudService.get_namespace_export_sinks rpc method.get_namespace_export_sinksr#   N)	r   r'   r   r(   r)   r  r  r+   GetNamespaceExportSinksResponser-   r   r   r   rD  y	  r  z'CloudService.get_namespace_export_sinks9temporalio.api.cloud.cloudservice.v1.GetNamespacesRequest:temporalio.api.cloud.cloudservice.v1.GetNamespacesResponsec              	     r  )z3Invokes the CloudService.get_namespaces rpc method.get_namespacesr#   N)	r   r'   r   r(   r)   r  r  r+   GetNamespacesResponser-   r   r   r   rH  	  r  zCloudService.get_namespaces<temporalio.api.cloud.cloudservice.v1.GetNexusEndpointRequest=temporalio.api.cloud.cloudservice.v1.GetNexusEndpointResponsec              	     r  )z7Invokes the CloudService.get_nexus_endpoint rpc method.r  r#   N)	r   r'   r   r(   r)   r  r  r+   r  r-   r   r   r   r  	  r  zCloudService.get_nexus_endpoint=temporalio.api.cloud.cloudservice.v1.GetNexusEndpointsRequest>temporalio.api.cloud.cloudservice.v1.GetNexusEndpointsResponsec              	     r  )z8Invokes the CloudService.get_nexus_endpoints rpc method.get_nexus_endpointsr#   N)	r   r'   r   r(   r)   r  r  r+   GetNexusEndpointsResponser-   r   r   r   rN  	  r  z CloudService.get_nexus_endpoints5temporalio.api.cloud.cloudservice.v1.GetRegionRequest6temporalio.api.cloud.cloudservice.v1.GetRegionResponsec              	     r  )z/Invokes the CloudService.get_region rpc method.
get_regionr#   N)	r   r'   r   r(   r)   r  r  r+   GetRegionResponser-   r   r   r   rR  	  r  zCloudService.get_region6temporalio.api.cloud.cloudservice.v1.GetRegionsRequest7temporalio.api.cloud.cloudservice.v1.GetRegionsResponsec              	     r  )z0Invokes the CloudService.get_regions rpc method.get_regionsr#   N)	r   r'   r   r(   r)   r  r  r+   GetRegionsResponser-   r   r   r   rV  	  r  zCloudService.get_regions=temporalio.api.cloud.cloudservice.v1.GetServiceAccountRequest>temporalio.api.cloud.cloudservice.v1.GetServiceAccountResponsec              	     r  )z8Invokes the CloudService.get_service_account rpc method.get_service_accountr#   N)	r   r'   r   r(   r)   r  r  r+   GetServiceAccountResponser-   r   r   r   rZ  	  r  z CloudService.get_service_account>temporalio.api.cloud.cloudservice.v1.GetServiceAccountsRequest?temporalio.api.cloud.cloudservice.v1.GetServiceAccountsResponsec              	     r  )z9Invokes the CloudService.get_service_accounts rpc method.get_service_accountsr#   N)	r   r'   r   r(   r)   r  r  r+   GetServiceAccountsResponser-   r   r   r   r^  	  r  z!CloudService.get_service_accounts4temporalio.api.cloud.cloudservice.v1.GetUsageRequest5temporalio.api.cloud.cloudservice.v1.GetUsageResponsec              	     r  )z.Invokes the CloudService.get_usage rpc method.	get_usager#   N)	r   r'   r   r(   r)   r  r  r+   GetUsageResponser-   r   r   r   rb  	
  r  zCloudService.get_usage3temporalio.api.cloud.cloudservice.v1.GetUserRequest4temporalio.api.cloud.cloudservice.v1.GetUserResponsec              	     r  )z-Invokes the CloudService.get_user rpc method.get_userr#   N)	r   r'   r   r(   r)   r  r  r+   GetUserResponser-   r   r   r   rf  
  r  zCloudService.get_user8temporalio.api.cloud.cloudservice.v1.GetUserGroupRequest9temporalio.api.cloud.cloudservice.v1.GetUserGroupResponsec              	     r  )z3Invokes the CloudService.get_user_group rpc method.get_user_groupr#   N)	r   r'   r   r(   r)   r  r  r+   GetUserGroupResponser-   r   r   r   rj  -
  r  zCloudService.get_user_group?temporalio.api.cloud.cloudservice.v1.GetUserGroupMembersRequest@temporalio.api.cloud.cloudservice.v1.GetUserGroupMembersResponsec              	     r  )z;Invokes the CloudService.get_user_group_members rpc method.get_user_group_membersr#   N)	r   r'   r   r(   r)   r  r  r+   GetUserGroupMembersResponser-   r   r   r   rn  ?
  r  z#CloudService.get_user_group_members9temporalio.api.cloud.cloudservice.v1.GetUserGroupsRequest:temporalio.api.cloud.cloudservice.v1.GetUserGroupsResponsec              	     r  )z4Invokes the CloudService.get_user_groups rpc method.get_user_groupsr#   N)	r   r'   r   r(   r)   r  r  r+   GetUserGroupsResponser-   r   r   r   rr  Q
  r  zCloudService.get_user_groups4temporalio.api.cloud.cloudservice.v1.GetUsersRequest5temporalio.api.cloud.cloudservice.v1.GetUsersResponsec              	     r  )z.Invokes the CloudService.get_users rpc method.	get_usersr#   N)	r   r'   r   r(   r)   r  r  r+   GetUsersResponser-   r   r   r   rv  c
  r  zCloudService.get_usersAtemporalio.api.cloud.cloudservice.v1.RemoveUserGroupMemberRequestBtemporalio.api.cloud.cloudservice.v1.RemoveUserGroupMemberResponsec              	     r  )z=Invokes the CloudService.remove_user_group_member rpc method.remove_user_group_memberr#   N)	r   r'   r   r(   r)   r  r  r+   RemoveUserGroupMemberResponser-   r   r   r   rz  u
  r  z%CloudService.remove_user_group_memberGtemporalio.api.cloud.cloudservice.v1.RenameCustomSearchAttributeRequestHtemporalio.api.cloud.cloudservice.v1.RenameCustomSearchAttributeResponsec              	     r  )zCInvokes the CloudService.rename_custom_search_attribute rpc method.rename_custom_search_attributer#   N)	r   r'   r   r(   r)   r  r  r+   #RenameCustomSearchAttributeResponser-   r   r   r   r~  
  r  z+CloudService.rename_custom_search_attributeGtemporalio.api.cloud.cloudservice.v1.SetUserGroupNamespaceAccessRequestHtemporalio.api.cloud.cloudservice.v1.SetUserGroupNamespaceAccessResponsec              	     r  )zDInvokes the CloudService.set_user_group_namespace_access rpc method.set_user_group_namespace_accessr#   N)	r   r'   r   r(   r)   r  r  r+   #SetUserGroupNamespaceAccessResponser-   r   r   r   r  
  r  z,CloudService.set_user_group_namespace_accessBtemporalio.api.cloud.cloudservice.v1.SetUserNamespaceAccessRequestCtemporalio.api.cloud.cloudservice.v1.SetUserNamespaceAccessResponsec              	     r  )z>Invokes the CloudService.set_user_namespace_access rpc method.set_user_namespace_accessr#   N)	r   r'   r   r(   r)   r  r  r+   SetUserNamespaceAccessResponser-   r   r   r   r  
  r  z&CloudService.set_user_namespace_access9temporalio.api.cloud.cloudservice.v1.UpdateAccountRequest:temporalio.api.cloud.cloudservice.v1.UpdateAccountResponsec              	     r  )z3Invokes the CloudService.update_account rpc method.update_accountr#   N)	r   r'   r   r(   r)   r  r  r+   UpdateAccountResponser-   r   r   r   r  
  r  zCloudService.update_account8temporalio.api.cloud.cloudservice.v1.UpdateApiKeyRequest9temporalio.api.cloud.cloudservice.v1.UpdateApiKeyResponsec              	     r  )z3Invokes the CloudService.update_api_key rpc method.update_api_keyr#   N)	r   r'   r   r(   r)   r  r  r+   UpdateApiKeyResponser-   r   r   r   r  
  r  zCloudService.update_api_key;temporalio.api.cloud.cloudservice.v1.UpdateNamespaceRequest<temporalio.api.cloud.cloudservice.v1.UpdateNamespaceResponsec              	     r  )z5Invokes the CloudService.update_namespace rpc method.ry  r#   N)	r   r'   r   r(   r)   r  r  r+   rz  r-   r   r   r   ry  
  r  zCloudService.update_namespaceEtemporalio.api.cloud.cloudservice.v1.UpdateNamespaceExportSinkRequestFtemporalio.api.cloud.cloudservice.v1.UpdateNamespaceExportSinkResponsec              	     r  )zAInvokes the CloudService.update_namespace_export_sink rpc method.update_namespace_export_sinkr#   N)	r   r'   r   r(   r)   r  r  r+   !UpdateNamespaceExportSinkResponser-   r   r   r   r  
  r  z)CloudService.update_namespace_export_sink?temporalio.api.cloud.cloudservice.v1.UpdateNamespaceTagsRequest@temporalio.api.cloud.cloudservice.v1.UpdateNamespaceTagsResponsec              	     r  )z:Invokes the CloudService.update_namespace_tags rpc method.update_namespace_tagsr#   N)	r   r'   r   r(   r)   r  r  r+   UpdateNamespaceTagsResponser-   r   r   r   r    r  z"CloudService.update_namespace_tags?temporalio.api.cloud.cloudservice.v1.UpdateNexusEndpointRequest@temporalio.api.cloud.cloudservice.v1.UpdateNexusEndpointResponsec              	     r  )z:Invokes the CloudService.update_nexus_endpoint rpc method.r  r#   N)	r   r'   r   r(   r)   r  r  r+   r  r-   r   r   r   r    r  z"CloudService.update_nexus_endpoint@temporalio.api.cloud.cloudservice.v1.UpdateServiceAccountRequestAtemporalio.api.cloud.cloudservice.v1.UpdateServiceAccountResponsec              	     r  )z;Invokes the CloudService.update_service_account rpc method.update_service_accountr#   N)	r   r'   r   r(   r)   r  r  r+   UpdateServiceAccountResponser-   r   r   r   r  )  r  z#CloudService.update_service_account6temporalio.api.cloud.cloudservice.v1.UpdateUserRequest7temporalio.api.cloud.cloudservice.v1.UpdateUserResponsec              	     r  )z0Invokes the CloudService.update_user rpc method.update_userr#   N)	r   r'   r   r(   r)   r  r  r+   UpdateUserResponser-   r   r   r   r  ;  r  zCloudService.update_user;temporalio.api.cloud.cloudservice.v1.UpdateUserGroupRequest<temporalio.api.cloud.cloudservice.v1.UpdateUserGroupResponsec              	     r  )z6Invokes the CloudService.update_user_group rpc method.update_user_groupr#   N)	r   r'   r   r(   r)   r  r  r+   UpdateUserGroupResponser-   r   r   r   r  M  r  zCloudService.update_user_groupGtemporalio.api.cloud.cloudservice.v1.ValidateNamespaceExportSinkRequestHtemporalio.api.cloud.cloudservice.v1.ValidateNamespaceExportSinkResponsec              	     r  )zCInvokes the CloudService.validate_namespace_export_sink rpc method.validate_namespace_export_sinkr#   N)	r   r'   r   r(   r)   r  r  r+   #ValidateNamespaceExportSinkResponser-   r   r   r   r  _  r  z+CloudService.validate_namespace_export_sinkr  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r	  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r"  r   r   r   r   r   r   r   r#  )
r   r&  r   r   r   r   r   r   r   r'  )
r   r*  r   r   r   r   r   r   r   r+  )
r   r.  r   r   r   r   r   r   r   r/  )
r   r2  r   r   r   r   r   r   r   r3  )
r   r6  r   r   r   r   r   r   r   r7  )
r   r:  r   r   r   r   r   r   r   r;  )
r   r>  r   r   r   r   r   r   r   r?  )
r   rB  r   r   r   r   r   r   r   rC  )
r   rF  r   r   r   r   r   r   r   rG  )
r   rJ  r   r   r   r   r   r   r   rK  )
r   rL  r   r   r   r   r   r   r   rM  )
r   rP  r   r   r   r   r   r   r   rQ  )
r   rT  r   r   r   r   r   r   r   rU  )
r   rX  r   r   r   r   r   r   r   rY  )
r   r\  r   r   r   r   r   r   r   r]  )
r   r`  r   r   r   r   r   r   r   ra  )
r   rd  r   r   r   r   r   r   r   re  )
r   rh  r   r   r   r   r   r   r   ri  )
r   rl  r   r   r   r   r   r   r   rm  )
r   rp  r   r   r   r   r   r   r   rq  )
r   rt  r   r   r   r   r   r   r   ru  )
r   rx  r   r   r   r   r   r   r   ry  )
r   r|  r   r   r   r   r   r   r   r}  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )=r  r  r  r  r   r  r  r  r  r  r  r  r  r  r  r   r  r  r
  r  r  r  r  r  r   r$  r(  r,  r0  r4  r8  r<  r@  rD  rH  r  rN  rR  rV  rZ  r^  rb  rf  rj  rn  rr  rv  rz  r~  r  r  r  r  ry  r  r  r  r  r  r  r  r   r   r   r   r  y  s   
r  c                   @  s   e Zd ZdZd%ddZdi dfd&ddZdi dfd'ddZdi dfd(ddZdi dfd)ddZdi dfd*d!d"Z	di dfd(d#d$Z
dS )+TestServicezRPC calls for the TestService.r
   r   c                 C  r   )r   testNr   r   r   r   r   r   u  r   zTestService.__init__FNr   google.protobuf.empty_pb2.Emptyr   r   r   r   r   r   r   4temporalio.api.testservice.v1.GetCurrentTimeResponsec              	     r!   )z4Invokes the TestService.get_current_time rpc method.get_current_timer#   N)r   r'   r   r(   r)   testservicer+   GetCurrentTimeResponser-   r   r   r   r  z  r.   zTestService.get_current_time5temporalio.api.testservice.v1.LockTimeSkippingRequest6temporalio.api.testservice.v1.LockTimeSkippingResponsec              	     r!   )z6Invokes the TestService.lock_time_skipping rpc method.lock_time_skippingr#   N)r   r'   r   r(   r)   r  r+   LockTimeSkippingResponser-   r   r   r   r    r.   zTestService.lock_time_skipping*temporalio.api.testservice.v1.SleepRequest+temporalio.api.testservice.v1.SleepResponsec              	     r!   )z)Invokes the TestService.sleep rpc method.sleepr#   Nr   r'   r   r(   r)   r  r+   SleepResponser-   r   r   r   r    r.   zTestService.sleep/temporalio.api.testservice.v1.SleepUntilRequestc              	     r!   )z/Invokes the TestService.sleep_until rpc method.sleep_untilr#   Nr  r-   r   r   r   r    r.   zTestService.sleep_until7temporalio.api.testservice.v1.UnlockTimeSkippingRequest8temporalio.api.testservice.v1.UnlockTimeSkippingResponsec              	     r!   )z8Invokes the TestService.unlock_time_skipping rpc method.unlock_time_skippingr#   N)r   r'   r   r(   r)   r  r+   UnlockTimeSkippingResponser-   r   r   r   r    r.   z TestService.unlock_time_skippingc              	     r!   )zCInvokes the TestService.unlock_time_skipping_with_sleep rpc method.unlock_time_skipping_with_sleepr#   Nr  r-   r   r   r   r    r.   z+TestService.unlock_time_skipping_with_sleepr  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )
r   r  r   r   r   r   r   r   r   r  )r  r  r  r  r   r  r  r  r  r  r  r   r   r   r   r  r  s6    
r  c                   @  s,   e Zd ZdZdddZdi dfdddZdS )HealthServicez RPC calls for the HealthService.r
   r   c                 C  r   )r   healthNr   r   r   r   r   r     r   zHealthService.__init__FNr   4temporalio.bridge.proto.health.v1.HealthCheckRequestr   r   r   r   r   r   r   5temporalio.bridge.proto.health.v1.HealthCheckResponsec              	     r  )z+Invokes the HealthService.check rpc method.checkr#   N)	r   r'   r   r(   bridgeprotor  r+   HealthCheckResponser-   r   r   r   r    r  zHealthService.checkr  )
r   r  r   r   r   r   r   r   r   r  )r  r  r  r  r   r  r   r   r   r   r    s    
r  )r  
__future__r   datetimer   typingr   r   r   r   google.protobuf.empty_pb2google$temporalio.api.cloud.cloudservice.v1r(   !temporalio.api.operatorservice.v1temporalio.api.testservice.v1!temporalio.api.workflowservice.v1!temporalio.bridge.proto.health.v1temporalio.servicer   r	   r  r  r  r  r   r   r   r   <module>   sN                 b        u