7VdZddlmZddlmZddlmZGddejZ y)z7Generated client library for composer version v1alpha2.)absolute_import)base_api)composer_v1alpha2_messagescXeZdZdZeZdZdZdZdgZ dZ dZ dZ d Z dZdZd Z d$fd ZGd d ej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGddej&ZGd d!ej&ZGd"d#ej&ZxZ S)%ComposerV1alpha2z?Generated client library for service composer version v1alpha2.z https://composer.googleapis.com/z%https://composer.mtls.googleapis.com/composerz.https://www.googleapis.com/auth/cloud-platformv1alpha2 CLIENT_ID CLIENT_SECRETzgoogle-cloud-sdkNc r|xs |j}tt|||||||||| | |  |j ||_|j ||_|j||_ |j||_ |j||_ |j||_|j!||_|j%||_|j)||_|j-||_|j1||_|j5||_y)zCreate a new composer handle.) credentialsget_credentialshttpmodel log_request log_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BASE_URLsuperr__init__zVComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesService.Ns7 6 6k[xH(c) !r6cL|jd}|j|||S)aELists task instances for a specified DAG run. Args: request: (ComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTaskInstancesResponse) The response message. Listr@rBrEs r5razRComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesService.List\1##F+f __ '88r6c Jtjddddgdggddddd d S) Nzv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/dagRuns/{dagRunsId}/taskInstancesrJzHcomposer.projects.locations.environments.dags.dagRuns.taskInstances.listparentfilterpageSize pageTokenz v1alpha2/{+parent}/taskInstancesrMHComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesListRequestListTaskInstancesResponseFrPr\r^r6r5r_zVComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesService.is7!7!7Y\ zJ88d6 "r6r: __name__ __module__ __qualname____doc___NAMErr? method_configra __classcell__r4s@r5rr87s1d HE 8 C 8 Dr6rcVeZdZdZdZfdZddZde_ddZde_xZ S) @ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsServicezLService class for the projects_locations_environments_dags_dagRuns resource.rcNttj||i|_yr:)rrrrr;r<s r5rzIComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.__init__|s$  L Ld\]cd dr6cL|jd}|j|||S)a Retrieves a DAG run. Args: request: (ComposerProjectsLocationsEnvironmentsDagsDagRunsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (DagRun) The response message. r?r@rBrEs r5r?zDComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.GetrHr6c Ftjddddgdggddddd S) Nzvv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/dagRuns/{dagRunsId}rJz9composer.projects.locations.environments.dags.dagRuns.getrKrLrM:ComposerProjectsLocationsEnvironmentsDagsDagRunsGetRequestDagRunFrPr\r^r6r5r_zIComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.s7 6 6KMxH(V# !r6cL|jd}|j|||S)aLists DAG runs of a DAG. Args: request: (ComposerProjectsLocationsEnvironmentsDagsDagRunsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListDagRunsResponse) The response message. rar@rBrEs r5razEComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.Listrbr6c Jtjddddgdggddddd d S) Nzjv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/dagRunsrJz:composer.projects.locations.environments.dags.dagRuns.listrd)rfrgrhrunsCountPerDagzv1alpha2/{+parent}/dagRunsrM;ComposerProjectsLocationsEnvironmentsDagsDagRunsListRequestListDagRunsResponseFrPr\r^r6r5r_zIComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.s4!7!7~N zJK2W0 "r6r:rkrss@r5rruws1V :E 8 C 8 Dr6rc>eZdZdZdZfdZddZde_xZS)>ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksServicezJService class for the projects_locations_environments_dags_tasks resource.rcNttj||i|_yr:)rrrrr;r<s r5rzGComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksService.__init__$  J JDZ[ab dr6cL|jd}|j|||S)aLists tasks of a DAG. Args: request: (ComposerProjectsLocationsEnvironmentsDagsTasksListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTasksResponse) The response message. rar@rBrEs r5razCComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksService.Listrbr6c Jtjddddgdgddgddd d d S) Nzhv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/tasksrJz8composer.projects.locations.environments.dags.tasks.listrdrgrhzv1alpha2/{+parent}/tasksrM9ComposerProjectsLocationsEnvironmentsDagsTasksListRequestListTasksResponseFrPr\r^r6r5r_zGComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksService.s9!7!7|L zJ +.0U. "r6r: rlrmrnrorprrarqrrrss@r5rrs"T 8E 8 Dr6rceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _ddZ de _ddZ de _xZS)9ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsServicezDService class for the projects_locations_environments_dags resource.r!cNttj||i|_yr:)rrr rr;r<s r5rzBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.__init__s$  E EtUV\] dr6cL|jd}|j|||S)aActivates a dag. Args: request: (ComposerProjectsLocationsEnvironmentsDagsActivateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Dag) The response message. Activater@rBrEs r5rzBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.Activates1##J/f __ '88r6c Ftjddddgdggddddd S) Nzkv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:activatePOSTz6composer.projects.locations.environments.dags.activaterKzv1alpha2/{+name}:activateactivateDagRequest8ComposerProjectsLocationsEnvironmentsDagsActivateRequestDagFrPr\r^r6r5r_zBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.s4X%;%;JxH1*T  &r6cL|jd}|j|||S)zRetrieves a DAG. Args: request: (ComposerProjectsLocationsEnvironmentsDagsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Dag) The response message. r?r@rBrEs r5r?z=ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.GetrHr6c Ftjddddgdggddddd S) Nzbv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}rJz1composer.projects.locations.environments.dags.getrKrLrM3ComposerProjectsLocationsEnvironmentsDagsGetRequestrFrPr\r^r6r5r_zBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.s4 6 6vExH(O  !r6cL|jd}|j|||S)aRetrieves DAG source code. Args: request: (ComposerProjectsLocationsEnvironmentsDagsGetSourceCodeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SourceCode) The response message. GetSourceCoder@rBrEs r5rzGComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.GetSourceCodes1##O4f __ '88r6c Ftjddddgdggddddd S) Nzpv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:getSourceCoderJz;composer.projects.locations.environments.dags.getSourceCodedagzv1alpha2/{+dag}:getSourceCoderM=ComposerProjectsLocationsEnvironmentsDagsGetSourceCodeRequest SourceCodeFrPr\r^r6r5r_zBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.)s7(*@*@EOwG5Y' +r6cL|jd}|j|||S)aLists DAGs in an environment. Args: request: (ComposerProjectsLocationsEnvironmentsDagsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListDagsResponse) The response message. rar@rBrEs r5raz>ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.List7rbr6c Jtjddddgdgddgddd d d S) NzYv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dagsrJz2composer.projects.locations.environments.dags.listrdrgrhzv1alpha2/{+parent}/dagsrM4ComposerProjectsLocationsEnvironmentsDagsListRequestListDagsResponseFrPr\r^r6r5r_zBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.Ds9!7!7mF zJ +./P- "r6cL|jd}|j|||S)a8List DAGs with statistics for a given time interval. Args: request: (ComposerProjectsLocationsEnvironmentsDagsListStatsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListDagStatsResponse) The response message. ListStatsr@rBrEs r5rzCComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.ListStatsRs1##K0f __ '88r6c Jtjddddgdggddddd d S) Nzcv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags:listStatsrJz7composer.projects.locations.environments.dags.listStats environment)interval_endTimeinterval_startTimergrhz&v1alpha2/{+environment}/dags:listStatsrM9ComposerProjectsLocationsEnvironmentsDagsListStatsRequestListDagStatsResponseFrPr\r^r6r5r_zBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService._s4h&<&<wK%"OX>U1 'r6cL|jd}|j|||S)zPauses a dag. Args: request: (ComposerProjectsLocationsEnvironmentsDagsPauseRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Dag) The response message. Pauser@rBrEs r5rz?ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.Pausem1##G,f __ '88r6c Ftjddddgdggddddd S) Nzhv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:pauserz3composer.projects.locations.environments.dags.pauserKzv1alpha2/{+name}:pausepauseDagRequest5ComposerProjectsLocationsEnvironmentsDagsPauseRequestrFrPr\r^r6r5r_zBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.zs4("8"8|GxH.'Q  #r6cL|jd}|j|||S)aTrigger a DAG run. Args: request: (ComposerProjectsLocationsEnvironmentsDagsTriggerRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (DagRun) The response message. Triggerr@rBrEs r5rzAComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.Trigger1##I.f __ '88r6c Ftjddddgdggddddd S) Nzjv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:triggerrz5composer.projects.locations.environments.dags.triggerrzv1alpha2/{+dag}:triggertriggerDagRequest7ComposerProjectsLocationsEnvironmentsDagsTriggerRequestrzFrPr\r^r6r5r_zBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.s4H$:$:~IwG/)S# %r6r:)rlrmrnrorprrrqr?rrarrrrrrss@r5r rs|N 2E 8 H 8 C 8 #M 8 D 8 I 8 E 8 Gr6r ceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _xZ S)LComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsServicezWService class for the projects_locations_environments_userWorkloadsConfigMaps resource.r#cNttj||i|_yr:)rrr"rr;r<s r5rzUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.__init__s%  X XZ^hiop dr6cL|jd}|j|||S)aCreates a user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (UserWorkloadsConfigMap) The response message. Creater@rBrEs r5rzSComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Create1##H-f __ '88r6c Ftjddddgdggddddd S) Nlv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsConfigMapsrzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.createrd*v1alpha2/{+parent}/userWorkloadsConfigMapsuserWorkloadsConfigMapIComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateRequestUserWorkloadsConfigMapFrPr\r^r6r5r_zUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.s78#9#9A[ zJB.e3 $r6cL|jd}|j|||S)aDeletes a user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. Deleter@rBrEs r5rzSComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Deleterr6c Ftjddddgdggddddd S) Nv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsConfigMaps/{userWorkloadsConfigMapsId}DELETEzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.deleterKrLrMIComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteRequestEmptyFrPr\r^r6r5r_zUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.s78#9#9][xH(e" $r6cL|jd}|j|||S)aGets an existing user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (UserWorkloadsConfigMap) The response message. r?r@rBrEs r5r?zPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.GetrHr6c Ftjddddgdggddddd S) NrrJzDcomposer.projects.locations.environments.userWorkloadsConfigMaps.getrKrLrMFComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetRequestrFrPr\r^r6r5r_zUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.s7 6 6]XxH(b3 !r6cL|jd}|j|||S)aLists user workloads ConfigMaps. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListUserWorkloadsConfigMapsResponse) The response message. rar@rBrEs r5razQComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Listrbr6c Jtjddddgdgddgddd d d S) NrrJzEcomposer.projects.locations.environments.userWorkloadsConfigMaps.listrdrgrhrrMGComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListRequest#ListUserWorkloadsConfigMapsResponseFrPr\r^r6r5r_zUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService. s<!7!7AY zJ +.Bc@ "r6cL|jd}|j|||S)awUpdates a user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (UserWorkloadsConfigMap) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (UserWorkloadsConfigMap) The response message. Updater@rBrEs r5rzSComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Updaterr6c Ftjddddgdggddddd S) NrPUTzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.updaterKrL rFrPr\r^r6r5r_zUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.&s78#9#9][xH(!23 $r6r: rlrmrnrorprrrqrr?rarrrrss@r5r"rs^a EE 8 F 8 F 8 C 8 D 8 Fr6r"ceZdZdZdZfdZddZde_ddZde_ddZ d e _dd Z d e _dd Z d e _xZ S)IComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsServicezTService class for the projects_locations_environments_userWorkloadsSecrets resource.r%cNttj||i|_yr:)rrr$rr;r<s r5rzRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.__init__9s%  U UW[eflm dr6cL|jd}|j|||S)aCreates a user workloads Secret. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (UserWorkloadsSecret) The response message. rr@rBrEs r5rzPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Create>rr6c Ftjddddgdggddddd S) Niv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsSecretsrzDcomposer.projects.locations.environments.userWorkloadsSecrets.createrd'v1alpha2/{+parent}/userWorkloadsSecretsuserWorkloadsSecretFComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateRequestUserWorkloadsSecretFrPr\r^r6r5r_zRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Ks48#9#9}X zJ?+b0 $r6cL|jd}|j|||S)aDeletes a user workloads Secret. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rr@rBrEs r5rzPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.DeleteYrr6c Ftjddddgdggddddd S) Nv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsSecrets/{userWorkloadsSecretsId}rzDcomposer.projects.locations.environments.userWorkloadsSecrets.deleterKrLrMFComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteRequestrFrPr\r^r6r5r_zRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.fs78#9#9WXxH(b" $r6cL|jd}|j|||S)aGets an existing user workloads Secret. Values of the "data" field in the response are cleared. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (UserWorkloadsSecret) The response message. r?r@rBrEs r5r?zMComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.GettrHr6c Ftjddddgdggddddd S) NrrJzAcomposer.projects.locations.environments.userWorkloadsSecrets.getrKrLrMCComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsGetRequestrFrPr\r^r6r5r_zRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.s7 6 6WUxH(_0 !r6cL|jd}|j|||S)aLists user workloads Secrets. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListUserWorkloadsSecretsResponse) The response message. rar@rBrEs r5razNComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Listrbr6c Jtjddddgdgddgddd d d S) NrrJzBcomposer.projects.locations.environments.userWorkloadsSecrets.listrdrgrhrrMDComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsListRequest ListUserWorkloadsSecretsResponseFrPr\r^r6r5r_zRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.s9!7!7}V zJ +.?`= "r6cL|jd}|j|||S)anUpdates a user workloads Secret. This method is supported for Cloud Composer environments in versions composer-3-airflow-*.*.*-build.* and newer. Args: request: (UserWorkloadsSecret) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (UserWorkloadsSecret) The response message. rr@rBrEs r5rzPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Updaterr6c Ftjddddgdggddddd S) NrrzDcomposer.projects.locations.environments.userWorkloadsSecrets.updaterKrLrrFrPr\r^r6r5r_zRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.s78#9#9WXxH(!/0 $r6r:rrss@r5r$r4s^^ BE 8 F 8 F 8 C 8 D 8 Fr6r$c>eZdZdZdZfdZddZde_xZS)>ComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsServicezIService class for the projects_locations_environments_workloads resource.r'cNttj||i|_yr:)rrr&rr;r<s r5rzGComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsService.__init__rr6cL|jd}|j|||S)aLists workloads in a Cloud Composer environment. Workload is a unit that runs a single Composer component. This method is supported for Cloud Composer environments in versions composer-2.*.*-airflow-*.*.* and newer. Args: request: (ComposerProjectsLocationsEnvironmentsWorkloadsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListWorkloadsResponse) The response message. rar@rBrEs r5razCComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsService.Listrbr6c Jtjddddgdggddddd d S) Nz^v1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/workloadsrJz7composer.projects.locations.environments.workloads.listrdrezv1alpha2/{+parent}/workloadsrM9ComposerProjectsLocationsEnvironmentsWorkloadsListRequestListWorkloadsResponseFrPr\r^r6r5r_zGComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsService.s4!7!7rK zJ84U2 "r6r:rrss@r5r&rs"S 7E 8 Dr6r&ceZdZdZdZfdZd$dZde_d$dZde_d$dZ d e _d$d Z d e _d$d Z d e _d$dZ de _d$dZ de _d$dZde_d$dZde_d$dZde_d$dZde_d$dZde_d$dZde_d$dZde_d$d Zd!e_d$d"Zd#e_xZS)%5ComposerV1alpha2.ProjectsLocationsEnvironmentsServicez?Service class for the projects_locations_environments resource.r)cNttj||i|_yr:)rrr(rr;r<s r5rz>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.__init__s$  A A4QRXY dr6cL|jd}|j|||S)aCheck if an upgrade operation on the environment will succeed. In case of problems detailed info can be found in the returned Operation. Args: request: (ComposerProjectsLocationsEnvironmentsCheckUpgradeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. CheckUpgrader@rBrEs r5rzBComposerV1alpha2.ProjectsLocationsEnvironmentsService.CheckUpgrade1##N3f __ '88r6c Ftjddddgdggddddd S) Nzav1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:checkUpgraderz5composer.projects.locations.environments.checkUpgraderz$v1alpha2/{+environment}:checkUpgradecheckUpgradeRequest8ComposerProjectsLocationsEnvironmentsCheckUpgradeRequest OperationFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.4)?)?uI%"O<+T& *r6cL|jd}|j|||S)a Create a new environment. Args: request: (ComposerProjectsLocationsEnvironmentsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rr@rBrEs r5rzComposerV1alpha2.ProjectsLocationsEnvironmentsService.s48#9#9WC zJ7#N& $r6cL|jd}|j|||S)a@Triggers database failover (only for highly resilient environments). Args: request: (ComposerProjectsLocationsEnvironmentsDatabaseFailoverRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. DatabaseFailoverr@rBrEs r5rzFComposerV1alpha2.ProjectsLocationsEnvironmentsService.DatabaseFailover*2##$67f __ '88r6c Ftjddddgdggddddd S) Nzev1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:databaseFailoverrz9composer.projects.locations.environments.databaseFailoverrz(v1alpha2/{+environment}:databaseFailoverdatabaseFailoverRequestComposerV1alpha2.ProjectsLocationsEnvironmentsService.7s4X-C-CyM%"O@/X& .r6cL|jd}|j|||S)aDelete an environment. Args: request: (ComposerProjectsLocationsEnvironmentsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rr@rBrEs r5rzComposerV1alpha2.ProjectsLocationsEnvironmentsService.Rs48#9#9hCxH(N& $r6cL|jd}|j|||S)a2Executes Airflow CLI command. Args: request: (ComposerProjectsLocationsEnvironmentsExecuteAirflowCommandRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ExecuteAirflowCommandResponse) The response message. ExecuteAirflowCommandr@rBrEs r5r zKComposerV1alpha2.ProjectsLocationsEnvironmentsService.ExecuteAirflowCommand`s2##$;composer.projects.locations.environments.executeAirflowCommandrz-v1alpha2/{+environment}:executeAirflowCommandexecuteAirflowCommandRequestAComposerProjectsLocationsEnvironmentsExecuteAirflowCommandRequestExecuteAirflowCommandResponseFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.ms4(2H2H~R%"OE4]: 3r6cL|jd}|j|||S)a5Fetches database properties. Args: request: (ComposerProjectsLocationsEnvironmentsFetchDatabasePropertiesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (FetchDatabasePropertiesResponse) The response message. FetchDatabasePropertiesr@rBrEs r5rzMComposerV1alpha2.ProjectsLocationsEnvironmentsService.FetchDatabaseProperties{s2##$=>f __ '88r6c Ftjddddgdggddddd S) Nzlv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:fetchDatabasePropertiesrJz@composer.projects.locations.environments.fetchDatabasePropertiesrz/v1alpha2/{+environment}:fetchDatabasePropertiesrMCComposerProjectsLocationsEnvironmentsFetchDatabasePropertiesRequestFetchDatabasePropertiesResponseFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.s7H4J4JAT%"OG_< 5r6cL|jd}|j|||S)a Get an existing environment. Args: request: (ComposerProjectsLocationsEnvironmentsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Environment) The response message. r?r@rBrEs r5r?z9ComposerV1alpha2.ProjectsLocationsEnvironmentsService.GetrHr6c Ftjddddgdggddddd S) Nr rJz,composer.projects.locations.environments.getrKrLrM/ComposerProjectsLocationsEnvironmentsGetRequest EnvironmentFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.s4 6 6h@xH(K( !r6cL|jd}|j|||S)aList environments. Args: request: (ComposerProjectsLocationsEnvironmentsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListEnvironmentsResponse) The response message. rar@rBrEs r5raz:ComposerV1alpha2.ProjectsLocationsEnvironmentsService.Listrbr6c Jtjddddgdgddgddd d d S) NrrJz-composer.projects.locations.environments.listrdrgrhrrM0ComposerProjectsLocationsEnvironmentsListRequestListEnvironmentsResponseFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.s9!7!7WA zJ +.7L5 "r6cL|jd}|j|||S)a#Lists DAG import errors. Args: request: (ComposerProjectsLocationsEnvironmentsListImportErrorsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListImportErrorsResponse) The response message. ListImportErrorsr@rBrEs r5r zFComposerV1alpha2.ProjectsLocationsEnvironmentsService.ListImportErrorsrr6c Jtjddddgdgddgddd d d S) Nzev1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:listImportErrorsrJz9composer.projects.locations.environments.listImportErrorsrrgrhz(v1alpha2/{+environment}:listImportErrorsrMComposerV1alpha2.ProjectsLocationsEnvironmentsService.s9X-C-CyM%"O +.@X5 .r6cL|jd}|j|||S)aLoads a snapshot of a Cloud Composer environment. As a result of this operation, a snapshot of environment's specified in LoadSnapshotRequest is loaded into the environment. Args: request: (ComposerProjectsLocationsEnvironmentsLoadSnapshotRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. LoadSnapshotr@rBrEs r5r%zBComposerV1alpha2.ProjectsLocationsEnvironmentsService.LoadSnapshotrr6c Ftjddddgdggddddd S) Nzav1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:loadSnapshotrz5composer.projects.locations.environments.loadSnapshotrz$v1alpha2/{+environment}:loadSnapshotloadSnapshotRequest8ComposerProjectsLocationsEnvironmentsLoadSnapshotRequestrFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.rr6cL|jd}|j|||S)a"Migrates an environment to a new major version. Args: request: (ComposerProjectsLocationsEnvironmentsMigrateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. Migrater@rBrEs r5r*z=ComposerV1alpha2.ProjectsLocationsEnvironmentsService.Migraterr6c Ftjddddgdggddddd S) Nz\v1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:migraterz0composer.projects.locations.environments.migraterKzv1alpha2/{+name}:migratemigrateEnvironmentRequest3ComposerProjectsLocationsEnvironmentsMigrateRequestrFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.s4H$:$:pDxH01O& %r6cL|jd}|j|||S)aUpdate an environment. Args: request: (ComposerProjectsLocationsEnvironmentsPatchRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. Patchr@rBrEs r5r/z;ComposerV1alpha2.ProjectsLocationsEnvironmentsService.Patchrr6c Htjddddgdgdgdddd d S) Nr PATCHz.composer.projects.locations.environments.patchrK updateMaskrLr1ComposerProjectsLocationsEnvironmentsPatchRequestrFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.*s6("8"8hBxH"^(#M& #r6cL|jd}|j|||S)aDPolls Airflow CLI command execution and fetches logs. Args: request: (ComposerProjectsLocationsEnvironmentsPollAirflowCommandRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (PollAirflowCommandResponse) The response message. PollAirflowCommandr@rBrEs r5r5zHComposerV1alpha2.ProjectsLocationsEnvironmentsService.PollAirflowCommand82##$89f __ '88r6c Ftjddddgdggddddd S) Nzgv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:pollAirflowCommandrz;composer.projects.locations.environments.pollAirflowCommandrz*v1alpha2/{+environment}:pollAirflowCommandpollAirflowCommandRequest>ComposerProjectsLocationsEnvironmentsPollAirflowCommandRequestPollAirflowCommandResponseFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.E4x/E/E{O%"OB1Z7 0r6cL|jd}|j|||S)aRestart Airflow web server. Args: request: (ComposerProjectsLocationsEnvironmentsRestartWebServerRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. RestartWebServerr@rBrEs r5r=zFComposerV1alpha2.ProjectsLocationsEnvironmentsService.RestartWebServerSrr6c Ftjddddgdggddddd S) Nzev1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:restartWebServerrz9composer.projects.locations.environments.restartWebServerrKz!v1alpha2/{+name}:restartWebServerrestartWebServerRequestComposerV1alpha2.ProjectsLocationsEnvironmentsService.`s4X-C-CyMxH9/X& .r6cL|jd}|j|||S)aCreates a snapshots of a Cloud Composer environment. As a result of this operation, snapshot of environment's state is stored in a location specified in the SaveSnapshotRequest. Args: request: (ComposerProjectsLocationsEnvironmentsSaveSnapshotRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. SaveSnapshotr@rBrEs r5rBzBComposerV1alpha2.ProjectsLocationsEnvironmentsService.SaveSnapshotnrr6c Ftjddddgdggddddd S) Nzav1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:saveSnapshotrz5composer.projects.locations.environments.saveSnapshotrz$v1alpha2/{+environment}:saveSnapshotsaveSnapshotRequest8ComposerProjectsLocationsEnvironmentsSaveSnapshotRequestrFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.{rr6cL|jd}|j|||S)a3Stops Airflow CLI command execution. Args: request: (ComposerProjectsLocationsEnvironmentsStopAirflowCommandRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (StopAirflowCommandResponse) The response message. StopAirflowCommandr@rBrEs r5rGzHComposerV1alpha2.ProjectsLocationsEnvironmentsService.StopAirflowCommandr6r6c Ftjddddgdggddddd S) Nzgv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:stopAirflowCommandrz;composer.projects.locations.environments.stopAirflowCommandrz*v1alpha2/{+environment}:stopAirflowCommandstopAirflowCommandRequest>ComposerProjectsLocationsEnvironmentsStopAirflowCommandRequestStopAirflowCommandResponseFrPr\r^r6r5r_z>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.r;r6r:)rlrmrnrorprrrqrrrr rr?rar r%r*r/r5r=rBrGrrrss@r5r(rs I -E 8 "L 8 F 8 &" 8 F 8 +' 8 -) 8 C 8 D 8 &" 8 "L 8 G 8 E 8 ($ 8 &" 8 "L 8 ($$r6r(c>eZdZdZdZfdZddZde_xZS)6ComposerV1alpha2.ProjectsLocationsImageVersionsServicez@Service class for the projects_locations_imageVersions resource.r+cNttj||i|_yr:)rrr*rr;r<s r5rz?ComposerV1alpha2.ProjectsLocationsImageVersionsService.__init__s$  B BDRSYZ dr6cL|jd}|j|||S)a*List ImageVersions for provided location. Args: request: (ComposerProjectsLocationsImageVersionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListImageVersionsResponse) The response message. rar@rBrEs r5raz;ComposerV1alpha2.ProjectsLocationsImageVersionsService.Listrbr6c Jtjddddgdggddddd d S) NzDv1alpha2/projects/{projectsId}/locations/{locationsId}/imageVersionsrJz.composer.projects.locations.imageVersions.listrd)includePastReleasesrgrhz v1alpha2/{+parent}/imageVersionsrM1ComposerProjectsLocationsImageVersionsListRequestListImageVersionsResponseFrPr\r^r6r5r_z?ComposerV1alpha2.ProjectsLocationsImageVersionsService.s4!7!7XB zJE8M6 "r6r:rrss@r5r*rMs"J .E 8 Dr6r*ceZdZdZdZfdZd dZde_d dZde_d dZ d e _d d Z d e _xZ S) 3ComposerV1alpha2.ProjectsLocationsOperationsServicez=Service class for the projects_locations_operations resource.r-cNttj||i|_yr:)rrr,rr;r<s r5rzs48#9#9kAxH/.L" $r6cL|jd}|j|||S)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: (ComposerProjectsLocationsOperationsDeleteRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Empty) The response message. rr@rBrEs r5rz:ComposerV1alpha2.ProjectsLocationsOperationsService.Deleterr6c Ftjddddgdggddddd S) NPv1alpha2/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}rz-composer.projects.locations.operations.deleterKrLrM0ComposerProjectsLocationsOperationsDeleteRequestrFrPr\r^r6r5r_zs48#9#9dAxH(L" $r6cL|jd}|j|||S)aGets 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: (ComposerProjectsLocationsOperationsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. r?r@rBrEs r5r?z7ComposerV1alpha2.ProjectsLocationsOperationsService.Get rHr6c Ftjddddgdggddddd S) Nr^rJz*composer.projects.locations.operations.getrKrLrM-ComposerProjectsLocationsOperationsGetRequestrFrPr\r^r6r5r_zs4 6 6d>xH(I& !r6cL|jd}|j|||S)aLists operations that match the specified filter in the request. If the server doesn't support this method, it returns `UNIMPLEMENTED`. Args: request: (ComposerProjectsLocationsOperationsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListOperationsResponse) The response message. rar@rBrEs r5raz8ComposerV1alpha2.ProjectsLocationsOperationsService.List$rbr6c Jtjddddgdggddddd d S) NzAv1alpha2/projects/{projectsId}/locations/{locationsId}/operationsrJz+composer.projects.locations.operations.listrKrezv1alpha2/{+name}/operationsrM.ComposerProjectsLocationsOperationsListRequestListOperationsResponseFrPr\r^r6r5r_z1s4!7!7U?xH83J3 "r6r:) rlrmrnrorprrXrqrr?rarrrss@r5r,rUsOG +E 8 F 8 F 8 C 8 Dr6r,c&eZdZdZdZfdZxZS))ComposerV1alpha2.ProjectsLocationsServicez2Service class for the projects_locations resource.r/cNttj||i|_yr:)rrr.rr;r<s r5rz2ComposerV1alpha2.ProjectsLocationsService.__init__Ds#  5 5tEfM dr6rlrmrnrorprrrrss@r5r.rh?s< E  r6r.c&eZdZdZdZfdZxZS) ComposerV1alpha2.ProjectsServicez(Service class for the projects resource.r1cNttj||i|_yr:)rrr0rr;r<s r5rz)ComposerV1alpha2.ProjectsService.__init__Ns#  , ,d' (*"."+), ()-6:/4<@?C /8>XE\E\>@>8O8O>@#h6M6M#JE1H1HENOHD[D[ObOAXAXOb#h6M6M#JxX-D-Dxt #h.E.E#Jt8+B+Btl !8!8  //  r6rN) ro __future__rapitools.base.pyr7googlecloudsdk.generated_clients.apis.composer.v1alpha2rrn BaseApiClientrr^r6r5rs'='%jG x--G r6