0~SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKrSSKJr "SS\R:5r"SS\R:5r"SS\R:5r \ RBr"Sr%/SQr&Sr'Sr(S7Sjr)Sr*S r+S!r,S"r-"S#S$\.5r/\R`S%5r1\R`S&5r2S8S'jr3S9S)jr4S7S*jr5S(\Rl4S+jr7S(\Rl\RpRlS(4S,jr9S-r:S9S.jr;S:S/jrS2r?S3r@S4rAS5rBS6rCg!\#a$ "SS\R:5r!\!r""SS5r$Nf=f);z6Functions to help with shelling out to other commands.)absolute_import)division)unicode_literalsN) argv_utils)config) exceptions)log) properties) named_configs)encoding)parallel) platforms)mapc\rSrSrSrSrg)OutputStreamProcessingException0z>Error class for errors raised during output stream processing.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r*lib/googlecloudsdk/core/execution_utils.pyrr0sFrrc,^\rSrSrSrU4SjrSrU=r$)PermissionError4z'User does not have execute permissions.cF>[[U] SRUS95 g)Nz_{err} Please verify that you have execute permission for all files in your CLOUD SDK bin folder)err)superr__init__format)selferror __class__s rr#PermissionError.__init__7s$ /4) --3VV->@rrrrrrrr#r __classcell__r's@rrr4s/@@rrc,^\rSrSrSrU4SjrSrU=r$)InvalidCommandError=z Command entered cannot be found.cF>[[U] SRUS95 g)Nz{cmd}: command not found)cmd)r"r-r#r$)r%r0r's rr#InvalidCommandError.__init__@s$ t-"))c)24rrr)r+s@rr-r-=s(44rr-c\rSrSrSrSrg)TimeoutExpiredNzDSimulate subprocess.TimeoutExpired on old (<3.3) versions of Python.rNrrrrr3r3NsNrr3c.\rSrSrSrSrSSjrSrSrg) SubprocessTimeoutWrapperTa-Forwarding wrapper for subprocess.Popen, adds timeout arg to wait. subprocess.Popen.wait doesn't provide a timeout in versions < 3.3. This class wraps subprocess.Popen, adds a backported wait that includes the timeout arg, and forwards other calls to the underlying subprocess.Popen. Callers generally shouldn't use this class directly: Subprocess will return either a subprocess.Popen or SubprocessTimeoutWrapper as appropriate based on the available version of subprocesses. See https://docs.python.org/3/library/subprocess.html#subprocess.Popen.wait. cXlgNproc)r%r;s rr#!SubprocessTimeoutWrapper.__init__csirNc`UcURR5$[R"5nX!-nSnURR5nUcX[R"5U:a [ 5e[R "U5 URR5nUcMXU$)zBusy-wait for wrapped process to have a return code. Args: timeout: int, Seconds to wait before raising TimeoutExpired. Returns: int, The subprocess return code. Raises: TimeoutExpired: if subprocess doesn't finish before the given timeout. g{Gz?)r;waittimepollr3sleep)r%timeoutnowlaterdelayrets rr>SubprocessTimeoutWrapper.waitgs yy~~ IIKcmee IINN c K 99;   5iinn K jrc.[URU5$r9)getattrr;)r%names r __getattr__$SubprocessTimeoutWrapper.__getattr__s TYY %%rr:r9) rrrrrr#r>rKrrrrr6r6Ts 4&rr6c[R"[RS5nU(aU$[R nU(d [ S5eU$)z8< >>rc [SS/U/UQ76$)zConstructs an argument list for calling the cmd interpreter. Args: executable_path: str, The full path to the cmd script. *args: args for the command Returns: An argument list to execute the cmd interpreter r0z/crsrprqs rArgsForCMDToolrs edV_ >C>?B==Cc## [R"X5nSv [R"X5 g![R"X5 f=f7fr9)signal)signohandler old_handlers r_ReplaceSignalrTs3 e-+&  MM%%FMM%%sA5AA  Ac U(a[RUS'U(a[RUS'U(a[RUS'U(a;[U[5(a&UVs/sHn[R "U5PM nn[R "U4S[US90UD6nXlUR b!UR#5cUR%5 [U[&R(5(aUR+S5n[[-[R.UR1US 955upU(aU"U 5 U(aU"U 5 UR2$s snf![aen U R[R:Xa[U R5eU R[R:Xa[US5eeSn A ff=f) zSee Exec docstring.stdoutstderrstdinrrrNutf-8)input) subprocessPIPE isinstancermr EncodePopenrOSErrorerrnoEACCESrstrerrorENOENTr-rrr@rsix text_typeencoderDecode communicate returncode) rqprocess_holderrout_funcerr_funcin_strextra_popen_kwargsarr!rrs r_Execr]so#-??x  #-??x  ",//w   4&& +/ /$Qhooa $d /M:##6M:LMA& vvxkkm && ]]7 #FHOOQ]]]-HIJ.&  V  V 30   yyELL CLL )) ell " Q ((  s+ E70 E2"E72E77 G&A G!!G&Fc 4[R"SU5 [5n[[R "5[R 5(ai[[RUR5 [[RUR5 [XXXE40UD6nSSS5 SSS5 O[XXXE40UD6nU(aURcW$[R"W5 g!,(df  NR=f!,(df  NL=f)a|Emulates the os.exec* set of commands, but uses subprocess. This executes the given command, waits for it to finish, and then exits this process with the exit code of the child process. Args: args: [str], The arguments to execute. The first argument is the command. env: {str: str}, An optional environment for the child process. no_exit: bool, True to just return the exit code of the child instead of exiting. out_func: str->None, a function to call with the stdout of the executed process. This can be e.g. log.file_only_logger.debug or log.out.write. err_func: str->None, a function to call with the stderr of the executed process. This can be e.g. log.file_only_logger.debug or log.err.write. in_str: bytes or str, input to send to the subprocess' stdin. **extra_popen_kwargs: Any additional kwargs will be passed through directly to subprocess.Popen Returns: int, The exit code of the child if no_exit is True, else this method does not return. Raises: PermissionError: if user does not have execute permission for cloud sdk bin files. InvalidCommandError: if the command entered cannot be found. Executing command: %sN)r rrr threadingcurrent_thread _MainThreadrrSIGTERMrSIGINTrrrRexit) rqrno_exitrrrrrret_vals rExecrsD)) #T* "#. ((*I,A,ABB (>(> ? &--)?)? @cX.,. A @ ? D#*(*G &&. N((7 A @ @ ?s$8%D C8,D 8 D D  Dc nU(a;[U[5(a&UVs/sHn[R"U5PM nn[R "U4S[ US90UD6n[5nXFlUR b!UR#5cUR%5 ['U5$s snf![aenUR[R:Xa[UR5eUR[R:Xa[US5eeSnAff=f![(a Us$f=f)anRun subprocess.Popen with optional timeout and custom env. Returns a running subprocess. Depending on the available version of the subprocess library, this will return either a subprocess.Popen or a SubprocessTimeoutWrapper (which forwards calls to a subprocess.Popen). Callers should catch TIMEOUT_EXPIRED_ERR instead of subprocess.TimeoutExpired to be compatible with both classes. Args: args: [str], The arguments to execute. The first argument is the command. env: {str: str}, An optional environment for the child process. **extra_popen_kwargs: Any additional kwargs will be passed through directly to subprocess.Popen Returns: subprocess.Popen or SubprocessTimeoutWrapper, The running subprocess. Raises: PermissionError: if user does not have execute permission for cloud sdk bin files. InvalidCommandError: if the command entered cannot be found. rrrN)rrmr rrrrrrrrrrr-rrrr@rr6 NameError)rqrrrrr!rs r Subprocessrs0   4&&*. /$Qhooa $d /M:##6M:LMA"#.&vvxkkm #A &&0   yyELL CLL )) ell " Q ((    H s; B3 B."B3# D%.B33 D"=A DD"% D43D4cTU(a URO URnURnU"5=(d SnU(d#UR5bUR 5 gUR S5nURS5nU(aU"U5 Mm![ a gf=f)zR@"S5n U RC[DU SU45nU RC[DU S U 45nURG5 URG5 SSS5 URTb [;U 5 U RVnSSS5 SSS5 U(aURTcW$[XRZ"W5 gs sn f![2a]n U R4[4R6:XdU R4[4R8:XaSn A GN$[;U 5 [=U 5eSn A ff=f!,(df  N=f![Han[;U 5 [=U5eSnAff=f![2aenUR4[4RJ:Xa[MURN5eUR4[4RP:Xa[SUS 5eeSnAff=f!,(df  GN^=f!,(df  GNh=f) aEmulates the os.exec* set of commands, but uses subprocess. This executes the given command, waits for it to finish, and then exits this process with the exit code of the child process. Allows realtime processing of stderr and stdout from subprocess using threads. Args: args: [str], The arguments to execute. The first argument is the command. env: {str: str}, An optional environment for the child process. no_exit: bool, True to just return the exit code of the child instead of exiting. out_func: str->None, a function to call with each line of the stdout of the executed process. This can be e.g. log.file_only_logger.debug or log.out.write. err_func: str->None, a function to call with each line of the stderr of the executed process. This can be e.g. log.file_only_logger.debug or log.err.write. in_str: bytes or str, input to send to the subprocess' stdin. **extra_popen_kwargs: Any additional kwargs will be passed through directly to subprocess.Popen Returns: int, The exit code of the child if no_exit is True, else this method does not return. Raises: PermissionError: if user does not have execute permission for cloud sdk bin files. InvalidCommandError: if the command entered cannot be found. rrrrrrrNFTr).r rrrrrrrrPrintstatusrrrrmr rrrrrrrwriterrrEPIPEEINVALrrr GetPool ApplyAsyncrr~ Exceptionrrrrr-rrrRr)rqrrrrrrrout_handler_funcerr_handler_funcrrexcpoolstd_out_futurestd_err_futureer!rs rExecWithStreamingOutputr>sJ)) #T* s#!#.fnnn&<&<=  ~'='= >!.SYY!5SZZ%5%5 &0oo7#( JtT** /33d(//!$d$3   T Ks:??$.OO K7I K!" ==(//8& 9 GGMM& ! GGMMO 3"d!__-B./8H-IKN!__-B./7G-HJN       #$    * 1 gk ?>p &&. N((7]4 9 U[[( U\\) #3C88  9#" 3 Q /2 2 3 99 $ - - YY%,, &#DG, , Q ? >>=s%N,4AN L(, J A+L(85J.LAK/L$NN,L( K,an[9U 5 [;U5eSnAff=f![0aenUR2[2R@:Xa[CURD5eUR2[2RF:Xa[IUS5eeSnAff=f!,(df  GNL=f!,(df  GNV=f) aFEmulates the os.exec* set of commands, but uses subprocess. This executes the given command, waits for it to finish, and then exits this process with the exit code of the child process. Allows realtime processing of stderr and stdout from subprocess without threads. Args: args: [str], The arguments to execute. The first argument is the command. env: {str: str}, An optional environment for the child process. no_exit: bool, True to just return the exit code of the child instead of exiting. out_func: str->None, a function to call with each line of the stdout of the executed process. This can be e.g. log.file_only_logger.debug or log.out.write. err_func: str->None, a function to call with each line of the stderr of the executed process. This can be e.g. log.file_only_logger.debug or log.err.write. in_str: bytes or str, input to send to the subprocess' stdin. raw_output: bool, stream raw lines of output perserving line endings/formatting. **extra_popen_kwargs: Any additional kwargs will be passed through directly to subprocess.Popen Returns: int, The exit code of the child if no_exit is True, else this method does not return. Raises: PermissionError: if user does not have execute permission for cloud sdk bin files. InvalidCommandError: if the command entered cannot be found. rrrrrN)rrrr)*r rrrrrrrrrrrrrrmr rrrrrrrrrrrrrrrr rrrrr-rrrrRr)rqrrrrr raw_outputrrr r rrrrr!rs r"ExecWithStreamingOutputNonThreadedrsjP)) #T* s#!#.fnnn&<&<=  ~'='= >!.SYY!5SZZ%5%5 &0oo7## JtT** /33d(//!$d$3   T Ks:??$.OO K7I K ==(//8& 9 GGMM& ! GGMMO 3 !!1A&0 2 !    * 1 gc ?>h &&. N((7U4 9 U[[( U\\) #3C88  9 3 Q /2 2 3 99 $ - - YY%,, &#DG, , G ? >>=s%L44AL" J0, H A%J025H( J3*L"L4J0 J)TRT5 gr9)r) unused_signalrrrs r_Handler(UninterruptibleSection.._Handler s LLr)r$ CtrlCSection)rrrs`` rUninterruptibleSectionrs4 & &?? ' B' h rcSn[U5$)z._Handler's  r)r)rs rRaisesKeyboardInterruptr$%s h rc6[[RU5$)aRun a section of code with CTRL-C redirected handler. Args: handler: func(), handler to call if SIGINT is received. In every case original Ctrl-C handler is not invoked. Returns: Context manager that redirects ctrl-c handler during its lifetime. )rrr)rs rrr-s  w //rc  Sn[US5(a URnO[US5(a URnUbg[RR 5[RR :Xa[R"SSSS[R"UR5/[R[RS9nUR5up4URS :wa6[U5(a%[S R!URX455egg["R$"['[(R*55nS US '[R"/S Q[R[RUS9nUR5up4UR-S5nURS :wa$[SR!UR55e0nUR/5R1S5Hpn[2R4"SU5R75up[9U 5n [9U 5n UR;U 5n U (dU /Xy'M_U R=U 5 Mr UR/n UR/n U (aSU R?5nUR;U5n U (a"U RAU 5 U RAU 5 U (aMSU Hn [CU 5 M g)zKills a subprocess using an OS specific method when python can't do it. This also kills all processes rooted in this process. Args: p: the Popen or multiprocessing.Process object to kill Raises: RuntimeError: if it fails to kill the process Nrrtaskkillz/Fz/Tz/PID)rrrz:Failed to call taskkill on pid {0} stdout: {1} stderr: {2}z en_US.UTF-8LANG)psz-e-ozppid=r*zpid=)rrrrz*Failed to get subprocesses of process: {0} z\s*(\d+)\s+(\d+))"rrrrOperatingSystemCurrentWINDOWSrrrrrrr_IsTaskKillError RuntimeErrorr$r rzryrPrQrstriprrematchgroupsintrrkpoprl_KillPID)rrtaskkill_processrrnew_envget_pids_processpid_maprppidrchildrenall_pids to_processcurrents rKillSubprocessrA:sl $ Q  < (335V""a',>@kt Yd HcT"h  +wH%%J  gW%h (#! *smrcSn[R"S54nUH nX0;dM g UHnURU5(dM g g)zReturns whether the stderr output of taskkill indicates it failed. Args: stderr: the string error output of the taskkill command Returns: True iff the stderr is considered to represent an actual error. )zAccess is denied.z)The operation attempted is not supported.z)There is no running instance of the task.z6There is no running instance of the task to terminate.zThe process "\d+" not found\.FT)r2compilesearch)rnon_error_reasonsnon_error_patternsreasonpatterns rr/r/sX@ jj125!f  "$g~~f $ rc0[R"U[R5 [R"5S-n[R"5U:aB[ U5(dg[R "S5 [R"5U:aMB[R"U[R5 g![aKnSUR;a1[R"[R"5S5 SnAgSnAgSnAff=f)zKills the given process with SIGTERM, then with SIGKILL if it doesn't stop. Args: pid: The process id of the process to check. Ng?zNo such process)rPkillrrr?_IsStillRunningrASIGKILLrrrreraiserRexc_info)rdeadliner&s rr7r7s ,GGC yy{QH ))+ S ! ! jjo ))+ GGC ,.*++/,s$A&C)/C%C D >1*+ ,s.3 B>Br9)NNNN)NFNNN)NFNNNF)Dr __future__rrr contextlibrrPr2rrrRrr?googlecloudsdk.corerrrr r "googlecloudsdk.core.configurationsr googlecloudsdk.core.utilr r rr six.movesrErrorrrr-r3TIMEOUT_EXPIRED_ERRAttributeErrorr6rWrcrirsrrrrrobjectrcontextmanagerrrrrrrrrrrrrrr$rrAr/r7rMrrrras =&'   +&*#*<--. Gj&6&6G@j&&@4***4>&"11@ P: B>6 = :"0!V!6 ## && -b :z+ \%*399(!&+.99+.::+;+;$) )< ,!%$)%)%)#' gV,0/40404.227 fR (  0Pl>,0w6&Oz''O'.&.&6&s9 F'F<;F<