
    L9                     V    S r SSKJr  SSKJr  SSKJr   " S S\R                  5      r	g)z;Generated client library for composerflex version v1alpha1.    )absolute_import)base_api)composerflex_v1alpha1_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rU =r$ )ComposerflexV1alpha1
   zCGenerated client library for service composerflex version v1alpha1.z$https://composerflex.googleapis.com/z)https://composerflex.mtls.googleapis.com/composerflexz.https://www.googleapis.com/auth/cloud-platformv1alpha1	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        g)z!Create a new composerflex handle.)
credentialsget_credentialshttpmodellog_requestlog_responsecredentials_argsdefault_global_paramsadditional_http_headersresponse_encodingN)BASE_URLsuperr   __init__ ProjectsLocationsContextsServiceprojects_locations_contexts%ProjectsLocationsWorkflowsRunsService!projects_locations_workflows_runs!ProjectsLocationsWorkflowsServiceprojects_locations_workflowsProjectsLocationsServiceprojects_locationsProjectsServiceprojects)selfurlr   r   r   r   r   r   r   r   r   r   	__class__s               _lib/googlecloudsdk/generated_clients/apis/composerflex/v1alpha1/composerflex_v1alpha1_client.pyr   ComposerflexV1alpha1.__init__   s     
C	
.'%)3 7+ / - (,'L'LT'RD$-1-W-WX\-]D*(,(N(Nt(TD%";;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rU =r$ )5ComposerflexV1alpha1.ProjectsLocationsContextsService0   z;Service class for the projects_locations_contexts resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g N)r   r   r   r   _upload_configsr%   clientr'   s     r(   r   >ComposerflexV1alpha1.ProjectsLocationsContextsService.__init__5   s$     AA4QRXYdr*   c                 D    U R                  S5      nU R                  X1US9$ )zCreates a new context.

Args:
  request: (ComposerflexProjectsLocationsContextsCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
Createglobal_paramsGetMethodConfig
_RunMethodr%   requestr7   configs       r(   r5   <ComposerflexV1alpha1.ProjectsLocationsContextsService.Create:   /     ##H-f__
  8 8r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )N?v1alpha1/projects/{projectsId}/locations/{locationsId}/contextsPOSTz/composerflex.projects.locations.contexts.createparentv1alpha1/{+parent}/contextscontext2ComposerflexProjectsLocationsContextsCreateRequest	OperationF	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 r*   r(   <lambda>>ComposerflexV1alpha1.ProjectsLocationsContextsService.<lambda>G   s4    8#9#9SC zJ3N&$r*   c                 D    U R                  S5      nU R                  X1US9$ )a  Deletes a context. A context cannot be deleted if any workflows are bound to it.

Args:
  request: (ComposerflexProjectsLocationsContextsDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
Deleter6   r8   r;   s       r(   rZ   <ComposerflexV1alpha1.ProjectsLocationsContextsService.DeleteU   r?   r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NLv1alpha1/projects/{projectsId}/locations/{locationsId}/contexts/{contextsId}DELETEz/composerflex.projects.locations.contexts.deletenamev1alpha1/{+name} 2ComposerflexProjectsLocationsContextsDeleteRequestrG   FrH   rT   rV   r*   r(   rW   rX   b   s4    8#9#9`CxH(N&$r*   c                 D    U R                  S5      nU R                  X1US9$ )zRetrieves a context.

Args:
  request: (ComposerflexProjectsLocationsContextsGetRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Context) The response message.
Getr6   r8   r;   s       r(   rd   9ComposerflexV1alpha1.ProjectsLocationsContextsService.Getp   /     ##E*f__
  8 8r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr]   GETz,composerflex.projects.locations.contexts.getr_   r`   ra   /ComposerflexProjectsLocationsContextsGetRequestContextFrH   rT   rV   r*   r(   rW   rX   }   s4     6 6`@xH(K$!r*   c                 D    U R                  S5      nU R                  X1US9$ )a  Lists contexts within a project and location.

Args:
  request: (ComposerflexProjectsLocationsContextsListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListContextsResponse) The response message.
Listr6   r8   r;   s       r(   rl   :ComposerflexV1alpha1.ProjectsLocationsContextsService.List   /     ##F+f__
  8 8r*   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )NrA   rh   z-composerflex.projects.locations.contexts.listrC   filterorderBypageSize	pageTokenrD   ra   0ComposerflexProjectsLocationsContextsListRequestListContextsResponseFrH   rT   rV   r*   r(   rW   rX      s4    !7!7SA zJC3L1"r*   r0   r/   __name__
__module____qualname____firstlineno____doc___NAMEr   r5   method_configrZ   rd   rl   __static_attributes____classcell__r'   s   @r(   r   r,   0   sO    E)E
8F8F8C8Dr*   r   c                   d   ^  \ 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	r
U =r$ ):ComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService   zAService class for the projects_locations_workflows_runs resource.r   c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r   r   r0   r1   s     r(   r   CComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.__init__   s$     FFVW]^dr*   c                 D    U R                  S5      nU R                  X1US9$ )zRetrieves a workflow run.

Args:
  request: (ComposerflexProjectsLocationsWorkflowsRunsGetRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (WorkflowRun) The response message.
rd   r6   r8   r;   s       r(   rd   >ComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.Get   rf   r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nz\v1alpha1/projects/{projectsId}/locations/{locationsId}/workflows/{workflowsId}/runs/{runsId}rh   z2composerflex.projects.locations.workflows.runs.getr_   r`   ra   4ComposerflexProjectsLocationsWorkflowsRunsGetRequestWorkflowRunFrH   rT   rV   r*   r(   rW   CComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.<lambda>   s4     6 6pFxH(P(!r*   c                 D    U R                  S5      nU R                  X1US9$ )a  Lists runs of a workflow in a project and location. If the workflow is set to the wildcard "-", then workflow runs from all workflows in the project and location will be listed.

Args:
  request: (ComposerflexProjectsLocationsWorkflowsRunsListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListWorkflowRunsResponse) The response message.
rl   r6   r8   r;   s       r(   rl   ?ComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.List   rn   r*   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )NzSv1alpha1/projects/{projectsId}/locations/{locationsId}/workflows/{workflowsId}/runsrh   z3composerflex.projects.locations.workflows.runs.listrC   rp   zv1alpha1/{+parent}/runsra   5ComposerflexProjectsLocationsWorkflowsRunsListRequestListWorkflowRunsResponseFrH   rT   rV   r*   r(   rW   r      s4    !7!7gG zJC/Q5"r*   rw   r/   )ry   rz   r{   r|   r}   r~   r   rd   r   rl   r   r   r   s   @r(   r   r      s1    K/E
8C8Dr*   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rU =r$ )6ComposerflexV1alpha1.ProjectsLocationsWorkflowsService   z<Service class for the projects_locations_workflows resource.r    c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r   r   r0   r1   s     r(   r   ?ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.__init__   s$     BBDRSYZdr*   c                 D    U R                  S5      nU R                  X1US9$ )zCreates a workflow from an Airflow DAG.

Args:
  request: (ComposerflexProjectsLocationsWorkflowsCreateRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
r5   r6   r8   r;   s       r(   r5   =ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.Create   r?   r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )N@v1alpha1/projects/{projectsId}/locations/{locationsId}/workflowsrB   z0composerflex.projects.locations.workflows.createrC   v1alpha1/{+parent}/workflowsworkflow3ComposerflexProjectsLocationsWorkflowsCreateRequestrG   FrH   rT   rV   r*   r(   rW   ?ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.<lambda>   s4    8#9#9TD zJ4 O&$r*   c                 D    U R                  S5      nU R                  X1US9$ )ai  Deletes a workflow, forcefully stopping any pending workflow runs and task instances. Long-running operations executing in external systems will continue.

Args:
  request: (ComposerflexProjectsLocationsWorkflowsDeleteRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Operation) The response message.
rZ   r6   r8   r;   s       r(   rZ   =ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.Delete  r?   r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )NNv1alpha1/projects/{projectsId}/locations/{locationsId}/workflows/{workflowsId}r^   z0composerflex.projects.locations.workflows.deleter_   r`   ra   3ComposerflexProjectsLocationsWorkflowsDeleteRequestrG   FrH   rT   rV   r*   r(   rW   r     s4    8#9#9bDxH(O&$r*   c                 D    U R                  S5      nU R                  X1US9$ )zRetrieves a workflow.

Args:
  request: (ComposerflexProjectsLocationsWorkflowsGetRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (Workflow) The response message.
rd   r6   r8   r;   s       r(   rd   :ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.Get&  rf   r*   c                  B    [         R                  " SSSS/S// SSSSS	S
9$ )Nr   rh   z-composerflex.projects.locations.workflows.getr_   r`   ra   0ComposerflexProjectsLocationsWorkflowsGetRequestWorkflowFrH   rT   rV   r*   r(   rW   r   3  s4     6 6bAxH(L%!r*   c                 D    U R                  S5      nU R                  X1US9$ )a  Lists workflows in a project and location.

Args:
  request: (ComposerflexProjectsLocationsWorkflowsListRequest) input message
  global_params: (StandardQueryParameters, default: None) global arguments
Returns:
  (ListWorkflowsResponse) The response message.
rl   r6   r8   r;   s       r(   rl   ;ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.ListA  rn   r*   c                  F    [         R                  " SSSS/S// SQSSSS	S
S9$ )Nr   rh   z.composerflex.projects.locations.workflows.listrC   rp   r   ra   1ComposerflexProjectsLocationsWorkflowsListRequestListWorkflowsResponseFrH   rT   rV   r*   r(   rW   r   N  s4    !7!7TB zJC4M2"r*   rw   r/   rx   r   s   @r(   r   r      sO    F*E
8F8F8C8Dr*   r   c                   0   ^  \ rS rSrSrSrU 4S jrSrU =r$ )-ComposerflexV1alpha1.ProjectsLocationsServicei\  z2Service class for the projects_locations resource.r"   c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r!   r   r0   r1   s     r(   r   6ComposerflexV1alpha1.ProjectsLocationsService.__init__a  s#     994I&Qdr*   rw   	ry   rz   r{   r|   r}   r~   r   r   r   r   s   @r(   r!   r   \  s    < E r*   r!   c                   0   ^  \ rS rSrSrSrU 4S jrSrU =r$ )$ComposerflexV1alpha1.ProjectsServiceif  z(Service class for the projects resource.r$   c                 N   > [         [        R                  U ]  U5        0 U l        g r/   )r   r   r#   r   r0   r1   s     r(   r   -ComposerflexV1alpha1.ProjectsService.__init__k  s#     00$@Hdr*   rw   r   r   s   @r(   r#   r   f  s    2E r*   r#   )r$   r"   r   r    r   )ra   NTNNFFNNNN)ry   rz   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   s   @r(   r   r   
   s    K/3(=-(=>'(*"."+-,()-6:/4<@?C	/*t)@)@ tl>h.E.E >@t(*A*A tl!8!8 //  r*   r   N)
r}   
__future__r   apitools.base.pyr   ;googlecloudsdk.generated_clients.apis.composerflex.v1alpha1r   r   BaseApiClientr   rV   r*   r(   <module>r      s'    A ' % rd811 dr*   