mN dZddlmZddlmZddlmZddlZddlZddlZddlZddl m Z ddl m Z ddlmZdd lmZdd lmZddlm Zdd lmZdd lmZdd lmZdZdZdZdZdZdZdZ dZ!ejDGddejFZ$y)z._IsPromptingSubcommandsc # # Q4( ( aD#A&$.B)99!#8#;=@ABCz-yz--yes)_GetSubcommandTwoLevelsetr isdisjointr-)selfargsrGsubcommand_two_levelrIrHs ` @r8BypassConfirmationPromptzRun.BypassConfirmationPrompts"    66t< C 34 DMM R ++T7O<mm)rdm mm7# = 5rJc >dgdgi}d}|j|}|j|gD]m}t|jt|jxsgs5t j djdj|||y)zPrevents running Airflow CLI commands without required arguments. Args: args: argparse.Namespace, An object that contains the values for the arguments specified in the .Args() method. )userscreate)z-pz --passwordz--use-random-passwordc|Dcgc]}dj|}}djdj|Scc}w)Nz"{}"z[{}]r)r&r')ra quoted_argss r8_StringifyRequiredCmdArgsz>Run.CheckForRequiredCmdArgs.._StringifyRequiredCmdArgss</78x!V]]1%xk8 ]]499[1 229s?zMThe subcommand "{}" requires one of the following command line arguments: {}. N) rKgetrLrMr command_utilErrorr&r')rNrOrequired_cmd_argsrXrPsubcommand_required_cmd_argss r8CheckForRequiredCmdArgszRun.CheckForRequiredCmdArgss KL3 66t< ):(=(=b)"$ ) * 5 5c$--:M26N O   #V-.)*FGIJ J)"rJcd}|jtjvr5tjt j |jdd}|S)NTF)messagedefault cancel_on_no)rr[SUBCOMMAND_DEPRECATIONr PromptContinueDEPRECATION_WARNINGr&)rNrOresponses r8DeprecationWarningPromptzRun.DeprecationWarningPromptsHH ,===**%,,T__=h OrJc|jdf}|jr|j|jf}|S|jr|j|jdf}|S)aExtract and return two level nested Airflow subcommand in unified shape. There are two ways to execute nested Airflow subcommands via gcloud, e.g.: 1. {command} myenv users create -- -u User 2. {command} myenv users -- create -u User The method returns here (users, create) in both cases. It is possible that first element of args.cmd_args will not be a nested subcommand, but that is ok as it will not break entire logic. So, essentially there can be subcommand_two_level = ['info', '--anonymize']. Args: args: argparse.Namespace, An object that contains the values for the arguments specified in the .Args() method. Returns: subcommand_two_level: two level subcommand in unified format Nr)rrr)rNrOrPs r8rKzRun._GetSubcommandTwoLevels`(!OOT2 "oot/E/EF  "oot}}Q/?@ rJcpfd}d|j|\}}||||j|jj|j|jj|j|jj sydj ||}||j|jj vrh||||j|jj |j|j|jj |jy||y)NcHtj|||s ||yyN)rDIsVersionInRange)commandrGr*r+_RaiseLackOfSupportErrors r8_CheckIsSupportedSubcommandzFRun.CheckSubcommandAirflowSupport.._CheckIsSupportedSubcommand s' ( 9 9 <5 /:5rJcLtjdj||)NzWThe subcommand "{}" is not supported for Composer environments with Airflow version {}.)r[r\r&)rnrGs r8rozCRun.CheckSubcommandAirflowSupport.._RaiseLackOfSupportErrors(    &&,fWo&F IIrJz{} {})rKr$rr*r+r,r&)rNrOrGrprrtwo_level_subcommand_stringros @r8CheckSubcommandAirflowSupportz!Run.CheckSubcommandAirflowSupport s!; I %)$?$?$E!J!O !!$//2?? !!$//2==?  $ $  33 4 ")..=N"OD55 334! %  # #DOO 4 % %&7 99E  # #DOO 4 % %&7 99C E:OLrJcv|jr-tj|ddstjdyy)Nz1.10.14zgNested subcommands are supported only for Composer environments with Airflow version 1.10.14 or higher.)rrDrmr[r\)rNrOrGs r8#CheckSubcommandNestedAirflowSupportz'Run.CheckSubcommandNestedAirflowSupport.sB  ' 8 8 Y .    4 55 . rJc|jjxr |jjj}|r!tjt |dzS|S)Nz Make sure you have followed https://cloud.google.com/composer/docs/how-to/accessing/airflow-cli#private-ip to enable access to your private Cloud Composer environment from your machine.)configprivateEnvironmentConfigenablePrivateEnvironmentr[r\str)rNerrorenv_obj is_privates r8ConvertKubectlErrorzRun.ConvertKubectlError6s]// I//HH    e*   LrJc4tjd|dS)Nz-airflow-([\d\.]+)r)refindall)rN image_versions r8_ExtractAirflowVersionzRun._ExtractAirflowVersionDs ::+] ;A >>rJc<|jj}tj|}d|v}tj||d5 |jj j }|j|}|j|||j||tj|}tjt|} tjjdj!||j#||d| dg} |r| j%d| j'dt(d d |j*g|j,r| j%|j,|j.r| j'|j.tj0tj2|| tj4j  dddy#tj6$r} |j9| |d} ~ wwxYw#1swYyxYw) aRuns Airflow command using kubectl on the GKE Cluster. This mode the command is executed by connecting to the cluster and running `kubectl pod exec` command. It requires access to GKE Control plane. Args: args: argparse.Namespace, An object that contains the values for the arguments specified in the .Args() method. env_obj: Cloud Composer Environment object. zno-ttyN) pod_substrkubectl_namespacez?Executing within the following Kubernetes cluster namespace: {}execz--stdinz--ttyz --containerz--airflow)out_func)rw gkeClusterr[ExtractGkeClusterLocationIdTemporaryKubeconfigsoftwareConfig imageVersionrrsruFetchKubectlNamespace GetGkePodWORKER_POD_SUBSTRr statusPrintr&rQr-extendWORKER_CONTAINERrrrRunKubectlCommandAddKubectlNamespaceout KubectlErrorr~) rNrOr| cluster_idcluster_location_idttyrrG kubectl_nspod kubectl_argses r8 _RunKubectlzRun._RunKubectlGs**J&BB7K $ C  ) )Z 355BB 55mD **4A 00G!77 F $$(JH   # % %%dO<Y/    g & ,dIt O Q  ! !   d44 5 ==   dmm ,&&  , ,Z FWW]] $9  > & &3&&q'223?  s+H FG%%H8H  HHHc  |jjj}|j|}|jj j }|j|||j|||j|||jg}|jr|j|j|jr|j|jtj j#dj%dj'|t)j*|j|jxsd|jxsg||j-}|rD|j.r8tj j#dj%|j.|j.st1j2dtj j#dd}d } d } t4} d} d} d}|sV|sSd} t7j85t;j<| t?j@tB tBzt)jD|j.|jF|jH| ||j- } d } | jJ}| jL}|jOd ddd| tXk(rt1j2d|st[| t\zt^} nLt4} |D]/}tj"|j`r |j`nd1|djbd z} |s|sS| r| jdr| jdjfr| jdjhr8tjhdj%| jdjhtjhdj%| jdjftk| jdjfyyyy#1swYaxYw#tP$rtj j#d tjRdt)jT|j.|jF| |jH||j-}tjRdtW|z|r2|jLr&|jLD]}tj"|| rd}d} n!#tjRd| d z } YnxYwYi| d z } YrxYw)Nz(Executing the command: [ airflow {} ]...rY)rnr parametersenvironment_ref release_trackz)Command has been started. execution_id={}zBCannot execute subcommand for environment. Got empty execution Id.z#Use ctrl-c to interrupt the commandFr) execution_idpod_name pod_namespacenext_line_numberrrc|jSrl) lineNumber)lines r8zRun._RunApi..sdoorJ)keyzInterrupting the command...zStopping the airflow command...)rrforcerrrzStop airflow command result...Tz7Error during stopping airflow command. Retrying pollingz$Cannot fetch airflow command status.zError message: {}zCommand exit code: {})6rwrrrCONCEPTS environmentParsersrurQrrr-rrr rrr&r'environments_api_utilExecuteAirflowCommand ReleaseTrack executionIdr[r\DEFAULT_POLL_TIME_SECONDSr RaisesKeyboardInterrupttimesleeprandomuniformPOLL_JITTER_SECONDSPollAirflowCommandr podNamespace outputEndoutputsortKeyboardInterruptdebugStopAirflowCommandrzMAX_CONSECUTIVE_POLL_ERRORSminEXP_BACKOFF_MULTIPLIERMAX_POLL_TIME_SECONDScontentrexitInfoexitCoder{exit)rNrOr|rrGenv_refr4execute_result output_end next_linecur_consequetive_poll_errorswait_time_seconds poll_result interrupted force_stoplines stop_resultrs r8_RunApiz Run._RunApizs^NN11>>M11-@Omm''--/G&&t_=,,T?C!!$8 ?? C  jj''( }} jjJJ299#((3-H+@@))/R==&B'') N.44 jj 5 < <((   % %    N JJ:;JI#$ 1KKJe)*  4 4 6 ** 335HIJ .@@)55%))*77(% --/  +*+ &",,*$$% **5* 6!7T &)D D  !GHH   6 68M 6D ))DLLDLLb 9"I((1, qt{++ 0D0D0M0M    # # %,,[-A-A-G-GHI ii'..{/C/C/L/LMN ;   ( () 1N+{o7 6", 67 , ))5 6-@@)55%))*77% --/  + ))4S5EE F [//#**iio+ J+ , ))M N &! + &*$)$sDP='B*P0P=0P:5P==(U &B7TU T<:U U c|j||j|tj|j j j j}|jjj}tj||j }|j|k7r.tjdj!|jt#j$|j&j(j*r|j-||y|j/||y)N)rzGCannot execute subcommand for environment in state {}. Must be RUNNING.)r)rhr_api_utilGetMessagesModuler EnvironmentStateValueValuesEnumRUNNINGrrrrGetstater[r\r&rD%IsVersionAirflowCommandsApiCompatiblerwrrrr)rNrO running_staterr|s r8rzRun.Runs!!$'  &..'')k&&wwmm''--/G#''t002G}} %    #VGMM2 #HHnn33@@ ll4! tW%rJN)__name__ __module__ __qualname____doc__r[r$ classmethodr9rQr_rhrKrsrur~rrrrrJr8rr3sj&P&::3H3Hj,$\JB :"MH5 ?13fi*V&rJr)%r __future__rrrr.rrrgooglecloudsdk.api_lib.composerrrrrgooglecloudsdk.callioper#googlecloudsdk.command_lib.composerr rDr r[googlecloudsdk.corer r googlecloudsdk.core.consoler rrrfrrrrrDefaultUniverseOnlyCommandrrrJr8rsC&' V<(b=D/#2$#5  H&$,,H&H&rJ