
    ߝ                     V    S r SSKJr  SSKJr  SSKJr   " S S\R                  5      r	g)z1Generated client library for composer version v1.    )absolute_import)base_api)composer_v1_messagesc                     ^  \ rS rSrSr\rSrSrSr	S/r
SrSrS	rS
rS rSrSr     SU 4S jjr " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      r " S S\R(                  5      rSrU =r$ )
ComposerV1
   z9Generated client library for service composer version v1.z https://composer.googleapis.com/z%https://composer.mtls.googleapis.com/composerz.https://www.googleapis.com/auth/cloud-platformv1	CLIENT_IDCLIENT_SECRETzgoogle-cloud-sdkNc                   > U=(       d    U R                   n[        [        U ]  XX4UXgUU	U
US9  U R	                  U 5      U l        U R                  U 5      U l        U R                  U 5      U l	        U R                  U 5      U l        U R                  U 5      U l        U R                  U 5      U l        U R!                  U 5      U l        U R%                  U 5      U l        g)zCreate a new composer handle.)
credentialsget_credentialshttpmodellog_requestlog_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BASE_URLsuperr   __init__;ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService7projects_locations_environments_userWorkloadsConfigMaps8ProjectsLocationsEnvironmentsUserWorkloadsSecretsService4projects_locations_environments_userWorkloadsSecrets-ProjectsLocationsEnvironmentsWorkloadsService)projects_locations_environments_workloads$ProjectsLocationsEnvironmentsServiceprojects_locations_environments%ProjectsLocationsImageVersionsService projects_locations_imageVersions"ProjectsLocationsOperationsServiceprojects_locations_operationsProjectsLocationsServiceprojects_locationsProjectsServiceprojects)selfurlr   r   r   r   r   r   r   r   r   r   	__class__s               Klib/googlecloudsdk/generated_clients/apis/composer/v1/composer_v1_client.pyr   ComposerV1.__init__   s     
C	*d$'%)3 7+ % - DH  DD  DD  EI  DJD@@D@}@}  C  ADD=595g5ghl5mD2+/+T+TUY+ZD(,0,V,VW[,\D))-)P)PQU)VD&";;DAD((.DM    c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ )FComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService3   zWService class for the projects_locations_environments_userWorkloadsConfigMaps resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g N)r   r   r   r   _upload_configsr+   clientr-   s     r.   r   OComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.__init__8   s$    JRRTXbcijdr0   c                 D    U R                  S5      nU R                  X1US9$ )a  Creates 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.
Createglobal_paramsGetMethodConfig
_RunMethodr+   requestr=   configs       r.   r;   MComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Create=   /     ##H-f__
  8 8r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nfv1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsConfigMapsPOSTzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.createparent$v1/{+parent}/userWorkloadsConfigMapsuserWorkloadsConfigMapIComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateRequestUserWorkloadsConfigMapF	flat_pathhttp_method	method_idordered_paramspath_paramsquery_paramsrelative_pathrequest_fieldrequest_type_nameresponse_type_namesupports_downloadr   ApiMethodInfo r0   r.   <lambda>OComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.<lambda>J   s4    8#9#9z[ zJ<.e3$r0   c                 D    U R                  S5      nU R                  X1US9$ )au  Deletes 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<   r>   rA   s       r.   r`   MComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.DeleteX   rE   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nv1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsConfigMaps/{userWorkloadsConfigMapsId}DELETEzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.deletename
v1/{+name} IComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteRequestEmptyFrN   rZ   r\   r0   r.   r]   r^   e   s7    8#9#9 W[xH"e"$r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Gets 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.
Getr<   r>   rA   s       r.   rk   JComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Gets   /     ##E*f__
  8 8r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nrc   GETzDcomposer.projects.locations.environments.userWorkloadsConfigMaps.getre   rf   rg   FComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetRequestrM   FrN   rZ   r\   r0   r.   r]   r^      s7     6 6 WXxH"b3!r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Lists 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.
