
    L9                     V    d Z ddlmZ ddlmZ ddlmZ  G d dej                        Z	y)z;Generated client library for composerflex version v1alpha1.    )absolute_import)base_api)composerflex_v1alpha1_messagesc                   2    e Zd ZdZeZdZdZdZdgZ	dZ
dZdZd	Zd ZdZd
Z	 	 	 	 	 d fd	Z G d dej&                        Z G d dej&                        Z G d dej&                        Z G d dej&                        Z G d dej&                        Z xZS )ComposerflexV1alpha1zCGenerated 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                 >   |xs | j                   }t        t        |   |||||||||	|
|       | j	                  |       | _        | j                  |       | _        | j                  |       | _	        | j                  |       | _        | j                  |       | _        y)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   zComposerflexV1alpha1.__init__   s     
C	
.'d%l)3 7+ / - (,'L'LT'RD$-1-W-WX\-]D*(,(N(Nt(TD%";;DAD((.DM    c                        e Zd ZdZdZ fdZddZd e_        ddZd e_        ddZ	d	 e	_        dd
Z
d e
_         xZS )5ComposerflexV1alpha1.ProjectsLocationsContextsServicez;Service class for the projects_locations_contexts resource.r   c                 N    t         t        j                  |   |       i | _        y N)r   r   r   r   _upload_configsr$   clientr&   s     r'   r   z>ComposerflexV1alpha1.ProjectsLocationsContextsService.__init__5   s$     AA4QRXYdr(   c                 L    | j                  d      }| j                  |||      S )a  Creates 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$   requestr3   configs       r'   r1   z<ComposerflexV1alpha1.ProjectsLocationsContextsService.Create:   1     ##H-f__
'  8 8r(   c                  F    t        j                  ddddgdgg ddddd	
      S )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>z>ComposerflexV1alpha1.ProjectsLocationsContextsService.<lambda>G   s4    8#9#9SC zJ3N&$r(   c                 L    | j                  d      }| j                  |||      S )aB  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.
      Deleter2   r4   r7   s       r'   rT   z<ComposerflexV1alpha1.ProjectsLocationsContextsService.DeleteU   r:   r(   c                  F    t        j                  ddddgdgg ddddd	
      S )NLv1alpha1/projects/{projectsId}/locations/{locationsId}/contexts/{contextsId}DELETEz/composerflex.projects.locations.contexts.deletenamev1alpha1/{+name} 2ComposerflexProjectsLocationsContextsDeleteRequestrB   FrC   rO   rQ   r(   r'   rR   z>ComposerflexV1alpha1.ProjectsLocationsContextsService.<lambda>b   s4    8#9#9`CxH(N&$r(   c                 L    | j                  d      }| j                  |||      S )a  Retrieves a context.

      Args:
        request: (ComposerflexProjectsLocationsContextsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Context) The response message.
      Getr2   r4   r7   s       r'   r]   z9ComposerflexV1alpha1.ProjectsLocationsContextsService.Getp   1     ##E*f__
'  8 8r(   c                  F    t        j                  ddddgdgg ddddd	
      S )NrV   GETz,composerflex.projects.locations.contexts.getrX   rY   rZ   /ComposerflexProjectsLocationsContextsGetRequestContextFrC   rO   rQ   r(   r'   rR   z>ComposerflexV1alpha1.ProjectsLocationsContextsService.<lambda>}   s4     6 6`@xH(K$!r(   c                 L    | j                  d      }| j                  |||      S )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.
      Listr2   r4   r7   s       r'   rd   z:ComposerflexV1alpha1.ProjectsLocationsContextsService.List   1     ##F+f__
'  8 8r(   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr<   r`   z-composerflex.projects.locations.contexts.listr>   filterorderBypageSize	pageTokenr?   rZ   0ComposerflexProjectsLocationsContextsListRequestListContextsResponseFrC   rO   rQ   r(   r'   rR   z>ComposerflexV1alpha1.ProjectsLocationsContextsService.<lambda>   s4    !7!7SA zJC3L1"r(   r,   __name__
__module____qualname____doc___NAMEr   r1   method_configrT   r]   rd   __classcell__r&   s   @r'   r   r*   0   sO    E)E
8F8F8C8Dr(   r   c                   V     e Zd ZdZdZ fdZddZd e_        ddZd e_         xZ	S )	:ComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsServicezAService class for the projects_locations_workflows_runs resource.r   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r   r   r-   r.   s     r'   r   zCComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.__init__   s$     FFVW]^dr(   c                 L    | j                  d      }| j                  |||      S )a  Retrieves a workflow run.

      Args:
        request: (ComposerflexProjectsLocationsWorkflowsRunsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (WorkflowRun) The response message.
      r]   r2   r4   r7   s       r'   r]   z>ComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.Get   r^   r(   c                  F    t        j                  ddddgdgg ddddd	
      S )Nz\v1alpha1/projects/{projectsId}/locations/{locationsId}/workflows/{workflowsId}/runs/{runsId}r`   z2composerflex.projects.locations.workflows.runs.getrX   rY   rZ   4ComposerflexProjectsLocationsWorkflowsRunsGetRequestWorkflowRunFrC   rO   rQ   r(   r'   rR   zCComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.<lambda>   s4     6 6pFxH(P(!r(   c                 L    | j                  d      }| j                  |||      S )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.
      rd   r2   r4   r7   s       r'   rd   z?ComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.List   re   r(   c                  J    t        j                  ddddgdgg ddddd	d
      S )NzSv1alpha1/projects/{projectsId}/locations/{locationsId}/workflows/{workflowsId}/runsr`   z3composerflex.projects.locations.workflows.runs.listr>   rg   zv1alpha1/{+parent}/runsrZ   5ComposerflexProjectsLocationsWorkflowsRunsListRequestListWorkflowRunsResponseFrC   rO   rQ   r(   r'   rR   zCComposerflexV1alpha1.ProjectsLocationsWorkflowsRunsService.<lambda>   s4    !7!7gG zJC/Q5"r(   r,   )
ro   rp   rq   rr   rs   r   r]   rt   rd   ru   rv   s   @r'   r   rx      s1    K/E
8C8Dr(   r   c                        e Zd ZdZdZ fdZddZd e_        ddZd e_        ddZ	d	 e	_        dd
Z
d e
_         xZS )6ComposerflexV1alpha1.ProjectsLocationsWorkflowsServicez<Service class for the projects_locations_workflows resource.r   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r   r   r-   r.   s     r'   r   z?ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.__init__   s$     BBDRSYZdr(   c                 L    | j                  d      }| j                  |||      S )a  Creates a workflow from an Airflow DAG.

      Args:
        request: (ComposerflexProjectsLocationsWorkflowsCreateRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Operation) The response message.
      r1   r2   r4   r7   s       r'   r1   z=ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.Create   r:   r(   c                  F    t        j                  ddddgdgg ddddd	
      S )N@v1alpha1/projects/{projectsId}/locations/{locationsId}/workflowsr=   z0composerflex.projects.locations.workflows.creater>   v1alpha1/{+parent}/workflowsworkflow3ComposerflexProjectsLocationsWorkflowsCreateRequestrB   FrC   rO   rQ   r(   r'   rR   z?ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.<lambda>   s4    8#9#9TD zJ4 O&$r(   c                 L    | j                  d      }| j                  |||      S )a  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.
      rT   r2   r4   r7   s       r'   rT   z=ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.Delete  r:   r(   c                  F    t        j                  ddddgdgg ddddd	
      S )NNv1alpha1/projects/{projectsId}/locations/{locationsId}/workflows/{workflowsId}rW   z0composerflex.projects.locations.workflows.deleterX   rY   rZ   3ComposerflexProjectsLocationsWorkflowsDeleteRequestrB   FrC   rO   rQ   r(   r'   rR   z?ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.<lambda>  s4    8#9#9bDxH(O&$r(   c                 L    | j                  d      }| j                  |||      S )a  Retrieves a workflow.

      Args:
        request: (ComposerflexProjectsLocationsWorkflowsGetRequest) input message
        global_params: (StandardQueryParameters, default: None) global arguments
      Returns:
        (Workflow) The response message.
      r]   r2   r4   r7   s       r'   r]   z:ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.Get&  r^   r(   c                  F    t        j                  ddddgdgg ddddd	
      S )Nr   r`   z-composerflex.projects.locations.workflows.getrX   rY   rZ   0ComposerflexProjectsLocationsWorkflowsGetRequestWorkflowFrC   rO   rQ   r(   r'   rR   z?ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.<lambda>3  s4     6 6bAxH(L%!r(   c                 L    | j                  d      }| j                  |||      S )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.
      rd   r2   r4   r7   s       r'   rd   z;ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.ListA  re   r(   c                  J    t        j                  ddddgdgg ddddd	d
      S )Nr   r`   z.composerflex.projects.locations.workflows.listr>   rg   r   rZ   1ComposerflexProjectsLocationsWorkflowsListRequestListWorkflowsResponseFrC   rO   rQ   r(   r'   rR   z?ComposerflexV1alpha1.ProjectsLocationsWorkflowsService.<lambda>N  s4    !7!7TB zJC4M2"r(   r,   rn   rv   s   @r'   r   r      sO    F*E
8F8F8C8Dr(   r   c                   &     e Zd ZdZdZ fdZ xZS )-ComposerflexV1alpha1.ProjectsLocationsServicez2Service class for the projects_locations resource.r!   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r    r   r-   r.   s     r'   r   z6ComposerflexV1alpha1.ProjectsLocationsService.__init__a  s#     994I&Qdr(   ro   rp   rq   rr   rs   r   ru   rv   s   @r'   r    r   \  s    < E r(   r    c                   &     e Zd ZdZdZ fdZ xZS )$ComposerflexV1alpha1.ProjectsServicez(Service class for the projects resource.r#   c                 N    t         t        j                  |   |       i | _        y r,   )r   r   r"   r   r-   r.   s     r'   r   z-ComposerflexV1alpha1.ProjectsService.__init__k  s#     00$@Hdr(   r   rv   s   @r'   r"   r   f  s    2E r(   r"   )rZ   NTNNFFNNNN)ro   rp   rq   rr   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"   ru   rv   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)
rr   
__future__r   apitools.base.pyr   ;googlecloudsdk.generated_clients.apis.composerflex.v1alpha1r   r   BaseApiClientr   rQ   r(   r'   <module>r      s'    A ' % rd811 dr(   