
                         6   S r SSKJr  SSKJr  SSKJr  SSKJr  SSKJr  SSK	J
r
  SSKJr  SS	KJr  S
SS.r\R                   " \R"                  R$                  \R"                  R&                  5      \R(                   " S S\R*                  5      5       5       rg)z)Command to update the specified pipeline.    )absolute_import)division)unicode_literals)	pipelines)base)flags)labels_util)logz{description}a^           To update the pipeline `my-pipeline` with its destination targeting HTTP endpoint URI 'https://example-endpoint.com' and network attachment 'my-network-attachment', run:

          $ {command} my-pipeline --location=us-central1 --destinations=http_endpoint_uri='https://example-endpoint.com',network_attachment=my-network-attachment
        )DESCRIPTIONEXAMPLESc                   2    \ rS rSrSr\r\S 5       rS r	Sr
g)Update%   zUpdate an Eventarc pipeline.c                    [         R                  " U5        [         R                  " USS9  [         R                  " U5        [         R                  " U5        [         R
                  " US5        [         R                  " U5        [         R                  " USSS9  [        R                  " U5        [        R                  R                  U5        g )NF)requiredz#The logging config of the pipeline.T)
with_clearhidden)r   AddUpdatePipelineResourceArgsAddPipelineDestinationsArgAddInputPayloadFormatArgsAddMediationsArgAddLoggingConfigArgAddRetryPolicyArgsAddCryptoKeyArgr	   AddUpdateLabelsFlagsr   
ASYNC_FLAGAddToParser)clsparsers     (lib/surface/eventarc/pipelines/update.pyArgsUpdate.Args,   s    	''/	$$Ve<	##F+	6"	f&KL	V$	&T%@$$V,OO'    c                 <   [         R                  " 5       nUR                  R                  R	                  5       nUR                  R
                  R	                  5       n[        R                  " SR                  UR                  UR                  UR                  5      5        UR                  U5      n[        R                  R                  U5      R!                  UR#                  5       UR$                  5      nUR'                  UR)                  S5      UR)                  S5      UR)                  S5      UR)                  S5      UR)                  S5      UR)                  S5      UR)                  S5      UR)                  S	5      UR)                  S
5      UR)                  S5      UR*                  UR,                  UR)                  S5      UR.                  S9nUR1                  UUR3                  UUR4                  UR6                  UR8                  UR:                  UR<                  UR>                  UR@                  URB                  URD                  URF                  URI                  5       US9U5      nURJ                  (       a  U$ URM                  USU5      $ )zRun the update command.z2Updating pipeline {} for project {} in location {}destinationsinput_payload_format_json+input_payload_format_avro_schema_definition/input_payload_format_protobuf_schema_definition
mediationslogging_configmax_retry_attemptsmin_retry_delaymax_retry_delay
crypto_keyerror_message_bus)r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   clear_crypto_keylabelsr/   clear_error_message_bus)pipeline_refr%   r&   r'   r(   r)   r*   r+   r,   r-   crypto_key_namer1   error_message_bus_refUpdating)'r   PipelineClientV1CONCEPTSpipelineParser/   r
   debugformatpipelinesId
projectsIdlocationsIdGetr	   DiffFromUpdateArgsApplyLabelsValueClassr1   BuildUpdateMaskIsSpecifiedr0   needs_updater2   PatchBuildPipeliner%   r&   r'   r(   r)   r*   r+   r,   r-   r.   	GetOrNoneasync_WaitFor)	selfargsclientr3   r5   original_pipelinelabels_update_resultupdate_mask	operations	            r    Run
Update.Run9   sO   '')F==))//1L MM;;AACII<CC$$##$$	
 

<0&++::4@FF!#4#;#; ((%%n5"&"2"23N"O484D4D95
 9=8H8H=9
 ##L1''(89++,@A(():;(():;##L1..#00**+>? $ < <% ) K* %**&*&D&D8<8h8h<@<p<p..#66 00 00 OO'113"7 	 	
 	#I( {{>>)Z>>r#    N)__name__
__module____qualname____firstlineno____doc___DETAILED_HELPdetailed_helpclassmethodr!   rT   __static_attributes__rV   r#   r    r   r   %   s#     % -
( 
(>?r#   r   N)r[   
__future__r   r   r   googlecloudsdk.api_lib.eventarcr   googlecloudsdk.callioper   #googlecloudsdk.command_lib.eventarcr   $googlecloudsdk.command_lib.util.argsr	   googlecloudsdk.corer
   r\   ReleaseTracksReleaseTrackBETAGADefaultUniverseOnlyUpdateCommandr   rV   r#   r    <module>rl      s    0 &  ' 5 ( 5 < # # D%%**D,=,=,@,@AP?T P?  BP?r#   