
                             d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl	m
Z
 dd	d
Zej                   ej                  ej                  j                         G d dej                                       Zy)z8Command to update a Pipeline for the Data Pipelines API.    )absolute_import)division)unicode_literals)util)base)flagsz{description}z         To update a Data Pipeline ``PIPELINE_NAME'' of project ``example'' in region ``us-central1'', run:

          $ {command} abc PIPELINE_NAME --project=example --region=us-central1
              --display-name="new_name"
        )DESCRIPTIONEXAMPLESc                   *    e Zd ZdZeZed        Zd Zy)Updatez"Updates a Data Pipelines Pipeline.c                    t        j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j
                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                  d      j                  |        t        j                   d      j                  |        t        j"                  d      j                  |        t        j$                  d      j                  |        t        j&                  d      j                  |        t        j(                  d      j                  |        t        j*                  d      j                  |        t        j,                  d      j                  |        t        j.                  d      j                  |        t        j0                  d      j                  |        y )NzData Pipelines pipelineF)required)r   AddUpdatePipelineFlagsGetDisplayNameArgAddToParserGetTemplateTypeArgGetScheduleArgGetTimeZoneArgGetTemplateFileGcsLocationArgGetParametersArgGetMaxWorkersArgGetNumWorkersArgGetNetworkArgGetSubnetworkArgGetWorkerMachineTypeArgGetTempLocationArgGetDataflowKmsKeyArgGetDisablePublicIpsArg!GetDataflowServiceAccountEmailArg"GetSchedulerServiceAccountEmailArgGetEnableStreamingEngineArgGetAdditionalExperimentsArgGetAdditionalUserLabelsArgGetWorkerRegionArgsGetFlexRsGoalArgGetStreamingUpdateArgs)parsers    ,lib/surface/datapipelines/pipeline/update.pyArgszUpdate.Args-   s7   	  (	56BB6J	e,88@	%(44V<	%(44V<	''7CCFK	E*66v>	E*66v>	E*66v>	'33F;	E*66v>	!!51==fE	e,88@	.::6B	  %0<<VD	++U;GGO	,,e<HHP	%%u5AA&I	%%u5AA&I	$$e4@@H	u-99&A	E*66v>	  %0<<VD    c                     t        j                         }|j                  j                  j	                         }|j                  |j                         |      S )zRun the update command.)pipelineargs)r   PipelinesClientCONCEPTSr,   ParsePatchRelativeName)selfr-   clientpipelines_refs       r(   Runz
Update.RunG   sD    !!#FMM**002M<<!;!;!=D<IIr*   N)	__name__
__module____qualname____doc___DETAILED_HELPdetailed_helpstaticmethodr)   r6    r*   r(   r   r   &   s&     + -E E2Jr*   r   N)r:   
__future__r   r   r   $googlecloudsdk.api_lib.datapipelinesr   googlecloudsdk.callioper   (googlecloudsdk.command_lib.datapipelinesr   r;   DefaultUniverseOnlyReleaseTracksReleaseTrackBETAUpdateCommandr   r>   r*   r(   <module>rH      sx    ? &  ' 5 ( : 			
 D%%**+#JT #J , #Jr*   