Listr<   r>   rA   s       r.   rr   KComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.List   /     ##F+f__
  8 8r0   c                  F    [         R                  " SSSS/S/SS/SSS	S
SS9$ )NrG   ro   zEcomposer.projects.locations.environments.userWorkloadsConfigMaps.listrI   pageSize	pageTokenrJ   rg   GComposerProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListRequest#ListUserWorkloadsConfigMapsResponseFrN   rZ   r\   r0   r.   r]   r^      s9    !7!7zY zJ +.<c@"r0   c                 D    U R                  S5      nU R                  X1US9$ )aS  Updates 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<   r>   rA   s       r.   r{   MComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService.Update   rE   r0   c                  B    [         R                  " SSSS/S// SSSSSS	9$ )
Nrc   PUTzGcomposer.projects.locations.environments.userWorkloadsConfigMaps.updatere   rf   	<request>rM   FrN   rZ   r\   r0   r.   r]   r^      s7    8#9#9 W[xH"!23$r0   r6   r5   __name__
__module____qualname____firstlineno____doc___NAMEr   r;   method_configr`   rk   rr   r{   __static_attributes____classcell__r-   s   @r.   r   r2   3   s^    aEE
8F8F8C8D8Fr0   r   c                      ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SS jrS \l        SS jrS \l        SrU =r$ )CComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService   zTService class for the projects_locations_environments_userWorkloadsSecrets resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g r5   )r   r   r   r   r6   r7   s     r.   r   LComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.__init__   s$    JOOQU_`fgdr0   c                 D    U R                  S5      nU R                  X1US9$ )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.
r;   r<   r>   rA   s       r.   r;   JComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Create   rE   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Ncv1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsSecretsrH   zDcomposer.projects.locations.environments.userWorkloadsSecrets.createrI   !v1/{+parent}/userWorkloadsSecretsuserWorkloadsSecretFComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateRequestUserWorkloadsSecretFrN   rZ   r\   r0   r.   r]   LComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.<lambda>   s4    8#9#9wX zJ9+b0$r0   c                 D    U R                  S5      nU R                  X1US9$ )ao  Deletes 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.
r`   r<   r>   rA   s       r.   r`   JComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Delete   rE   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )N|v1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/userWorkloadsSecrets/{userWorkloadsSecretsId}rd   zDcomposer.projects.locations.environments.userWorkloadsSecrets.deletere   rf   rg   FComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteRequestri   FrN   rZ   r\   r0   r.   r]   r      s7    8#9#9 QXxH"b"$r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Gets 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.
rk   r<   r>   rA   s       r.   rk   GComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Get  rm   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr   ro   zAcomposer.projects.locations.environments.userWorkloadsSecrets.getre   rf   rg   CComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsGetRequestr   FrN   rZ   r\   r0   r.   r]   r     s7     6 6 QUxH"_0!r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Lists 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.
rr   r<   r>   rA   s       r.   rr   HComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.List  rt   r0   c                  F    [         R                  " SSSS/S/SS/SSS	S
SS9$ )Nr   ro   zBcomposer.projects.locations.environments.userWorkloadsSecrets.listrI   rv   rw   r   rg   DComposerProjectsLocationsEnvironmentsUserWorkloadsSecretsListRequest ListUserWorkloadsSecretsResponseFrN   rZ   r\   r0   r.   r]   r   ,  s9    !7!7wV zJ +.9`="r0   c                 D    U R                  S5      nU R                  X1US9$ )aJ  Updates 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.
r{   r<   r>   rA   s       r.   r{   JComposerV1.ProjectsLocationsEnvironmentsUserWorkloadsSecretsService.Update:  rE   r0   c                  B    [         R                  " SSSS/S// SSSSSS	9$ )
Nr   r~   zDcomposer.projects.locations.environments.userWorkloadsSecrets.updatere   rf   r   r   FrN   rZ   r\   r0   r.   r]   r   G  s7    8#9#9 QXxH"!/0$r0   r   r5   r   r   s   @r.   r   r      s^    ^BE
8F8F8C8D8Fr0   r   c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	8ComposerV1.ProjectsLocationsEnvironmentsWorkloadsServiceiU  zIService class for the projects_locations_environments_workloads resource.r    c                 N   > [         [        R                  U ]  U5        0 U l        g r5   )r   r   r   r   r6   r7   s     r.   r   AComposerV1.ProjectsLocationsEnvironmentsWorkloadsService.__init__Z  s#    JDDdTU[\dr0   c                 D    U R                  S5      nU R                  X1US9$ )a  Lists 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.
rr   r<   r>   rA   s       r.   rr   =ComposerV1.ProjectsLocationsEnvironmentsWorkloadsService.List_  rt   r0   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )NzXv1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}/workloadsro   z7composer.projects.locations.environments.workloads.listrI   )filterrv   rw   zv1/{+parent}/workloadsrg   9ComposerProjectsLocationsEnvironmentsWorkloadsListRequestListWorkloadsResponseFrN   rZ   r\   r0   r.   r]   AComposerV1.ProjectsLocationsEnvironmentsWorkloadsService.<lambda>l  s4    !7!7lK zJ8.U2"r0   r   r5   r   r   r   r   r   r   r   rr   r   r   r   r   s   @r.   r   r   U  s"    S7E
8Dr0   r   c                     ^  \ rS rSrSrSrU 4S jrS"S jrS \l        S"S jr	S \	l        S"S	 jr
S
 \
l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS \l        S"S jrS  \l        S!rU =r$ )#/ComposerV1.ProjectsLocationsEnvironmentsServiceiz  z?Service class for the projects_locations_environments resource.r"   c                 N   > [         [        R                  U ]  U5        0 U l        g r5   )r   r   r!   r   r6   r7   s     r.   r   8ComposerV1.ProjectsLocationsEnvironmentsService.__init__  s"    J;;TKFSdr0   c                 D    U R                  S5      nU R                  X1US9$ )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.
CheckUpgrader<   r>   rA   s       r.   r   <ComposerV1.ProjectsLocationsEnvironmentsService.CheckUpgrade  /     ##N3f__
  8 8r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nz[v1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:checkUpgraderH   z5composer.projects.locations.environments.checkUpgradeenvironmentzv1/{+environment}:checkUpgradecheckUpgradeRequest8ComposerProjectsLocationsEnvironmentsCheckUpgradeRequest	OperationFrN   rZ   r\   r0   r.   r]   8ComposerV1.ProjectsLocationsEnvironmentsService.<lambda>  4    )?)?oI%"O6+T&*r0   c                 D    U R                  S5      nU R                  X1US9$ )zCreate a new environment.

Args:
  request: (ComposerProjectsLocationsEnvironmentsCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
r;   r<   r>   rA   s       r.   r;   6ComposerV1.ProjectsLocationsEnvironmentsService.Create  rE   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )N=v1/projects/{projectsId}/locations/{locationsId}/environmentsrH   z/composer.projects.locations.environments.createrI   v1/{+parent}/environmentsr   2ComposerProjectsLocationsEnvironmentsCreateRequestr   FrN   rZ   r\   r0   r.   r]   r     s4    8#9#9QC zJ1#N&$r0   c                 D    U R                  S5      nU R                  X1US9$ )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<   r>   rA   s       r.   r   @ComposerV1.ProjectsLocationsEnvironmentsService.DatabaseFailover  0     ##$67f__
  8 8r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nz_v1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:databaseFailoverrH   z9composer.projects.locations.environments.databaseFailoverr   z"v1/{+environment}:databaseFailoverdatabaseFailoverRequest<ComposerProjectsLocationsEnvironmentsDatabaseFailoverRequestr   FrN   rZ   r\   r0   r.   r]   r     s4    X-C-CsM%"O:/X&.r0   c                 D    U R                  S5      nU R                  X1US9$ )zDelete an environment.

Args:
  request: (ComposerProjectsLocationsEnvironmentsDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
r`   r<   r>   rA   s       r.   r`   6ComposerV1.ProjectsLocationsEnvironmentsService.Delete  rE   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NNv1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}rd   z/composer.projects.locations.environments.deletere   rf   rg   2ComposerProjectsLocationsEnvironmentsDeleteRequestr   FrN   rZ   r\   r0   r.   r]   r     s4    8#9#9bCxH"N&$r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Executes Airflow CLI command.

Args:
  request: (ComposerProjectsLocationsEnvironmentsExecuteAirflowCommandRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ExecuteAirflowCommandResponse) The response message.
ExecuteAirflowCommandr<   r>   rA   s       r.   r   EComposerV1.ProjectsLocationsEnvironmentsService.ExecuteAirflowCommand  s0     ##$;<f__
  8 8r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nzdv1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:executeAirflowCommandrH   z>composer.projects.locations.environments.executeAirflowCommandr   z'v1/{+environment}:executeAirflowCommandexecuteAirflowCommandRequestAComposerProjectsLocationsEnvironmentsExecuteAirflowCommandRequestExecuteAirflowCommandResponseFrN   rZ   r\   r0   r.   r]   r     s4    (2H2HxR%"O?4]:3r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Fetches database properties.

Args:
  request: (ComposerProjectsLocationsEnvironmentsFetchDatabasePropertiesRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (FetchDatabasePropertiesResponse) The response message.
FetchDatabasePropertiesr<   r>   rA   s       r.   r   GComposerV1.ProjectsLocationsEnvironmentsService.FetchDatabaseProperties  s0     ##$=>f__
  8 8r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nzfv1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:fetchDatabasePropertiesro   z@composer.projects.locations.environments.fetchDatabasePropertiesr   z)v1/{+environment}:fetchDatabasePropertiesrg   CComposerProjectsLocationsEnvironmentsFetchDatabasePropertiesRequestFetchDatabasePropertiesResponseFrN   rZ   r\   r0   r.   r]   r     s4    H4J4JzT%"OA_<5r0   c                 D    U R                  S5      nU R                  X1US9$ )zGet an existing environment.

Args:
  request: (ComposerProjectsLocationsEnvironmentsGetRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Environment) The response message.
rk   r<   r>   rA   s       r.   rk   3ComposerV1.ProjectsLocationsEnvironmentsService.Get&  rm   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr   ro   z,composer.projects.locations.environments.getre   rf   rg   /ComposerProjectsLocationsEnvironmentsGetRequestEnvironmentFrN   rZ   r\   r0   r.   r]   r   3  s4     6 6b@xH"K(!r0   c                 D    U R                  S5      nU R                  X1US9$ )zList environments.

Args:
  request: (ComposerProjectsLocationsEnvironmentsListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListEnvironmentsResponse) The response message.
rr   r<   r>   rA   s       r.   rr   4ComposerV1.ProjectsLocationsEnvironmentsService.ListA  rt   r0   c                  F    [         R                  " SSSS/S/SS/SSS	S
SS9$ )Nr   ro   z-composer.projects.locations.environments.listrI   rv   rw   r   rg   0ComposerProjectsLocationsEnvironmentsListRequestListEnvironmentsResponseFrN   rZ   r\   r0   r.   r]   r   N  s9    !7!7QA zJ +.1L5"r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Loads 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<   r>   rA   s       r.   r   <ComposerV1.ProjectsLocationsEnvironmentsService.LoadSnapshot\  r   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nz[v1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:loadSnapshotrH   z5composer.projects.locations.environments.loadSnapshotr   zv1/{+environment}:loadSnapshotloadSnapshotRequest8ComposerProjectsLocationsEnvironmentsLoadSnapshotRequestr   FrN   rZ   r\   r0   r.   r]   r   i  r   r0   c                 D    U R                  S5      nU R                  X1US9$ )zUpdate an environment.

Args:
  request: (ComposerProjectsLocationsEnvironmentsPatchRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
Patchr<   r>   rA   s       r.   r   5ComposerV1.ProjectsLocationsEnvironmentsService.Patchw  s/     ##G,f__
  8 8r0   c                  D    [         R                  " SSSS/S/S/SSSS	S
S9$ )Nr   PATCHz.composer.projects.locations.environments.patchre   
updateMaskrf   r   1ComposerProjectsLocationsEnvironmentsPatchRequestr   FrN   rZ   r\   r0   r.   r]   r     s6    ("8"8bBxH"^"#M&#r0   c                 D    U R                  S5      nU R                  X1US9$ )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.
PollAirflowCommandr<   r>   rA   s       r.   r   BComposerV1.ProjectsLocationsEnvironmentsService.PollAirflowCommand  0     ##$89f__
  8 8r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nzav1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:pollAirflowCommandrH   z;composer.projects.locations.environments.pollAirflowCommandr   z$v1/{+environment}:pollAirflowCommandpollAirflowCommandRequest>ComposerProjectsLocationsEnvironmentsPollAirflowCommandRequestPollAirflowCommandResponseFrN   rZ   r\   r0   r.   r]   r     4    x/E/EuO%"O<1Z70r0   c                 D    U R                  S5      nU R                  X1US9$ )zRestart Airflow web server.

Args:
  request: (ComposerProjectsLocationsEnvironmentsRestartWebServerRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
RestartWebServerr<   r>   rA   s       r.   r  @ComposerV1.ProjectsLocationsEnvironmentsService.RestartWebServer  r   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nz_v1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:restartWebServerrH   z9composer.projects.locations.environments.restartWebServerre   zv1/{+name}:restartWebServerrestartWebServerRequest<ComposerProjectsLocationsEnvironmentsRestartWebServerRequestr   FrN   rZ   r\   r0   r.   r]   r     s4    X-C-CsMxH3/X&.r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Creates 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<   r>   rA   s       r.   r  <ComposerV1.ProjectsLocationsEnvironmentsService.SaveSnapshot  r   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nz[v1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:saveSnapshotrH   z5composer.projects.locations.environments.saveSnapshotr   zv1/{+environment}:saveSnapshotsaveSnapshotRequest8ComposerProjectsLocationsEnvironmentsSaveSnapshotRequestr   FrN   rZ   r\   r0   r.   r]   r     r   r0   c                 D    U R                  S5      nU R                  X1US9$ )a  Stops Airflow CLI command execution.

Args:
  request: (ComposerProjectsLocationsEnvironmentsStopAirflowCommandRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (StopAirflowCommandResponse) The response message.
StopAirflowCommandr<   r>   rA   s       r.   r  BComposerV1.ProjectsLocationsEnvironmentsService.StopAirflowCommand  r   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nzav1/projects/{projectsId}/locations/{locationsId}/environments/{environmentsId}:stopAirflowCommandrH   z;composer.projects.locations.environments.stopAirflowCommandr   z$v1/{+environment}:stopAirflowCommandstopAirflowCommandRequest>ComposerProjectsLocationsEnvironmentsStopAirflowCommandRequestStopAirflowCommandResponseFrN   rZ   r\   r0   r.   r]   r     r  r0   r   r5   )r   r   r   r   r   r   r   r   r   r;   r   r`   r   r   rk   rr   r   r   r   r  r  r  r   r   r   s   @r.   r!   r   z  s    I-E
8"L8F8&"8F8+'8-)8C8D8"L8E8($8&"8"L8($$r0   r!   c                   J   ^  \ rS rSrSrSrU 4S jrSS jrS \l        Sr	U =r
$ )	0ComposerV1.ProjectsLocationsImageVersionsServicei  z@Service class for the projects_locations_imageVersions resource.r$   c                 N   > [         [        R                  U ]  U5        0 U l        g r5   )r   r   r#   r   r6   r7   s     r.   r   9ComposerV1.ProjectsLocationsImageVersionsService.__init__  s"    J<<dLVTdr0   c                 D    U R                  S5      nU R                  X1US9$ )a  List ImageVersions for provided location.

