
                        b    S r SSKJr  SSKJr  Sr " S S\R                  5      rS
S jrS
S jr	g	)zWrapper for runcompose binary.    )annotations)binary_operationszCould not locate Cloud Run executable run-compsose on the system PATH. Please ensure gcloud run up component is properly installed. See https://cloud.google.com/sdk/docs/components for more details.c                  N   ^  \ rS rSrSrU 4S jr         S SS jjrSrU =r$ )RunComposeWrapper    z2Binary operation wrapper for run-compose commands.c           
     X   > [         [        U ]
  " SSS[        0S[        [
        SS.UD6  g )Nzrun-composeMISSING_EXECT)binarycustom_errorsinstall_if_missingstd_err_funcstd_out_funccapture_output )superr   __init__MISSING_BINARYStreamErrHandlerStreamOutHandler)selfkwargs	__class__s     (lib/googlecloudsdk/command_lib/run/up.pyr   RunComposeWrapper.__init__#   s9    	
T+ %~6%%     c
                   US:X  a*  [         R                  U l        [         R                  U l        A
/ nU(       a  X/-  nU(       a  X/-  nUS:X  a7  USU/-  nU(       a  UR                  S5        U(       a  UR                  S5        US:X  a  USU/-  nU	(       a  USU	/-  nUS:X  a,  US	U/-  nUS
[        U5      /-  nUSU/-  nU	(       a  USU	/-  nU$ )Nupz--repoz--debugz	--dry-runresourcez--regionz--out	translatez--resources-configz--project-number)r   DefaultStreamOutHandlerstd_out_handlerDefaultStreamErrHandlerstd_err_handlerappendstr)r   commandcompose_filerepodebugdry_runresources_configproject_numberregionoutr   	exec_argss               r   _ParseArgsForCommand&RunComposeWrapper._ParseArgsForCommand0   s     $.FFd.FFdI9i>!i$Hd##i	#	%*J''i	gs^#	+(*:;;i&N(;<<iJ''i	gs^#	r   )r#   r!   )	NNNFFNNNN)r.   z
str | None)	__name__
__module____qualname____firstlineno____doc__r   r0   __static_attributes____classcell__)r   s   @r   r   r       s<    :	 ) ) )r   r   c                   ^ ^ UU 4S jnU$ )z0Processing for streaming stdout from subprocess.c                   > U (       a  U R                  5       n T(       a<  TR                  (       d  / Tl        U (       a  TR                  R                  U 5        g g g N)stripstdoutr$   liner   result_holders    r   HandleStdOut&StreamOutHandler.<locals>.HandleStdOut_   sF    ZZ\d!!!	##D) 
 r   r   )r@   r   rA   s   `` r   r   r   \   s    * 
r   c                   ^ ^ UU 4S jnU$ )z;Customized processing for streaming stderr from subprocess.c                   > U (       a  U R                  5         T(       a4  TR                  (       d  / Tl        TR                  R                  U 5        g g r;   )rstripstderrr$   r>   s    r   HandleStdErr&StreamErrHandler.<locals>.HandleStdErrn   s<    
kkm!!!!!$' r   r   )r@   r   rG   s   `` r   r   r   k   s    ( 
r   N)F)
r6   
__future__r   &googlecloudsdk.command_lib.util.anthosr   r   StreamingBinaryBackedOperationr   r   r   r   r   r   <module>rL      s8    % " D 9)HH 9xr   