OVSrSSKJr SSKJr SSKJr "SS\R5r g)z7Generated client library for composer version v1alpha2.)absolute_import)base_api)composer_v1alpha2_messagescd^\rSrSrSr\rSrSrSr S/r Sr Sr S r S rSrSrS rS&U4S 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%r!U=r"$)'ComposerV1alpha2 z?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 p>U=(d URn[[U]XX4UXgUU U U S9 UR U5UlUR U5UlURU5Ul URU5Ul URU5Ul URU5UlUR!U5UlUR%U5UlUR)U5UlUR-U5UlUR1U5UlUR5U5Ulg)zCreate a new composer handle.) credentialsget_credentialshttpmodel log_request log_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BASE_URLsuperr__init__[[RU]U5 0UlgN)rrrr_upload_configsr3clientr5s r6rVComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesService.__init__<s%  Y Y[_ijpq dr8cDURS5nURX1US9$)aRetrieves a task instance. Args: request: (ComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (TaskInstance) The response message. Get global_paramsGetMethodConfig _RunMethodr3requestrEconfigs r6rCQComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesService.GetA/##E*f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/dagRuns/{dagRunsId}/taskInstances/{taskInstancesId}GETzGcomposer.projects.locations.environments.dags.dagRuns.taskInstances.getnamev1alpha2/{+name}GComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesGetRequest TaskInstanceF flat_path http_method method_idordered_params path_params query_params relative_path request_fieldrequest_type_nameresponse_type_namesupports_downloadr ApiMethodInfor8r6VComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesService.Ns7 6 6k[xH(c) !r8cDURS5nURX1US9$)a!Lists task instances for a specified DAG run. Args: request: (ComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTaskInstancesResponse) The response message. ListrDrFrIs r6rgRComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesService.List\/##F+f __ 88r8cF[R"SSSS/S//SQSSSS S S 9 $) Nzv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/dagRuns/{dagRunsId}/taskInstancesrOzHcomposer.projects.locations.environments.dags.dagRuns.taskInstances.listparentfilterpageSize pageTokenz v1alpha2/{+parent}/taskInstancesrRHComposerProjectsLocationsEnvironmentsDagsDagRunsTaskInstancesListRequestListTaskInstancesResponseFrUrarcr8r6rdreis7!7!7Y\ zJ88d6 "r8r>r= __name__ __module__ __qualname____firstlineno____doc___NAMErrC method_configrg__static_attributes__ __classcell__r5s@r6rr:7s1d HE 8 C 8 Dr8rcd^\rSrSrSrSrU4SjrS SjrS\lS Sjr S\ lS r U=r $) @ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsServicewzLService class for the projects_locations_environments_dags_dagRuns resource.rcN>[[RU]U5 0Ulgr=)rrrrr>r?s r6rIComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.__init__|s$  L Ld\]cd dr8cDURS5nURX1US9$)zRetrieves a DAG run. Args: request: (ComposerProjectsLocationsEnvironmentsDagsDagRunsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (DagRun) The response message. rCrDrFrIs r6rCDComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.GetrMr8cB[R"SSSS/S//SSSSS S 9 $) Nzvv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/dagRuns/{dagRunsId}rOz9composer.projects.locations.environments.dags.dagRuns.getrPrQrR:ComposerProjectsLocationsEnvironmentsDagsDagRunsGetRequestDagRunFrUrarcr8r6rdIComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.s7 6 6KMxH(V# !r8cDURS5nURX1US9$)zLists DAG runs of a DAG. Args: request: (ComposerProjectsLocationsEnvironmentsDagsDagRunsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListDagRunsResponse) The response message. rgrDrFrIs r6rgEComposerV1alpha2.ProjectsLocationsEnvironmentsDagsDagRunsService.Listrir8cF[R"SSSS/S//SQSSSS S S 9 $) Nzjv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/dagRunsrOz:composer.projects.locations.environments.dags.dagRuns.listrk)rmrnrorunsCountPerDagzv1alpha2/{+parent}/dagRunsrR;ComposerProjectsLocationsEnvironmentsDagsDagRunsListRequestListDagRunsResponseFrUrarcr8r6rdrs4!7!7~N zJK2W0 "r8rrr=rsr}s@r6rrws1V :E 8 C 8 Dr8rcJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) >ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksServicezJService class for the projects_locations_environments_dags_tasks resource.r cN>[[RU]U5 0Ulgr=)rrrrr>r?s r6rGComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksService.__init__$  J JDZ[ab dr8cDURS5nURX1US9$)zLists tasks of a DAG. Args: request: (ComposerProjectsLocationsEnvironmentsDagsTasksListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListTasksResponse) The response message. rgrDrFrIs r6rgCComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksService.Listrir8cF[R"SSSS/S/SS/SSS S S S 9 $) Nzhv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}/tasksrOz8composer.projects.locations.environments.dags.tasks.listrkrnrozv1alpha2/{+parent}/tasksrR9ComposerProjectsLocationsEnvironmentsDagsTasksListRequestListTasksResponseFrUrarcr8r6rdGComposerV1alpha2.ProjectsLocationsEnvironmentsDagsTasksService.s9!7!7|L zJ +.0U. "r8rrr= rtrurvrwrxryrrgrzr{r|r}s@r6rrs"T 8E 8 Dr8rc^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSSjr S\ lSSjrS\lSrU=r$)9ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsServicezDService class for the projects_locations_environments_dags resource.r"cN>[[RU]U5 0Ulgr=)rrr!rr>r?s r6rBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.__init__s$  E EtUV\] dr8cDURS5nURX1US9$)zActivates a dag. Args: request: (ComposerProjectsLocationsEnvironmentsDagsActivateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Dag) The response message. ActivaterDrFrIs r6rBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.Activates/##J/f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzkv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:activatePOSTz6composer.projects.locations.environments.dags.activaterPzv1alpha2/{+name}:activateactivateDagRequest8ComposerProjectsLocationsEnvironmentsDagsActivateRequestDagFrUrarcr8r6rdBComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.s4X%;%;JxH1*T  &r8cDURS5nURX1US9$)zRetrieves a DAG. Args: request: (ComposerProjectsLocationsEnvironmentsDagsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Dag) The response message. rCrDrFrIs r6rC=ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.GetrMr8cB[R"SSSS/S//SSSSS S 9 $) Nzbv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}rOz1composer.projects.locations.environments.dags.getrPrQrR3ComposerProjectsLocationsEnvironmentsDagsGetRequestrFrUrarcr8r6rdrs4 6 6vExH(O  !r8cDURS5nURX1US9$)zRetrieves DAG source code. Args: request: (ComposerProjectsLocationsEnvironmentsDagsGetSourceCodeRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (SourceCode) The response message. GetSourceCoderDrFrIs r6rGComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.GetSourceCodes/##O4f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzpv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:getSourceCoderOz;composer.projects.locations.environments.dags.getSourceCodedagzv1alpha2/{+dag}:getSourceCoderR=ComposerProjectsLocationsEnvironmentsDagsGetSourceCodeRequest SourceCodeFrUrarcr8r6rdr)s7(*@*@EOwG5Y' +r8cDURS5nURX1US9$)zLists DAGs in an environment. Args: request: (ComposerProjectsLocationsEnvironmentsDagsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListDagsResponse) The response message. rgrDrFrIs r6rg>ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.List7rir8cF[R"SSSS/S/SS/SSS S S S 9 $) NzYv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dagsrOz2composer.projects.locations.environments.dags.listrkrnrozv1alpha2/{+parent}/dagsrR4ComposerProjectsLocationsEnvironmentsDagsListRequestListDagsResponseFrUrarcr8r6rdrDs9!7!7mF zJ +./P- "r8cDURS5nURX1US9$)aList 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. ListStatsrDrFrIs r6rCComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.ListStatsRs/##K0f __ 88r8cF[R"SSSS/S//SQSSSS S S 9 $) Nzcv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags:listStatsrOz7composer.projects.locations.environments.dags.listStats environment)interval_endTimeinterval_startTimernroz&v1alpha2/{+environment}/dags:listStatsrR9ComposerProjectsLocationsEnvironmentsDagsListStatsRequestListDagStatsResponseFrUrarcr8r6rdr_s4h&<&<wK%"OX>U1 'r8cDURS5nURX1US9$)zPauses a dag. Args: request: (ComposerProjectsLocationsEnvironmentsDagsPauseRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Dag) The response message. PauserDrFrIs r6r?ComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.Pausem/##G,f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzhv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:pauserz3composer.projects.locations.environments.dags.pauserPzv1alpha2/{+name}:pausepauseDagRequest5ComposerProjectsLocationsEnvironmentsDagsPauseRequestrFrUrarcr8r6rdrzs4("8"8|GxH.'Q  #r8cDURS5nURX1US9$)zTrigger a DAG run. Args: request: (ComposerProjectsLocationsEnvironmentsDagsTriggerRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (DagRun) The response message. TriggerrDrFrIs r6rAComposerV1alpha2.ProjectsLocationsEnvironmentsDagsService.Trigger/##I.f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzjv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/dags/{dagsId}:triggerrz5composer.projects.locations.environments.dags.triggerrzv1alpha2/{+dag}:triggertriggerDagRequest7ComposerProjectsLocationsEnvironmentsDagsTriggerRequestrFrUrarcr8r6rdrs4H$:$:~IwG/)S# %r8rrr=)rtrurvrwrxryrrrzrCrrgrrrr{r|r}s@r6r!rs|N 2E 8 H 8 C 8 #M 8 D 8 I 8 E 8 Gr8r!c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)LComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsServiceizWService class for the projects_locations_environments_userWorkloadsConfigMaps resource.r$cN>[[RU]U5 0Ulgr=)rrr#rr>r?s r6rUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.__init__s%  X XZ^hiop dr8cDURS5nURX1US9$)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. CreaterDrFrIs r6rSComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Create/##H-f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nlv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsConfigMapsrzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.createrk*v1alpha2/{+parent}/userWorkloadsConfigMapsuserWorkloadsConfigMapIComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateRequestUserWorkloadsConfigMapFrUrarcr8r6rdUComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.s78#9#9A[ zJB.e3 $r8cDURS5nURX1US9$)auDeletes 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. DeleterDrFrIs r6rSComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Deleterr8cB[R"SSSS/S//SSSSS S 9 $) Nv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsConfigMaps/{userWorkloadsConfigMapsId}DELETEzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.deleterPrQrRIComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteRequestEmptyFrUrarcr8r6rdrs78#9#9][xH(e" $r8cDURS5nURX1US9$)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. rCrDrFrIs r6rCPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.GetrMr8cB[R"SSSS/S//SSSSS S 9 $) NrrOzDcomposer.projects.locations.environments.userWorkloadsConfigMaps.getrPrQrRFComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetRequestrFrUrarcr8r6rdrs7 6 6]XxH(b3 !r8cDURS5nURX1US9$)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. rgrDrFrIs r6rgQComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Listrir8cF[R"SSSS/S/SS/SSS S S S 9 $) NrrOzEcomposer.projects.locations.environments.userWorkloadsConfigMaps.listrkrnrorrRGComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListRequest#ListUserWorkloadsConfigMapsResponseFrUrarcr8r6rdr s<!7!7AY zJ +.Bc@ "r8cDURS5nURX1US9$)aSUpdates 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. UpdaterDrFrIs r6rSComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Updaterr8cB[R"SSSS/S//SSSSSS 9 $) NrPUTzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.updaterPrQ rFrUrarcr8r6rdr&s78#9#9][xH(!23 $r8rrr=rtrurvrwrxryrrrzrrCrgrr{r|r}s@r6r#rs^a EE 8 F 8 F 8 C 8 D 8 Fr8r#c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lSS jr S\ lSr U=r$)IComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsServicei4zTService class for the projects_locations_environments_userWorkloadsSecrets resource.r&cN>[[RU]U5 0Ulgr=)rrr%rr>r?s r6rRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.__init__9s%  U UW[eflm dr8cDURS5nURX1US9$)a}Creates 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. rrDrFrIs r6rPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Create>rr8cB[R"SSSS/S//SSSSS S 9 $) Niv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsSecretsrzDcomposer.projects.locations.environments.userWorkloadsSecrets.createrk'v1alpha2/{+parent}/userWorkloadsSecretsuserWorkloadsSecretFComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateRequestUserWorkloadsSecretFrUrarcr8r6rdRComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Ks48#9#9}X zJ?+b0 $r8cDURS5nURX1US9$)aoDeletes 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. rrDrFrIs r6rPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.DeleteYrr8cB[R"SSSS/S//SSSSS S 9 $) Nv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsSecrets/{userWorkloadsSecretsId}rzDcomposer.projects.locations.environments.userWorkloadsSecrets.deleterPrQrRFComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteRequestrFrUrarcr8r6rdrfs78#9#9WXxH(b" $r8cDURS5nURX1US9$)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. rCrDrFrIs r6rCMComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.GettrMr8cB[R"SSSS/S//SSSSS S 9 $) NrrOzAcomposer.projects.locations.environments.userWorkloadsSecrets.getrPrQrRCComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsGetRequestrFrUrarcr8r6rdrs7 6 6WUxH(_0 !r8cDURS5nURX1US9$)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. rgrDrFrIs r6rgNComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Listrir8cF[R"SSSS/S/SS/SSS S S S 9 $) NrrOzBcomposer.projects.locations.environments.userWorkloadsSecrets.listrkrnrorrRDComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsListRequest ListUserWorkloadsSecretsResponseFrUrarcr8r6rdrs9!7!7}V zJ +.?`= "r8cDURS5nURX1US9$)aJUpdates 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. rrDrFrIs r6rPComposerV1alpha2.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Updaterr8cB[R"SSSS/S//SSSSSS 9 $) NrrzDcomposer.projects.locations.environments.userWorkloadsSecrets.updaterPrQrrFrUrarcr8r6rdrs78#9#9WXxH(!/0 $r8rrr=rr}s@r6r%r4s^^ BE 8 F 8 F 8 C 8 D 8 Fr8r%cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) >ComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsServiceizIService class for the projects_locations_environments_workloads resource.r(cN>[[RU]U5 0Ulgr=)rrr'rr>r?s r6rGComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsService.__init__rr8cDURS5nURX1US9$)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. rgrDrFrIs r6rgCComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsService.Listrir8cF[R"SSSS/S//SQSSSS S S 9 $) Nz^v1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/workloadsrOz7composer.projects.locations.environments.workloads.listrkrlzv1alpha2/{+parent}/workloadsrR9ComposerProjectsLocationsEnvironmentsWorkloadsListRequestListWorkloadsResponseFrUrarcr8r6rdGComposerV1alpha2.ProjectsLocationsEnvironmentsWorkloadsService.s4!7!7rK zJ84U2 "r8rrr=rr}s@r6r'rs"S 7E 8 Dr8r'c^\rSrSrSrSrU4SjrS&SjrS\lS&Sjr S\ lS&S jr S \ lS&S jr S \ lS&S jr S\ lS&Sjr S\ lS&SjrS\lS&SjrS\lS&SjrS\lS&SjrS\lS&SjrS\lS&SjrS\lS&SjrS\lS&SjrS \lS&S!jrS"\lS&S#jrS$\lS%rU=r$)'5ComposerV1alpha2.ProjectsLocationsEnvironmentsServiceiz?Service class for the projects_locations_environments resource.r*cN>[[RU]U5 0Ulgr=)rrr)rr>r?s r6r>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.__init__s$  A A4QRXY dr8cDURS5nURX1US9$)a\Check 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. CheckUpgraderDrFrIs r6r%BComposerV1alpha2.ProjectsLocationsEnvironmentsService.CheckUpgrade/##N3f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzav1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:checkUpgraderz5composer.projects.locations.environments.checkUpgraderz$v1alpha2/{+environment}:checkUpgradecheckUpgradeRequest8ComposerProjectsLocationsEnvironmentsCheckUpgradeRequest OperationFrUrarcr8r6rd>ComposerV1alpha2.ProjectsLocationsEnvironmentsService.4)?)?uI%"O<+T& *r8cDURS5nURX1US9$)zCreate a new environment. Args: request: (ComposerProjectsLocationsEnvironmentsCreateRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rrDrFrIs r6rcomposer.projects.locations.environments.executeAirflowCommandrz-v1alpha2/{+environment}:executeAirflowCommandexecuteAirflowCommandRequestAComposerProjectsLocationsEnvironmentsExecuteAirflowCommandRequestExecuteAirflowCommandResponseFrUrarcr8r6rdr,ms4(2H2H~R%"OE4]: 3r8cDURS5nURX1US9$)aFetches database properties. Args: request: (ComposerProjectsLocationsEnvironmentsFetchDatabasePropertiesRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (FetchDatabasePropertiesResponse) The response message. FetchDatabasePropertiesrDrFrIs r6rHMComposerV1alpha2.ProjectsLocationsEnvironmentsService.FetchDatabaseProperties{s0##$=>f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzlv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:fetchDatabasePropertiesrOz@composer.projects.locations.environments.fetchDatabasePropertiesrz/v1alpha2/{+environment}:fetchDatabasePropertiesrRCComposerProjectsLocationsEnvironmentsFetchDatabasePropertiesRequestFetchDatabasePropertiesResponseFrUrarcr8r6rdr,s7H4J4JAT%"OG_< 5r8cDURS5nURX1US9$)zGet an existing environment. Args: request: (ComposerProjectsLocationsEnvironmentsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Environment) The response message. rCrDrFrIs r6rC9ComposerV1alpha2.ProjectsLocationsEnvironmentsService.GetrMr8cB[R"SSSS/S//SSSSS S 9 $) Nr>rOz,composer.projects.locations.environments.getrPrQrR/ComposerProjectsLocationsEnvironmentsGetRequest EnvironmentFrUrarcr8r6rdr,s4 6 6h@xH(K( !r8cDURS5nURX1US9$)zList environments. Args: request: (ComposerProjectsLocationsEnvironmentsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListEnvironmentsResponse) The response message. rgrDrFrIs r6rg:ComposerV1alpha2.ProjectsLocationsEnvironmentsService.Listrir8cF[R"SSSS/S/SS/SSS S S S 9 $) Nr1rOz-composer.projects.locations.environments.listrkrnror2rR0ComposerProjectsLocationsEnvironmentsListRequestListEnvironmentsResponseFrUrarcr8r6rdr,s9!7!7WA zJ +.7L5 "r8cDURS5nURX1US9$)zLists DAG import errors. Args: request: (ComposerProjectsLocationsEnvironmentsListImportErrorsRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListImportErrorsResponse) The response message. ListImportErrorsrDrFrIs r6rXFComposerV1alpha2.ProjectsLocationsEnvironmentsService.ListImportErrorsr7r8cF[R"SSSS/S/SS/SSS S S S 9 $) Nzev1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:listImportErrorsrOz9composer.projects.locations.environments.listImportErrorsrrnroz(v1alpha2/{+environment}:listImportErrorsrRPATCHz.composer.projects.locations.environments.patchrP updateMaskrQr1ComposerProjectsLocationsEnvironmentsPatchRequestr+FrUrarcr8r6rdr,*s6("8"8hBxH"^(#M& #r8cDURS5nURX1US9$)a Polls Airflow CLI command execution and fetches logs. Args: request: (ComposerProjectsLocationsEnvironmentsPollAirflowCommandRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (PollAirflowCommandResponse) The response message. PollAirflowCommandrDrFrIs r6rqHComposerV1alpha2.ProjectsLocationsEnvironmentsService.PollAirflowCommand80##$89f __ 88r8cB[R"SSSS/S//SSSSS S 9 $) Nzgv1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:pollAirflowCommandrz;composer.projects.locations.environments.pollAirflowCommandrz*v1alpha2/{+environment}:pollAirflowCommandpollAirflowCommandRequest>ComposerProjectsLocationsEnvironmentsPollAirflowCommandRequestPollAirflowCommandResponseFrUrarcr8r6rdr,E4x/E/E{O%"OB1Z7 0r8cDURS5nURX1US9$)zRestart Airflow web server. Args: request: (ComposerProjectsLocationsEnvironmentsRestartWebServerRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. RestartWebServerrDrFrIs r6rzFComposerV1alpha2.ProjectsLocationsEnvironmentsService.RestartWebServerSr7r8cB[R"SSSS/S//SSSSS S 9 $) Nzev1alpha2/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:restartWebServerrz9composer.projects.locations.environments.restartWebServerrPz!v1alpha2/{+name}:restartWebServerrestartWebServerRequestComposerProjectsLocationsEnvironmentsStopAirflowCommandRequestStopAirflowCommandResponseFrUrarcr8r6rdr,rxr8rrr=)rtrurvrwrxryrr%rzrr5rrArHrCrgrXr^rdrjrqrzrrr{r|r}s@r6r)r!s 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 ($$r8r)cJ^\rSrSrSrSrU4SjrSSjrS\lSr U=r $) 6ComposerV1alpha2.ProjectsLocationsImageVersionsServiceiz@Service class for the projects_locations_imageVersions resource.r,cN>[[RU]U5 0Ulgr=)rrr+rr>r?s r6r?ComposerV1alpha2.ProjectsLocationsImageVersionsService.__init__s$  B BDRSYZ dr8cDURS5nURX1US9$)aList ImageVersions for provided location. Args: request: (ComposerProjectsLocationsImageVersionsListRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (ListImageVersionsResponse) The response message. rgrDrFrIs r6rg;ComposerV1alpha2.ProjectsLocationsImageVersionsService.Listrir8cF[R"SSSS/S//SQSSSS S S 9 $) NzDv1alpha2/projects/{projectsId}/locations/{locationsId}/imageVersionsrOz.composer.projects.locations.imageVersions.listrk)includePastReleasesrnroz v1alpha2/{+parent}/imageVersionsrR1ComposerProjectsLocationsImageVersionsListRequestListImageVersionsResponseFrUrarcr8r6rd?ComposerV1alpha2.ProjectsLocationsImageVersionsService.s4!7!7XB zJE8M6 "r8rrr=rr}s@r6r+rs"J .E 8 Dr8r+c^\rSrSrSrSrU4SjrSSjrS\lSSjr S\ lSS jr S \ lSS jr S \ lS r U=r $)3ComposerV1alpha2.ProjectsLocationsOperationsServiceiz=Service class for the projects_locations_operations resource.r.cN>[[RU]U5 0Ulgr=)rrr-rr>r?s r6rs48#9#9kAxH/.L" $r8cDURS5nURX1US9$)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. rrDrFrIs r6r:ComposerV1alpha2.ProjectsLocationsOperationsService.Deleterr8cB[R"SSSS/S//SSSSS S 9 $) NPv1alpha2/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}rz-composer.projects.locations.operations.deleterPrQrR0ComposerProjectsLocationsOperationsDeleteRequestrFrUrarcr8r6rdrs48#9#9dAxH(L" $r8cDURS5nURX1US9$)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: (ComposerProjectsLocationsOperationsGetRequest) input message global_params: (StandardQueryParameters, default: None) global arguments Returns: (Operation) The response message. rCrDrFrIs r6rC7ComposerV1alpha2.ProjectsLocationsOperationsService.Get rMr8cB[R"SSSS/S//SSSSS S 9 $) NrrOz*composer.projects.locations.operations.getrPrQrR-ComposerProjectsLocationsOperationsGetRequestr+FrUrarcr8r6rdrs4 6 6d>xH(I& !r8cDURS5nURX1US9$)a^Lists 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. rgrDrFrIs r6rg8ComposerV1alpha2.ProjectsLocationsOperationsService.List$rir8cF[R"SSSS/S//SQSSSS S S 9 $) NzAv1alpha2/projects/{projectsId}/locations/{locationsId}/operationsrOz+composer.projects.locations.operations.listrP)rmrnroreturnPartialSuccesszv1alpha2/{+name}/operationsrR.ComposerProjectsLocationsOperationsListRequestListOperationsResponseFrUrarcr8r6rdr1s4!7!7U?xHP3J3 "r8rrr=)rtrurvrwrxryrrrzrrCrgr{r|r}s@r6r-rsOG +E 8 F 8 F 8 C 8 Dr8r-c0^\rSrSrSrSrU4SjrSrU=r$))ComposerV1alpha2.ProjectsLocationsServicei?z2Service class for the projects_locations resource.r0cN>[[RU]U5 0Ulgr=)rrr/rr>r?s r6r2ComposerV1alpha2.ProjectsLocationsService.__init__Ds#  5 5tEfM dr8rr rtrurvrwrxryrr{r|r}s@r6r/r?s< E  r8r/c0^\rSrSrSrSrU4SjrSrU=r$) ComposerV1alpha2.ProjectsServiceiIz(Service class for the projects resource.r2cN>[[RU]U5 0Ulgr=)rrr1rr>r?s r6r)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  //  r8rN) rx __future__rapitools.base.pyr7googlecloudsdk.generated_clients.apis.composer.v1alpha2rr BaseApiClientrrcr8r6rs'='%jG x--G r8