VSrSSKJr SSKJr SSKJr "SS\R5r g)z1Generated client library for dataproc version v1.)absolute_import)base_api)dataproc_v1_messagesc6^\rSrSrSr\rSrSrSr S/r Sr Sr S r S rSrSrS rS0U4S jjr"S S\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS\R(5r"SS \R(5r"S!S"\R(5r"S#S$\R(5r "S%S&\R(5r!"S'S(\R(5r""S)S*\R(5r#"S+S,\R(5r$"S-S.\R(5r%S/r&U=r'$)1 DataprocV1 z9Generated client library for service dataproc version v1.z https://dataproc.googleapis.com/z%https://dataproc.mtls.googleapis.com/dataprocz.https://www.googleapis.com/auth/cloud-platformv1 CLIENT_ID CLIENT_SECRETzgoogle-cloud-sdkNc L>U=(d URn[[U]XX4UXgUU U U S9 UR U5UlUR U5UlURU5Ul URU5Ul URU5Ul URU5UlUR!U5UlUR%U5UlUR)U5UlUR-U5UlUR1U5UlUR5U5UlUR9U5UlUR=U5UlURAU5Ul!UREU5Ul#URIU5Ul%g)zCreate a new dataproc handle.) credentialsget_credentialshttpmodel log_request log_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)&BASE_URLsuperr__init__+ProjectsLocationsAutoscalingPoliciesService&projects_locations_autoscalingPolicies0ProjectsLocationsBatchesSparkApplicationsService,projects_locations_batches_sparkApplicationsProjectsLocationsBatchesServiceprojects_locations_batches"ProjectsLocationsOperationsServiceprojects_locations_operations(ProjectsLocationsSessionTemplatesService#projects_locations_sessionTemplates1ProjectsLocationsSessionsSparkApplicationsService-projects_locations_sessions_sparkApplications ProjectsLocationsSessionsServiceprojects_locations_sessions)ProjectsLocationsWorkflowTemplatesService$projects_locations_workflowTemplatesProjectsLocationsServiceprojects_locations)ProjectsRegionsAutoscalingPoliciesService$projects_regions_autoscalingPolicies(ProjectsRegionsClustersNodeGroupsService$projects_regions_clusters_nodeGroupsProjectsRegionsClustersServiceprojects_regions_clustersProjectsRegionsJobsServiceprojects_regions_jobs ProjectsRegionsOperationsServiceprojects_regions_operations'ProjectsRegionsWorkflowTemplatesService"projects_regions_workflowTemplatesProjectsRegionsServiceprojects_regionsProjectsServiceprojects) selfurlrrrrrrrrrr __class__s Klib/googlecloudsdk/generated_clients/apis/dataproc/v1/dataproc_v1_client.pyrDataprocV1.__init__s  C *d$ '%)3 7+%-372b2bcg2hD/8<8m8mnr8sD5&*&J&J4&PD#)-)P)PQU)VD&/3/\/\]a/bD,9=9o9opt9uD6'+'L'LT'RD$040^0^_c0dD-";;DAD040^0^_c0dD-040]0]^b0cD-%)%H%H%ND"!%!@!@!FD'+'L'LT'RD$.2.Z.Z[_.`D+ 77=D((.DMc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSrU=r$)6DataprocV1.ProjectsLocationsAutoscalingPoliciesService<zFService class for the projects_locations_autoscalingPolicies resource.rcN>[[RU]U5 0UlgN)rrrr_upload_configsr=clientr?s r@r?DataprocV1.ProjectsLocationsAutoscalingPoliciesService.__init__As# J B BDRSYZ drBcDURS5nURX1US9$)zCreates new autoscaling policy. Args: request: (DataprocProjectsLocationsAutoscalingPoliciesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AutoscalingPolicy) The response message. Create global_paramsGetMethodConfig _RunMethodr=requestrOconfigs r@rM=DataprocV1.ProjectsLocationsAutoscalingPoliciesService.CreateF/##H-f __ 88rBcB[R"SSSS/S//SSSSS S 9 $) NDv1/projects/{projectsId}/locations/{locationsId}/autoscalingPoliciesPOSTz6dataproc.projects.locations.autoscalingPolicies.createparent v1/{+parent}/autoscalingPoliciesautoscalingPolicy9DataprocProjectsLocationsAutoscalingPoliciesCreateRequestAutoscalingPolicyF flat_path http_method method_idordered_params path_params query_params relative_path request_fieldrequest_type_nameresponse_type_namesupports_downloadr ApiMethodInforBr@?DataprocV1.ProjectsLocationsAutoscalingPoliciesService.Ss48#9#9XJ zJ8)U. $rBcDURS5nURX1US9$)aFDeletes an autoscaling policy. It is an error to delete an autoscaling policy that is in use by one or more clusters. Args: request: (DataprocProjectsLocationsAutoscalingPoliciesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. DeleterNrPrSs r@rr=DataprocV1.ProjectsLocationsAutoscalingPoliciesService.DeletearWrBcB[R"SSSS/S//SSSSS S 9 $) N\v1/projects/{projectsId}/locations/{locationsId}/autoscalingPolicies/{autoscalingPoliciesId}DELETEz6dataproc.projects.locations.autoscalingPolicies.deletename v1/{+name}9DataprocProjectsLocationsAutoscalingPoliciesDeleteRequestEmptyFr`rlrnrBr@rorpns48#9#9pJxH"U" $rBcDURS5nURX1US9$)zRetrieves autoscaling policy. Args: request: (DataprocProjectsLocationsAutoscalingPoliciesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AutoscalingPolicy) The response message. GetrNrPrSs r@r}:DataprocV1.ProjectsLocationsAutoscalingPoliciesService.Get|/##E*f __ 88rBcB[R"SSSS/S//SSSSS S 9 $) NruGETz3dataproc.projects.locations.autoscalingPolicies.getrwrxry6DataprocProjectsLocationsAutoscalingPoliciesGetRequestr_Fr`rlrnrBr@rorps4 6 6pGxH"R. !rBcDURS5nURX1US9$)aUGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (DataprocProjectsLocationsAutoscalingPoliciesGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. GetIamPolicyrNrPrSs r@rCDataprocV1.ProjectsLocationsAutoscalingPoliciesService.GetIamPolicy/##N3f __ 88rBcB[R"SSSS/S//SSSSS S 9 $) Nziv1/projects/{projectsId}/locations/{locationsId}/autoscalingPolicies/{autoscalingPoliciesId}:getIamPolicyrZzr_Fr`rlrnrBr@rorps48#9#9pJxH"!-. $rBrHrG__name__ __module__ __qualname____firstlineno____doc___NAMErrM method_configrrr}rrrrr__static_attributes__ __classcell__r?s@r@rrD<sP 4E 8 F 8 F 8 C 8 "L 8 D 8 "L 8 ($ 8 FrBrc^\rSrSrSrSrU4SjrS4SjrS\lS4Sjr S\ lS4S jr S \ lS4S jr S \ lS4S jr S\ lS4Sjr S\ lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS \lS4S!jrS"\lS4S#jrS$\lS4S%jrS&\lS4S'jrS(\lS4S)jrS*\lS4S+jrS,\lS4S-jrS.\lS4S/jrS0\lS4S1jrS2\lS3rU=r $)5;DataprocV1.ProjectsLocationsBatchesSparkApplicationsServiceizLService class for the projects_locations_batches_sparkApplications resource.rcN>[[RU]U5 0UlgrG)rrrrrHrIs r@rDDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.__init__#s# J G GWX^_ drBcDURS5nURX1US9$)a9Obtain high level information corresponding to a single Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationResponse) The response message. AccessrNrPrSs r@rBDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.Access(rWrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzsv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:accessrzDataprocProjectsLocationsBatchesSparkApplicationsAccessRequestAccessSparkApplicationResponseFr`rlrnrBr@roDDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.5s98#9#9HPxHZ)Z; $rBcDURS5nURX1US9$)a@Obtain environment details for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationEnvironmentInfoResponse) The response message. AccessEnvironmentInforNrPrSs r@rQDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.AccessEnvironmentInfoC0##$; 'rBcDURS5nURX1US9$)a.Obtain build data for Native Job. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessNativeBuildInfoRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationNativeBuildInfoResponse) The response message. AccessNativeBuildInforNrPrSs r@rQDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.AccessNativeBuildInfoyrrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:accessNativeBuildInforzKdataproc.projects.locations.batches.sparkApplications.accessNativeBuildInforwr[ v1/{+name}:accessNativeBuildInforyMDataprocProjectsLocationsBatchesSparkApplicationsAccessNativeBuildInfoRequest-AccessSparkApplicationNativeBuildInfoResponseFr`rlrnrBr@rorrrBcDURS5nURX1US9$)a^Obtain data corresponding to a particular Native SQL Query for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessNativeSqlQueryRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationNativeSqlQueryResponse) The response message. AccessNativeSqlQueryrNrPrSs r@rPDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.AccessNativeSqlQuery0##$:;f __ 88rBcF[R"SSSS/S/SS/SSS S S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:accessNativeSqlQueryrzJdataproc.projects.locations.batches.sparkApplications.accessNativeSqlQueryrw executionIdr[v1/{+name}:accessNativeSqlQueryryLDataprocProjectsLocationsBatchesSparkApplicationsAccessNativeSqlQueryRequest,AccessSparkApplicationNativeSqlQueryResponseFr`rlrnrBr@rors<1G1GV^xH#X.7hI 2rBcDURS5nURX1US9$)aObtain Spark Plan Graph for a Spark Application SQL execution. Limits the number of clusters returned as part of the graph to 10000. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessSqlPlanRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationSqlSparkPlanGraphResponse) The response message. AccessSqlPlanrNrPrSs r@rIDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.AccessSqlPlan/##O4f __ 88rBcF[R"SSSS/S/SS/SSS S S S 9 $) Nzzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:accessSqlPlanrzCdataproc.projects.locations.batches.sparkApplications.accessSqlPlanrwrr[v1/{+name}:accessSqlPlanryEDataprocProjectsLocationsBatchesSparkApplicationsAccessSqlPlanRequest/AccessSparkApplicationSqlSparkPlanGraphResponseFr`rlrnrBr@rors<(*@*@OWxH#X.0aL +rBcDURS5nURX1US9$)aKObtain data corresponding to a particular SQL Query for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessSqlQueryRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationSqlQueryResponse) The response message. AccessSqlQueryrNrPrSs r@rJDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.AccessSqlQuery0##$45f __ 88rBcF[R"SSSS/S//SQSSSS S S 9 $) Nz{v1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:accessSqlQueryrzDdataproc.projects.locations.batches.sparkApplications.accessSqlQueryrwdetailsrr[planDescriptionv1/{+name}:accessSqlQueryryFDataprocProjectsLocationsBatchesSparkApplicationsAccessSqlQueryRequest&AccessSparkApplicationSqlQueryResponseFr`rlrnrBr@rors78+A+APXxHL1bC ,rBcDURS5nURX1US9$)aRObtain data corresponding to a spark stage attempt for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessStageAttemptRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationStageAttemptResponse) The response message. AccessStageAttemptrNrPrSs r@rNDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.AccessStageAttemptrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:accessStageAttemptrzHdataproc.projects.locations.batches.sparkApplications.accessStageAttemptrwr[stageAttemptIdstageIdsummaryMetricsMaskv1/{+name}:accessStageAttemptryJDataprocProjectsLocationsBatchesSparkApplicationsAccessStageAttemptRequest*AccessSparkApplicationStageAttemptResponseFr`rlrnrBr@rors7x/E/ET\xHR5fG 0rBcDURS5nURX1US9$)aObtain RDD operation graph for a Spark Application Stage. Limits the number of clusters returned as part of the graph to 10000. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSparkApplicationStageRddOperationGraphResponse) The response message. AccessStageRddGraphrNrPrSs r@rODataprocV1.ProjectsLocationsBatchesSparkApplicationsService.AccessStageRddGraph0##$9:f __ 88rBcF[R"SSSS/S/SS/SSS S S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:accessStageRddGraphrzIdataproc.projects.locations.batches.sparkApplications.accessStageRddGraphrwr[rv1/{+name}:accessStageRddGraphryKDataprocProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphRequest4AccessSparkApplicationStageRddOperationGraphResponseFr`rlrnrBr@ror s<0F0FU]xH *6gQ 1rBcDURS5nURX1US9$)aFObtain high level information and list of Spark Applications corresponding to a batch. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationsResponse) The response message. SearchrNrPrSs r@rBDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchrWrBcF[R"SSSS/S//SQSSSS S S 9 $) Nz]v1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications:searchrzDataprocProjectsLocationsBatchesSparkApplicationsSearchRequestSearchSparkApplicationsResponseFr`rlrnrBr@ror(s48#9#9qP zJu=Z< $rBcDURS5nURX1US9$)aUObtain executor summary with respect to a spark stage attempt. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationExecutorStageSummaryResponse) The response message. SearchExecutorStageSummaryrNrPrSs r@rVDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchExecutorStageSummary60##$@Af __ 88rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchExecutorStageSummaryrzPdataproc.projects.locations.batches.sparkApplications.searchExecutorStageSummaryrwrrr[rr%v1/{+name}:searchExecutorStageSummaryryRDataprocProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryRequest2SearchSparkApplicationExecutorStageSummaryResponseFr`rlrnrBr@rorCs7x7M7M\dxHU=nO 8rBcDURS5nURX1US9$)a@Obtain data corresponding to executors for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchExecutorsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationExecutorsResponse) The response message. SearchExecutorsrNrPrSs r@r%KDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchExecutorsQ0##$56f __ 88rBcF[R"SSSS/S//SQSSSS S S 9 $) Nz|v1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchExecutorsrzEdataproc.projects.locations.batches.sparkApplications.searchExecutorsrwexecutorStatusrrr[v1/{+name}:searchExecutorsryGDataprocProjectsLocationsBatchesSparkApplicationsSearchExecutorsRequest'SearchSparkApplicationExecutorsResponseFr`rlrnrBr@ror^s7H,B,BQYxHJ2cD -rBcDURS5nURX1US9$)a6Obtain list of spark jobs corresponding to a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchJobsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationJobsResponse) The response message. SearchJobsrNrPrSs r@r/FDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchJobsl/##L1f __ 88rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzwv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchJobsrz@dataproc.projects.locations.batches.sparkApplications.searchJobsrw) jobStatusrrr[v1/{+name}:searchJobsryBDataprocProjectsLocationsBatchesSparkApplicationsSearchJobsRequest"SearchSparkApplicationJobsResponseFr`rlrnrBr@rorys7x'='=LTxHE-^? (rBcDURS5nURX1US9$)aWObtain data corresponding to Native SQL Queries for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchNativeSqlQueriesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationNativeSqlQueriesResponse) The response message. SearchNativeSqlQueriesrNrPrSs r@r8RDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchNativeSqlQueries0##$<=f __ 88rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchNativeSqlQueriesrzLdataproc.projects.locations.batches.sparkApplications.searchNativeSqlQueriesrwrrr[!v1/{+name}:searchNativeSqlQueriesryNDataprocProjectsLocationsBatchesSparkApplicationsSearchNativeSqlQueriesRequest.SearchSparkApplicationNativeSqlQueriesResponseFr`rlrnrBr@rors783I3IX`xH89jK 4rBcDURS5nURX1US9$)aDObtain data corresponding to SQL Queries for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationSqlQueriesResponse) The response message. SearchSqlQueriesrNrPrSs r@rALDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchSqlQueries0##$67f __ 88rBcF[R"SSSS/S//SQSSSS S S 9 $) Nz}v1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchSqlQueriesrzFdataproc.projects.locations.batches.sparkApplications.searchSqlQueriesrw)rrrr[rv1/{+name}:searchSqlQueriesryHDataprocProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesRequest(SearchSparkApplicationSqlQueriesResponseFr`rlrnrBr@rors7X-C-CRZxHV3dE .rBcDURS5nURX1US9$)afObtain data corresponding to tasks for a spark stage attempt for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationStageAttemptTasksResponse) The response message. SearchStageAttemptTasksrNrPrSs r@rISDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchStageAttemptTasks0##$=>f __ 88rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchStageAttemptTasksrzMdataproc.projects.locations.batches.sparkApplications.searchStageAttemptTasksrwrrr[ sortRuntimerr taskStatus"v1/{+name}:searchStageAttemptTasksryODataprocProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksRequest/SearchSparkApplicationStageAttemptTasksResponseFr`rlrnrBr@rors7H4J4JYaxHr:kL 5rBcDURS5nURX1US9$)aUObtain data corresponding to a spark stage attempts for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationStageAttemptsResponse) The response message. SearchStageAttemptsrNrPrSs r@rTODataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchStageAttemptsr rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchStageAttemptsrzIdataproc.projects.locations.batches.sparkApplications.searchStageAttemptsrwrrr[rrv1/{+name}:searchStageAttemptsryKDataprocProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsRequest+SearchSparkApplicationStageAttemptsResponseFr`rlrnrBr@rors70F0FU]xHY6gH 1rBcDURS5nURX1US9$)a7Obtain data corresponding to stages for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSearchStagesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSparkApplicationStagesResponse) The response message. SearchStagesrNrPrSs r@r\HDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SearchStagesrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzyv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:searchStagesrzBdataproc.projects.locations.batches.sparkApplications.searchStagesrw)rrr[ stageStatusrv1/{+name}:searchStagesryDDataprocProjectsLocationsBatchesSparkApplicationsSearchStagesRequest$SearchSparkApplicationStagesResponseFr`rlrnrBr@rors7)?)?NVxH]/`A *rBcDURS5nURX1US9$)aBObtain summary of Executor Summary for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSparkApplicationExecutorsResponse) The response message. SummarizeExecutorsrNrPrSs r@rdNDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SummarizeExecutorsrrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:summarizeExecutorsrzHdataproc.projects.locations.batches.sparkApplications.summarizeExecutorsrwr[v1/{+name}:summarizeExecutorsryJDataprocProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsRequest*SummarizeSparkApplicationExecutorsResponseFr`rlrnrBr@rors9x/E/ET\xHZ5fG 0rBcDURS5nURX1US9$)a,Obtain summary of Jobs for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSummarizeJobsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSparkApplicationJobsResponse) The response message. SummarizeJobsrNrPrSs r@rkIDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SummarizeJobs)rrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:summarizeJobsrzCdataproc.projects.locations.batches.sparkApplications.summarizeJobsrwr[v1/{+name}:summarizeJobsryEDataprocProjectsLocationsBatchesSparkApplicationsSummarizeJobsRequest%SummarizeSparkApplicationJobsResponseFr`rlrnrBr@ror6s9(*@*@OWxHZ0aB +rBcDURS5nURX1US9$)aUObtain summary of Tasks for a Spark Application Stage Attempt. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSparkApplicationStageAttemptTasksResponse) The response message. SummarizeStageAttemptTasksrNrPrSs r@rrVDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SummarizeStageAttemptTasksDrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:summarizeStageAttemptTasksrzPdataproc.projects.locations.batches.sparkApplications.summarizeStageAttemptTasksrwr[rr%v1/{+name}:summarizeStageAttemptTasksryRDataprocProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksRequest2SummarizeSparkApplicationStageAttemptTasksResponseFr`rlrnrBr@rorQs7x7M7M\dxH<=nO 8rBcDURS5nURX1US9$)a2Obtain summary of Stages for a Spark Application. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsSummarizeStagesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSparkApplicationStagesResponse) The response message. SummarizeStagesrNrPrSs r@rzKDataprocV1.ProjectsLocationsBatchesSparkApplicationsService.SummarizeStages_r'rBcD[R"SSSS/S/S/SSSS S S 9 $) Nz|v1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:summarizeStagesrzEdataproc.projects.locations.batches.sparkApplications.summarizeStagesrwr[v1/{+name}:summarizeStagesryGDataprocProjectsLocationsBatchesSparkApplicationsSummarizeStagesRequest'SummarizeSparkApplicationStagesResponseFr`rlrnrBr@rorls9H,B,BQYxHZ2cD -rBcDURS5nURX1US9$)a$Write wrapper objects from dataplane to spanner. Args: request: (DataprocProjectsLocationsBatchesSparkApplicationsWriteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (WriteSparkApplicationContextResponse) The response message. WriterNrPrSs r@rADataprocV1.ProjectsLocationsBatchesSparkApplicationsService.Writez/##G,f __ 88rBcB[R"SSSS/S//SSSSS S 9 $) Nzrv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}/sparkApplications/{sparkApplicationsId}:writerZz;dataproc.projects.locations.batches.sparkApplications.writerwv1/{+name}:write#writeSparkApplicationContextRequest=DataprocProjectsLocationsBatchesSparkApplicationsWriteRequest$WriteSparkApplicationContextResponseFr`rlrnrBr@rors7("8"8GOxH(;YA #rBrrG!rrrrrrrrrrrrrrrrrrrr%r/r8rArIrTr\rdrkrrrzrrrrs@r@rrsxV :E 8 F 8 +' 8 I 8 +' 8 *& 8 #M 8 $N  8 ($ 8 )% 8 F 8 0, 8 %O! 8 J 8 ,( 8 &" 8 -) 8 )% 8 "L 8 ($ 8 #M 8 0, 8 %O! 8 ErBrc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)*DataprocV1.ProjectsLocationsBatchesServiceiz:Service class for the projects_locations_batches resource.r cN>[[RU]U5 0UlgrG)rrrrrHrIs r@r3DataprocV1.ProjectsLocationsBatchesService.__init__s" J 6 6FvN drBcDURS5nURX1US9$)aAnalyze a Batch for possible recommendations and insights. Args: request: (DataprocProjectsLocationsBatchesAnalyzeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. AnalyzerNrPrSs r@r2DataprocV1.ProjectsLocationsBatchesService.Analyzes/##I.f __ 88rBcB[R"SSSS/S//SSSSS S 9 $) NzLv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}:analyzerZz+dataproc.projects.locations.batches.analyzerwzv1/{+name}:analyzeanalyzeBatchRequest.DataprocProjectsLocationsBatchesAnalyzeRequest OperationFr`rlrnrBr@ro3DataprocV1.ProjectsLocationsBatchesService.s4H$:$:`?xH*+J& %rBcDURS5nURX1US9$)zCreates a batch workload that executes asynchronously. Args: request: (DataprocProjectsLocationsBatchesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rMrNrPrSs r@rM1DataprocV1.ProjectsLocationsBatchesService.CreaterWrBcF[R"SSSS/S/SS/SSS S S S 9 $) N8v1/projects/{projectsId}/locations/{locationsId}/batchesrZz*dataproc.projects.locations.batches.creater[batchId requestIdv1/{+parent}/batchesbatch-DataprocProjectsLocationsBatchesCreateRequestrFr`rlrnrBr@rors98#9#9L> zJ-,I& $rBcDURS5nURX1US9$)aqDeletes the batch workload resource. If the batch is not in a CANCELLED, SUCCEEDED or FAILED State, the delete operation fails and the response returns FAILED_PRECONDITION. Args: request: (DataprocProjectsLocationsBatchesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr1DataprocV1.ProjectsLocationsBatchesService.DeleterWrBcB[R"SSSS/S//SSSSS S 9 $) NDv1/projects/{projectsId}/locations/{locationsId}/batches/{batchesId}rvz*dataproc.projects.locations.batches.deleterwrxry-DataprocProjectsLocationsBatchesDeleteRequestr{Fr`rlrnrBr@rors48#9#9X>xH"I" $rBcDURS5nURX1US9$)zGets the batch workload resource representation. Args: request: (DataprocProjectsLocationsBatchesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Batch) The response message. r}rNrPrSs r@r}.DataprocV1.ProjectsLocationsBatchesService.GetrrBcB[R"SSSS/S//SSSSS S 9 $) Nrrz'dataproc.projects.locations.batches.getrwrxry*DataprocProjectsLocationsBatchesGetRequestBatchFr`rlrnrBr@rors4 6 6X;xH"F" !rBcDURS5nURX1US9$)zLists batch workloads. Args: request: (DataprocProjectsLocationsBatchesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListBatchesResponse) The response message. rrNrPrSs r@r/DataprocV1.ProjectsLocationsBatchesService.List rrBcF[R"SSSS/S//SQSSSS S S 9 $) Nrrz(dataproc.projects.locations.batches.listr[filterorderByrrrry+DataprocProjectsLocationsBatchesListRequestListBatchesResponseFr`rlrnrBr@rors4!7!7L< zJC,G0 "rBrrG)rrrrrrrrrrMrrr}rrrrs@r@rrs^D (E 8 G 8 F 8 F 8 C 8 DrBrc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lS r U=r $)-DataprocV1.ProjectsLocationsOperationsServicei&z=Service class for the projects_locations_operations resource.r"cN>[[RU]U5 0UlgrG)rrr!rrHrIs r@r6DataprocV1.ProjectsLocationsOperationsService.__init__+s" J 9 94I&Q drBcDURS5nURX1US9$)a Starts asynchronous cancellation on a long-running operation. The server makes a best effort to cancel the operation, but success is not guaranteed. If the server doesn't support this method, it returns google.rpc.Code.UNIMPLEMENTED. Clients can use Operations.GetOperation or other methods to check whether the cancellation succeeded or whether the operation completed despite cancellation. On successful cancellation, the operation is not deleted; instead, it becomes an operation with an Operation.error value with a google.rpc.Status.code of 1, corresponding to Code.CANCELLED. Args: request: (DataprocProjectsLocationsOperationsCancelRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. CancelrNrPrSs r@r4DataprocV1.ProjectsLocationsOperationsService.Cancel0rWrBcB[R"SSSS/S//SSSSS S 9 $) NzQv1/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}:cancelrZz-dataproc.projects.locations.operations.cancelrwv1/{+name}:cancelry0DataprocProjectsLocationsOperationsCancelRequestr{Fr`rlrnrBr@ro6DataprocV1.ProjectsLocationsOperationsService.=s48#9#9eAxH)L" $rBcDURS5nURX1US9$)aDeletes a long-running operation. This method indicates that the client is no longer interested in the operation result. It does not cancel the operation. If the server doesn't support this method, it returns google.rpc.Code.UNIMPLEMENTED. Args: request: (DataprocProjectsLocationsOperationsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr4DataprocV1.ProjectsLocationsOperationsService.DeleteKrWrBcB[R"SSSS/S//SSSSS S 9 $) NJv1/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}rvz-dataproc.projects.locations.operations.deleterwrxry0DataprocProjectsLocationsOperationsDeleteRequestr{Fr`rlrnrBr@rorXs48#9#9^AxH"L" $rBcDURS5nURX1US9$)adGets the latest state of a long-running operation. Clients can use this method to poll the operation result at intervals as recommended by the API service. Args: request: (DataprocProjectsLocationsOperationsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. r}rNrPrSs r@r}1DataprocV1.ProjectsLocationsOperationsService.GetfrrBcB[R"SSSS/S//SSSSS S 9 $) Nrrz*dataproc.projects.locations.operations.getrwrxry-DataprocProjectsLocationsOperationsGetRequestrFr`rlrnrBr@rorss4 6 6^>xH"I& !rBcDURS5nURX1US9$)a\Lists operations that match the specified filter in the request. If the server doesn't support this method, it returns UNIMPLEMENTED. Args: request: (DataprocProjectsLocationsOperationsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListOperationsResponse) The response message. rrNrPrSs r@r2DataprocV1.ProjectsLocationsOperationsService.ListrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nz;v1/projects/{projectsId}/locations/{locationsId}/operationsrz+dataproc.projects.locations.operations.listrwrrrreturnPartialSuccessrxry.DataprocProjectsLocationsOperationsListRequestListOperationsResponseFr`rlrnrBr@rors4!7!7O?xHP"J3 "rBrrG)rrrrrrrrrrrr}rrrrs@r@r!r&sOG +E 8 F 8 F 8 C 8 DrBr!c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)3DataprocV1.ProjectsLocationsSessionTemplatesServiceizCService class for the projects_locations_sessionTemplates resource.r$cN>[[RU]U5 0UlgrG)rrr#rrHrIs r@rs48#9#9UG zJ5'R, $rBcDURS5nURX1US9$)zDeletes a session template. Args: request: (DataprocProjectsLocationsSessionTemplatesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr:DataprocV1.ProjectsLocationsSessionTemplatesService.DeleterWrBcB[R"SSSS/S//SSSSS S 9 $) NVv1/projects/{projectsId}/locations/{locationsId}/sessionTemplates/{sessionTemplatesId}rvz3dataproc.projects.locations.sessionTemplates.deleterwrxry6DataprocProjectsLocationsSessionTemplatesDeleteRequestr{Fr`rlrnrBr@rors48#9#9jGxH"R" $rBcDURS5nURX1US9$)a Gets the resource representation for a session template. Args: request: (DataprocProjectsLocationsSessionTemplatesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SessionTemplate) The response message. r}rNrPrSs r@r}7DataprocV1.ProjectsLocationsSessionTemplatesService.GetrrBcB[R"SSSS/S//SSSSS S 9 $) Nrrz0dataproc.projects.locations.sessionTemplates.getrwrxry3DataprocProjectsLocationsSessionTemplatesGetRequestrFr`rlrnrBr@rors4 6 6jDxH"O, !rBcDURS5nURX1US9$)zLists session templates. Args: request: (DataprocProjectsLocationsSessionTemplatesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSessionTemplatesResponse) The response message. rrNrPrSs r@r8DataprocV1.ProjectsLocationsSessionTemplatesService.ListrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nrrz1dataproc.projects.locations.sessionTemplates.listr[rrrrry4DataprocProjectsLocationsSessionTemplatesListRequestListSessionTemplatesResponseFr`rlrnrBr@rors4!7!7UE zJ85P9 "rBcDURS5nURX1US9$)zUpdates the session template synchronously. Args: request: (SessionTemplate) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SessionTemplate) The response message. PatchrNrPrSs r@r9DataprocV1.ProjectsLocationsSessionTemplatesService.PatchrrBcB[R"SSSS/S//SSSSSS 9 $) NrPATCHz2dataproc.projects.locations.sessionTemplates.patchrwrxrrFr`rlrnrBr@rors4("8"8jFxH"!+, #rBrrG)rrrrrrrrMrrrr}rrrrrs@r@r#rs^M 1E 8 F 8 F 8 C 8 D 8 ErBr#c^\rSrSrSrSrU4SjrS4SjrS\lS4Sjr S\ lS4S jr S \ lS4S jr S \ lS4S jr S\ lS4Sjr S\ lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS\lS4SjrS \lS4S!jrS"\lS4S#jrS$\lS4S%jrS&\lS4S'jrS(\lS4S)jrS*\lS4S+jrS,\lS4S-jrS.\lS4S/jrS0\lS4S1jrS2\lS3rU=r $)5[[RU]U5 0UlgrG)rrr%rrHrIs r@rEDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.__init__2s# J H H$XY_` drBcDURS5nURX1US9$)aAObtain high level information corresponding to a single Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationResponse) The response message. rrNrPrSs r@rCDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.Access7rWrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzuv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessrz=dataproc.projects.locations.sessions.sparkApplications.accessrwr[rry?DataprocProjectsLocationsSessionsSparkApplicationsAccessRequest%AccessSessionSparkApplicationResponseFr`rlrnrBr@roEDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.Ds98#9#9JQxHZ)[B $rBcDURS5nURX1US9$)aHObtain environment details for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationEnvironmentInfoResponse) The response message. rrNrPrSs r@rRDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessEnvironmentInfoRrrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessEnvironmentInforzLdataproc.projects.locations.sessions.sparkApplications.accessEnvironmentInforwr[rryNDataprocProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoRequest4AccessSessionSparkApplicationEnvironmentInfoResponseFr`rlrnrBr@ror_9(2H2HY`xHZ8jQ 3rBcDURS5nURX1US9$)a>Obtain data corresponding to a spark job for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessJobRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationJobResponse) The response message. rrNrPrSs r@rFDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessJobmrrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nzxv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessJobrz@dataproc.projects.locations.sessions.sparkApplications.accessJobrwrr[rryBDataprocProjectsLocationsSessionsSparkApplicationsAccessJobRequest(AccessSessionSparkApplicationJobResponseFr`rlrnrBr@rorzs<h&<&<MTxHx(,^E 'rBcDURS5nURX1US9$)acObtain data corresponding to Native Build Information for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessNativeBuildInfoRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationNativeBuildInfoResponse) The response message. rrNrPrSs r@rRDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessNativeBuildInforrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessNativeBuildInforzLdataproc.projects.locations.sessions.sparkApplications.accessNativeBuildInforwr[rryNDataprocProjectsLocationsSessionsSparkApplicationsAccessNativeBuildInfoRequest4AccessSessionSparkApplicationNativeBuildInfoResponseFr`rlrnrBr@rorrrBcDURS5nURX1US9$)afObtain data corresponding to a particular Native SQL Query for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessNativeSqlQueryRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationNativeSqlQueryResponse) The response message. rrNrPrSs r@rQDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessNativeSqlQueryrrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessNativeSqlQueryrzKdataproc.projects.locations.sessions.sparkApplications.accessNativeSqlQueryrwrr[rryMDataprocProjectsLocationsSessionsSparkApplicationsAccessNativeSqlQueryRequest3AccessSessionSparkApplicationNativeSqlQueryResponseFr`rlrnrBr@rors<1G1GX_xH#X.7iP 2rBcDURS5nURX1US9$)aObtain Spark Plan Graph for a Spark Application SQL execution. Limits the number of clusters returned as part of the graph to 10000. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessSqlPlanRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationSqlSparkPlanGraphResponse) The response message. rrNrPrSs r@rJDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessSqlPlanrrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nz|v1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessSqlPlanrzDdataproc.projects.locations.sessions.sparkApplications.accessSqlPlanrwrr[rryFDataprocProjectsLocationsSessionsSparkApplicationsAccessSqlPlanRequest6AccessSessionSparkApplicationSqlSparkPlanGraphResponseFr`rlrnrBr@rors<(*@*@QXxH#X.0bS +rBcDURS5nURX1US9$)aSObtain data corresponding to a particular SQL Query for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessSqlQueryRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationSqlQueryResponse) The response message. rrNrPrSs r@rKDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessSqlQueryrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nz}v1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessSqlQueryrzEdataproc.projects.locations.sessions.sparkApplications.accessSqlQueryrwrrryGDataprocProjectsLocationsSessionsSparkApplicationsAccessSqlQueryRequest-AccessSessionSparkApplicationSqlQueryResponseFr`rlrnrBr@rors78+A+ARYxHL1cJ ,rBcDURS5nURX1US9$)aZObtain data corresponding to a spark stage attempt for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessStageAttemptRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationStageAttemptResponse) The response message. rrNrPrSs r@rODataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessStageAttemptrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessStageAttemptrzIdataproc.projects.locations.sessions.sparkApplications.accessStageAttemptrwrrryKDataprocProjectsLocationsSessionsSparkApplicationsAccessStageAttemptRequest1AccessSessionSparkApplicationStageAttemptResponseFr`rlrnrBr@rors7x/E/EV]xHR5gN 0rBcDURS5nURX1US9$)aObtain RDD operation graph for a Spark Application Stage. Limits the number of clusters returned as part of the graph to 10000. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AccessSessionSparkApplicationStageRddOperationGraphResponse) The response message. rrNrPrSs r@rPDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.AccessStageRddGraphr rBcF[R"SSSS/S/SS/SSS S S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:accessStageRddGraphrzJdataproc.projects.locations.sessions.sparkApplications.accessStageRddGraphrwr[rr ryLDataprocProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphRequest;AccessSessionSparkApplicationStageRddOperationGraphResponseFr`rlrnrBr@rors<0F0FW^xH *6hX 1rBcDURS5nURX1US9$)aNObtain high level information and list of Spark Applications corresponding to a batch. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationsResponse) The response message. rrNrPrSs r@rCDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.Search*rWrBcF[R"SSSS/S//SQSSSS S S 9 $) Nz_v1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications:searchrz=dataproc.projects.locations.sessions.sparkApplications.searchr[rrry?DataprocProjectsLocationsSessionsSparkApplicationsSearchRequest&SearchSessionSparkApplicationsResponseFr`rlrnrBr@ror7s48#9#9sQ zJu=[C $rBcDURS5nURX1US9$)a]Obtain executor summary with respect to a spark stage attempt. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationExecutorStageSummaryResponse) The response message. rrNrPrSs r@rWDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchExecutorStageSummaryErrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchExecutorStageSummaryrzQdataproc.projects.locations.sessions.sparkApplications.searchExecutorStageSummaryrwr r!rySDataprocProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryRequest9SearchSessionSparkApplicationExecutorStageSummaryResponseFr`rlrnrBr@rorRs7x7M7M^exHU=oV 8rBcDURS5nURX1US9$)aHObtain data corresponding to executors for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchExecutorsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationExecutorsResponse) The response message. r%rNrPrSs r@r%LDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchExecutors`r'rBcF[R"SSSS/S//SQSSSS S S 9 $) Nz~v1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchExecutorsrzFdataproc.projects.locations.sessions.sparkApplications.searchExecutorsrwr)r+ryHDataprocProjectsLocationsSessionsSparkApplicationsSearchExecutorsRequest.SearchSessionSparkApplicationExecutorsResponseFr`rlrnrBr@rorms7H,B,BSZxHJ2dK -rBcDURS5nURX1US9$)a>Obtain list of spark jobs corresponding to a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchJobsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationJobsResponse) The response message. r/rNrPrSs r@r/GDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchJobs{r1rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzyv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchJobsrzAdataproc.projects.locations.sessions.sparkApplications.searchJobsrw)jobIdsr3rrr[r4ryCDataprocProjectsLocationsSessionsSparkApplicationsSearchJobsRequest)SearchSessionSparkApplicationJobsResponseFr`rlrnrBr@rors7x'='=NUxHO-_F (rBcDURS5nURX1US9$)a_Obtain data corresponding to Native SQL Queries for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchNativeSqlQueriesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationNativeSqlQueriesResponse) The response message. r8rNrPrSs r@r8SDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchNativeSqlQueriesr:rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchNativeSqlQueriesrzMdataproc.projects.locations.sessions.sparkApplications.searchNativeSqlQueriesrwr<r=ryODataprocProjectsLocationsSessionsSparkApplicationsSearchNativeSqlQueriesRequest5SearchSessionSparkApplicationNativeSqlQueriesResponseFr`rlrnrBr@rors783I3IZaxH89kR 4rBcDURS5nURX1US9$)aLObtain data corresponding to SQL Queries for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationSqlQueriesResponse) The response message. rArNrPrSs r@rAMDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchSqlQueriesrCrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchSqlQueriesrzGdataproc.projects.locations.sessions.sparkApplications.searchSqlQueriesrw)r operationIdsrrr[rrEryIDataprocProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesRequest/SearchSessionSparkApplicationSqlQueriesResponseFr`rlrnrBr@rors7X-C-CT[xHf3eL .rBcDURS5nURX1US9$)anObtain data corresponding to tasks for a spark stage attempt for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationStageAttemptTasksResponse) The response message. rIrNrPrSs r@rITDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchStageAttemptTasksrKrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchStageAttemptTasksrzNdataproc.projects.locations.sessions.sparkApplications.searchStageAttemptTasksrwrMrPryPDataprocProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksRequest6SearchSessionSparkApplicationStageAttemptTasksResponseFr`rlrnrBr@rors7H4J4J[bxHr:lS 5rBcDURS5nURX1US9$)a]Obtain data corresponding to a spark stage attempts for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationStageAttemptsResponse) The response message. rTrNrPrSs r@rTPDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchStageAttemptsr rBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchStageAttemptsrzJdataproc.projects.locations.sessions.sparkApplications.searchStageAttemptsrwrWrXryLDataprocProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsRequest2SearchSessionSparkApplicationStageAttemptsResponseFr`rlrnrBr@rors70F0FW^xHY6hO 1rBcDURS5nURX1US9$)a?Obtain data corresponding to stages for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSearchStagesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SearchSessionSparkApplicationStagesResponse) The response message. r\rNrPrSs r@r\IDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SearchStagesrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nz{v1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:searchStagesrzCdataproc.projects.locations.sessions.sparkApplications.searchStagesrw)rrr[stageIdsr_rr`ryEDataprocProjectsLocationsSessionsSparkApplicationsSearchStagesRequest+SearchSessionSparkApplicationStagesResponseFr`rlrnrBr@rors7)?)?PWxHi/aH *rBcDURS5nURX1US9$)aJObtain summary of Executor Summary for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSessionSparkApplicationExecutorsResponse) The response message. rdrNrPrSs r@rdODataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SummarizeExecutorsrrBcD[R"SSSS/S/S/SSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:summarizeExecutorsrzIdataproc.projects.locations.sessions.sparkApplications.summarizeExecutorsrwr[rgryKDataprocProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsRequest1SummarizeSessionSparkApplicationExecutorsResponseFr`rlrnrBr@ror*s9x/E/EV]xHZ5gN 0rBcDURS5nURX1US9$)a4Obtain summary of Jobs for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSummarizeJobsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSessionSparkApplicationJobsResponse) The response message. rkrNrPrSs r@rkJDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SummarizeJobs8rrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nz|v1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:summarizeJobsrzDdataproc.projects.locations.sessions.sparkApplications.summarizeJobsrwr3r[rnryFDataprocProjectsLocationsSessionsSparkApplicationsSummarizeJobsRequest,SummarizeSessionSparkApplicationJobsResponseFr`rlrnrBr@rorEs<(*@*@QXxH)0bI +rBcDURS5nURX1US9$)a]Obtain summary of Tasks for a Spark Application Stage Attempt. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSessionSparkApplicationStageAttemptTasksResponse) The response message. rrrNrPrSs r@rrWDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SummarizeStageAttemptTasksSrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nzv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:summarizeStageAttemptTasksrzQdataproc.projects.locations.sessions.sparkApplications.summarizeStageAttemptTasksrwrurvrySDataprocProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksRequest9SummarizeSessionSparkApplicationStageAttemptTasksResponseFr`rlrnrBr@ror`s7x7M7M^exH<=oV 8rBcDURS5nURX1US9$)a:Obtain summary of Stages for a Spark Application. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsSummarizeStagesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SummarizeSessionSparkApplicationStagesResponse) The response message. rzrNrPrSs r@rzLDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.SummarizeStagesnr'rBcF[R"SSSS/S/SS/SSS S S S 9 $) Nz~v1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:summarizeStagesrzFdataproc.projects.locations.sessions.sparkApplications.summarizeStagesrwr[rNr}ryHDataprocProjectsLocationsSessionsSparkApplicationsSummarizeStagesRequest.SummarizeSessionSparkApplicationStagesResponseFr`rlrnrBr@ror{s<H,B,BSZxH +2dK -rBcDURS5nURX1US9$)a,Write wrapper objects from dataplane to spanner. Args: request: (DataprocProjectsLocationsSessionsSparkApplicationsWriteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (WriteSessionSparkApplicationContextResponse) The response message. rrNrPrSs r@rBDataprocV1.ProjectsLocationsSessionsSparkApplicationsService.WriterrBcB[R"SSSS/S//SSSSS S 9 $) Nztv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}/sparkApplications/{sparkApplicationsId}:writerZzDataprocProjectsLocationsSessionsSparkApplicationsWriteRequest+WriteSessionSparkApplicationContextResponseFr`rlrnrBr@rors7("8"8IPxH(BZH #rBrrGrrs@r@r%r-sxW ;E 8 F 8 +' 8 I 8 +' 8 *& 8 #M 8 $N  8 ($ 8 )% 8 F 8 0, 8 %O! 8 J 8 ,( 8 &" 8 -) 8 )% 8 "L 8 ($ 8 #M 8 0, 8 %O! 8 ErBr%c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)+DataprocV1.ProjectsLocationsSessionsServiceiz;Service class for the projects_locations_sessions resource.r(cN>[[RU]U5 0UlgrG)rrr'rrHrIs r@r4DataprocV1.ProjectsLocationsSessionsService.__init__" J 7 7GO drBcDURS5nURX1US9$)zCreate an interactive session asynchronously. Args: request: (DataprocProjectsLocationsSessionsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rMrNrPrSs r@rM2DataprocV1.ProjectsLocationsSessionsService.CreaterWrBcF[R"SSSS/S/SS/SSS S S S 9 $) N9v1/projects/{projectsId}/locations/{locationsId}/sessionsrZz+dataproc.projects.locations.sessions.creater[r sessionIdv1/{+parent}/sessionssession.DataprocProjectsLocationsSessionsCreateRequestrFr`rlrnrBr@ro4DataprocV1.ProjectsLocationsSessionsService.s98#9#9M? zJ!;/-J& $rBcDURS5nURX1US9$)a@Deletes the interactive session resource. If the session is not in terminal state, it is terminated, and then deleted. Args: request: (DataprocProjectsLocationsSessionsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrrNrPrSs r@rr2DataprocV1.ProjectsLocationsSessionsService.DeleterWrBcD[R"SSSS/S/S/SSSS S S 9 $) NFv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}rvz+dataproc.projects.locations.sessions.deleterwrrxry.DataprocProjectsLocationsSessionsDeleteRequestrFr`rlrnrBr@rorxs68#9#9Z?xH!]"J& $rBcDURS5nURX1US9$)aGets the resource representation for an interactive session. Args: request: (DataprocProjectsLocationsSessionsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Session) The response message. r}rNrPrSs r@r}/DataprocV1.ProjectsLocationsSessionsService.GetrrBcB[R"SSSS/S//SSSSS S 9 $) Nr|rz(dataproc.projects.locations.sessions.getrwrxry+DataprocProjectsLocationsSessionsGetRequestSessionFr`rlrnrBr@rorxs4 6 6Z<xH"G$ !rBcDURS5nURX1US9$)zLists interactive sessions. Args: request: (DataprocProjectsLocationsSessionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSessionsResponse) The response message. rrNrPrSs r@r0DataprocV1.ProjectsLocationsSessionsService.ListrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nrsrz)dataproc.projects.locations.sessions.listr[rrury,DataprocProjectsLocationsSessionsListRequestListSessionsResponseFr`rlrnrBr@rorx s4!7!7M= zJC-H1 "rBcDURS5nURX1US9$)zTerminates the interactive session. Args: request: (DataprocProjectsLocationsSessionsTerminateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. TerminaterNrPrSs r@r5DataprocV1.ProjectsLocationsSessionsService.TerminaterrBcB[R"SSSS/S//SSSSS S 9 $) NzPv1/projects/{projectsId}/locations/{locationsId}/sessions/{sessionsId}:terminaterZz.dataproc.projects.locations.sessions.terminaterwzv1/{+name}:terminateterminateSessionRequest1DataprocProjectsLocationsSessionsTerminateRequestrFr`rlrnrBr@rorx's4h&<&<dBxH,/M& 'rBrrG)rrrrrrrrMrrrr}rrrrrs@r@r'rls^E )E 8 F 8 F 8 C 8 D 8 IrBr'c4^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSSjrS\lSSjrS\lSrU=r$)4DataprocV1.ProjectsLocationsWorkflowTemplatesServicei5zDService class for the projects_locations_workflowTemplates resource.r*cN>[[RU]U5 0UlgrG)rrr)rrHrIs r@r=DataprocV1.ProjectsLocationsWorkflowTemplatesService.__init__:# J @ @$PQWX drBcDURS5nURX1US9$)zCreates new workflow template. Args: request: (DataprocProjectsLocationsWorkflowTemplatesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (WorkflowTemplate) The response message. rMrNrPrSs r@rM;DataprocV1.ProjectsLocationsWorkflowTemplatesService.Create?rWrBcB[R"SSSS/S//SSSSS S 9 $) NBv1/projects/{projectsId}/locations/{locationsId}/workflowTemplatesrZz4dataproc.projects.locations.workflowTemplates.creater[v1/{+parent}/workflowTemplatesworkflowTemplate7DataprocProjectsLocationsWorkflowTemplatesCreateRequestWorkflowTemplateFr`rlrnrBr@ro=DataprocV1.ProjectsLocationsWorkflowTemplatesService.Ls48#9#9VH zJ6(S- $rBcDURS5nURX1US9$)aDeletes a workflow template. It does not cancel in-progress workflows. Args: request: (DataprocProjectsLocationsWorkflowTemplatesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr;DataprocV1.ProjectsLocationsWorkflowTemplatesService.DeleteZrWrBcD[R"SSSS/S/S/SSSS S S 9 $) NXv1/projects/{projectsId}/locations/{locationsId}/workflowTemplates/{workflowTemplatesId}rvz4dataproc.projects.locations.workflowTemplates.deleterwversionrxry7DataprocProjectsLocationsWorkflowTemplatesDeleteRequestr{Fr`rlrnrBr@rorgs68#9#9lHxH["S" $rBcDURS5nURX1US9$)aURetrieves the latest workflow template.Can retrieve previously instantiated template by specifying optional version parameter. Args: request: (DataprocProjectsLocationsWorkflowTemplatesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (WorkflowTemplate) The response message. r}rNrPrSs r@r}8DataprocV1.ProjectsLocationsWorkflowTemplatesService.GeturrBcD[R"SSSS/S/S/SSSS S S 9 $) Nrrz1dataproc.projects.locations.workflowTemplates.getrwrrxry4DataprocProjectsLocationsWorkflowTemplatesGetRequestrFr`rlrnrBr@rors6 6 6lExH["P- !rBcDURS5nURX1US9$)aSGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (DataprocProjectsLocationsWorkflowTemplatesGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@rADataprocV1.ProjectsLocationsWorkflowTemplatesService.GetIamPolicyrrBcB[R"SSSS/S//SSSSS S 9 $) Nzev1/projects/{projectsId}/locations/{locationsId}/workflowTemplates/{workflowTemplatesId}:getIamPolicyrZz:dataproc.projects.locations.workflowTemplates.getIamPolicyrrr=DataprocProjectsLocationsWorkflowTemplatesGetIamPolicyRequestrFr`rlrnrBr@ror4)?)?yN"|L3+Y# *rBcDURS5nURX1US9$)aInstantiates a template and begins execution.The returned Operation can be used to track execution of workflow by polling operations.get. The Operation will complete when entire workflow is finished.The running workflow can be aborted via operations.cancel. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.The Operation.metadata will be WorkflowMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see Using WorkflowMetadata (https://cloud.google.com/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).On successful completion, Operation.response will be Empty. Args: request: (DataprocProjectsLocationsWorkflowTemplatesInstantiateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. InstantiaterNrPrSs r@r@DataprocV1.ProjectsLocationsWorkflowTemplatesService.Instantiate/##M2f __ 88rBcB[R"SSSS/S//SSSSS S 9 $) Nzdv1/projects/{projectsId}/locations/{locationsId}/workflowTemplates/{workflowTemplatesId}:instantiaterZz9dataproc.projects.locations.workflowTemplates.instantiaterwv1/{+name}:instantiate"instantiateWorkflowTemplateRequest(>xMxH.:X& )rBcDURS5nURX1US9$)aInstantiates a template and begins execution.This method is equivalent to executing the sequence CreateWorkflowTemplate, InstantiateWorkflowTemplate, DeleteWorkflowTemplate.The returned Operation can be used to track execution of workflow by polling operations.get. The Operation will complete when entire workflow is finished.The running workflow can be aborted via operations.cancel. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.The Operation.metadata will be WorkflowMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see Using WorkflowMetadata (https://cloud.google.com/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).On successful completion, Operation.response will be Empty. Args: request: (DataprocProjectsLocationsWorkflowTemplatesInstantiateInlineRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. InstantiateInlinerNrPrSs r@rFDataprocV1.ProjectsLocationsWorkflowTemplatesService.InstantiateInline0##$78f __ 88rBcD[R"SSSS/S/S/SSSS S S 9 $) NzTv1/projects/{projectsId}/locations/{locationsId}/workflowTemplates:instantiateInlinerZz?dataproc.projects.locations.workflowTemplates.instantiateInliner[r0v1/{+parent}/workflowTemplates:instantiateInlinerBDataprocProjectsLocationsWorkflowTemplatesInstantiateInlineRequestrFr`rlrnrBr@rors6h.D.DhS zJ!]H(^& /rBcDURS5nURX1US9$)a$Lists workflows that match the specified filter in the request. Args: request: (DataprocProjectsLocationsWorkflowTemplatesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListWorkflowTemplatesResponse) The response message. rrNrPrSs r@r9DataprocV1.ProjectsLocationsWorkflowTemplatesService.ListrrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nrrz2dataproc.projects.locations.workflowTemplates.listr[rrrry5DataprocProjectsLocationsWorkflowTemplatesListRequestListWorkflowTemplatesResponseFr`rlrnrBr@rors9!7!7VF zJ +.6Q: "rBcDURS5nURX1US9$)arSets the access control policy on the specified resource. Replaces any existing policy.Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIED errors. Args: request: (DataprocProjectsLocationsWorkflowTemplatesSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@rADataprocV1.ProjectsLocationsWorkflowTemplatesService.SetIamPolicyrrBcB[R"SSSS/S//SSSSS S 9 $) Nzev1/projects/{projectsId}/locations/{locationsId}/workflowTemplates/{workflowTemplatesId}:setIamPolicyrZz:dataproc.projects.locations.workflowTemplates.setIamPolicyrrr=DataprocProjectsLocationsWorkflowTemplatesSetIamPolicyRequestrFr`rlrnrBr@ror rrBcDURS5nURX1US9$)aJReturns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (DataprocProjectsLocationsWorkflowTemplatesTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rrNrPrSs r@rGDataprocV1.ProjectsLocationsWorkflowTemplatesService.TestIamPermissions rrBcB[R"SSSS/S//SSSSS S 9 $) Nzkv1/projects/{projectsId}/locations/{locationsId}/workflowTemplates/{workflowTemplatesId}:testIamPermissionsrZz@dataproc.projects.locations.workflowTemplates.testIamPermissionsrrrCDataprocProjectsLocationsWorkflowTemplatesTestIamPermissionsRequestrFr`rlrnrBr@ror$ 4x/E/ET"|L91_7 0rBcDURS5nURX1US9$a+Updates (replaces) workflow template. The updated template must contain version that matches the current server version. Args: request: (WorkflowTemplate) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (WorkflowTemplate) The response message. rrNrPrSs r@r;DataprocV1.ProjectsLocationsWorkflowTemplatesService.Update2 rWrBcB[R"SSSS/S//SSSSSS 9 $) Nrrz4dataproc.projects.locations.workflowTemplates.updaterwrxrrFr`rlrnrBr@ror? s48#9#9lHxH"!,- $rBrrGrrrrrrrrMrrrr}rrrrrrrrrrs@r@r)r5sN 2E 8 F 8 F 8 C 8 "L 8 !K 8 '# 8 D 8 "L 8 ($ 8 FrBr)c0^\rSrSrSrSrU4SjrSrU=r$)#DataprocV1.ProjectsLocationsServiceiM z2Service class for the projects_locations resource.r,cN>[[RU]U5 0UlgrG)rrr+rrHrIs r@r,DataprocV1.ProjectsLocationsService.__init__R s" J / /?G drBr rrrrrrrrrrs@r@r+rM s< E  rBr+c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSrU=r$)4DataprocV1.ProjectsRegionsAutoscalingPoliciesServiceiW zDService class for the projects_regions_autoscalingPolicies resource.r.cN>[[RU]U5 0UlgrG)rrr-rrHrIs r@r=DataprocV1.ProjectsRegionsAutoscalingPoliciesService.__init__\ rrBcDURS5nURX1US9$)zCreates new autoscaling policy. Args: request: (DataprocProjectsRegionsAutoscalingPoliciesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AutoscalingPolicy) The response message. rMrNrPrSs r@rM;DataprocV1.ProjectsRegionsAutoscalingPoliciesService.Createa rWrBcB[R"SSSS/S//SSSSS S 9 $) N@v1/projects/{projectsId}/regions/{regionsId}/autoscalingPoliciesrZz4dataproc.projects.regions.autoscalingPolicies.creater[r\r]7DataprocProjectsRegionsAutoscalingPoliciesCreateRequestr_Fr`rlrnrBr@ro=DataprocV1.ProjectsRegionsAutoscalingPoliciesService.n s48#9#9TH zJ8)S. $rBcDURS5nURX1US9$)aDDeletes an autoscaling policy. It is an error to delete an autoscaling policy that is in use by one or more clusters. Args: request: (DataprocProjectsRegionsAutoscalingPoliciesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr;DataprocV1.ProjectsRegionsAutoscalingPoliciesService.Delete| rWrBcB[R"SSSS/S//SSSSS S 9 $) NXv1/projects/{projectsId}/regions/{regionsId}/autoscalingPolicies/{autoscalingPoliciesId}rvz4dataproc.projects.regions.autoscalingPolicies.deleterwrxry7DataprocProjectsRegionsAutoscalingPoliciesDeleteRequestr{Fr`rlrnrBr@ror s48#9#9lHxH"S" $rBcDURS5nURX1US9$)zRetrieves autoscaling policy. Args: request: (DataprocProjectsRegionsAutoscalingPoliciesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (AutoscalingPolicy) The response message. r}rNrPrSs r@r}8DataprocV1.ProjectsRegionsAutoscalingPoliciesService.Get rrBcB[R"SSSS/S//SSSSS S 9 $) Nrrz1dataproc.projects.regions.autoscalingPolicies.getrwrxry4DataprocProjectsRegionsAutoscalingPoliciesGetRequestr_Fr`rlrnrBr@ror s4 6 6lExH"P. !rBcDURS5nURX1US9$)aSGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (DataprocProjectsRegionsAutoscalingPoliciesGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@rADataprocV1.ProjectsRegionsAutoscalingPoliciesService.GetIamPolicy rrBcB[R"SSSS/S//SSSSS S 9 $) Nzev1/projects/{projectsId}/regions/{regionsId}/autoscalingPolicies/{autoscalingPoliciesId}:getIamPolicyrZz:dataproc.projects.regions.autoscalingPolicies.getIamPolicyrrr=DataprocProjectsRegionsAutoscalingPoliciesGetIamPolicyRequestrFr`rlrnrBr@ror rrBcDURS5nURX1US9$)aLists autoscaling policies in the project. Args: request: (DataprocProjectsRegionsAutoscalingPoliciesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListAutoscalingPoliciesResponse) The response message. rrNrPrSs r@r9DataprocV1.ProjectsRegionsAutoscalingPoliciesService.List rrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nrrz2dataproc.projects.regions.autoscalingPolicies.listr[rrr\ry5DataprocProjectsRegionsAutoscalingPoliciesListRequestrFr`rlrnrBr@ror s9!7!7TF zJ +.8Q< "rBcDURS5nURX1US9$)arSets the access control policy on the specified resource. Replaces any existing policy.Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIED errors. Args: request: (DataprocProjectsRegionsAutoscalingPoliciesSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@rADataprocV1.ProjectsRegionsAutoscalingPoliciesService.SetIamPolicy rrBcB[R"SSSS/S//SSSSS S 9 $) Nzev1/projects/{projectsId}/regions/{regionsId}/autoscalingPolicies/{autoscalingPoliciesId}:setIamPolicyrZz:dataproc.projects.regions.autoscalingPolicies.setIamPolicyrrr=DataprocProjectsRegionsAutoscalingPoliciesSetIamPolicyRequestrFr`rlrnrBr@ror rrBcDURS5nURX1US9$)aJReturns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (DataprocProjectsRegionsAutoscalingPoliciesTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rrNrPrSs r@rGDataprocV1.ProjectsRegionsAutoscalingPoliciesService.TestIamPermissions rrBcB[R"SSSS/S//SSSSS S 9 $) Nzkv1/projects/{projectsId}/regions/{regionsId}/autoscalingPolicies/{autoscalingPoliciesId}:testIamPermissionsrZz@dataproc.projects.regions.autoscalingPolicies.testIamPermissionsrrrCDataprocProjectsRegionsAutoscalingPoliciesTestIamPermissionsRequestrFr`rlrnrBr@ror rrBcDURS5nURX1US9$rrPrSs r@r;DataprocV1.ProjectsRegionsAutoscalingPoliciesService.Update rWrBcB[R"SSSS/S//SSSSSS 9 $) Nrrz4dataproc.projects.regions.autoscalingPolicies.updaterwrxrr_Fr`rlrnrBr@ror+ s48#9#9lHxH"!-. $rBrrGrrs@r@r-rW sN 2E 8 F 8 F 8 C 8 "L 8 D 8 "L 8 ($ 8 FrBr-c4^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSSjrS\lSSjrS\lSrU=r$)3DataprocV1.ProjectsRegionsClustersNodeGroupsServicei9 zDService class for the projects_regions_clusters_nodeGroups resource.r0cN>[[RU]U5 0UlgrG)rrr/rrHrIs r@r rrBcDURS5nURX1US9$)aCreates a node group in a cluster. The returned Operation.metadata is NodeGroupOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#nodegroupoperationmetadata). Args: request: (DataprocProjectsRegionsClustersNodeGroupsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rMrNrPrSs r@rM:DataprocV1.ProjectsRegionsClustersNodeGroupsService.CreateC rWrBcF[R"SSSS/S//SQSSSS S S 9 $) NMv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}/nodeGroupsrZz4dataproc.projects.regions.clusters.nodeGroups.creater[) nodeGroupIdparentOperationIdrv1/{+parent}/nodeGroups nodeGroup6DataprocProjectsRegionsClustersNodeGroupsCreateRequestrFr`rlrnrBr@roP s48#9#9aH zJF/!R& $rBcDURS5nURX1US9$)aDeletes a node group in a cluster. The returned Operation.metadata is NodeGroupOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#nodegroupoperationmetadata). Args: request: (DataprocProjectsRegionsClustersNodeGroupsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrrNrPrSs r@rr:DataprocV1.ProjectsRegionsClustersNodeGroupsService.Delete^ rWrBcD[R"SSSS/S/S/SSSS S S 9 $) N\v1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}/nodeGroups/{nodeGroupsId}rvz4dataproc.projects.regions.clusters.nodeGroups.deleterwrrxry6DataprocProjectsRegionsClustersNodeGroupsDeleteRequestrFr`rlrnrBr@rork s68#9#9pHxH!]"R& $rBcDURS5nURX1US9$)aGets the resource representation for a node group in a cluster. Args: request: (DataprocProjectsRegionsClustersNodeGroupsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (NodeGroup) The response message. r}rNrPrSs r@r}7DataprocV1.ProjectsRegionsClustersNodeGroupsService.Gety rrBcB[R"SSSS/S//SSSSS S 9 $) Nr rz1dataproc.projects.regions.clusters.nodeGroups.getrwrxry3DataprocProjectsRegionsClustersNodeGroupsGetRequest NodeGroupFr`rlrnrBr@ror s4 6 6pExH"O& !rBcDURS5nURX1US9$)aLists all node groups in a cluster. Args: request: (DataprocProjectsRegionsClustersNodeGroupsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListNodeGroupsResponse) The response message. rrNrPrSs r@r8DataprocV1.ProjectsRegionsClustersNodeGroupsService.List rrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nrrz2dataproc.projects.regions.clusters.nodeGroups.listr[rrrry4DataprocProjectsRegionsClustersNodeGroupsListRequestListNodeGroupsResponseFr`rlrnrBr@ror s9!7!7aF zJ +./P3 "rBcDURS5nURX1US9$)zRepair nodes in a node group. Args: request: (DataprocProjectsRegionsClustersNodeGroupsRepairRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. RepairrNrPrSs r@r:DataprocV1.ProjectsRegionsClustersNodeGroupsService.Repair rWrBcB[R"SSSS/S//SSSSS S 9 $) Nzcv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}/nodeGroups/{nodeGroupsId}:repairrZz4dataproc.projects.regions.clusters.nodeGroups.repairrwzv1/{+name}:repairrepairNodeGroupRequest6DataprocProjectsRegionsClustersNodeGroupsRepairRequestrFr`rlrnrBr@ror 48#9#9wHxH).R& $rBcDURS5nURX1US9$)aResizes a node group in a cluster. The returned Operation.metadata is NodeGroupOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#nodegroupoperationmetadata). Args: request: (DataprocProjectsRegionsClustersNodeGroupsResizeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. ResizerNrPrSs r@r:DataprocV1.ProjectsRegionsClustersNodeGroupsService.Resize rWrBcB[R"SSSS/S//SSSSS S 9 $) Nzcv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}/nodeGroups/{nodeGroupsId}:resizerZz4dataproc.projects.regions.clusters.nodeGroups.resizerwzv1/{+name}:resizeresizeNodeGroupRequest6DataprocProjectsRegionsClustersNodeGroupsResizeRequestrFr`rlrnrBr@ror rrBcDURS5nURX1US9$)aStarts all the VMs in a node group in a cluster. The returned Operation.metadata is NodeGroupOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#nodegroupoperationmetadata). Args: request: (DataprocProjectsRegionsClustersNodeGroupsStartRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. StartrNrPrSs r@r#9DataprocV1.ProjectsRegionsClustersNodeGroupsService.Start rrBcB[R"SSSS/S//SSSSS S 9 $) Nzbv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}/nodeGroups/{nodeGroupsId}:startrZz3dataproc.projects.regions.clusters.nodeGroups.startrwzv1/{+name}:startstartNodeGroupRequest5DataprocProjectsRegionsClustersNodeGroupsStartRequestrFr`rlrnrBr@ror s4("8"8vGxH(-Q& #rBcDURS5nURX1US9$)aStops all the VMs in a node group in a cluster. The returned Operation.metadata is NodeGroupOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#nodegroupoperationmetadata). Args: request: (DataprocProjectsRegionsClustersNodeGroupsStopRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. StoprNrPrSs r@r)8DataprocV1.ProjectsRegionsClustersNodeGroupsService.Stop rrBcB[R"SSSS/S//SSSSS S 9 $) Nzav1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}/nodeGroups/{nodeGroupsId}:stoprZz2dataproc.projects.regions.clusters.nodeGroups.stoprwzv1/{+name}:stopstopNodeGroupRequest4DataprocProjectsRegionsClustersNodeGroupsStopRequestrFr`rlrnrBr@ror s4!7!7uFxH',P& "rBcDURS5nURX1US9$)aUpdates labels on the node group in a cluster. The returned Operation.metadata is NodeGroupOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#nodegroupoperationmetadata). Args: request: (DataprocProjectsRegionsClustersNodeGroupsUpdateLabelsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. UpdateLabelsrNrPrSs r@r/@DataprocV1.ProjectsRegionsClustersNodeGroupsService.UpdateLabels rrBcB[R"SSSS/S//SSSSS S 9 $) Nziv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}/nodeGroups/{nodeGroupsId}:updateLabelsrZz:dataproc.projects.regions.clusters.nodeGroups.updateLabelsrwzv1/{+name}:updateLabelsupdateLabelsNodeGroupRequest[[RU]U5 0UlgrG)rrr1rrHrIs r@r2DataprocV1.ProjectsRegionsClustersService.__init__V s" J 5 5tEfM drBcDURS5nURX1US9$)aCreates a cluster in a project. The returned Operation.metadata will be ClusterOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#clusteroperationmetadata). Args: request: (DataprocProjectsRegionsClustersCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rMrNrPrSs r@rM0DataprocV1.ProjectsRegionsClustersService.Create[ rWrBc H[R"SSSS/SS/SS/SSS S S S 9 $) NrZz)dataproc.projects.regions.clusters.create projectIdregionactionOnFailedPrimaryWorkersr1v1/projects/{projectId}/regions/{region}/clusterscluster,DataprocProjectsRegionsClustersCreateRequestrF rbrcrdrerfrgrhrirjrkrlrnrBr@ro2DataprocV1.ProjectsRegionsClustersService.h s<8#9#9=#X. (+4kBIH& $rBcDURS5nURX1US9$)aDeletes a cluster in a project. The returned Operation.metadata will be ClusterOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#clusteroperationmetadata). Args: request: (DataprocProjectsRegionsClustersDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrrNrPrSs r@rr0DataprocV1.ProjectsRegionsClustersService.Deleteu rWrBc H[R"SS/SQ/SQ/SQSSSS S S 9 $) Nrvz)dataproc.projects.regions.clusters.deleterArB clusterNamerMrArB) clusterUuidgracefulTerminationTimeoutr?v1/projects/{projectId}/regions/{region}/clusters/{clusterName}ry,DataprocProjectsRegionsClustersDeleteRequestrFrGrlrnrBr@rorH s-8#9#9==:OWH& $rBcDURS5nURX1US9$)aSGets cluster diagnostic information. The returned Operation.metadata will be ClusterOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#clusteroperationmetadata). After the operation completes, Operation.response contains DiagnoseClusterResults (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#diagnoseclusterresults). Args: request: (DataprocProjectsRegionsClustersDiagnoseRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. DiagnoserNrPrSs r@rT2DataprocV1.ProjectsRegionsClustersService.Diagnose s/##J/f __ 88rBc D[R"SS/SQ/SQ/SSSSS S 9 $) NrZz+dataproc.projects.regions.clusters.diagnoserLrNzHv1/projects/{projectId}/regions/{region}/clusters/{clusterName}:diagnosediagnoseClusterRequest.DataprocProjectsRegionsClustersDiagnoseRequestrFrGrlrnrBr@rorH s-X%;%;?=:`.J& &rBcDURS5nURX1US9$)zGets the resource representation for a cluster in a project. Args: request: (DataprocProjectsRegionsClustersGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Cluster) The response message. r}rNrPrSs r@r}-DataprocV1.ProjectsRegionsClustersService.Get rrBc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrz&dataproc.projects.regions.clusters.getrLrNrQry)DataprocProjectsRegionsClustersGetRequestClusterFrGrlrnrBr@rorH s- 6 6:=:WE$ !rBcDURS5nURX1US9$)a4Exports a template for a cluster in a project that can be used in future CreateCluster requests. Args: request: (DataprocProjectsRegionsClustersGetClusterAsTemplateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Cluster) The response message. GetClusterAsTemplaterNrPrSs r@r_>DataprocV1.ProjectsRegionsClustersService.GetClusterAsTemplate rrBc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrz7dataproc.projects.regions.clusters.getClusterAsTemplaterLrNzTv1/projects/{projectId}/regions/{region}/clusters/{clusterName}:getClusterAsTemplatery:DataprocProjectsRegionsClustersGetClusterAsTemplateRequestr]FrGrlrnrBr@rorH s-1G1GK=:lV$ 2rBcDURS5nURX1US9$)aHGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (DataprocProjectsRegionsClustersGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r6DataprocV1.ProjectsRegionsClustersService.GetIamPolicy rrBcB[R"SSSS/S//SSSSS S 9 $) NzOv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}:getIamPolicyrZz/dataproc.projects.regions.clusters.getIamPolicyrrr2DataprocProjectsRegionsClustersGetIamPolicyRequestrFr`rlrnrBr@rorH 4)?)?cC"|L3+N# *rBcDURS5nURX1US9$)apInject encrypted credentials into all of the VMs in a cluster.The target cluster must be a personal auth cluster assigned to the user who is issuing the RPC. Args: request: (DataprocProjectsRegionsClustersInjectCredentialsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. InjectCredentialsrNrPrSs r@ri;DataprocV1.ProjectsRegionsClustersService.InjectCredentials rrBcF[R"SSS/SQ/SQ/SSSS S S 9 $) NzTv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}:injectCredentialsrZz4dataproc.projects.regions.clusters.injectCredentials)projectrBrE)rErlrBz4v1/{+project}/{+region}/{+cluster}:injectCredentialsinjectCredentialsRequest7DataprocProjectsRegionsClustersInjectCredentialsRequestrFr`rlrnrBr@rorH s0h.D.DhH74L0S& /rBcDURS5nURX1US9$)aLists all regions/{region}/clusters in a project alphabetically. Args: request: (DataprocProjectsRegionsClustersListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListClustersResponse) The response message. rrNrPrSs r@r.DataprocV1.ProjectsRegionsClustersService.List rrBc H[R"SSSS/SS//SQSSSS S S 9 $) Nrz'dataproc.projects.regions.clusters.listrArBrrDry*DataprocProjectsRegionsClustersListRequestListClustersResponseFrGrlrnrBr@rorH s7!7!7;#X. (+8IF1 "rBcDURS5nURX1US9$)aUpdates a cluster in a project. The returned Operation.metadata will be ClusterOperationMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#clusteroperationmetadata). The cluster must be in a RUNNING state or an error is returned. Args: request: (DataprocProjectsRegionsClustersPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrNrPrSs r@r/DataprocV1.ProjectsRegionsClustersService.Patch- rrBc H[R"SS/SQ/SQ/SQSSSS S S 9 $) Nrz(dataproc.projects.regions.clusters.patchrLrN)gracefulDecommissionTimeoutr updateMaskrQrE+DataprocProjectsRegionsClustersPatchRequestrFrGrlrnrBr@rorH: s-("8"8<=:OWG& #rBcDURS5nURX1US9$)zRepairs a cluster. Args: request: (DataprocProjectsRegionsClustersRepairRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrNrPrSs r@r0DataprocV1.ProjectsRegionsClustersService.RepairG rWrBc D[R"SS/SQ/SQ/SSSSS S 9 $) NrZz)dataproc.projects.regions.clusters.repairrLrNzFv1/projects/{projectId}/regions/{region}/clusters/{clusterName}:repairrepairClusterRequest,DataprocProjectsRegionsClustersRepairRequestrFrGrlrnrBr@rorHT s-8#9#9==:^,H& $rBcDURS5nURX1US9$)agSets the access control policy on the specified resource. Replaces any existing policy.Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIED errors. Args: request: (DataprocProjectsRegionsClustersSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r6DataprocV1.ProjectsRegionsClustersService.SetIamPolicya rrBcB[R"SSSS/S//SSSSS S 9 $) NzOv1/projects/{projectsId}/regions/{regionsId}/clusters/{clustersId}:setIamPolicyrZz/dataproc.projects.regions.clusters.setIamPolicyrrr2DataprocProjectsRegionsClustersSetIamPolicyRequestrFr`rlrnrBr@rorHn rgrBcDURS5nURX1US9$)zStarts a cluster in a project. Args: request: (DataprocProjectsRegionsClustersStartRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. r#rNrPrSs r@r#/DataprocV1.ProjectsRegionsClustersService.Start| rrBc D[R"SS/SQ/SQ/SSSSS S 9 $) NrZz(dataproc.projects.regions.clusters.startrLrNzEv1/projects/{projectId}/regions/{region}/clusters/{clusterName}:startstartClusterRequest+DataprocProjectsRegionsClustersStartRequestrFrGrlrnrBr@rorH s-("8"8<=:]+G& #rBcDURS5nURX1US9$)zStops a cluster in a project. Args: request: (DataprocProjectsRegionsClustersStopRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. r)rNrPrSs r@r).DataprocV1.ProjectsRegionsClustersService.Stop rrBc D[R"SS/SQ/SQ/SSSSS S 9 $) NrZz'dataproc.projects.regions.clusters.stoprLrNzDv1/projects/{projectId}/regions/{region}/clusters/{clusterName}:stopstopClusterRequest*DataprocProjectsRegionsClustersStopRequestrFrGrlrnrBr@rorH s-!7!7;=:\*F& "rBcDURS5nURX1US9$)a?Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (DataprocProjectsRegionsClustersTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rrNrPrSs r@r[[RU]U5 0UlgrG)rrr3rrHrIs r@r.DataprocV1.ProjectsRegionsJobsService.__init__ s" J 1 14A&I drBcDURS5nURX1US9$)aStarts a job cancellation request. To access the job resource after cancellation, call regions/{region}/jobs.list (https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/list) or regions/{region}/jobs.get (https://cloud.google.com/dataproc/docs/reference/rest/v1/projects.regions.jobs/get). Args: request: (DataprocProjectsRegionsJobsCancelRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rrNrPrSs r@r,DataprocV1.ProjectsRegionsJobsService.Cancel rWrBc D[R"SS/SQ/SQ/SSSSS S 9 $) NrZz%dataproc.projects.regions.jobs.cancelrArBrrrArBz s-8#9#9974T(D  $rBcDURS5nURX1US9$)a7Deletes the job from the project. If the job is active, the delete fails, and the response returns FAILED_PRECONDITION. Args: request: (DataprocProjectsRegionsJobsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr,DataprocV1.ProjectsRegionsJobsService.Delete rWrBc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrvz%dataproc.projects.regions.jobs.deleterr5v1/projects/{projectId}/regions/{region}/jobs/{jobId}ry(DataprocProjectsRegionsJobsDeleteRequestr{FrGrlrnrBr@ror s-8#9#9974MD" $rBcDURS5nURX1US9$)zGets the resource representation for a job in a project. Args: request: (DataprocProjectsRegionsJobsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. r}rNrPrSs r@r})DataprocV1.ProjectsRegionsJobsService.Get rrBc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrz"dataproc.projects.regions.jobs.getrrrry%DataprocProjectsRegionsJobsGetRequestrFrGrlrnrBr@ror s- 6 6674MA  !rBcDURS5nURX1US9$)aDGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (DataprocProjectsRegionsJobsGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r2DataprocV1.ProjectsRegionsJobsService.GetIamPolicy# rrBcB[R"SSSS/S//SSSSS S 9 $) NzGv1/projects/{projectsId}/regions/{regionsId}/jobs/{jobsId}:getIamPolicyrZz+dataproc.projects.regions.jobs.getIamPolicyrrr.DataprocProjectsRegionsJobsGetIamPolicyRequestrFr`rlrnrBr@ror0 4)?)?[?"|L3+J# *rBcDURS5nURX1US9$)a8Exports the resource representation for a job in a project as a template that can be used as a SubmitJobRequest. Args: request: (DataprocProjectsRegionsJobsGetJobAsTemplateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. GetJobAsTemplaterNrPrSs r@r6DataprocV1.ProjectsRegionsJobsService.GetJobAsTemplate> rCrBc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrz/dataproc.projects.regions.jobs.getJobAsTemplaterrzFv1/projects/{projectId}/regions/{region}/jobs/{jobId}:getJobAsTemplatery2DataprocProjectsRegionsJobsGetJobAsTemplateRequestrFrGrlrnrBr@rorK s-X-C-CC74^N  .rBcDURS5nURX1US9$)zLists regions/{region}/jobs in a project. Args: request: (DataprocProjectsRegionsJobsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListJobsResponse) The response message. rrNrPrSs r@r*DataprocV1.ProjectsRegionsJobsService.ListX rrBc H[R"SSSS/SS//SQSSSS S S 9 $) Nrz#dataproc.projects.regions.jobs.listrArB)rMrjobStateMatcherrrz-v1/projects/{projectId}/regions/{region}/jobsry&DataprocProjectsRegionsJobsListRequestListJobsResponseFrGrlrnrBr@rore s7!7!77#X. (+ZEB- "rBcDURS5nURX1US9$)zUpdates a job in a project. Args: request: (DataprocProjectsRegionsJobsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rrNrPrSs r@r+DataprocV1.ProjectsRegionsJobsService.Patchr rrBc F[R"SS/SQ/SQS/SSSS S S 9 $) Nrz$dataproc.projects.regions.jobs.patchrrrxrjob'DataprocProjectsRegionsJobsPatchRequestrFrGrlrnrBr@ror s/("8"8874"^MC  #rBcDURS5nURX1US9$)acSets the access control policy on the specified resource. Replaces any existing policy.Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIED errors. Args: request: (DataprocProjectsRegionsJobsSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r2DataprocV1.ProjectsRegionsJobsService.SetIamPolicy rrBcB[R"SSSS/S//SSSSS S 9 $) NzGv1/projects/{projectsId}/regions/{regionsId}/jobs/{jobsId}:setIamPolicyrZz+dataproc.projects.regions.jobs.setIamPolicyrrr.DataprocProjectsRegionsJobsSetIamPolicyRequestrFr`rlrnrBr@ror rrBcDURS5nURX1US9$)zSubmits a job to a cluster. Args: request: (DataprocProjectsRegionsJobsSubmitRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. SubmitrNrPrSs r@r,DataprocV1.ProjectsRegionsJobsService.Submit rWrBc D[R"SSSS/SS//SSSSS S 9 $) NrZz%dataproc.projects.regions.jobs.submitrArBz4v1/projects/{projectId}/regions/{region}/jobs:submitsubmitJobRequest(DataprocProjectsRegionsJobsSubmitRequestrFrGrlrnrBr@ror s78#9#99#X. (+L(D  $rBcDURS5nURX1US9$)zSubmits job to a cluster. Args: request: (DataprocProjectsRegionsJobsSubmitAsOperationRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. SubmitAsOperationrNrPrSs r@r7DataprocV1.ProjectsRegionsJobsService.SubmitAsOperation rrBc D[R"SSSS/SS//SSSSS S 9 $) NrZz0dataproc.projects.regions.jobs.submitAsOperationrArBz?v1/projects/{projectId}/regions/{region}/jobs:submitAsOperationr3DataprocProjectsRegionsJobsSubmitAsOperationRequestrFrGrlrnrBr@ror s7h.D.DD#X. (+W(O& /rBcDURS5nURX1US9$)a;Returns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (DataprocProjectsRegionsJobsTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rrNrPrSs r@r8DataprocV1.ProjectsRegionsJobsService.TestIamPermissions rrBcB[R"SSSS/S//SSSSS S 9 $) NzMv1/projects/{projectsId}/regions/{regionsId}/jobs/{jobsId}:testIamPermissionsrZz1dataproc.projects.regions.jobs.testIamPermissionsrrr4DataprocProjectsRegionsJobsTestIamPermissionsRequestrFr`rlrnrBr@ror s4x/E/EaE"|L91P7 0rBrrG)rrrrrrrrrrrr}rrrrrrrrrrrs@r@r3r s? #E 8 F 8 F 8 C 8 "L 8 &" 8 D 8 E 8 "L 8 F 8 '# 8 ($$rBr3c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSrU=r$)+DataprocV1.ProjectsRegionsOperationsServicei z;Service class for the projects_regions_operations resource.r6cN>[[RU]U5 0UlgrG)rrr5rrHrIs r@r4DataprocV1.ProjectsRegionsOperationsService.__init__ rorBcDURS5nURX1US9$)a Starts asynchronous cancellation on a long-running operation. The server makes a best effort to cancel the operation, but success is not guaranteed. If the server doesn't support this method, it returns google.rpc.Code.UNIMPLEMENTED. Clients can use Operations.GetOperation or other methods to check whether the cancellation succeeded or whether the operation completed despite cancellation. On successful cancellation, the operation is not deleted; instead, it becomes an operation with an Operation.error value with a google.rpc.Status.code of 1, corresponding to Code.CANCELLED. Args: request: (DataprocProjectsRegionsOperationsCancelRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrNrPrSs r@r2DataprocV1.ProjectsRegionsOperationsService.CancelrWrBcB[R"SSSS/S//SSSSS S 9 $) NzMv1/projects/{projectsId}/regions/{regionsId}/operations/{operationsId}:cancelrZz+dataproc.projects.regions.operations.cancelrwrry.DataprocProjectsRegionsOperationsCancelRequestr{Fr`rlrnrBr@ro4DataprocV1.ProjectsRegionsOperationsService. s48#9#9a?xH)J" $rBcDURS5nURX1US9$)aDeletes a long-running operation. This method indicates that the client is no longer interested in the operation result. It does not cancel the operation. If the server doesn't support this method, it returns google.rpc.Code.UNIMPLEMENTED. Args: request: (DataprocProjectsRegionsOperationsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr2DataprocV1.ProjectsRegionsOperationsService.DeleterWrBcB[R"SSSS/S//SSSSS S 9 $) NFv1/projects/{projectsId}/regions/{regionsId}/operations/{operationsId}rvz+dataproc.projects.regions.operations.deleterwrxry.DataprocProjectsRegionsOperationsDeleteRequestr{Fr`rlrnrBr@ror(s48#9#9Z?xH"J" $rBcDURS5nURX1US9$)abGets the latest state of a long-running operation. Clients can use this method to poll the operation result at intervals as recommended by the API service. Args: request: (DataprocProjectsRegionsOperationsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. r}rNrPrSs r@r}/DataprocV1.ProjectsRegionsOperationsService.Get6rrBcB[R"SSSS/S//SSSSS S 9 $) Nrrz(dataproc.projects.regions.operations.getrwrxry+DataprocProjectsRegionsOperationsGetRequestrFr`rlrnrBr@rorCs4 6 6Z<xH"G& !rBcDURS5nURX1US9$)aJGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (DataprocProjectsRegionsOperationsGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r8DataprocV1.ProjectsRegionsOperationsService.GetIamPolicyQrrBcB[R"SSSS/S//SSSSS S 9 $) NzSv1/projects/{projectsId}/regions/{regionsId}/operations/{operationsId}:getIamPolicyrZz1dataproc.projects.regions.operations.getIamPolicyrrr4DataprocProjectsRegionsOperationsGetIamPolicyRequestrFr`rlrnrBr@ror^4)?)?gE"|L3+P# *rBcDURS5nURX1US9$)aZLists operations that match the specified filter in the request. If the server doesn't support this method, it returns UNIMPLEMENTED. Args: request: (DataprocProjectsRegionsOperationsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListOperationsResponse) The response message. rrNrPrSs r@r0DataprocV1.ProjectsRegionsOperationsService.ListlrrBcF[R"SSSS/S//SQSSSS S S 9 $) Nz7v1/projects/{projectsId}/regions/{regionsId}/operationsrz)dataproc.projects.regions.operations.listrwrrxry,DataprocProjectsRegionsOperationsListRequestrFr`rlrnrBr@rorys4!7!7K=xHP"H3 "rBcDURS5nURX1US9$)aiSets the access control policy on the specified resource. Replaces any existing policy.Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIED errors. Args: request: (DataprocProjectsRegionsOperationsSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r8DataprocV1.ProjectsRegionsOperationsService.SetIamPolicyrrBcB[R"SSSS/S//SSSSS S 9 $) NzSv1/projects/{projectsId}/regions/{regionsId}/operations/{operationsId}:setIamPolicyrZz1dataproc.projects.regions.operations.setIamPolicyrrr4DataprocProjectsRegionsOperationsSetIamPolicyRequestrFr`rlrnrBr@rorrrBcDURS5nURX1US9$)aAReturns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (DataprocProjectsRegionsOperationsTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rrNrPrSs r@r>DataprocV1.ProjectsRegionsOperationsService.TestIamPermissionsrrBcB[R"SSSS/S//SSSSS S 9 $) NzYv1/projects/{projectsId}/regions/{regionsId}/operations/{operationsId}:testIamPermissionsrZz7dataproc.projects.regions.operations.testIamPermissionsrrr:DataprocProjectsRegionsOperationsTestIamPermissionsRequestrFr`rlrnrBr@rors4x/E/EmK"|L91V7 0rBrrG)rrrrrrrrrrrr}rrrrrrrs@r@r5r s}E )E 8 F 8 F 8 C 8 "L 8 D 8 "L 8 ($$rBr5c4^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSSjrS\lSSjrS\lSSjrS\lSrU=r$)2DataprocV1.ProjectsRegionsWorkflowTemplatesServiceizBService class for the projects_regions_workflowTemplates resource.r8cN>[[RU]U5 0UlgrG)rrr7rrHrIs r@r;DataprocV1.ProjectsRegionsWorkflowTemplatesService.__init__s" J > >NvV drBcDURS5nURX1US9$)zCreates new workflow template. Args: request: (DataprocProjectsRegionsWorkflowTemplatesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (WorkflowTemplate) The response message. rMrNrPrSs r@rM9DataprocV1.ProjectsRegionsWorkflowTemplatesService.CreaterWrBcB[R"SSSS/S//SSSSS S 9 $) N>v1/projects/{projectsId}/regions/{regionsId}/workflowTemplatesrZz2dataproc.projects.regions.workflowTemplates.creater[rr5DataprocProjectsRegionsWorkflowTemplatesCreateRequestrFr`rlrnrBr@ro;DataprocV1.ProjectsRegionsWorkflowTemplatesService.s48#9#9RF zJ6(Q- $rBcDURS5nURX1US9$)aDeletes a workflow template. It does not cancel in-progress workflows. Args: request: (DataprocProjectsRegionsWorkflowTemplatesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rrrNrPrSs r@rr9DataprocV1.ProjectsRegionsWorkflowTemplatesService.DeleterWrBcD[R"SSSS/S/S/SSSS S S 9 $) NTv1/projects/{projectsId}/regions/{regionsId}/workflowTemplates/{workflowTemplatesId}rvz2dataproc.projects.regions.workflowTemplates.deleterwrrxry5DataprocProjectsRegionsWorkflowTemplatesDeleteRequestr{Fr`rlrnrBr@rors68#9#9hFxH["Q" $rBcDURS5nURX1US9$)aSRetrieves the latest workflow template.Can retrieve previously instantiated template by specifying optional version parameter. Args: request: (DataprocProjectsRegionsWorkflowTemplatesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (WorkflowTemplate) The response message. r}rNrPrSs r@r}6DataprocV1.ProjectsRegionsWorkflowTemplatesService.GetrrBcD[R"SSSS/S/S/SSSS S S 9 $) Nrrz/dataproc.projects.regions.workflowTemplates.getrwrrxry2DataprocProjectsRegionsWorkflowTemplatesGetRequestrFr`rlrnrBr@ror s6 6 6hCxH["N- !rBcDURS5nURX1US9$)aQGets the access control policy for a resource. Returns an empty policy if the resource exists and does not have a policy set. Args: request: (DataprocProjectsRegionsWorkflowTemplatesGetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r?DataprocV1.ProjectsRegionsWorkflowTemplatesService.GetIamPolicyrrBcB[R"SSSS/S//SSSSS S 9 $) Nzav1/projects/{projectsId}/regions/{regionsId}/workflowTemplates/{workflowTemplatesId}:getIamPolicyrZz8dataproc.projects.regions.workflowTemplates.getIamPolicyrrr;DataprocProjectsRegionsWorkflowTemplatesGetIamPolicyRequestrFr`rlrnrBr@ror%4)?)?uL"|L3+W# *rBcDURS5nURX1US9$)a~Instantiates a template and begins execution.The returned Operation can be used to track execution of workflow by polling operations.get. The Operation will complete when entire workflow is finished.The running workflow can be aborted via operations.cancel. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.The Operation.metadata will be WorkflowMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see Using WorkflowMetadata (https://cloud.google.com/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).On successful completion, Operation.response will be Empty. Args: request: (DataprocProjectsRegionsWorkflowTemplatesInstantiateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrNrPrSs r@r>DataprocV1.ProjectsRegionsWorkflowTemplatesService.Instantiate3rrBcB[R"SSSS/S//SSSSS S 9 $) Nz`v1/projects/{projectsId}/regions/{regionsId}/workflowTemplates/{workflowTemplatesId}:instantiaterZz7dataproc.projects.regions.workflowTemplates.instantiaterwrr:DataprocProjectsRegionsWorkflowTemplatesInstantiateRequestrFr`rlrnrBr@ror@s4(>(>tKxH.:V& )rBcDURS5nURX1US9$)aInstantiates a template and begins execution.This method is equivalent to executing the sequence CreateWorkflowTemplate, InstantiateWorkflowTemplate, DeleteWorkflowTemplate.The returned Operation can be used to track execution of workflow by polling operations.get. The Operation will complete when entire workflow is finished.The running workflow can be aborted via operations.cancel. This will cause any inflight jobs to be cancelled and workflow-owned clusters to be deleted.The Operation.metadata will be WorkflowMetadata (https://cloud.google.com/dataproc/docs/reference/rpc/google.cloud.dataproc.v1#workflowmetadata). Also see Using WorkflowMetadata (https://cloud.google.com/dataproc/docs/concepts/workflows/debugging#using_workflowmetadata).On successful completion, Operation.response will be Empty. Args: request: (DataprocProjectsRegionsWorkflowTemplatesInstantiateInlineRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrNrPrSs r@rDDataprocV1.ProjectsRegionsWorkflowTemplatesService.InstantiateInlineNrrBcD[R"SSSS/S/S/SSSS S S 9 $) NzPv1/projects/{projectsId}/regions/{regionsId}/workflowTemplates:instantiateInlinerZz=dataproc.projects.regions.workflowTemplates.instantiateInliner[rrr@DataprocProjectsRegionsWorkflowTemplatesInstantiateInlineRequestrFr`rlrnrBr@ror[s6h.D.DdQ zJ!]H(\& /rBcDURS5nURX1US9$)a"Lists workflows that match the specified filter in the request. Args: request: (DataprocProjectsRegionsWorkflowTemplatesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListWorkflowTemplatesResponse) The response message. rrNrPrSs r@r7DataprocV1.ProjectsRegionsWorkflowTemplatesService.ListirrBcF[R"SSSS/S/SS/SSS S S S 9 $) Nrrz0dataproc.projects.regions.workflowTemplates.listr[rrrry3DataprocProjectsRegionsWorkflowTemplatesListRequestrFr`rlrnrBr@rorvs9!7!7RD zJ +.6O: "rBcDURS5nURX1US9$)apSets the access control policy on the specified resource. Replaces any existing policy.Can return NOT_FOUND, INVALID_ARGUMENT, and PERMISSION_DENIED errors. Args: request: (DataprocProjectsRegionsWorkflowTemplatesSetIamPolicyRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Policy) The response message. rrNrPrSs r@r?DataprocV1.ProjectsRegionsWorkflowTemplatesService.SetIamPolicyrrBcB[R"SSSS/S//SSSSS S 9 $) Nzav1/projects/{projectsId}/regions/{regionsId}/workflowTemplates/{workflowTemplatesId}:setIamPolicyrZz8dataproc.projects.regions.workflowTemplates.setIamPolicyrrr;DataprocProjectsRegionsWorkflowTemplatesSetIamPolicyRequestrFr`rlrnrBr@rorr rBcDURS5nURX1US9$)aHReturns permissions that a caller has on the specified resource. If the resource does not exist, this will return an empty set of permissions, not a NOT_FOUND error.Note: This operation is designed to be used for building permission-aware UIs and command-line tools, not for authorization checking. This operation may "fail open" without warning. Args: request: (DataprocProjectsRegionsWorkflowTemplatesTestIamPermissionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TestIamPermissionsResponse) The response message. rrNrPrSs r@rEDataprocV1.ProjectsRegionsWorkflowTemplatesService.TestIamPermissionsrrBcB[R"SSSS/S//SSSSS S 9 $) Nzgv1/projects/{projectsId}/regions/{regionsId}/workflowTemplates/{workflowTemplatesId}:testIamPermissionsrZz>dataproc.projects.regions.workflowTemplates.testIamPermissionsrrrADataprocProjectsRegionsWorkflowTemplatesTestIamPermissionsRequestrFr`rlrnrBr@rors4x/E/E{R"|L91]7 0rBcDURS5nURX1US9$rrPrSs r@r9DataprocV1.ProjectsRegionsWorkflowTemplatesService.UpdaterWrBcB[R"SSSS/S//SSSSSS 9 $) Nrrz2dataproc.projects.regions.workflowTemplates.updaterwrxrrFr`rlrnrBr@rors48#9#9hFxH"!,- $rBrrGrrs@r@r7rsL 0E 8 F 8 F 8 C 8 "L 8 !K 8 '# 8 D 8 "L 8 ($ 8 FrBr7c0^\rSrSrSrSrU4SjrSrU=r$)!DataprocV1.ProjectsRegionsServiceiz0Service class for the projects_regions resource.r:cN>[[RU]U5 0UlgrG)rrr9rrHrIs r@r*DataprocV1.ProjectsRegionsService.__init__s" J - -t=fE drBrrrs@r@r9r"s: E  rBr9c0^\rSrSrSrSrU4SjrSrU=r$)DataprocV1.ProjectsServiceiz(Service class for the projects resource.r<cN>[[RU]U5 0UlgrG)rrr;rrHrIs r@r#DataprocV1.ProjectsService.__init__s" J & &6v> drBrrrs@r@r;r&s2 E  rBr;)r<r,rr rr"r$r(r&r*r:r.r2r0r4r6r8) ryNTNNFFNNNN)(rrrrrmessagesMESSAGES_MODULEr MTLS_BASE_URL_PACKAGE_SCOPES_VERSION _CLIENT_ID_CLIENT_SECRET _USER_AGENT_CLIENT_CLASS_NAME _URL_VERSION_API_KEYrrBaseApiServicerrrr!r#r%r'r)r+r-r/r1r3r5r7r9r;rrrs@r@rr sA/ /(9- ( = >' (*"."+#, ()-6:/4<@?C /B`H4K4K`Du 9P9Pu nO(?(?Obt8+B+BtlO1H1HObu (:Q:Qu nO)@)@ObV(2I2IVp !8!8 `(2I2I`DV1H1HVpxx'>'>xt i8#:#:iV E)@)@ENV0G0GVp x66  //  rBrN) r __future__rapitools.base.pyr1googlecloudsdk.generated_clients.apis.dataproc.v1rr) BaseApiClientrrnrBr@r:s'7'%^]? '']? rB