0VSrSSKJr SSKJr SSKJr "SS\R5r g)z3Generated client library for dataflow version v1b3.)absolute_import)base_api)dataflow_v1b3_messagesc^\rSrSrSr\rSrSrSr SS/r Sr S r S r S rSrSrS rS9U4S jjr"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.S/\R(5r%"S0S1\R(5r&"S2S3\R(5r'"S4S5\R(5r("S6S7\R(5r)S8r*U=r+$): DataflowV1b3 z;Generated client library for service dataflow version v1b3.z https://dataflow.googleapis.com/z%https://dataflow.mtls.googleapis.com/dataflowz.https://www.googleapis.com/auth/cloud-platformz'https://www.googleapis.com/auth/computev1b3 CLIENT_ID CLIENT_SECRETzgoogle-cloud-sdkNc >U=(d URn[[U]XX4UXgUU U U S9 UR U5UlUR U5UlURU5Ul URU5Ul URU5Ul URU5UlUR!U5UlUR%U5UlUR)U5UlUR-U5UlUR1U5UlUR5U5UlUR9U5UlUR=U5UlURAU5Ul!UREU5Ul#URIU5Ul%URMU5Ul'URQU5Ul)URUU5Ul+URYU5Ul-g)zCreate a new dataflow handle.) credentialsget_credentialshttpmodel log_request log_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN).BASE_URLsuperr__init__/ProjectsCatalogTemplatesTemplateVersionsService*projects_catalogTemplates_templateVersionsProjectsCatalogTemplatesServiceprojects_catalogTemplatesProjectsJobsDebugServiceprojects_jobs_debugProjectsJobsMessagesServiceprojects_jobs_messagesProjectsJobsWorkItemsServiceprojects_jobs_workItemsProjectsJobsService projects_jobs#ProjectsLocationsDeploymentsServiceprojects_locations_deployments%ProjectsLocationsFlexTemplatesService projects_locations_flexTemplates!ProjectsLocationsJobsDebugServiceprojects_locations_jobs_debug$ProjectsLocationsJobsMessagesService projects_locations_jobs_messages%ProjectsLocationsJobsSnapshotsService!projects_locations_jobs_snapshots"ProjectsLocationsJobsStagesServiceprojects_locations_jobs_stages%ProjectsLocationsJobsWorkItemsService!projects_locations_jobs_workItemsProjectsLocationsJobsServiceprojects_locations_jobs!ProjectsLocationsSnapshotsServiceprojects_locations_snapshots!ProjectsLocationsTemplatesServiceprojects_locations_templatesProjectsLocationsServiceprojects_locationsProjectsSnapshotsServiceprojects_snapshotsProjectsTemplateVersionsServiceprojects_templateVersionsProjectsTemplatesServiceprojects_templatesProjectsServiceprojects) selfurlrrrrrrrrrr __class__s Olib/googlecloudsdk/generated_clients/apis/dataflow/v1b3/dataflow_v1b3_client.pyrDataflowV1b3.__init__s  C ,& '%)3 7+'-7;6j6jko6pD3%)%I%I$%OD"#<[[RU]U5 0UlgN)rrrr_upload_configsrEclientrGs rHrEDataflowV1b3.ProjectsCatalogTemplatesTemplateVersionsService.__init__Es# L H H$XY_` drJcDURS5nURX1US9$)aCreates a new Template with TemplateVersion. Requires project_id(projects) and template display_name(catalogTemplates). The template display_name is set by the user. Args: request: (DataflowProjectsCatalogTemplatesTemplateVersionsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TemplateVersion) The response message. Create global_paramsGetMethodConfig _RunMethodrErequestrWconfigs rHrUCDataflowV1b3.ProjectsCatalogTemplatesTemplateVersionsService.CreateJ/##H-f __ 88rJcB[R"SSSS/S//SSSSS S 9 $) NzQv1b3/projects/{projectsId}/catalogTemplates/{catalogTemplatesId}/templateVersionsPOSTz:dataflow.projects.catalogTemplates.templateVersions.createparentv1b3/{+parent}/templateVersionscreateTemplateVersionRequest=DataflowProjectsCatalogTemplatesTemplateVersionsCreateRequestTemplateVersionF flat_path http_method method_idordered_params path_params query_params relative_path request_fieldrequest_type_nameresponse_type_namesupports_downloadr ApiMethodInforJrHEDataflowV1b3.ProjectsCatalogTemplatesTemplateVersionsService.Ws48#9#9eN zJ74Y, $rJrPrO) __name__ __module__ __qualname____firstlineno____doc___NAMErrU method_config__static_attributes__ __classcell__rGs@rHrrL@s"T 8E 8 FrJrc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$),DataflowV1b3.ProjectsCatalogTemplatesServiceez9Service class for the projects_catalogTemplates resource.rcN>[[RU]U5 0UlgrO)rrrrrPrQs rHr5DataflowV1b3.ProjectsCatalogTemplatesService.__init__j" L 8 8$HP drJcDURS5nURX1US9$)aWCreates a new TemplateVersion (Important: not new Template) entry in the spanner table. Requires project_id and display_name (template). Args: request: (DataflowProjectsCatalogTemplatesCommitRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TemplateVersion) The response message. CommitrVrXr[s rHr3DataflowV1b3.ProjectsCatalogTemplatesService.Commitor_rJcB[R"SSSS/S//SSSSS S 9 $) NzGv1b3/projects/{projectsId}/catalogTemplates/{catalogTemplatesId}:commitraz)dataflow.projects.catalogTemplates.commitnamezv1b3/{+name}:commitcommitTemplateVersionRequest-DataflowProjectsCatalogTemplatesCommitRequestrfFrgrsrurJrHrv5DataflowV1b3.ProjectsCatalogTemplatesService.|s48#9#9[=xH+4I, $rJcDURS5nURX1US9$)a Deletes an existing Template. Do nothing if Template does not exist. Args: request: (DataflowProjectsCatalogTemplatesDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. DeleterVrXr[s rHr3DataflowV1b3.ProjectsCatalogTemplatesService.Deleter_rJcB[R"SSSS/S//SSSSS S 9 $) N@v1b3/projects/{projectsId}/catalogTemplates/{catalogTemplatesId}DELETEz)dataflow.projects.catalogTemplates.deleter v1b3/{+name}-DataflowProjectsCatalogTemplatesDeleteRequestEmptyFrgrsrurJrHrvrs48#9#9T=xH$I" $rJcDURS5nURX1US9$)aiGet TemplateVersion using project_id and display_name with an optional version_id field. Get latest (has tag "latest") TemplateVersion if version_id not set. Args: request: (DataflowProjectsCatalogTemplatesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TemplateVersion) The response message. GetrVrXr[s rHr0DataflowV1b3.ProjectsCatalogTemplatesService.Get/##E*f __ 88rJcB[R"SSSS/S//SSSSS S 9 $) NrGETz&dataflow.projects.catalogTemplates.getrrr*DataflowProjectsCatalogTemplatesGetRequestrfFrgrsrurJrHrvrs4 6 6T:xH$F, !rJcDURS5nURX1US9$)aiUpdates the label of the TemplateVersion. Label can be duplicated in Template, so either add or remove the label in the TemplateVersion. Args: request: (DataflowProjectsCatalogTemplatesLabelRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ModifyTemplateVersionLabelResponse) The response message. LabelrVrXr[s rHr2DataflowV1b3.ProjectsCatalogTemplatesService.Label/##G,f __ 88rJcB[R"SSSS/S//SSSSS S 9 $) NzFv1b3/projects/{projectsId}/catalogTemplates/{catalogTemplatesId}:labelraz(dataflow.projects.catalogTemplates.labelrzv1b3/{+name}:label!modifyTemplateVersionLabelRequest,DataflowProjectsCatalogTemplatesLabelRequest"ModifyTemplateVersionLabelResponseFrgrsrurJrHrvrs4("8"8Z<xH*9H? #rJcDURS5nURX1US9$)a/Updates the tag of the TemplateVersion, and tag is unique in Template. If tag exists in another TemplateVersion in the Template, updates the tag to this TemplateVersion will remove it from the old TemplateVersion and add it to this TemplateVersion. If request is remove_only (remove_only = true), remove the tag from this TemplateVersion. Args: request: (DataflowProjectsCatalogTemplatesTagRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ModifyTemplateVersionTagResponse) The response message. TagrVrXr[s rHr0DataflowV1b3.ProjectsCatalogTemplatesService.TagrrJcB[R"SSSS/S//SSSSS S 9 $) NzDv1b3/projects/{projectsId}/catalogTemplates/{catalogTemplatesId}:tagraz&dataflow.projects.catalogTemplates.tagrzv1b3/{+name}:tagmodifyTemplateVersionTagRequest*DataflowProjectsCatalogTemplatesTagRequest ModifyTemplateVersionTagResponseFrgrsrurJrHrvrs4 6 6X:xH(7F= !rJrxrO)ryrzr{r|r}r~rrrrrrrrrrs@rHrres^C 'E 8 F 8 F 8 C 8 E 8 CrJrcd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) %DataflowV1b3.ProjectsJobsDebugServicez3Service class for the projects_jobs_debug resource.r cN>[[RU]U5 0UlgrO)rrrrrPrQs rHr.DataflowV1b3.ProjectsJobsDebugService.__init__" L 1 14A&I drJcDURS5nURX1US9$)aGet encoded debug configuration for component. Not cacheable. Args: request: (DataflowProjectsJobsDebugGetConfigRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (GetDebugConfigResponse) The response message. GetConfigrVrXr[s rHr/DataflowV1b3.ProjectsJobsDebugService.GetConfig/##K0f __ 88rJc D[R"SSSS/SS//SSSSS S 9 $) Nraz&dataflow.projects.jobs.debug.getConfig projectIdjobIdz6v1b3/projects/{projectId}/jobs/{jobId}/debug/getConfiggetDebugConfigRequest)DataflowProjectsJobsDebugGetConfigRequestGetDebugConfigResponseF rirjrkrlrmrnrorprqrrrsrurJrHrv.DataflowV1b3.ProjectsJobsDebugService. s7h&<&<:#W-k*N-E3 'rJcDURS5nURX1US9$)aSend encoded debug capture data for component. Args: request: (DataflowProjectsJobsDebugSendCaptureRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SendDebugCaptureResponse) The response message. SendCapturerVrXr[s rHr1DataflowV1b3.ProjectsJobsDebugService.SendCapture/##M2f __ 88rJc D[R"SSSS/SS//SSSSS S 9 $) Nraz(dataflow.projects.jobs.debug.sendCapturerrz8v1b3/projects/{projectId}/jobs/{jobId}/debug/sendCapturesendDebugCaptureRequest+DataflowProjectsJobsDebugSendCaptureRequestSendDebugCaptureResponseFrrsrurJrHrvr's7(>(><#W-k*P/G5 )rJrxrO) ryrzr{r|r}r~rrrrrrrs@rHrrs1= !E 8 I 8 !KrJrcJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) (DataflowV1b3.ProjectsJobsMessagesServicei4z6Service class for the projects_jobs_messages resource.r"cN>[[RU]U5 0UlgrO)rrr!rrPrQs rHr1DataflowV1b3.ProjectsJobsMessagesService.__init__9s" L 4 4dDVL drJcDURS5nURX1US9$)a*Request the job status. To request the status of a job, we recommend using `projects.locations.jobs.messages.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.messages.list` is not recommended, as you can only request the status of jobs that are running in `us-central1`. Args: request: (DataflowProjectsJobsMessagesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListJobMessagesResponse) The response message. ListrVrXr[s rHr-DataflowV1b3.ProjectsJobsMessagesService.List>/##F+f __ 88rJc H[R"SSSS/SS//SQSSSS S S 9 $) Nrz$dataflow.projects.jobs.messages.listrr)endTimelocationminimumImportancepageSize pageToken startTimez/v1b3/projects/{projectId}/jobs/{jobId}/messagesr'DataflowProjectsJobsMessagesListRequestListJobMessagesResponseFrrsrurJrHrv1DataflowV1b3.ProjectsJobsMessagesService.Ks7!7!78#W-k*gGC4 "rJrxrO ryrzr{r|r}r~rrrrrrs@rHr!r4s"@ $E 8 DrJr!cd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) )DataflowV1b3.ProjectsJobsWorkItemsServiceiXz7Service class for the projects_jobs_workItems resource.r$cN>[[RU]U5 0UlgrO)rrr#rrPrQs rHr2DataflowV1b3.ProjectsJobsWorkItemsService.__init__]" L 5 5tEfM drJcDURS5nURX1US9$)zLeases a dataflow WorkItem to run. Args: request: (DataflowProjectsJobsWorkItemsLeaseRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (LeaseWorkItemResponse) The response message. LeaserVrXr[s rHr/DataflowV1b3.ProjectsJobsWorkItemsService.LeasebrrJc D[R"SSSS/SS//SSSSS S 9 $) Nraz&dataflow.projects.jobs.workItems.leaserrz6v1b3/projects/{projectId}/jobs/{jobId}/workItems:leaseleaseWorkItemRequest)DataflowProjectsJobsWorkItemsLeaseRequestLeaseWorkItemResponseFrrsrurJrHrv2DataflowV1b3.ProjectsJobsWorkItemsService.os7("8"8:#W-k*N,E2 #rJcDURS5nURX1US9$)aReports the status of dataflow WorkItems leased by a worker. Args: request: (DataflowProjectsJobsWorkItemsReportStatusRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ReportWorkItemStatusResponse) The response message. ReportStatusrVrXr[s rHr6DataflowV1b3.ProjectsJobsWorkItemsService.ReportStatus|/##N3f __ 88rJc D[R"SSSS/SS//SSSSS S 9 $) Nraz-dataflow.projects.jobs.workItems.reportStatusrrz=v1b3/projects/{projectId}/jobs/{jobId}/workItems:reportStatusreportWorkItemStatusRequest0DataflowProjectsJobsWorkItemsReportStatusRequestReportWorkItemStatusResponseFrrsrurJrHrvrs7)?)?A#W-k*U3L9 *rJrxrO ryrzr{r|r}r~rrrrrrrs@rHr#rXs1A %E 8 E 8 "LrJr#c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSrU=r$) DataflowV1b3.ProjectsJobsServiceiz-Service class for the projects_jobs resource.r&cN>[[RU]U5 0UlgrO)rrr%rrPrQs rHr)DataflowV1b3.ProjectsJobsService.__init__s" L , ,ds1x'='=5#} MTAA- (rJcDURS5nURX1US9$)a(Creates a Dataflow job. To create a job, we recommend using `projects.locations.jobs.create` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.create` is not recommended, as your job will always start in `us-central1`. Do not enter confidential information when you supply string values using the API. Args: request: (DataflowProjectsJobsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rUrVrXr[s rHrU'DataflowV1b3.ProjectsJobsService.Creater_rJc D[R"SSS/S//SQSSSSS S 9 $) Nrazdataflow.projects.jobs.creater)r replaceJobIdrv1b3/projects/{projectId}/jobsjob!DataflowProjectsJobsCreateRequestJobFrrsrurJrHrvrs18#9#91#} M96=  $rJcDURS5nURX1US9$)a Gets the state of the specified Cloud Dataflow job. To get the state of a job, we recommend using `projects.locations.jobs.get` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.get` is not recommended, as you can only get the state of jobs that are running in `us-central1`. Args: request: (DataflowProjectsJobsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rrVrXr[s rHr$DataflowV1b3.ProjectsJobsService.GetrrJc H[R"SSSS/SS/SS/SSS S S S 9 $) Nrzdataflow.projects.jobs.getrrrr&v1b3/projects/{projectId}/jobs/{jobId}rDataflowProjectsJobsGetRequestr FrrsrurJrHrvrs< 6 6.#W-k* &)>:  !rJcDURS5nURX1US9$)aRequest the job status. To request the status of a job, we recommend using `projects.locations.jobs.getMetrics` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.getMetrics` is not recommended, as you can only request the status of jobs that are running in `us-central1`. Args: request: (DataflowProjectsJobsGetMetricsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (JobMetrics) The response message. GetMetricsrVrXr[s rHr+DataflowV1b3.ProjectsJobsService.GetMetricsrrJc H[R"SSSS/SS/SS/SSS S S S 9 $) Nrz!dataflow.projects.jobs.getMetricsrrrrz.v1b3/projects/{projectId}/jobs/{jobId}/metricsr%DataflowProjectsJobsGetMetricsRequest JobMetricsFrrsrurJrHrvrs<x'='=5#W-k* +.FA' (rJcDURS5nURX1US9$)aList the jobs of a project. To list the jobs of a project in a region, we recommend using `projects.locations.jobs.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). To list the all jobs across all regions, use `projects.jobs.aggregated`. Using `projects.jobs.list` is not recommended, because you can only get the list of jobs that are running in `us-central1`. `projects.locations.jobs.list` and `projects.jobs.list` support filtering the list of jobs by name. Filtering by name isn't supported by `projects.jobs.aggregated`. Args: request: (DataflowProjectsJobsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListJobsResponse) The response message. rrVrXr[s rHr%DataflowV1b3.ProjectsJobsService.ListrrJc D[R"SSS/S//SQSSSSS S 9 $) Nrzdataflow.projects.jobs.listrrrrDataflowProjectsJobsListRequestrFrrsrurJrHrvrs1!7!7/#} MT6;- "rJcDURS5nURX1US9$)zSnapshot the state of a streaming job. Args: request: (DataflowProjectsJobsSnapshotRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Snapshot) The response message. SnapshotrVrXr[s rHr)DataflowV1b3.ProjectsJobsService.Snapshot"/##J/f __ 88rJc D[R"SSSS/SS//SSSSS S 9 $) Nrazdataflow.projects.jobs.snapshotrrz/v1b3/projects/{projectId}/jobs/{jobId}:snapshotsnapshotJobRequest#DataflowProjectsJobsSnapshotRequestrFrrsrurJrHrvr/s7X%;%;3#W-k*G*?% &rJcDURS5nURX1US9$)a%Updates the state of an existing Cloud Dataflow job. To update the state of an existing job, we recommend using `projects.locations.jobs.update` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.update` is not recommended, as you can only update the state of jobs that are running in `us-central1`. Args: request: (DataflowProjectsJobsUpdateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. UpdaterVrXr[s rHr"'DataflowV1b3.ProjectsJobsService.Update<r_rJc H[R"SSSS/SS/SS/SSS S S S 9 $) NPUTzdataflow.projects.jobs.updaterrr updateMaskrr!DataflowProjectsJobsUpdateRequestr FrrsrurJrHrvrIs<8#9#91#W-k* ,/>=  $rJrxrO)ryrzr{r|r}r~rrrrUrrrrr"rrrs@rHr%rs|7 E 8 J 8 F 8 C 8 J 8 D 8 H 8 FrJr%c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSrU=r$)0DataflowV1b3.ProjectsLocationsDeploymentsServiceiVz>Service class for the projects_locations_deployments resource.r(cN>[[RU]U5 0UlgrO)rrr'rrPrQs rHr9DataflowV1b3.ProjectsLocationsDeploymentsService.__init__[s" L < v1b3/projects/{projectsId}/locations/{locationsId}/deploymentsraz.dataflow.projects.locations.deployments.createrb) deploymentId requestId validateOnlyv1b3/{+parent}/deployments deployment1DataflowProjectsLocationsDeploymentsCreateRequest OperationFrgrsrurJrHrv9DataflowV1b3.ProjectsLocationsDeploymentsService.ms48#9#9RB zJB2"M& $rJcDURS5nURX1US9$)aRequest that deletes `Deployment`. The result is an `Operation` which can be used to track the creation process. This process usually takes a few seconds, but can sometimes take much longer. The tracking `Operation` is automatically deleted after a few hours, so there is no need to call `DeleteOperation`. Args: request: (DataflowProjectsLocationsDeploymentsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrVrXr[s rHr7DataflowV1b3.ProjectsLocationsDeploymentsService.Delete{r_rJcF[R"SSSS/S//SQSSSS S S 9 $) NNv1b3/projects/{projectsId}/locations/{locationsId}/deployments/{deploymentsId}rz.dataflow.projects.locations.deployments.deleter) allowMissingetagr2rr1DataflowProjectsLocationsDeploymentsDeleteRequestr6FrgrsrurJrHrvr7s48#9#9bBxH=$M& $rJcDURS5nURX1US9$)zRequest to get Deployment. Args: request: (DataflowProjectsLocationsDeploymentsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Deployment) The response message. rrVrXr[s rHr4DataflowV1b3.ProjectsLocationsDeploymentsService.GetrrJcD[R"SSSS/S/S/SSSS S S 9 $) Nr;rz+dataflow.projects.locations.deployments.getrrrr.DataflowProjectsLocationsDeploymentsGetRequest DeploymentFrgrsrurJrHrvr7s6 6 6b?xHX$J' !rJcDURS5nURX1US9$)zRequest that lists `Deployments`. Args: request: (DataflowProjectsLocationsDeploymentsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListDeploymentsResponse) The response message. rrVrXr[s rHr5DataflowV1b3.ProjectsLocationsDeploymentsService.ListrrJcF[R"SSSS/S/SS/SSS S S S 9 $) Nr/rz,dataflow.projects.locations.deployments.listrbrrr3r/DataflowProjectsLocationsDeploymentsListRequestListDeploymentsResponseFrgrsrurJrHrvr7s9!7!7R@ zJ +.2K4 "rJcDURS5nURX1US9$)aRequest that lists revisions of a `Deployment`. Args: request: (DataflowProjectsLocationsDeploymentsListRevisionsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListDeploymentRevisionsResponse) The response message. ListRevisionsrVrXr[s rHrJ>DataflowV1b3.ProjectsLocationsDeploymentsService.ListRevisionss/##O4f __ 88rJcF[R"SSSS/S/SS/SSS S S S 9 $) Nz\v1b3/projects/{projectsId}/locations/{locationsId}/deployments/{deploymentsId}:listRevisionsrz5dataflow.projects.locations.deployments.listRevisionsrrrzv1b3/{+name}:listRevisionsr8DataflowProjectsLocationsDeploymentsListRevisionsRequestListDeploymentRevisionsResponseFrgrsrurJrHrvr7s9(*@*@pIxH +.2T< +rJcDURS5nURX1US9$)a!Request that updates or optionally creates a new `Deployment`. The result is an `Operation` which can be used to track the update/creation process. This process usually takes a few seconds, but can sometimes take much longer. The tracking `Operation` is automatically deleted after a few hours, so there is no need to call `DeleteOperation`. Args: request: (DataflowProjectsLocationsDeploymentsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. PatchrVrXr[s rHrP6DataflowV1b3.ProjectsLocationsDeploymentsService.PatchrrJcF[R"SSSS/S//SQSSSS S S 9 $) Nr;PATCHz-dataflow.projects.locations.deployments.patchr)r<r1r&r2rr40DataflowProjectsLocationsDeploymentsPatchRequestr6FrgrsrurJrHrvr7s4("8"8bAxHP$"L& #rJcDURS5nURX1US9$)aRequest that rollback `Deployment` to any of the previous revisions. Args: request: (DataflowProjectsLocationsDeploymentsRollbackRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. RollbackrVrXr[s rHrV9DataflowV1b3.ProjectsLocationsDeploymentsService.RollbackrrJcB[R"SSSS/S//SSSSS S 9 $) NzWv1b3/projects/{projectsId}/locations/{locationsId}/deployments/{deploymentsId}:rollbackraz0dataflow.projects.locations.deployments.rollbackrzv1b3/{+name}:rollbackrollbackDeploymentRequest3DataflowProjectsLocationsDeploymentsRollbackRequestr6FrgrsrurJrHrvr7s4X%;%;kDxH-1O& &rJrxrO)ryrzr{r|r}r~rrUrrrrrJrPrVrrrs@rHr'r)Vs|H ,E 8 F 8 F 8 C 8 D 8 #M 8 E 8 HrJr'cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) 2DataflowV1b3.ProjectsLocationsFlexTemplatesServiceiz@Service class for the projects_locations_flexTemplates resource.r*cN>[[RU]U5 0UlgrO)rrr)rrPrQs rHr;DataflowV1b3.ProjectsLocationsFlexTemplatesService.__init__"" L > >NvV drJcDURS5nURX1US9$)aLaunch a job with a FlexTemplate. Args: request: (DataflowProjectsLocationsFlexTemplatesLaunchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (LaunchFlexTemplateResponse) The response message. LaunchrVrXr[s rHra9DataflowV1b3.ProjectsLocationsFlexTemplatesService.Launch'r_rJc D[R"SSSS/SS//SSSSS S 9 $) Nraz0dataflow.projects.locations.flexTemplates.launchrrzCv1b3/projects/{projectId}/locations/{location}/flexTemplates:launchlaunchFlexTemplateRequest3DataflowProjectsLocationsFlexTemplatesLaunchRequestLaunchFlexTemplateResponseFrrsrurJrHrv;DataflowV1b3.ProjectsLocationsFlexTemplatesService.4s78#9#9D#Z0-[1O7 $rJrxrO) ryrzr{r|r}r~rrarrrrs@rHr)r\s"J .E 8 FrJr)c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) .DataflowV1b3.ProjectsLocationsJobsDebugServiceiAz=Service class for the projects_locations_jobs_debug resource.r,cN>[[RU]U5 0UlgrO)rrr+rrPrQs rHr7DataflowV1b3.ProjectsLocationsJobsDebugService.__init__F" L : :DJ6R drJcDURS5nURX1US9$)aGet encoded debug configuration for component. Not cacheable. Args: request: (DataflowProjectsLocationsJobsDebugGetConfigRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (GetDebugConfigResponse) The response message. rrVrXr[s rHr8DataflowV1b3.ProjectsLocationsJobsDebugService.GetConfigKrrJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nraz0dataflow.projects.locations.jobs.debug.getConfigrrrrrrzKv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/debug/getConfigr2DataflowProjectsLocationsJobsDebugGetConfigRequestrFrrsrurJrHrv7DataflowV1b3.ProjectsLocationsJobsDebugService.Xs-h&<&<D96c-N3 'rJcDURS5nURX1US9$)aGet worker stacktraces from debug capture. Args: request: (DataflowProjectsLocationsJobsDebugGetWorkerStacktracesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (GetWorkerStacktracesResponse) The response message. GetWorkerStacktracesrVrXr[s rHruCDataflowV1b3.ProjectsLocationsJobsDebugService.GetWorkerStacktraceses0##$:;f __ 88rJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nraz;dataflow.projects.locations.jobs.debug.getWorkerStacktracesrprqzVv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/debug/getWorkerStacktracesgetWorkerStacktracesRequest=DataflowProjectsLocationsJobsDebugGetWorkerStacktracesRequestGetWorkerStacktracesResponseFrrsrurJrHrvrsrs-1G1GO96n3Y9 2rJcDURS5nURX1US9$)a Send encoded debug capture data for component. Args: request: (DataflowProjectsLocationsJobsDebugSendCaptureRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SendDebugCaptureResponse) The response message. rrVrXr[s rHr:DataflowV1b3.ProjectsLocationsJobsDebugService.SendCapturerrJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nraz2dataflow.projects.locations.jobs.debug.sendCapturerprqzMv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/debug/sendCapturer4DataflowProjectsLocationsJobsDebugSendCaptureRequestrFrrsrurJrHrvrss-(>(>F96e/P5 )rJrxrO) ryrzr{r|r}r~rrrrurrrrs@rHr+riAsAG +E 8 I 8 *& 8 !KrJr+cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) 1DataflowV1b3.ProjectsLocationsJobsMessagesServiceiz@Service class for the projects_locations_jobs_messages resource.r.cN>[[RU]U5 0UlgrO)rrr-rrPrQs rHr:DataflowV1b3.ProjectsLocationsJobsMessagesService.__init__s" L = =tMfU drJcDURS5nURX1US9$)a3Request the job status. To request the status of a job, we recommend using `projects.locations.jobs.messages.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.messages.list` is not recommended, as you can only request the status of jobs that are running in `us-central1`. Args: request: (DataflowProjectsLocationsJobsMessagesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListJobMessagesResponse) The response message. rrVrXr[s rHr6DataflowV1b3.ProjectsLocationsJobsMessagesService.ListrrJc H[R"SS/SQ/SQ/SQSSSS S S 9 $) Nrz.dataflow.projects.locations.jobs.messages.listrprq)rrrrrzDv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/messagesr0DataflowProjectsLocationsJobsMessagesListRequestrFrrsrurJrHrv:DataflowV1b3.ProjectsLocationsJobsMessagesService.s-!7!7B96[\L4 "rJrxrOrrs@rHr-rs"J .E 8 DrJr-cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) 2DataflowV1b3.ProjectsLocationsJobsSnapshotsServiceizAService class for the projects_locations_jobs_snapshots resource.r0cN>[[RU]U5 0UlgrO)rrr/rrPrQs rHr;DataflowV1b3.ProjectsLocationsJobsSnapshotsService.__init__r_rJcDURS5nURX1US9$)zLists snapshots. Args: request: (DataflowProjectsLocationsJobsSnapshotsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSnapshotsResponse) The response message. rrVrXr[s rHr7DataflowV1b3.ProjectsLocationsJobsSnapshotsService.ListrrJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrz/dataflow.projects.locations.jobs.snapshots.listrprqzEv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/snapshotsr1DataflowProjectsLocationsJobsSnapshotsListRequestListSnapshotsResponseFrrsrurJrHrv;DataflowV1b3.ProjectsLocationsJobsSnapshotsService.s-!7!7C96]M2 "rJrxrOrrs@rHr/rs"K /E 8 DrJr/cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) /DataflowV1b3.ProjectsLocationsJobsStagesServiceiz>Service class for the projects_locations_jobs_stages resource.r2cN>[[RU]U5 0UlgrO)rrr1rrPrQs rHr8DataflowV1b3.ProjectsLocationsJobsStagesService.__init__s" L ; ;TKFS drJcDURS5nURX1US9$)azRequest detailed information about the execution status of a stage of the job. EXPERIMENTAL. This API is subject to change or removal without notice. Args: request: (DataflowProjectsLocationsJobsStagesGetExecutionDetailsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (StageExecutionDetails) The response message. GetExecutionDetailsrVrXr[s rHrCDataflowV1b3.ProjectsLocationsJobsStagesService.GetExecutionDetails0##$9:f __ 88rJc H[R"SS/SQ/SQ/SQSSSS S S 9 $) Nrz;dataflow.projects.locations.jobs.stages.getExecutionDetails)rrrstageId)rrrr)rrrrz]v1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/stages/{stageId}/executionDetailsr=DataflowProjectsLocationsJobsStagesGetExecutionDetailsRequestStageExecutionDetailsFrrsrurJrHrv8DataflowV1b3.ProjectsLocationsJobsStagesService.s-0F0FODAFuY2 1rJrxrO) ryrzr{r|r}r~rrrrrrs@rHr1rs#H ,E 8 )%%rJr1cd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) 2DataflowV1b3.ProjectsLocationsJobsWorkItemsServiceizAService class for the projects_locations_jobs_workItems resource.r4cN>[[RU]U5 0UlgrO)rrr3rrPrQs rHr;DataflowV1b3.ProjectsLocationsJobsWorkItemsService.__init__ r_rJcDURS5nURX1US9$)zLeases a dataflow WorkItem to run. Args: request: (DataflowProjectsLocationsJobsWorkItemsLeaseRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (LeaseWorkItemResponse) The response message. rrVrXr[s rHr8DataflowV1b3.ProjectsLocationsJobsWorkItemsService.LeaserrJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nraz0dataflow.projects.locations.jobs.workItems.leaserprqzKv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/workItems:leaser2DataflowProjectsLocationsJobsWorkItemsLeaseRequestrFrrsrurJrHrv;DataflowV1b3.ProjectsLocationsJobsWorkItemsService.s-("8"8D96c,N2 #rJcDURS5nURX1US9$)a$Reports the status of dataflow WorkItems leased by a worker. Args: request: (DataflowProjectsLocationsJobsWorkItemsReportStatusRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ReportWorkItemStatusResponse) The response message. rrVrXr[s rHr?DataflowV1b3.ProjectsLocationsJobsWorkItemsService.ReportStatus)rrJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nraz7dataflow.projects.locations.jobs.workItems.reportStatusrprqzRv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/workItems:reportStatusr9DataflowProjectsLocationsJobsWorkItemsReportStatusRequestrFrrsrurJrHrvr6s-)?)?K96j3U9 *rJrxrOrrs@rHr3rs1K /E 8 E 8 "LrJr3c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSrU=r$))DataflowV1b3.ProjectsLocationsJobsServiceiCz7Service class for the projects_locations_jobs resource.r6cN>[[RU]U5 0UlgrO)rrr5rrPrQs rHr2DataflowV1b3.ProjectsLocationsJobsService.__init__HrrJcDURS5nURX1US9$)a1Creates a Dataflow job. To create a job, we recommend using `projects.locations.jobs.create` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.create` is not recommended, as your job will always start in `us-central1`. Do not enter confidential information when you supply string values using the API. Args: request: (DataflowProjectsLocationsJobsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rUrVrXr[s rHrU0DataflowV1b3.ProjectsLocationsJobsService.CreateMr_rJc H[R"SSSS/SS/SS/SSS S S S 9 $) Nraz'dataflow.projects.locations.jobs.createrrrr3v1b3/projects/{projectId}/locations/{location}/jobsr*DataflowProjectsLocationsJobsCreateRequestr FrrsrurJrHrv2DataflowV1b3.ProjectsLocationsJobsService.Zs<8#9#9;#Z0-$f-KF  $rJcDURS5nURX1US9$)aGets the state of the specified Cloud Dataflow job. To get the state of a job, we recommend using `projects.locations.jobs.get` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.get` is not recommended, as you can only get the state of jobs that are running in `us-central1`. Args: request: (DataflowProjectsLocationsJobsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rrVrXr[s rHr-DataflowV1b3.ProjectsLocationsJobsService.GetgrrJc F[R"SS/SQ/SQS/SSSS S S 9 $) Nrz$dataflow.projects.locations.jobs.getrprqr;v1b3/projects/{projectId}/locations/{location}/jobs/{jobId}r'DataflowProjectsLocationsJobsGetRequestr FrrsrurJrHrvrts/ 6 6896XSC  !rJcDURS5nURX1US9$)agRequest detailed information about the execution status of the job. EXPERIMENTAL. This API is subject to change or removal without notice. Args: request: (DataflowProjectsLocationsJobsGetExecutionDetailsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (JobExecutionDetails) The response message. rrVrXr[s rHr=DataflowV1b3.ProjectsLocationsJobsService.GetExecutionDetailsrrJc H[R"SS/SQ/SQSS/SSS S S S 9 $) Nrz4dataflow.projects.locations.jobs.getExecutionDetailsrprqrrzLv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/executionDetailsr7DataflowProjectsLocationsJobsGetExecutionDetailsRequestJobExecutionDetailsFrrsrurJrHrvrs20F0FH96 +.dS0 1rJcDURS5nURX1US9$)aRequest the job status. To request the status of a job, we recommend using `projects.locations.jobs.getMetrics` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.getMetrics` is not recommended, as you can only request the status of jobs that are running in `us-central1`. Args: request: (DataflowProjectsLocationsJobsGetMetricsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (JobMetrics) The response message. rrVrXr[s rHr4DataflowV1b3.ProjectsLocationsJobsService.GetMetricsrrJc F[R"SS/SQ/SQS/SSSS S S 9 $) Nrz+dataflow.projects.locations.jobs.getMetricsrprqrzCv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}/metricsr.DataflowProjectsLocationsJobsGetMetricsRequestrFrrsrurJrHrvrs/x'='=?96!][J' (rJcDURS5nURX1US9$)aList the jobs of a project. To list the jobs of a project in a region, we recommend using `projects.locations.jobs.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). To list the all jobs across all regions, use `projects.jobs.aggregated`. Using `projects.jobs.list` is not recommended, because you can only get the list of jobs that are running in `us-central1`. `projects.locations.jobs.list` and `projects.jobs.list` support filtering the list of jobs by name. Filtering by name isn't supported by `projects.jobs.aggregated`. Args: request: (DataflowProjectsLocationsJobsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListJobsResponse) The response message. rrVrXr[s rHr.DataflowV1b3.ProjectsLocationsJobsService.ListrrJc H[R"SSSS/SS//SQSSSS S S 9 $) Nrz%dataflow.projects.locations.jobs.listrr)rrrrrrr(DataflowProjectsLocationsJobsListRequestrFrrsrurJrHrvrs7!7!79#Z0-HKD- "rJcDURS5nURX1US9$)zSnapshot the state of a streaming job. Args: request: (DataflowProjectsLocationsJobsSnapshotRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Snapshot) The response message. rrVrXr[s rHr2DataflowV1b3.ProjectsLocationsJobsService.SnapshotrrJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nraz)dataflow.projects.locations.jobs.snapshotrprqzDv1b3/projects/{projectId}/locations/{location}/jobs/{jobId}:snapshotr,DataflowProjectsLocationsJobsSnapshotRequestrFrrsrurJrHrvrs-X%;%;=96\*H% &rJcDURS5nURX1US9$)a.Updates the state of an existing Cloud Dataflow job. To update the state of an existing job, we recommend using `projects.locations.jobs.update` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.update` is not recommended, as you can only update the state of jobs that are running in `us-central1`. Args: request: (DataflowProjectsLocationsJobsUpdateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. r"rVrXr[s rHr"0DataflowV1b3.ProjectsLocationsJobsService.Updater_rJc F[R"SS/SQ/SQS/SSSS S S 9 $) Nr%z'dataflow.projects.locations.jobs.updaterprqr&rr*DataflowProjectsLocationsJobsUpdateRequestr FrrsrurJrHrvrs/8#9#9;96"^SF  $rJrxrO)ryrzr{r|r}r~rrUrrrrrrr"rrrs@rHr5rCs}A %E 8 F 8 C 8 )% 8 J 8 D 8 H 8 FrJr5c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) .DataflowV1b3.ProjectsLocationsSnapshotsServiceiz[[RU]U5 0UlgrO)rrr7rrPrQs rHr7DataflowV1b3.ProjectsLocationsSnapshotsService.__init__rlrJcDURS5nURX1US9$)zDeletes a snapshot. Args: request: (DataflowProjectsLocationsSnapshotsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (DeleteSnapshotResponse) The response message. rrVrXr[s rHr5DataflowV1b3.ProjectsLocationsSnapshotsService.Delete r_rJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrz,dataflow.projects.locations.snapshots.deleterr snapshotIdrrrEv1b3/projects/{projectId}/locations/{location}/snapshots/{snapshotId}r/DataflowProjectsLocationsSnapshotsDeleteRequestDeleteSnapshotResponseFrrsrurJrHrv7DataflowV1b3.ProjectsLocationsSnapshotsService.s-8#9#9@>;]K3 $rJcDURS5nURX1US9$)zGets information about a snapshot. Args: request: (DataflowProjectsLocationsSnapshotsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Snapshot) The response message. rrVrXr[s rHr2DataflowV1b3.ProjectsLocationsSnapshotsService.Get'rrJc D[R"SS/SQ/SQ/SSSSS S 9 $) Nrz)dataflow.projects.locations.snapshots.getrrrr,DataflowProjectsLocationsSnapshotsGetRequestrFrrsrurJrHrvr4s- 6 6=>;]H% !rJcDURS5nURX1US9$)zLists snapshots. Args: request: (DataflowProjectsLocationsSnapshotsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSnapshotsResponse) The response message. rrVrXr[s rHr3DataflowV1b3.ProjectsLocationsSnapshotsService.ListArrJc F[R"SSSS/SS/S/SSSS S S 9 $) Nrz*dataflow.projects.locations.snapshots.listrrrz8v1b3/projects/{projectId}/locations/{location}/snapshotsr-DataflowProjectsLocationsSnapshotsListRequestrFrrsrurJrHrvrNs9!7!7>#Z0-YPI2 "rJrxrO) ryrzr{r|r}r~rrrrrrrrs@rHr7rs@F *E 8 F 8 C 8 DrJr7c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) .DataflowV1b3.ProjectsLocationsTemplatesServicei[z[[RU]U5 0UlgrO)rrr9rrPrQs rHr7DataflowV1b3.ProjectsLocationsTemplatesService.__init__`rlrJcDURS5nURX1US9$)a[Creates a Cloud Dataflow job from a template. Do not enter confidential information when you supply string values using the API. To create a job, we recommend using `projects.locations.templates.create` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.templates.create` is not recommended, because your job will always start in `us-central1`. Args: request: (DataflowProjectsLocationsTemplatesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rUrVrXr[s rHrU5DataflowV1b3.ProjectsLocationsTemplatesService.Createer_rJc D[R"SSSS/SS//SSSSS S 9 $) Nraz,dataflow.projects.locations.templates.createrrz8v1b3/projects/{projectId}/locations/{location}/templatescreateJobFromTemplateRequest/DataflowProjectsLocationsTemplatesCreateRequestr FrrsrurJrHrv7DataflowV1b3.ProjectsLocationsTemplatesService.rs78#9#9@#Z0-P4K  $rJcDURS5nURX1US9$)a%Get the template associated with a template. To get the template, we recommend using `projects.locations.templates.get` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.templates.get` is not recommended, because only templates that are running in `us-central1` are retrieved. Args: request: (DataflowProjectsLocationsTemplatesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (GetTemplateResponse) The response message. rrVrXr[s rHr2DataflowV1b3.ProjectsLocationsTemplatesService.GetrrJc H[R"SSSS/SS/SS/SSS S S S 9 $) Nrz)dataflow.projects.locations.templates.getrrgcsPathrz[[RU]U5 0UlgrO)rrr;rrPrQs rHr.DataflowV1b3.ProjectsLocationsService.__init__rrJcDURS5nURX1US9$)aSend a worker_message to the service. Args: request: (DataflowProjectsLocationsWorkerMessagesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SendWorkerMessagesResponse) The response message. WorkerMessagesrVrXr[s rHr4DataflowV1b3.ProjectsLocationsService.WorkerMessages0##$45f __ 88rJc D[R"SSSS/SS//SSSSS S 9 $) Nraz*dataflow.projects.locations.workerMessagesrrz=v1b3/projects/{projectId}/locations/{location}/WorkerMessagessendWorkerMessagesRequest.DataflowProjectsLocationsWorkerMessagesRequestSendWorkerMessagesResponseFrrsrurJrHrv.DataflowV1b3.ProjectsLocationsService.s78+A+A>#Z0-U1J7 ,rJrxrO) ryrzr{r|r}r~rrrrrrs@rHr;rs"< E 8 $N  rJr;cd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) %DataflowV1b3.ProjectsSnapshotsServiceiz2Service class for the projects_snapshots resource.r>cN>[[RU]U5 0UlgrO)rrr=rrPrQs rHr.DataflowV1b3.ProjectsSnapshotsService.__init__rrJcDURS5nURX1US9$)zGets information about a snapshot. Args: request: (DataflowProjectsSnapshotsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Snapshot) The response message. rrVrXr[s rHr)DataflowV1b3.ProjectsSnapshotsService.GetrrJc F[R"SSSS/SS/S/SSSS S S 9 $) Nrzdataflow.projects.snapshots.getrrrz0v1b3/projects/{projectId}/snapshots/{snapshotId}r#DataflowProjectsSnapshotsGetRequestrFrrsrurJrHrv.DataflowV1b3.ProjectsSnapshotsService.s9 6 63#\2 ,/ \H?% !rJcDURS5nURX1US9$)zLists snapshots. Args: request: (DataflowProjectsSnapshotsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListSnapshotsResponse) The response message. rrVrXr[s rHr*DataflowV1b3.ProjectsSnapshotsService.ListrrJc D[R"SSS/S/SS/SSSS S S 9 $) Nrz dataflow.projects.snapshots.listrrr#v1b3/projects/{projectId}/snapshotsr$DataflowProjectsSnapshotsListRequestrFrrsrurJrHrvrs6!7!74#} Mz*;@2 "rJrxrO) ryrzr{r|r}r~rrrrrrrs@rHr=r s1< E 8 C 8 DrJr=cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) ,DataflowV1b3.ProjectsTemplateVersionsServiceiz9Service class for the projects_templateVersions resource.r@cN>[[RU]U5 0UlgrO)rrr?rrPrQs rHr5DataflowV1b3.ProjectsTemplateVersionsService.__init__rrJcDURS5nURX1US9$)aList TemplateVersions using project_id and an optional display_name field. List all the TemplateVersions in the Template if display set. List all the TemplateVersions in the Project if display_name not set. Args: request: (DataflowProjectsTemplateVersionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTemplateVersionsResponse) The response message. rrVrXr[s rHr1DataflowV1b3.ProjectsTemplateVersionsService.ListrrJcF[R"SSSS/S/SS/SSS S S S 9 $) Nz+v1b3/projects/{projectsId}/templateVersionsrz'dataflow.projects.templateVersions.listrbrrrcr+DataflowProjectsTemplateVersionsListRequestListTemplateVersionsResponseFrgrsrurJrHrv5DataflowV1b3.ProjectsTemplateVersionsService.,s9!7!7?; zJ +.7G9 "rJrxrOrrs@rHr?rs"C 'E 8 DrJr?c~^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS S jr S \ lS r U=r $) %DataflowV1b3.ProjectsTemplatesServicei:z2Service class for the projects_templates resource.rBcN>[[RU]U5 0UlgrO)rrrArrPrQs rHr.DataflowV1b3.ProjectsTemplatesService.__init__?rrJcDURS5nURX1US9$)aRCreates a Cloud Dataflow job from a template. Do not enter confidential information when you supply string values using the API. To create a job, we recommend using `projects.locations.templates.create` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.templates.create` is not recommended, because your job will always start in `us-central1`. Args: request: (DataflowProjectsTemplatesCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Job) The response message. rUrVrXr[s rHrU,DataflowV1b3.ProjectsTemplatesService.CreateDr_rJc @[R"SSS/S//SSSSSS 9 $) Nraz"dataflow.projects.templates.createrz#v1b3/projects/{projectId}/templatesr&DataflowProjectsTemplatesCreateRequestr FrrsrurJrHrv.DataflowV1b3.ProjectsTemplatesService.Qs18#9#96#} M;4B  $rJcDURS5nURX1US9$)aGet the template associated with a template. To get the template, we recommend using `projects.locations.templates.get` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.templates.get` is not recommended, because only templates that are running in `us-central1` are retrieved. Args: request: (DataflowProjectsTemplatesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (GetTemplateResponse) The response message. rrVrXr[s rHr)DataflowV1b3.ProjectsTemplatesService.Get^rrJc D[R"SSS/S//SQSSSSS S 9 $) Nrzdataflow.projects.templates.getr)rrrz'v1b3/projects/{projectId}/templates:getr#DataflowProjectsTemplatesGetRequestrFrrsrurJrHrvr,ks1 6 63#} M4??0 !rJcDURS5nURX1US9$)aLaunches a template. To launch a template, we recommend using `projects.locations.templates.launch` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.templates.launch` is not recommended, because jobs launched from the template will always start in `us-central1`. Args: request: (DataflowProjectsTemplatesLaunchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (LaunchTemplateResponse) The response message. rarVrXr[s rHra,DataflowV1b3.ProjectsTemplatesService.Launchxr_rJc D[R"SSS/S//SQSSSSS S 9 $) Nraz"dataflow.projects.templates.launchr)rrrrr2z*v1b3/projects/{projectId}/templates:launchr&DataflowProjectsTemplatesLaunchRequestrFrrsrurJrHrvr,s18#9#96#} MzB0B3 $rJrxrOrrs@rHrAr%:s@< E 8 F 8 C 8 FrJrAcd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) DataflowV1b3.ProjectsServiceiz(Service class for the projects resource.rDcN>[[RU]U5 0UlgrO)rrrCrrPrQs rHr%DataflowV1b3.ProjectsService.__init__s" L ( ($8@ drJcDURS5nURX1US9$)zDeletes a snapshot. Args: request: (DataflowProjectsDeleteSnapshotsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (DeleteSnapshotResponse) The response message. DeleteSnapshotsrVrXr[s rHr:,DataflowV1b3.ProjectsService.DeleteSnapshotss0##$56f __ 88rJc D[R"SSS/S/SS/SSSS S S 9 $) Nrz!dataflow.projects.deleteSnapshotsrrrrr&DataflowProjectsDeleteSnapshotsRequestrFrrsrurJrHrv%DataflowV1b3.ProjectsService.s6H,B,B5#} M ,/;B3 -rJcDURS5nURX1US9$)zSend a worker_message to the service. Args: request: (DataflowProjectsWorkerMessagesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SendWorkerMessagesResponse) The response message. rrVrXr[s rHr+DataflowV1b3.ProjectsService.WorkerMessagesrrJc @[R"SSS/S//SSSSSS 9 $) Nraz dataflow.projects.workerMessagesrz(v1b3/projects/{projectId}/WorkerMessagesr%DataflowProjectsWorkerMessagesRequestr FrrsrurJrHrvr>s18+A+A4#} M@1A7 ,rJrxrO) ryrzr{r|r}r~rr:rrrrrs@rHrCr6s12 E 8 %O! 8 $N  rJrC)rDrrr&r r"r$r<r(r*r6r,r.r0r2r4r8r:r>r@rB) rNTNNFFNNNN),ryrzr{r|r}messagesMESSAGES_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;r=r?rArCrrrs@rHrr sC/ /(9- ( =?h i' (*"."+%, ()-6:/4<@?C #/J#8O8O#JO(?(?Ob<!8!8<|"H$;$;"H<X%<%<<|~H33~@EH,C,CEN"h.E.E"HV(*A*AVp"X-D-D"H"h.E.E"H"8+B+B"H<h.E.E<|~X%<%<~@V(*A*AVpV(*A*AVp"!8!8"H<!8!8<|#(?(?#JV!8!8Vp<//<<rJrN) r} __future__rapitools.base.pyr3googlecloudsdk.generated_clients.apis.dataflow.v1b3rrC BaseApiClientrrurJrHrTs'9'%bD8))DrJ