
    z	                         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
KJr   " S S\
R"                  5      rg)zKill job command.    )absolute_import)division)unicode_literals)dataproc)util)base)flags)log)
console_ioc                   .    \ rS rSrSr\S 5       rS rSrg)Kill   zcKill an active job.

Kill an active job.

## EXAMPLES

To cancel a job, run:

  $ {command} job_id
c                     [         R                  " U R                  5       5      n[        R                  " USUR
                  5        [        R                  " U5        g )Nkill)dpDataprocReleaseTrackr	   AddJobResourceArgapi_versionAddAsync)clsparserr   s      !lib/surface/dataproc/jobs/kill.pyArgs	Kill.Args*   s=    {{3++-.H	FFH,@,@A	NN6    c                 X   [         R                  " U R                  5       5      nUR                  R                  R                  5       nUR                  R                  UR                  UR                  UR                  UR                  R                  5       S9n[        R                  " SR                  UR                  5      SSS9  UR                  R                   R#                  U5      n[$        R&                  R)                  SR                  UR                  5      5        UR*                  (       a  UnU$ [,        R.                  " UUUSUR                  R0                  R2                  R4                  S9n[$        R&                  R)                  S	R                  U5      5        U$ )
N)	projectIdregionjobIdcancelJobRequestzThe job '{0}' will be killed.TzCancellation aborted by user.)messagecancel_on_nocancel_stringz%Job cancellation initiated for [{0}].zWaiting for job cancellation)r"   
goal_statezKilled [{0}].)r   r   r   CONCEPTSjobParsemessages(DataprocProjectsRegionsJobsCancelRequestr   r   r    CancelJobRequestr   PromptContinueformatclientprojects_regions_jobsCancelr
   statusPrintasync_r   WaitForJobTermination	JobStatusStateValueValuesEnum	CANCELLED)selfargsr   job_refrequestr'   
output_jobs          r   RunKill.Run0   sT   {{4,,./Hmm%%'GHH##~~mm!**;;=	 I ?G /66txx@57
 //
/
/
6
6w
?CJJ/66w}}EG {{j  --


0&&00EEOOQj 
jj--g67r    N)	__name__
__module____qualname____firstlineno____doc__classmethodr   r=   __static_attributes__r?   r   r   r   r      s     	  
r   r   N)rD   
__future__r   r   r   googlecloudsdk.api_lib.dataprocr   r   r   googlecloudsdk.callioper   #googlecloudsdk.command_lib.dataprocr	   googlecloudsdk.corer
   googlecloudsdk.core.consoler   Commandr   r?   r   r   <module>rN      s5      &  ' : 0 ( 5 # 204<< 0r   