
                         z    S r SSKJr  SSKJ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.    )absolute_import)division)unicode_literals)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                   F   ^  \ rS rSrSrU 4S jr        SS 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	                 x   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S:X  a  U
SU/-  n
U
S	[        U5      /-  n
U
SU/-  n
U
$ )
Nupz--repoz--debugz	--dry-runresourcez--region	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regionr   	exec_argss              r   _ParseArgsForCommand&RunComposeWrapper._ParseArgsForCommand2   s     $.FFd.FFdI9i>!i$Hd##i	#	%*J''i+(*:;;i&N(;<<iJ''ir   )r%   r#   )NNNFFNNN)	__name__
__module____qualname____firstlineno____doc__r   r1   __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   )rA   r   rB   s   `` r   r   r   Y   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>.HandleStdErrk   s<    
kkm!!!!!$' r   r   )rA   r   rH   s   `` r   r   r   h   s    ( 
r   N)F)r7   
__future__r   r   r   &googlecloudsdk.command_lib.util.anthosr   r   StreamingBinaryBackedOperationr   r   r   r   r   r   <module>rM      s>    % &  ' D 4)HH 4nr   