Args:
  request: (ComposerProjectsLocationsImageVersionsListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListImageVersionsResponse) The response message.
rr   r<   r>   rA   s       r.   rr   5ComposerV1.ProjectsLocationsImageVersionsService.List  rt   r0   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nz>v1/projects/{projectsId}/locations/{locationsId}/imageVersionsro   z.composer.projects.locations.imageVersions.listrI   )includePastReleasesrv   rw   zv1/{+parent}/imageVersionsrg   1ComposerProjectsLocationsImageVersionsListRequestListImageVersionsResponseFrN   rZ   r\   r0   r.   r]   9ComposerV1.ProjectsLocationsImageVersionsService.<lambda>  s4    !7!7RB zJE2M6"r0   r   r5   r   r   s   @r.   r#   r    s"    J.E
8Dr0   r#   c                   ~   ^  \ rS rSrSrSrU 4S jrSS jrS \l        SS jr	S \	l        SS	 jr
S
 \
l        SrU =r$ )-ComposerV1.ProjectsLocationsOperationsServicei#  z=Service class for the projects_locations_operations resource.r&   c                 N   > [         [        R                  U ]  U5        0 U l        g r5   )r   r   r%   r   r6   r7   s     r.   r   6ComposerV1.ProjectsLocationsOperationsService.__init__(  s"    J994I&Qdr0   c                 D    U R                  S5      nU R                  X1US9$ )a  Deletes 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.
r`   r<   r>   rA   s       r.   r`   4ComposerV1.ProjectsLocationsOperationsService.Delete-  rE   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NJv1/projects/{projectsId}/locations/{locationsId}/operations/{operationsId}rd   z-composer.projects.locations.operations.deletere   rf   rg   0ComposerProjectsLocationsOperationsDeleteRequestri   FrN   rZ   r\   r0   r.   r]   6ComposerV1.ProjectsLocationsOperationsService.<lambda>:  s4    8#9#9^AxH"L"$r0   c                 D    U R                  S5      nU R                  X1US9$ )ad  Gets 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.
rk   r<   r>   rA   s       r.   rk   1ComposerV1.ProjectsLocationsOperationsService.GetH  rm   r0   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr*  ro   z*composer.projects.locations.operations.getre   rf   rg   -ComposerProjectsLocationsOperationsGetRequestr   FrN   rZ   r\   r0   r.   r]   r,  U  s4     6 6^>xH"I&!r0   c                 D    U R                  S5      nU R                  X1US9$ )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.
rr   r<   r>   rA   s       r.   rr   2ComposerV1.ProjectsLocationsOperationsService.Listc  rt   r0   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nz;v1/projects/{projectsId}/locations/{locationsId}/operationsro   z+composer.projects.locations.operations.listre   )r   rv   rw   returnPartialSuccesszv1/{+name}/operationsrg   .ComposerProjectsLocationsOperationsListRequestListOperationsResponseFrN   rZ   r\   r0   r.   r]   r,  p  s4    !7!7O?xHP-J3"r0   r   r5   )r   r   r   r   r   r   r   r`   r   rk   rr   r   r   r   s   @r.   r%   r$  #  s@    G+E
8F8C8Dr0   r%   c                   0   ^  \ rS rSrSrSrU 4S jrSrU =r$ )#ComposerV1.ProjectsLocationsServicei~  z2Service class for the projects_locations resource.r(   c                 N   > [         [        R                  U ]  U5        0 U l        g r5   )r   r   r'   r   r6   r7   s     r.   r   ,ComposerV1.ProjectsLocationsService.__init__  s"    J//?Gdr0   r   	r   r   r   r   r   r   r   r   r   r   s   @r.   r'   r8  ~  s    < E r0   r'   c                   0   ^  \ rS rSrSrSrU 4S jrSrU =r$ )ComposerV1.ProjectsServicei  z(Service class for the projects resource.r*   c                 N   > [         [        R                  U ]  U5        0 U l        g r5   )r   r   r)   r   r6   r7   s     r.   r   #ComposerV1.ProjectsService.__init__  s"    J&&6v>dr0   r   r;  r   s   @r.   r)   r=    s    2E r0   r)   )r*   r(   r"   r   r   r    r$   r&   )rg   NTNNFFNNNN)r   r   r   r   r   messagesMESSAGES_MODULEr   MTLS_BASE_URL_PACKAGE_SCOPES_VERSION
_CLIENT_ID_CLIENT_SECRET_USER_AGENT_CLIENT_CLASS_NAME_URL_VERSION_API_KEYr   r   BaseApiServicer   r   r   r!   r#   r%   r'   r)   r   r   r   s   @r.   r   r   
   s    A//(9-(=>'(*"."+#,()-6:/4<@?C	/0OHD[D[ ObOAXAX Ob#h6M6M #JBX-D-D BH#h.E.E #JY8+B+B Yv!8!8 //  r0   r   N)
r   
__future__r   apitools.base.pyr   1googlecloudsdk.generated_clients.apis.composer.v1r   r@  BaseApiClientr   r\   r0   r.   <module>rQ     s'    7 ' % ^F'' Fr0   